Blame src/unix/fsevents.c

Packit b5b901
/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
Packit b5b901
 * Permission is hereby granted, free of charge, to any person obtaining a copy
Packit b5b901
 * of this software and associated documentation files (the "Software"), to
Packit b5b901
 * deal in the Software without restriction, including without limitation the
Packit b5b901
 * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
Packit b5b901
 * sell copies of the Software, and to permit persons to whom the Software is
Packit b5b901
 * furnished to do so, subject to the following conditions:
Packit b5b901
 *
Packit b5b901
 * The above copyright notice and this permission notice shall be included in
Packit b5b901
 * all copies or substantial portions of the Software.
Packit b5b901
 *
Packit b5b901
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
Packit b5b901
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
Packit b5b901
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
Packit b5b901
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
Packit b5b901
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
Packit b5b901
 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
Packit b5b901
 * IN THE SOFTWARE.
Packit b5b901
 */
Packit b5b901
Packit b5b901
#include "uv.h"
Packit b5b901
#include "internal.h"
Packit b5b901
Packit Service e08953
#if TARGET_OS_IPHONE || MAC_OS_X_VERSION_MAX_ALLOWED < 1070
Packit b5b901
Packit b5b901
/* iOS (currently) doesn't provide the FSEvents-API (nor CoreServices) */
Packit Service e08953
/* macOS prior to 10.7 doesn't provide the full FSEvents API so use kqueue */
Packit b5b901
Packit b5b901
int uv__fsevents_init(uv_fs_event_t* handle) {
Packit b5b901
  return 0;
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
int uv__fsevents_close(uv_fs_event_t* handle) {
Packit b5b901
  return 0;
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
void uv__fsevents_loop_delete(uv_loop_t* loop) {
Packit b5b901
}
Packit b5b901
Packit b5b901
#else /* TARGET_OS_IPHONE */
Packit b5b901
Packit Service e08953
#include "darwin-stub.h"
Packit Service e08953
Packit b5b901
#include <dlfcn.h>
Packit b5b901
#include <assert.h>
Packit b5b901
#include <stdlib.h>
Packit b5b901
#include <pthread.h>
Packit b5b901
Packit Service e08953
static const int kFSEventsModified =
Packit Service e08953
    kFSEventStreamEventFlagItemChangeOwner |
Packit Service e08953
    kFSEventStreamEventFlagItemFinderInfoMod |
Packit Service e08953
    kFSEventStreamEventFlagItemInodeMetaMod |
Packit Service e08953
    kFSEventStreamEventFlagItemModified |
Packit Service e08953
    kFSEventStreamEventFlagItemXattrMod;
Packit Service e08953
Packit Service e08953
static const int kFSEventsRenamed =
Packit Service e08953
    kFSEventStreamEventFlagItemCreated |
Packit Service e08953
    kFSEventStreamEventFlagItemRemoved |
Packit Service e08953
    kFSEventStreamEventFlagItemRenamed;
Packit Service e08953
Packit Service e08953
static const int kFSEventsSystem =
Packit Service e08953
    kFSEventStreamEventFlagUserDropped |
Packit Service e08953
    kFSEventStreamEventFlagKernelDropped |
Packit Service e08953
    kFSEventStreamEventFlagEventIdsWrapped |
Packit Service e08953
    kFSEventStreamEventFlagHistoryDone |
Packit Service e08953
    kFSEventStreamEventFlagMount |
Packit Service e08953
    kFSEventStreamEventFlagUnmount |
Packit Service e08953
    kFSEventStreamEventFlagRootChanged;
Packit b5b901
Packit b5b901
typedef struct uv__fsevents_event_s uv__fsevents_event_t;
Packit b5b901
typedef struct uv__cf_loop_signal_s uv__cf_loop_signal_t;
Packit b5b901
typedef struct uv__cf_loop_state_s uv__cf_loop_state_t;
Packit b5b901
Packit b5b901
enum uv__cf_loop_signal_type_e {
Packit b5b901
  kUVCFLoopSignalRegular,
Packit b5b901
  kUVCFLoopSignalClosing
Packit b5b901
};
Packit b5b901
typedef enum uv__cf_loop_signal_type_e uv__cf_loop_signal_type_t;
Packit b5b901
Packit b5b901
struct uv__cf_loop_signal_s {
Packit b5b901
  QUEUE member;
Packit b5b901
  uv_fs_event_t* handle;
Packit b5b901
  uv__cf_loop_signal_type_t type;
Packit b5b901
};
Packit b5b901
Packit b5b901
struct uv__fsevents_event_s {
Packit b5b901
  QUEUE member;
Packit b5b901
  int events;
Packit b5b901
  char path[1];
Packit b5b901
};
Packit b5b901
Packit b5b901
struct uv__cf_loop_state_s {
Packit b5b901
  CFRunLoopRef loop;
Packit b5b901
  CFRunLoopSourceRef signal_source;
Packit b5b901
  int fsevent_need_reschedule;
Packit b5b901
  FSEventStreamRef fsevent_stream;
Packit b5b901
  uv_sem_t fsevent_sem;
Packit b5b901
  uv_mutex_t fsevent_mutex;
Packit b5b901
  void* fsevent_handles[2];
Packit b5b901
  unsigned int fsevent_handle_count;
Packit b5b901
};
Packit b5b901
Packit b5b901
/* Forward declarations */
Packit b5b901
static void uv__cf_loop_cb(void* arg);
Packit b5b901
static void* uv__cf_loop_runner(void* arg);
Packit b5b901
static int uv__cf_loop_signal(uv_loop_t* loop,
Packit b5b901
                              uv_fs_event_t* handle,
Packit b5b901
                              uv__cf_loop_signal_type_t type);
Packit b5b901
Packit b5b901
/* Lazy-loaded by uv__fsevents_global_init(). */
Packit b5b901
static CFArrayRef (*pCFArrayCreate)(CFAllocatorRef,
Packit b5b901
                                    const void**,
Packit b5b901
                                    CFIndex,
Packit b5b901
                                    const CFArrayCallBacks*);
Packit b5b901
static void (*pCFRelease)(CFTypeRef);
Packit b5b901
static void (*pCFRunLoopAddSource)(CFRunLoopRef,
Packit b5b901
                                   CFRunLoopSourceRef,
Packit b5b901
                                   CFStringRef);
Packit b5b901
static CFRunLoopRef (*pCFRunLoopGetCurrent)(void);
Packit b5b901
static void (*pCFRunLoopRemoveSource)(CFRunLoopRef,
Packit b5b901
                                      CFRunLoopSourceRef,
Packit b5b901
                                      CFStringRef);
Packit b5b901
static void (*pCFRunLoopRun)(void);
Packit b5b901
static CFRunLoopSourceRef (*pCFRunLoopSourceCreate)(CFAllocatorRef,
Packit b5b901
                                                    CFIndex,
Packit b5b901
                                                    CFRunLoopSourceContext*);
Packit b5b901
static void (*pCFRunLoopSourceSignal)(CFRunLoopSourceRef);
Packit b5b901
static void (*pCFRunLoopStop)(CFRunLoopRef);
Packit b5b901
static void (*pCFRunLoopWakeUp)(CFRunLoopRef);
Packit b5b901
static CFStringRef (*pCFStringCreateWithFileSystemRepresentation)(
Packit b5b901
    CFAllocatorRef,
Packit b5b901
    const char*);
Packit b5b901
static CFStringEncoding (*pCFStringGetSystemEncoding)(void);
Packit b5b901
static CFStringRef (*pkCFRunLoopDefaultMode);
Packit b5b901
static FSEventStreamRef (*pFSEventStreamCreate)(CFAllocatorRef,
Packit b5b901
                                                FSEventStreamCallback,
Packit b5b901
                                                FSEventStreamContext*,
Packit b5b901
                                                CFArrayRef,
Packit b5b901
                                                FSEventStreamEventId,
Packit b5b901
                                                CFTimeInterval,
Packit b5b901
                                                FSEventStreamCreateFlags);
Packit b5b901
static void (*pFSEventStreamFlushSync)(FSEventStreamRef);
Packit b5b901
static void (*pFSEventStreamInvalidate)(FSEventStreamRef);
Packit b5b901
static void (*pFSEventStreamRelease)(FSEventStreamRef);
Packit b5b901
static void (*pFSEventStreamScheduleWithRunLoop)(FSEventStreamRef,
Packit b5b901
                                                 CFRunLoopRef,
Packit b5b901
                                                 CFStringRef);
Packit Service e08953
static int (*pFSEventStreamStart)(FSEventStreamRef);
Packit b5b901
static void (*pFSEventStreamStop)(FSEventStreamRef);
Packit b5b901
Packit b5b901
#define UV__FSEVENTS_PROCESS(handle, block)                                   \
Packit b5b901
    do {                                                                      \
Packit b5b901
      QUEUE events;                                                           \
Packit b5b901
      QUEUE* q;                                                               \
Packit b5b901
      uv__fsevents_event_t* event;                                            \
Packit b5b901
      int err;                                                                \
Packit b5b901
      uv_mutex_lock(&(handle)->cf_mutex);                                     \
Packit b5b901
      /* Split-off all events and empty original queue */                     \
Packit b5b901
      QUEUE_MOVE(&(handle)->cf_events, &events);                              \
Packit b5b901
      /* Get error (if any) and zero original one */                          \
Packit b5b901
      err = (handle)->cf_error;                                               \
Packit b5b901
      (handle)->cf_error = 0;                                                 \
Packit b5b901
      uv_mutex_unlock(&(handle)->cf_mutex);                                   \
Packit b5b901
      /* Loop through events, deallocating each after processing */           \
Packit b5b901
      while (!QUEUE_EMPTY(&events)) {                                         \
Packit b5b901
        q = QUEUE_HEAD(&events);                                              \
Packit b5b901
        event = QUEUE_DATA(q, uv__fsevents_event_t, member);                  \
Packit b5b901
        QUEUE_REMOVE(q);                                                      \
Packit b5b901
        /* NOTE: Checking uv__is_active() is required here, because handle    \
Packit b5b901
         * callback may close handle and invoking it after it will lead to    \
Packit b5b901
         * incorrect behaviour */                                             \
Packit b5b901
        if (!uv__is_closing((handle)) && uv__is_active((handle)))             \
Packit b5b901
          block                                                               \
Packit b5b901
        /* Free allocated data */                                             \
Packit b5b901
        uv__free(event);                                                      \
Packit b5b901
      }                                                                       \
Packit b5b901
      if (err != 0 && !uv__is_closing((handle)) && uv__is_active((handle)))   \
Packit b5b901
        (handle)->cb((handle), NULL, 0, err);                                 \
Packit b5b901
    } while (0)
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in UV loop's thread, when there're events to report to handle */
Packit b5b901
static void uv__fsevents_cb(uv_async_t* cb) {
Packit b5b901
  uv_fs_event_t* handle;
Packit b5b901
Packit b5b901
  handle = cb->data;
Packit b5b901
Packit b5b901
  UV__FSEVENTS_PROCESS(handle, {
Packit b5b901
    handle->cb(handle, event->path[0] ? event->path : NULL, event->events, 0);
Packit b5b901
  });
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in CF thread, pushed event into handle's event list */
Packit b5b901
static void uv__fsevents_push_event(uv_fs_event_t* handle,
Packit b5b901
                                    QUEUE* events,
Packit b5b901
                                    int err) {
Packit b5b901
  assert(events != NULL || err != 0);
Packit b5b901
  uv_mutex_lock(&handle->cf_mutex);
Packit b5b901
Packit b5b901
  /* Concatenate two queues */
Packit b5b901
  if (events != NULL)
Packit b5b901
    QUEUE_ADD(&handle->cf_events, events);
Packit b5b901
Packit b5b901
  /* Propagate error */
Packit b5b901
  if (err != 0)
Packit b5b901
    handle->cf_error = err;
Packit b5b901
  uv_mutex_unlock(&handle->cf_mutex);
Packit b5b901
Packit b5b901
  uv_async_send(handle->cf_cb);
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in CF thread, when there're events in FSEventStream */
Packit Service e08953
static void uv__fsevents_event_cb(const FSEventStreamRef streamRef,
Packit b5b901
                                  void* info,
Packit b5b901
                                  size_t numEvents,
Packit b5b901
                                  void* eventPaths,
Packit b5b901
                                  const FSEventStreamEventFlags eventFlags[],
Packit b5b901
                                  const FSEventStreamEventId eventIds[]) {
Packit b5b901
  size_t i;
Packit b5b901
  int len;
Packit b5b901
  char** paths;
Packit b5b901
  char* path;
Packit b5b901
  char* pos;
Packit b5b901
  uv_fs_event_t* handle;
Packit b5b901
  QUEUE* q;
Packit b5b901
  uv_loop_t* loop;
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
  uv__fsevents_event_t* event;
Packit b5b901
  FSEventStreamEventFlags flags;
Packit b5b901
  QUEUE head;
Packit b5b901
Packit b5b901
  loop = info;
Packit b5b901
  state = loop->cf_state;
Packit b5b901
  assert(state != NULL);
Packit b5b901
  paths = eventPaths;
Packit b5b901
Packit b5b901
  /* For each handle */
Packit b5b901
  uv_mutex_lock(&state->fsevent_mutex);
Packit b5b901
  QUEUE_FOREACH(q, &state->fsevent_handles) {
Packit b5b901
    handle = QUEUE_DATA(q, uv_fs_event_t, cf_member);
Packit b5b901
    QUEUE_INIT(&head;;
Packit b5b901
Packit b5b901
    /* Process and filter out events */
Packit b5b901
    for (i = 0; i < numEvents; i++) {
Packit b5b901
      flags = eventFlags[i];
Packit b5b901
Packit b5b901
      /* Ignore system events */
Packit b5b901
      if (flags & kFSEventsSystem)
Packit b5b901
        continue;
Packit b5b901
Packit b5b901
      path = paths[i];
Packit b5b901
      len = strlen(path);
Packit b5b901
Packit Service e08953
      if (handle->realpath_len == 0)
Packit Service e08953
        continue; /* This should be unreachable */
Packit Service e08953
Packit b5b901
      /* Filter out paths that are outside handle's request */
Packit Service e08953
      if (len < handle->realpath_len)
Packit Service e08953
        continue;
Packit Service e08953
Packit Service e08953
      /* Make sure that realpath actually named a directory,
Packit Service e08953
       * (unless watching root, which alone keeps a trailing slash on the realpath)
Packit Service e08953
       * or that we matched the whole string */
Packit Service e08953
      if (handle->realpath_len != len &&
Packit Service e08953
          handle->realpath_len > 1 &&
Packit Service e08953
          path[handle->realpath_len] != '/')
Packit b5b901
        continue;
Packit b5b901
Packit Service e08953
      if (memcmp(path, handle->realpath, handle->realpath_len) != 0)
Packit Service e08953
        continue;
Packit Service e08953
Packit Service e08953
      if (!(handle->realpath_len == 1 && handle->realpath[0] == '/')) {
Packit Service e08953
        /* Remove common prefix, unless the watched folder is "/" */
Packit b5b901
        path += handle->realpath_len;
Packit b5b901
        len -= handle->realpath_len;
Packit b5b901
Packit Service e08953
        /* Ignore events with path equal to directory itself */
Packit Service e08953
        if (len <= 1 && (flags & kFSEventStreamEventFlagItemIsDir))
Packit Service e08953
          continue;
Packit Service e08953
Packit Service e08953
        if (len == 0) {
Packit Service e08953
          /* Since we're using fsevents to watch the file itself,
Packit Service e08953
           * realpath == path, and we now need to get the basename of the file back
Packit Service e08953
           * (for commonality with other codepaths and platforms). */
Packit Service e08953
          while (len < handle->realpath_len && path[-1] != '/') {
Packit Service e08953
            path--;
Packit Service e08953
            len++;
Packit Service e08953
          }
Packit Service e08953
          /* Created and Removed seem to be always set, but don't make sense */
Packit Service e08953
          flags &= ~kFSEventsRenamed;
Packit Service e08953
        } else {
Packit Service e08953
          /* Skip forward slash */
Packit b5b901
          path++;
Packit b5b901
          len--;
Packit b5b901
        }
Packit b5b901
      }
Packit b5b901
Packit b5b901
      /* Do not emit events from subdirectories (without option set) */
Packit Service e08953
      if ((handle->cf_flags & UV_FS_EVENT_RECURSIVE) == 0 && *path != '\0') {
Packit b5b901
        pos = strchr(path + 1, '/');
Packit b5b901
        if (pos != NULL)
Packit b5b901
          continue;
Packit b5b901
      }
Packit b5b901
Packit b5b901
      event = uv__malloc(sizeof(*event) + len);
Packit b5b901
      if (event == NULL)
Packit b5b901
        break;
Packit b5b901
Packit b5b901
      memset(event, 0, sizeof(*event));
Packit b5b901
      memcpy(event->path, path, len + 1);
Packit b5b901
      event->events = UV_RENAME;
Packit b5b901
Packit Service e08953
      if (0 == (flags & kFSEventsRenamed)) {
Packit Service e08953
        if (0 != (flags & kFSEventsModified) ||
Packit Service e08953
            0 == (flags & kFSEventStreamEventFlagItemIsDir))
Packit Service e08953
          event->events = UV_CHANGE;
Packit b5b901
      }
Packit b5b901
Packit b5b901
      QUEUE_INSERT_TAIL(&head, &event->member);
Packit b5b901
    }
Packit b5b901
Packit b5b901
    if (!QUEUE_EMPTY(&head))
Packit b5b901
      uv__fsevents_push_event(handle, &head, 0);
Packit b5b901
  }
Packit b5b901
  uv_mutex_unlock(&state->fsevent_mutex);
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in CF thread */
Packit b5b901
static int uv__fsevents_create_stream(uv_loop_t* loop, CFArrayRef paths) {
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
  FSEventStreamContext ctx;
Packit b5b901
  FSEventStreamRef ref;
Packit b5b901
  CFAbsoluteTime latency;
Packit b5b901
  FSEventStreamCreateFlags flags;
Packit b5b901
Packit b5b901
  /* Initialize context */
Packit Service e08953
  memset(&ctx, 0, sizeof(ctx));
Packit b5b901
  ctx.info = loop;
Packit b5b901
Packit b5b901
  latency = 0.05;
Packit b5b901
Packit b5b901
  /* Explanation of selected flags:
Packit b5b901
   * 1. NoDefer - without this flag, events that are happening continuously
Packit b5b901
   *    (i.e. each event is happening after time interval less than `latency`,
Packit b5b901
   *    counted from previous event), will be deferred and passed to callback
Packit b5b901
   *    once they'll either fill whole OS buffer, or when this continuous stream
Packit b5b901
   *    will stop (i.e. there'll be delay between events, bigger than
Packit b5b901
   *    `latency`).
Packit b5b901
   *    Specifying this flag will invoke callback after `latency` time passed
Packit b5b901
   *    since event.
Packit b5b901
   * 2. FileEvents - fire callback for file changes too (by default it is firing
Packit b5b901
   *    it only for directory changes).
Packit b5b901
   */
Packit b5b901
  flags = kFSEventStreamCreateFlagNoDefer | kFSEventStreamCreateFlagFileEvents;
Packit b5b901
Packit b5b901
  /*
Packit b5b901
   * NOTE: It might sound like a good idea to remember last seen StreamEventId,
Packit b5b901
   * but in reality one dir might have last StreamEventId less than, the other,
Packit b5b901
   * that is being watched now. Which will cause FSEventStream API to report
Packit b5b901
   * changes to files from the past.
Packit b5b901
   */
Packit b5b901
  ref = pFSEventStreamCreate(NULL,
Packit b5b901
                             &uv__fsevents_event_cb,
Packit b5b901
                             &ctx,
Packit b5b901
                             paths,
Packit b5b901
                             kFSEventStreamEventIdSinceNow,
Packit b5b901
                             latency,
Packit b5b901
                             flags);
Packit b5b901
  assert(ref != NULL);
Packit b5b901
Packit b5b901
  state = loop->cf_state;
Packit b5b901
  pFSEventStreamScheduleWithRunLoop(ref,
Packit b5b901
                                    state->loop,
Packit b5b901
                                    *pkCFRunLoopDefaultMode);
Packit b5b901
  if (!pFSEventStreamStart(ref)) {
Packit b5b901
    pFSEventStreamInvalidate(ref);
Packit b5b901
    pFSEventStreamRelease(ref);
Packit b5b901
    return UV_EMFILE;
Packit b5b901
  }
Packit b5b901
Packit b5b901
  state->fsevent_stream = ref;
Packit b5b901
  return 0;
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in CF thread */
Packit b5b901
static void uv__fsevents_destroy_stream(uv_loop_t* loop) {
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
Packit b5b901
  state = loop->cf_state;
Packit b5b901
Packit b5b901
  if (state->fsevent_stream == NULL)
Packit b5b901
    return;
Packit b5b901
Packit b5b901
  /* Stop emitting events */
Packit b5b901
  pFSEventStreamStop(state->fsevent_stream);
Packit b5b901
Packit b5b901
  /* Release stream */
Packit b5b901
  pFSEventStreamInvalidate(state->fsevent_stream);
Packit b5b901
  pFSEventStreamRelease(state->fsevent_stream);
Packit b5b901
  state->fsevent_stream = NULL;
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in CF thread, when there're new fsevent handles to add to stream */
Packit b5b901
static void uv__fsevents_reschedule(uv_fs_event_t* handle,
Packit b5b901
                                    uv__cf_loop_signal_type_t type) {
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
  QUEUE* q;
Packit b5b901
  uv_fs_event_t* curr;
Packit b5b901
  CFArrayRef cf_paths;
Packit b5b901
  CFStringRef* paths;
Packit b5b901
  unsigned int i;
Packit b5b901
  int err;
Packit b5b901
  unsigned int path_count;
Packit b5b901
Packit b5b901
  state = handle->loop->cf_state;
Packit b5b901
  paths = NULL;
Packit b5b901
  cf_paths = NULL;
Packit b5b901
  err = 0;
Packit b5b901
  /* NOTE: `i` is used in deallocation loop below */
Packit b5b901
  i = 0;
Packit b5b901
Packit b5b901
  /* Optimization to prevent O(n^2) time spent when starting to watch
Packit b5b901
   * many files simultaneously
Packit b5b901
   */
Packit b5b901
  uv_mutex_lock(&state->fsevent_mutex);
Packit b5b901
  if (state->fsevent_need_reschedule == 0) {
Packit b5b901
    uv_mutex_unlock(&state->fsevent_mutex);
Packit b5b901
    goto final;
Packit b5b901
  }
Packit b5b901
  state->fsevent_need_reschedule = 0;
Packit b5b901
  uv_mutex_unlock(&state->fsevent_mutex);
Packit b5b901
Packit b5b901
  /* Destroy previous FSEventStream */
Packit b5b901
  uv__fsevents_destroy_stream(handle->loop);
Packit b5b901
Packit b5b901
  /* Any failure below will be a memory failure */
Packit b5b901
  err = UV_ENOMEM;
Packit b5b901
Packit b5b901
  /* Create list of all watched paths */
Packit b5b901
  uv_mutex_lock(&state->fsevent_mutex);
Packit b5b901
  path_count = state->fsevent_handle_count;
Packit b5b901
  if (path_count != 0) {
Packit b5b901
    paths = uv__malloc(sizeof(*paths) * path_count);
Packit b5b901
    if (paths == NULL) {
Packit b5b901
      uv_mutex_unlock(&state->fsevent_mutex);
Packit b5b901
      goto final;
Packit b5b901
    }
Packit b5b901
Packit b5b901
    q = &state->fsevent_handles;
Packit b5b901
    for (; i < path_count; i++) {
Packit b5b901
      q = QUEUE_NEXT(q);
Packit b5b901
      assert(q != &state->fsevent_handles);
Packit b5b901
      curr = QUEUE_DATA(q, uv_fs_event_t, cf_member);
Packit b5b901
Packit b5b901
      assert(curr->realpath != NULL);
Packit b5b901
      paths[i] =
Packit b5b901
          pCFStringCreateWithFileSystemRepresentation(NULL, curr->realpath);
Packit b5b901
      if (paths[i] == NULL) {
Packit b5b901
        uv_mutex_unlock(&state->fsevent_mutex);
Packit b5b901
        goto final;
Packit b5b901
      }
Packit b5b901
    }
Packit b5b901
  }
Packit b5b901
  uv_mutex_unlock(&state->fsevent_mutex);
Packit b5b901
  err = 0;
Packit b5b901
Packit b5b901
  if (path_count != 0) {
Packit b5b901
    /* Create new FSEventStream */
Packit b5b901
    cf_paths = pCFArrayCreate(NULL, (const void**) paths, path_count, NULL);
Packit b5b901
    if (cf_paths == NULL) {
Packit b5b901
      err = UV_ENOMEM;
Packit b5b901
      goto final;
Packit b5b901
    }
Packit b5b901
    err = uv__fsevents_create_stream(handle->loop, cf_paths);
Packit b5b901
  }
Packit b5b901
Packit b5b901
final:
Packit b5b901
  /* Deallocate all paths in case of failure */
Packit b5b901
  if (err != 0) {
Packit b5b901
    if (cf_paths == NULL) {
Packit b5b901
      while (i != 0)
Packit b5b901
        pCFRelease(paths[--i]);
Packit b5b901
      uv__free(paths);
Packit b5b901
    } else {
Packit b5b901
      /* CFArray takes ownership of both strings and original C-array */
Packit b5b901
      pCFRelease(cf_paths);
Packit b5b901
    }
Packit b5b901
Packit b5b901
    /* Broadcast error to all handles */
Packit b5b901
    uv_mutex_lock(&state->fsevent_mutex);
Packit b5b901
    QUEUE_FOREACH(q, &state->fsevent_handles) {
Packit b5b901
      curr = QUEUE_DATA(q, uv_fs_event_t, cf_member);
Packit b5b901
      uv__fsevents_push_event(curr, NULL, err);
Packit b5b901
    }
Packit b5b901
    uv_mutex_unlock(&state->fsevent_mutex);
Packit b5b901
  }
Packit b5b901
Packit b5b901
  /*
Packit b5b901
   * Main thread will block until the removal of handle from the list,
Packit b5b901
   * we must tell it when we're ready.
Packit b5b901
   *
Packit b5b901
   * NOTE: This is coupled with `uv_sem_wait()` in `uv__fsevents_close`
Packit b5b901
   */
Packit b5b901
  if (type == kUVCFLoopSignalClosing)
Packit b5b901
    uv_sem_post(&state->fsevent_sem);
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
static int uv__fsevents_global_init(void) {
Packit b5b901
  static pthread_mutex_t global_init_mutex = PTHREAD_MUTEX_INITIALIZER;
Packit b5b901
  static void* core_foundation_handle;
Packit b5b901
  static void* core_services_handle;
Packit b5b901
  int err;
Packit b5b901
Packit b5b901
  err = 0;
Packit b5b901
  pthread_mutex_lock(&global_init_mutex);
Packit b5b901
  if (core_foundation_handle != NULL)
Packit b5b901
    goto out;
Packit b5b901
Packit b5b901
  /* The libraries are never unloaded because we currently don't have a good
Packit b5b901
   * mechanism for keeping a reference count. It's unlikely to be an issue
Packit b5b901
   * but if it ever becomes one, we can turn the dynamic library handles into
Packit b5b901
   * per-event loop properties and have the dynamic linker keep track for us.
Packit b5b901
   */
Packit b5b901
  err = UV_ENOSYS;
Packit b5b901
  core_foundation_handle = dlopen("/System/Library/Frameworks/"
Packit b5b901
                                  "CoreFoundation.framework/"
Packit b5b901
                                  "Versions/A/CoreFoundation",
Packit b5b901
                                  RTLD_LAZY | RTLD_LOCAL);
Packit b5b901
  if (core_foundation_handle == NULL)
Packit b5b901
    goto out;
Packit b5b901
Packit b5b901
  core_services_handle = dlopen("/System/Library/Frameworks/"
Packit b5b901
                                "CoreServices.framework/"
Packit b5b901
                                "Versions/A/CoreServices",
Packit b5b901
                                RTLD_LAZY | RTLD_LOCAL);
Packit b5b901
  if (core_services_handle == NULL)
Packit b5b901
    goto out;
Packit b5b901
Packit b5b901
  err = UV_ENOENT;
Packit b5b901
#define V(handle, symbol)                                                     \
Packit b5b901
  do {                                                                        \
Packit b5b901
    *(void **)(&p ## symbol) = dlsym((handle), #symbol);                      \
Packit b5b901
    if (p ## symbol == NULL)                                                  \
Packit b5b901
      goto out;                                                               \
Packit b5b901
  }                                                                           \
Packit b5b901
  while (0)
Packit b5b901
  V(core_foundation_handle, CFArrayCreate);
Packit b5b901
  V(core_foundation_handle, CFRelease);
Packit b5b901
  V(core_foundation_handle, CFRunLoopAddSource);
Packit b5b901
  V(core_foundation_handle, CFRunLoopGetCurrent);
Packit b5b901
  V(core_foundation_handle, CFRunLoopRemoveSource);
Packit b5b901
  V(core_foundation_handle, CFRunLoopRun);
Packit b5b901
  V(core_foundation_handle, CFRunLoopSourceCreate);
Packit b5b901
  V(core_foundation_handle, CFRunLoopSourceSignal);
Packit b5b901
  V(core_foundation_handle, CFRunLoopStop);
Packit b5b901
  V(core_foundation_handle, CFRunLoopWakeUp);
Packit b5b901
  V(core_foundation_handle, CFStringCreateWithFileSystemRepresentation);
Packit b5b901
  V(core_foundation_handle, CFStringGetSystemEncoding);
Packit b5b901
  V(core_foundation_handle, kCFRunLoopDefaultMode);
Packit b5b901
  V(core_services_handle, FSEventStreamCreate);
Packit b5b901
  V(core_services_handle, FSEventStreamFlushSync);
Packit b5b901
  V(core_services_handle, FSEventStreamInvalidate);
Packit b5b901
  V(core_services_handle, FSEventStreamRelease);
Packit b5b901
  V(core_services_handle, FSEventStreamScheduleWithRunLoop);
Packit b5b901
  V(core_services_handle, FSEventStreamStart);
Packit b5b901
  V(core_services_handle, FSEventStreamStop);
Packit b5b901
#undef V
Packit b5b901
  err = 0;
Packit b5b901
Packit b5b901
out:
Packit b5b901
  if (err && core_services_handle != NULL) {
Packit b5b901
    dlclose(core_services_handle);
Packit b5b901
    core_services_handle = NULL;
Packit b5b901
  }
Packit b5b901
Packit b5b901
  if (err && core_foundation_handle != NULL) {
Packit b5b901
    dlclose(core_foundation_handle);
Packit b5b901
    core_foundation_handle = NULL;
Packit b5b901
  }
Packit b5b901
Packit b5b901
  pthread_mutex_unlock(&global_init_mutex);
Packit b5b901
  return err;
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in UV loop */
Packit b5b901
static int uv__fsevents_loop_init(uv_loop_t* loop) {
Packit b5b901
  CFRunLoopSourceContext ctx;
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
  pthread_attr_t attr_storage;
Packit b5b901
  pthread_attr_t* attr;
Packit b5b901
  int err;
Packit b5b901
Packit b5b901
  if (loop->cf_state != NULL)
Packit b5b901
    return 0;
Packit b5b901
Packit b5b901
  err = uv__fsevents_global_init();
Packit b5b901
  if (err)
Packit b5b901
    return err;
Packit b5b901
Packit b5b901
  state = uv__calloc(1, sizeof(*state));
Packit b5b901
  if (state == NULL)
Packit b5b901
    return UV_ENOMEM;
Packit b5b901
Packit b5b901
  err = uv_mutex_init(&loop->cf_mutex);
Packit b5b901
  if (err)
Packit b5b901
    goto fail_mutex_init;
Packit b5b901
Packit b5b901
  err = uv_sem_init(&loop->cf_sem, 0);
Packit b5b901
  if (err)
Packit b5b901
    goto fail_sem_init;
Packit b5b901
Packit b5b901
  QUEUE_INIT(&loop->cf_signals);
Packit b5b901
Packit b5b901
  err = uv_sem_init(&state->fsevent_sem, 0);
Packit b5b901
  if (err)
Packit b5b901
    goto fail_fsevent_sem_init;
Packit b5b901
Packit b5b901
  err = uv_mutex_init(&state->fsevent_mutex);
Packit b5b901
  if (err)
Packit b5b901
    goto fail_fsevent_mutex_init;
Packit b5b901
Packit b5b901
  QUEUE_INIT(&state->fsevent_handles);
Packit b5b901
  state->fsevent_need_reschedule = 0;
Packit b5b901
  state->fsevent_handle_count = 0;
Packit b5b901
Packit b5b901
  memset(&ctx, 0, sizeof(ctx));
Packit b5b901
  ctx.info = loop;
Packit b5b901
  ctx.perform = uv__cf_loop_cb;
Packit b5b901
  state->signal_source = pCFRunLoopSourceCreate(NULL, 0, &ctx;;
Packit b5b901
  if (state->signal_source == NULL) {
Packit b5b901
    err = UV_ENOMEM;
Packit b5b901
    goto fail_signal_source_create;
Packit b5b901
  }
Packit b5b901
Packit b5b901
  /* In the unlikely event that pthread_attr_init() fails, create the thread
Packit b5b901
   * with the default stack size. We'll use a little more address space but
Packit b5b901
   * that in itself is not a fatal error.
Packit b5b901
   */
Packit b5b901
  attr = &attr_storage;
Packit b5b901
  if (pthread_attr_init(attr))
Packit b5b901
    attr = NULL;
Packit b5b901
Packit b5b901
  if (attr != NULL)
Packit b5b901
    if (pthread_attr_setstacksize(attr, 4 * PTHREAD_STACK_MIN))
Packit b5b901
      abort();
Packit b5b901
Packit b5b901
  loop->cf_state = state;
Packit b5b901
Packit b5b901
  /* uv_thread_t is an alias for pthread_t. */
Packit b5b901
  err = UV__ERR(pthread_create(&loop->cf_thread, attr, uv__cf_loop_runner, loop));
Packit b5b901
Packit b5b901
  if (attr != NULL)
Packit b5b901
    pthread_attr_destroy(attr);
Packit b5b901
Packit b5b901
  if (err)
Packit b5b901
    goto fail_thread_create;
Packit b5b901
Packit b5b901
  /* Synchronize threads */
Packit b5b901
  uv_sem_wait(&loop->cf_sem);
Packit b5b901
  return 0;
Packit b5b901
Packit b5b901
fail_thread_create:
Packit b5b901
  loop->cf_state = NULL;
Packit b5b901
Packit b5b901
fail_signal_source_create:
Packit b5b901
  uv_mutex_destroy(&state->fsevent_mutex);
Packit b5b901
Packit b5b901
fail_fsevent_mutex_init:
Packit b5b901
  uv_sem_destroy(&state->fsevent_sem);
Packit b5b901
Packit b5b901
fail_fsevent_sem_init:
Packit b5b901
  uv_sem_destroy(&loop->cf_sem);
Packit b5b901
Packit b5b901
fail_sem_init:
Packit b5b901
  uv_mutex_destroy(&loop->cf_mutex);
Packit b5b901
Packit b5b901
fail_mutex_init:
Packit b5b901
  uv__free(state);
Packit b5b901
  return err;
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in UV loop */
Packit b5b901
void uv__fsevents_loop_delete(uv_loop_t* loop) {
Packit b5b901
  uv__cf_loop_signal_t* s;
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
  QUEUE* q;
Packit b5b901
Packit b5b901
  if (loop->cf_state == NULL)
Packit b5b901
    return;
Packit b5b901
Packit b5b901
  if (uv__cf_loop_signal(loop, NULL, kUVCFLoopSignalRegular) != 0)
Packit b5b901
    abort();
Packit b5b901
Packit b5b901
  uv_thread_join(&loop->cf_thread);
Packit b5b901
  uv_sem_destroy(&loop->cf_sem);
Packit b5b901
  uv_mutex_destroy(&loop->cf_mutex);
Packit b5b901
Packit b5b901
  /* Free any remaining data */
Packit b5b901
  while (!QUEUE_EMPTY(&loop->cf_signals)) {
Packit b5b901
    q = QUEUE_HEAD(&loop->cf_signals);
Packit b5b901
    s = QUEUE_DATA(q, uv__cf_loop_signal_t, member);
Packit b5b901
    QUEUE_REMOVE(q);
Packit b5b901
    uv__free(s);
Packit b5b901
  }
Packit b5b901
Packit b5b901
  /* Destroy state */
Packit b5b901
  state = loop->cf_state;
Packit b5b901
  uv_sem_destroy(&state->fsevent_sem);
Packit b5b901
  uv_mutex_destroy(&state->fsevent_mutex);
Packit b5b901
  pCFRelease(state->signal_source);
Packit b5b901
  uv__free(state);
Packit b5b901
  loop->cf_state = NULL;
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in CF thread. This is the CF loop's body */
Packit b5b901
static void* uv__cf_loop_runner(void* arg) {
Packit b5b901
  uv_loop_t* loop;
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
Packit b5b901
  loop = arg;
Packit b5b901
  state = loop->cf_state;
Packit b5b901
  state->loop = pCFRunLoopGetCurrent();
Packit b5b901
Packit b5b901
  pCFRunLoopAddSource(state->loop,
Packit b5b901
                      state->signal_source,
Packit b5b901
                      *pkCFRunLoopDefaultMode);
Packit b5b901
Packit b5b901
  uv_sem_post(&loop->cf_sem);
Packit b5b901
Packit b5b901
  pCFRunLoopRun();
Packit b5b901
  pCFRunLoopRemoveSource(state->loop,
Packit b5b901
                         state->signal_source,
Packit b5b901
                         *pkCFRunLoopDefaultMode);
Packit b5b901
Packit Service e08953
  state->loop = NULL;
Packit Service e08953
Packit b5b901
  return NULL;
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in CF thread, executed after `uv__cf_loop_signal()` */
Packit b5b901
static void uv__cf_loop_cb(void* arg) {
Packit b5b901
  uv_loop_t* loop;
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
  QUEUE* item;
Packit b5b901
  QUEUE split_head;
Packit b5b901
  uv__cf_loop_signal_t* s;
Packit b5b901
Packit b5b901
  loop = arg;
Packit b5b901
  state = loop->cf_state;
Packit b5b901
Packit b5b901
  uv_mutex_lock(&loop->cf_mutex);
Packit b5b901
  QUEUE_MOVE(&loop->cf_signals, &split_head);
Packit b5b901
  uv_mutex_unlock(&loop->cf_mutex);
Packit b5b901
Packit b5b901
  while (!QUEUE_EMPTY(&split_head)) {
Packit b5b901
    item = QUEUE_HEAD(&split_head);
Packit b5b901
    QUEUE_REMOVE(item);
Packit b5b901
Packit b5b901
    s = QUEUE_DATA(item, uv__cf_loop_signal_t, member);
Packit b5b901
Packit b5b901
    /* This was a termination signal */
Packit b5b901
    if (s->handle == NULL)
Packit b5b901
      pCFRunLoopStop(state->loop);
Packit b5b901
    else
Packit b5b901
      uv__fsevents_reschedule(s->handle, s->type);
Packit b5b901
Packit b5b901
    uv__free(s);
Packit b5b901
  }
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in UV loop to notify CF thread */
Packit b5b901
int uv__cf_loop_signal(uv_loop_t* loop,
Packit b5b901
                       uv_fs_event_t* handle,
Packit b5b901
                       uv__cf_loop_signal_type_t type) {
Packit b5b901
  uv__cf_loop_signal_t* item;
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
Packit b5b901
  item = uv__malloc(sizeof(*item));
Packit b5b901
  if (item == NULL)
Packit b5b901
    return UV_ENOMEM;
Packit b5b901
Packit b5b901
  item->handle = handle;
Packit b5b901
  item->type = type;
Packit b5b901
Packit b5b901
  uv_mutex_lock(&loop->cf_mutex);
Packit b5b901
  QUEUE_INSERT_TAIL(&loop->cf_signals, &item->member);
Packit b5b901
Packit b5b901
  state = loop->cf_state;
Packit b5b901
  assert(state != NULL);
Packit b5b901
  pCFRunLoopSourceSignal(state->signal_source);
Packit b5b901
  pCFRunLoopWakeUp(state->loop);
Packit b5b901
Packit Service e08953
  uv_mutex_unlock(&loop->cf_mutex);
Packit Service e08953
Packit b5b901
  return 0;
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in UV loop to initialize handle */
Packit b5b901
int uv__fsevents_init(uv_fs_event_t* handle) {
Packit b5b901
  int err;
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
Packit b5b901
  err = uv__fsevents_loop_init(handle->loop);
Packit b5b901
  if (err)
Packit b5b901
    return err;
Packit b5b901
Packit b5b901
  /* Get absolute path to file */
Packit b5b901
  handle->realpath = realpath(handle->path, NULL);
Packit b5b901
  if (handle->realpath == NULL)
Packit b5b901
    return UV__ERR(errno);
Packit b5b901
  handle->realpath_len = strlen(handle->realpath);
Packit b5b901
Packit b5b901
  /* Initialize event queue */
Packit b5b901
  QUEUE_INIT(&handle->cf_events);
Packit b5b901
  handle->cf_error = 0;
Packit b5b901
Packit b5b901
  /*
Packit b5b901
   * Events will occur in other thread.
Packit b5b901
   * Initialize callback for getting them back into event loop's thread
Packit b5b901
   */
Packit b5b901
  handle->cf_cb = uv__malloc(sizeof(*handle->cf_cb));
Packit b5b901
  if (handle->cf_cb == NULL) {
Packit b5b901
    err = UV_ENOMEM;
Packit b5b901
    goto fail_cf_cb_malloc;
Packit b5b901
  }
Packit b5b901
Packit b5b901
  handle->cf_cb->data = handle;
Packit b5b901
  uv_async_init(handle->loop, handle->cf_cb, uv__fsevents_cb);
Packit b5b901
  handle->cf_cb->flags |= UV_HANDLE_INTERNAL;
Packit b5b901
  uv_unref((uv_handle_t*) handle->cf_cb);
Packit b5b901
Packit b5b901
  err = uv_mutex_init(&handle->cf_mutex);
Packit b5b901
  if (err)
Packit b5b901
    goto fail_cf_mutex_init;
Packit b5b901
Packit b5b901
  /* Insert handle into the list */
Packit b5b901
  state = handle->loop->cf_state;
Packit b5b901
  uv_mutex_lock(&state->fsevent_mutex);
Packit b5b901
  QUEUE_INSERT_TAIL(&state->fsevent_handles, &handle->cf_member);
Packit b5b901
  state->fsevent_handle_count++;
Packit b5b901
  state->fsevent_need_reschedule = 1;
Packit b5b901
  uv_mutex_unlock(&state->fsevent_mutex);
Packit b5b901
Packit b5b901
  /* Reschedule FSEventStream */
Packit b5b901
  assert(handle != NULL);
Packit b5b901
  err = uv__cf_loop_signal(handle->loop, handle, kUVCFLoopSignalRegular);
Packit b5b901
  if (err)
Packit b5b901
    goto fail_loop_signal;
Packit b5b901
Packit b5b901
  return 0;
Packit b5b901
Packit b5b901
fail_loop_signal:
Packit b5b901
  uv_mutex_destroy(&handle->cf_mutex);
Packit b5b901
Packit b5b901
fail_cf_mutex_init:
Packit b5b901
  uv__free(handle->cf_cb);
Packit b5b901
  handle->cf_cb = NULL;
Packit b5b901
Packit b5b901
fail_cf_cb_malloc:
Packit b5b901
  uv__free(handle->realpath);
Packit b5b901
  handle->realpath = NULL;
Packit b5b901
  handle->realpath_len = 0;
Packit b5b901
Packit b5b901
  return err;
Packit b5b901
}
Packit b5b901
Packit b5b901
Packit b5b901
/* Runs in UV loop to de-initialize handle */
Packit b5b901
int uv__fsevents_close(uv_fs_event_t* handle) {
Packit b5b901
  int err;
Packit b5b901
  uv__cf_loop_state_t* state;
Packit b5b901
Packit b5b901
  if (handle->cf_cb == NULL)
Packit b5b901
    return UV_EINVAL;
Packit b5b901
Packit b5b901
  /* Remove handle from  the list */
Packit b5b901
  state = handle->loop->cf_state;
Packit b5b901
  uv_mutex_lock(&state->fsevent_mutex);
Packit b5b901
  QUEUE_REMOVE(&handle->cf_member);
Packit b5b901
  state->fsevent_handle_count--;
Packit b5b901
  state->fsevent_need_reschedule = 1;
Packit b5b901
  uv_mutex_unlock(&state->fsevent_mutex);
Packit b5b901
Packit b5b901
  /* Reschedule FSEventStream */
Packit b5b901
  assert(handle != NULL);
Packit b5b901
  err = uv__cf_loop_signal(handle->loop, handle, kUVCFLoopSignalClosing);
Packit b5b901
  if (err)
Packit b5b901
    return UV__ERR(err);
Packit b5b901
Packit b5b901
  /* Wait for deinitialization */
Packit b5b901
  uv_sem_wait(&state->fsevent_sem);
Packit b5b901
Packit b5b901
  uv_close((uv_handle_t*) handle->cf_cb, (uv_close_cb) uv__free);
Packit b5b901
  handle->cf_cb = NULL;
Packit b5b901
Packit b5b901
  /* Free data in queue */
Packit b5b901
  UV__FSEVENTS_PROCESS(handle, {
Packit b5b901
    /* NOP */
Packit b5b901
  });
Packit b5b901
Packit b5b901
  uv_mutex_destroy(&handle->cf_mutex);
Packit b5b901
  uv__free(handle->realpath);
Packit b5b901
  handle->realpath = NULL;
Packit b5b901
  handle->realpath_len = 0;
Packit b5b901
Packit b5b901
  return 0;
Packit b5b901
}
Packit b5b901
Packit b5b901
#endif /* TARGET_OS_IPHONE */