Lines Matching defs:loop
61 static void uv__inotify_read(uv_loop_t* loop,
66 uv_loop_t* loop);
68 static int init_inotify(uv_loop_t* loop) {
71 if (loop->inotify_fd != -1)
78 loop->inotify_fd = fd;
79 uv__io_init(&loop->inotify_read_watcher, uv__inotify_read, loop->inotify_fd);
80 uv__io_start(loop, &loop->inotify_read_watcher, POLLIN);
86 int uv__inotify_fork(uv_loop_t* loop, void* old_watchers) {
101 loop->inotify_watchers = old_watchers;
130 maybe_free_watcher_list(watcher_list, loop);
151 static struct watcher_list* find_watcher(uv_loop_t* loop, int wd) {
154 return RB_FIND(watcher_root, CAST(&loop->inotify_watchers), &w);
157 static void maybe_free_watcher_list(struct watcher_list* w, uv_loop_t* loop) {
161 RB_REMOVE(watcher_root, CAST(&loop->inotify_watchers), w);
162 inotify_rm_watch(loop->inotify_fd, w->wd);
167 static void uv__inotify_read(uv_loop_t* loop,
183 size = read(loop->inotify_fd, buf, sizeof(buf));
203 w = find_watcher(loop, e->wd);
237 maybe_free_watcher_list(w, loop);
243 int uv_fs_event_init(uv_loop_t* loop, uv_fs_event_t* handle) {
244 uv__handle_init(loop, (uv_handle_t*)handle, UV_FS_EVENT);
262 err = init_inotify(handle->loop);
275 wd = inotify_add_watch(handle->loop->inotify_fd, path, events);
279 w = find_watcher(handle->loop, wd);
292 RB_INSERT(watcher_root, CAST(&handle->loop->inotify_watchers), w);
311 w = find_watcher(handle->loop, handle->wd);
319 maybe_free_watcher_list(w, handle->loop);