|
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 */
|