/push/:msgtoken sendet Push

express-server/node_modules/fsevents/src/async.cc

@@ -0,0 +1,43 @@
+/*
+** © 2014 by Philipp Dunkel <pip@pipobscure.com>
+** Licensed under MIT License.
+*/
+
+
+void async_propagate(uv_async_t *async) {
+  if (!async->data) return;
+  FSEvents *fse = (FSEvents *)async->data;
+  CFIndex idx, cnt;
+  fse_event *event;
+  char pathbuf[1024];
+  const char *pathptr = NULL;
+  uv_mutex_lock(&fse->mutex);
+  cnt = fse->events.size();
+  for (idx=0; idx<cnt; idx++) {
+    event = fse->events.at(idx);
+    if (event == NULL) continue;
+    pathptr = CFStringGetCStringPtr(event->path, kCFStringEncodingUTF8);
+    if (!pathptr) CFStringGetCString(event->path, pathbuf, 1024, kCFStringEncodingUTF8);
+    fse->emitEvent(pathptr ? pathptr : pathbuf, event->flags, event->id);
+    delete event;
+  }
+  if (cnt>0) fse->events.clear();
+  uv_mutex_unlock(&fse->mutex);
+}
+
+void FSEvents::asyncStart() {
+  if (async.data == this) return;
+  async.data = this;
+  uv_async_init(uv_default_loop(), &async, (uv_async_cb) async_propagate);
+}
+
+void FSEvents::asyncTrigger() {
+  if (async.data != this) return;
+  uv_async_send(&async);
+}
+
+void FSEvents::asyncStop() {
+  if (async.data != this) return;
+  async.data = NULL;
+  uv_close((uv_handle_t *) &async, NULL);
+}