Home
last modified time | relevance | path

Searched refs:w (Results 1 – 25 of 32) sorted by relevance

12

/libuv/src/
H A Dthreadpool.c58 struct uv__work* w; in worker() local
122 w->work(w); in worker()
127 uv__queue_insert_tail(&w->loop->wq, &w->wq); in worker()
271 w->loop = loop; in uv__work_submit()
272 w->work = work; in uv__work_submit()
273 w->done = done; in uv__work_submit()
274 post(&w->wq, kind); in uv__work_submit()
288 cancelled = !uv__queue_empty(&w->wq) && w->work != NULL; in uv__work_cancel()
298 w->work = uv__cancelled; in uv__work_cancel()
309 struct uv__work* w; in uv__work_done() local
[all …]
H A Drandom.c73 static void uv__random_work(struct uv__work* w) { in uv__random_work() argument
76 req = container_of(w, uv_random_t, work_req); in uv__random_work()
81 static void uv__random_done(struct uv__work* w, int status) { in uv__random_done() argument
84 req = container_of(w, uv_random_t, work_req); in uv__random_done()
H A Duv-common.h210 struct uv__work *w,
212 void (*work)(struct uv__work *w),
213 void (*done)(struct uv__work *w, int status));
/libuv/src/unix/
H A Dkqueue.c140 uv__io_t* w; in uv__io_poll() local
171 assert(w->pevents != 0); in uv__io_poll()
172 assert(w->fd >= 0); in uv__io_poll()
175 if ((w->events & POLLIN) == 0 && (w->pevents & POLLIN) != 0) { in uv__io_poll()
196 if ((w->events & POLLOUT) == 0 && (w->pevents & POLLOUT) != 0) { in uv__io_poll()
206 if ((w->events & UV__POLLPRI) == 0 && (w->pevents & UV__POLLPRI) != 0) { in uv__io_poll()
216 w->events = w->pevents; in uv__io_poll()
329 w = loop->watchers[fd]; in uv__io_poll()
331 if (w == NULL) { in uv__io_poll()
341 w->cb(loop, w, ev->fflags); /* XXX always uv__fs_event() */ in uv__io_poll()
[all …]
H A Dposix-poll.c93 if (loop->poll_fds[i].fd == w->fd) { in uv__pollfds_add()
102 pe->fd = w->fd; in uv__pollfds_add()
103 pe->events = w->pevents; in uv__pollfds_add()
141 uv__io_t* w; in uv__io_poll() local
165 assert(w->pevents != 0); in uv__io_poll()
166 assert(w->fd >= 0); in uv__io_poll()
169 uv__pollfds_add(loop, w); in uv__io_poll()
171 w->events = w->pevents; in uv__io_poll()
278 w = loop->watchers[fd]; in uv__io_poll()
280 if (w == NULL) { in uv__io_poll()
[all …]
H A Dpoll.c30 static void uv__poll_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) { in uv__poll_io() argument
34 handle = container_of(w, uv_poll_t, io_watcher); in uv__poll_io()
48 uv__io_stop(loop, w, POLLIN | POLLOUT | UV__POLLRDHUP | UV__POLLPRI); in uv__poll_io()
121 uv__io_t* w; in uv_poll_start() local
129 w = &handle->io_watcher; in uv_poll_start()
131 if (uv__fd_exists(handle->loop, w->fd)) in uv_poll_start()
132 if (watchers[w->fd] != w) in uv_poll_start()
H A Dcore.c833 uv__io_t* w; in uv__run_pending() local
842 w->cb(loop, w, POLLOUT); in uv__run_pending()
898 w->cb = cb; in uv__io_init()
899 w->fd = fd; in uv__io_init()
900 w->events = 0; in uv__io_init()
901 w->pevents = 0; in uv__io_init()
919 if (w->events == w->pevents) in uv__io_start()
927 loop->watchers[w->fd] = w; in uv__io_start()
937 if (w->fd == -1) in uv__io_stop()
951 w->events = 0; in uv__io_stop()
[all …]
H A Dloop.c135 uv__io_t* w; in uv_loop_fork() local
151 w = loop->watchers[i]; in uv_loop_fork()
152 if (w == NULL) in uv_loop_fork()
155 if (w->pevents != 0 && uv__queue_empty(&w->watcher_queue)) { in uv_loop_fork()
156 w->events = 0; /* Force re-registration in uv__io_poll. */ in uv_loop_fork()
157 uv__queue_insert_tail(&loop->watcher_queue, &w->watcher_queue); in uv_loop_fork()
H A Dlinux.c1331 uv__io_t* w; in uv__io_poll() local
1386 w->events = w->pevents; in uv__io_poll()
1389 fd = w->fd; in uv__io_poll()
1535 w->cb(loop, w, pe->events); in uv__io_poll()
2500 w.wd = wd; in find_watcher()
2507 if ((!w->iterating) && uv__queue_empty(&w->watchers)) { in maybe_free_watcher_list()
2511 uv__free(w); in maybe_free_watcher_list()
2632 if (w) in uv_fs_event_start()
2636 w = uv__malloc(sizeof(*w) + len); in uv_fs_event_start()
2640 w->wd = wd; in uv_fs_event_start()
[all …]
H A Dsunos.c152 uv__io_t* w; in uv__io_poll() local
179 assert(w->pevents != 0); in uv__io_poll()
183 w->fd, in uv__io_poll()
184 w->pevents, in uv__io_poll()
190 w->events = w->pevents; in uv__io_poll()
297 w = loop->watchers[fd]; in uv__io_poll()
300 if (w == NULL) in uv__io_poll()
310 w->cb(loop, w, pe->portev_events); in uv__io_poll()
315 if (w != loop->watchers[fd]) in uv__io_poll()
319 if (w->pevents != 0 && uv__queue_empty(&w->watcher_queue)) in uv__io_poll()
[all …]
H A Dos390.c821 uv__io_t* w; in uv__io_poll() local
846 assert(w->pevents != 0); in uv__io_poll()
847 assert(w->fd >= 0); in uv__io_poll()
851 assert(w->fd < (int) loop->nwatchers); in uv__io_poll()
853 e.events = w->pevents; in uv__io_poll()
854 e.fd = w->fd; in uv__io_poll()
856 if (w->events == 0) in uv__io_poll()
875 w->events = w->pevents; in uv__io_poll()
981 w = loop->watchers[fd]; in uv__io_poll()
983 if (w == NULL) { in uv__io_poll()
[all …]
H A Dgetnameinfo.c31 static void uv__getnameinfo_work(struct uv__work* w) { in uv__getnameinfo_work() argument
36 req = container_of(w, uv_getnameinfo_t, work_req); in uv__getnameinfo_work()
55 static void uv__getnameinfo_done(struct uv__work* w, int status) { in uv__getnameinfo_done() argument
60 req = container_of(w, uv_getnameinfo_t, work_req); in uv__getnameinfo_done()
H A Daix.c140 uv__io_t* w; in uv__io_poll() local
166 assert(w->pevents != 0); in uv__io_poll()
167 assert(w->fd >= 0); in uv__io_poll()
170 pc.events = w->pevents; in uv__io_poll()
171 pc.fd = w->fd; in uv__io_poll()
174 if (w->events == 0) { in uv__io_poll()
197 if (w->events != 0 || add_failed) { in uv__io_poll()
216 w->events = w->pevents; in uv__io_poll()
308 w = loop->watchers[pc.fd]; in uv__io_poll()
310 if (w == NULL) { in uv__io_poll()
[all …]
H A Dinternal.h250 void uv__io_init(uv__io_t* w, uv__io_cb cb, int fd);
251 void uv__io_start(uv_loop_t* loop, uv__io_t* w, unsigned int events);
252 void uv__io_stop(uv_loop_t* loop, uv__io_t* w, unsigned int events);
253 void uv__io_close(uv_loop_t* loop, uv__io_t* w);
254 void uv__io_feed(uv_loop_t* loop, uv__io_t* w);
255 int uv__io_active(const uv__io_t* w, unsigned int events);
279 void uv__server_io(uv_loop_t* loop, uv__io_t* w, unsigned int events);
H A Dgetaddrinfo.c98 static void uv__getaddrinfo_work(struct uv__work* w) { in uv__getaddrinfo_work() argument
102 req = container_of(w, uv_getaddrinfo_t, work_req); in uv__getaddrinfo_work()
108 static void uv__getaddrinfo_done(struct uv__work* w, int status) { in uv__getaddrinfo_done() argument
111 req = container_of(w, uv_getaddrinfo_t, work_req); in uv__getaddrinfo_done()
H A Dasync.c132 static void uv__async_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) { in uv__async_io() argument
140 assert(w == &loop->async_io_watcher); in uv__async_io()
143 r = read(w->fd, buf, sizeof(buf)); in uv__async_io()
H A Dsignal.c48 static void uv__signal_event(uv_loop_t* loop, uv__io_t* w, unsigned int events);
434 uv__io_t* w, in uv__signal_event() argument
H A Dstream.c76 static void uv__stream_io(uv_loop_t* loop, uv__io_t* w, unsigned int events);
508 void uv__server_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) { in uv__server_io() argument
513 stream = container_of(w, uv_stream_t, io_watcher); in uv__server_io()
1188 static void uv__stream_io(uv_loop_t* loop, uv__io_t* w, unsigned int events) { in uv__stream_io() argument
1191 stream = container_of(w, uv_stream_t, io_watcher); in uv__stream_io()
/libuv/test/
H A Dbenchmark-tcp-write-batch.c54 write_req* w; in connect_cb() local
61 w = &write_reqs[i]; in connect_cb()
62 r = uv_write(&w->req, req->handle, &w->buf, 1, write_cb); in connect_cb()
H A Dtest-tcp-write-in-a-row.c46 static void write_cb(uv_write_t* w, int status) { in write_cb() argument
H A Dtest-tty.c435 struct winsize w; in TEST_IMPL() local
441 r = openpty(&master_fd, &slave_fd, NULL, NULL, &w); in TEST_IMPL()
/libuv/src/win/
H A Dgetnameinfo.c41 static void uv__getnameinfo_work(struct uv__work* w) { in uv__getnameinfo_work() argument
48 req = container_of(w, uv_getnameinfo_t, work_req); in uv__getnameinfo_work()
79 static void uv__getnameinfo_done(struct uv__work* w, int status) { in uv__getnameinfo_done() argument
84 req = container_of(w, uv_getnameinfo_t, work_req); in uv__getnameinfo_done()
H A Dgetaddrinfo.c83 static void uv__getaddrinfo_work(struct uv__work* w) { in uv__getaddrinfo_work() argument
88 req = container_of(w, uv_getaddrinfo_t, work_req); in uv__getaddrinfo_work()
105 static void uv__getaddrinfo_done(struct uv__work* w, int status) { in uv__getaddrinfo_done() argument
116 req = container_of(w, uv_getaddrinfo_t, work_req); in uv__getaddrinfo_done()
/libuv/include/uv/
H A Dthreadpool.h31 void (*work)(struct uv__work *w);
32 void (*done)(struct uv__work *w, int status);
/libuv/
H A DMAINTAINERS.md46 $ git hash-object -w saghul.asc

Completed in 76 milliseconds

12