aboutsummaryrefslogtreecommitdiff
path: root/node_modules/fsevents/src/thread.cc
diff options
context:
space:
mode:
authorruki <waruqi@gmail.com>2018-11-08 00:38:48 +0800
committerruki <waruqi@gmail.com>2018-11-07 21:53:09 +0800
commit26105034da4fcce7ac883c899d781f016559310d (patch)
treec459a5dc4e3aa0972d9919033ece511ce76dd129 /node_modules/fsevents/src/thread.cc
parent2c77f00f1a7ecb6c8192f9c16d3b2001b254a107 (diff)
downloadxmake-docs-26105034da4fcce7ac883c899d781f016559310d.tar.gz
xmake-docs-26105034da4fcce7ac883c899d781f016559310d.zip
switch to vuepress
Diffstat (limited to 'node_modules/fsevents/src/thread.cc')
-rw-r--r--node_modules/fsevents/src/thread.cc72
1 files changed, 72 insertions, 0 deletions
diff --git a/node_modules/fsevents/src/thread.cc b/node_modules/fsevents/src/thread.cc
new file mode 100644
index 00000000..4813fdc5
--- /dev/null
+++ b/node_modules/fsevents/src/thread.cc
@@ -0,0 +1,72 @@
+/*
+** © 2014 by Philipp Dunkel <pip@pipobscure.com>
+** Licensed under MIT License.
+*/
+
+// constants from https://developer.apple.com/library/mac/documentation/Darwin/Reference/FSEvents_Ref/index.html#//apple_ref/doc/constant_group/FSEventStreamCreateFlags
+#ifndef kFSEventStreamCreateFlagNone
+#define kFSEventStreamCreateFlagNone 0x00000000
+#endif
+
+#ifndef kFSEventStreamCreateFlagUseCFTypes
+#define kFSEventStreamCreateFlagUseCFTypes 0x00000001
+#endif
+
+#ifndef kFSEventStreamCreateFlagNoDefer
+#define kFSEventStreamCreateFlagNoDefer 0x00000002
+#endif
+
+#ifndef kFSEventStreamCreateFlagWatchRoot
+#define kFSEventStreamCreateFlagWatchRoot 0x00000004
+#endif
+
+#ifndef kFSEventStreamCreateFlagIgnoreSelf
+#define kFSEventStreamCreateFlagIgnoreSelf 0x00000008
+#endif
+
+#ifndef kFSEventStreamCreateFlagFileEvents
+#define kFSEventStreamCreateFlagFileEvents 0x00000010
+#endif
+
+void FSEvents::threadStart() {
+ if (threadloop) return;
+ pthread_create(&thread, NULL, &FSEvents::threadRun, this);
+}
+
+void HandleStreamEvents(ConstFSEventStreamRef stream, void *ctx, size_t numEvents, void *eventPaths, const FSEventStreamEventFlags eventFlags[], const FSEventStreamEventId eventIds[]) {
+ FSEvents * fse = (FSEvents *)ctx;
+ size_t idx;
+ fse->lock();
+ for (idx=0; idx < numEvents; idx++) {
+ fse_event *event = new fse_event(
+ (CFStringRef)CFArrayGetValueAtIndex((CFArrayRef)eventPaths, idx),
+ eventFlags[idx],
+ eventIds[idx]
+ );
+ fse->events.push_back(event);
+ }
+ fse->asyncTrigger();
+ fse->unlock();
+}
+
+void *FSEvents::threadRun(void *ctx) {
+ FSEvents *fse = (FSEvents*)ctx;
+ FSEventStreamContext context = { 0, ctx, NULL, NULL, NULL };
+ fse->threadloop = CFRunLoopGetCurrent();
+ FSEventStreamRef stream = FSEventStreamCreate(NULL, &HandleStreamEvents, &context, fse->paths, kFSEventStreamEventIdSinceNow, (CFAbsoluteTime) 0.1, kFSEventStreamCreateFlagNone | kFSEventStreamCreateFlagWatchRoot | kFSEventStreamCreateFlagFileEvents | kFSEventStreamCreateFlagUseCFTypes);
+ FSEventStreamScheduleWithRunLoop(stream, fse->threadloop, kCFRunLoopDefaultMode);
+ FSEventStreamStart(stream);
+ CFRunLoopRun();
+ FSEventStreamStop(stream);
+ FSEventStreamUnscheduleFromRunLoop(stream, fse->threadloop, kCFRunLoopDefaultMode);
+ FSEventStreamInvalidate(stream);
+ FSEventStreamRelease(stream);
+ fse->threadloop = NULL;
+ return NULL;
+}
+
+void FSEvents::threadStop() {
+ if (!threadloop) return;
+ CFRunLoopStop(threadloop);
+ pthread_join(thread, NULL);
+}