| /libuv/test/ |
| H A D | benchmark-multi-accept.c | 115 sc = container_of(ipc_pipe, struct ipc_server_ctx, ipc_pipe); in ipc_connection_cb()
141 ctx = container_of(req, struct ipc_peer_ctx, write_req); in ipc_write_cb()
148 ctx = container_of(handle, struct ipc_peer_ctx, peer_handle); in ipc_close_cb()
155 ctx = container_of(req, struct ipc_client_ctx, connect_req); in ipc_connect_cb()
167 ctx = container_of(handle, struct ipc_client_ctx, ipc_pipe); in ipc_alloc_cb()
182 ctx = container_of(ipc_pipe, struct ipc_client_ctx, ipc_pipe); in ipc_read_cb()
284 ctx = container_of(handle, struct server_ctx, async_handle); in sv_async_cb()
294 ctx = container_of(server_handle, struct server_ctx, server_handle); in sv_connection_cb()
331 struct client_ctx* ctx = container_of(req, struct client_ctx, connect_req); in cl_connect_cb()
338 struct client_ctx* ctx = container_of(handle, struct client_ctx, idle_handle); in cl_idle_cb()
[all …]
|
| H A D | blackhole-server.c | 81 conn = container_of(stream, conn_rec, handle); in read_cb()
89 conn_rec* conn = container_of(req, conn_rec, shutdown_req); in shutdown_cb()
95 conn_rec* conn = container_of(handle, conn_rec, handle); in close_cb()
|
| H A D | benchmark-async.c | 44 struct ctx* ctx = container_of(handle, struct ctx, worker_async); in worker_async_cb()
56 struct ctx* ctx = container_of(handle, struct ctx, main_async); in main_async_cb()
|
| H A D | test-signal.c | 102 struct signal_ctx* ctx = container_of(handle, struct signal_ctx, handle); in signal_cb()
115 struct signal_ctx* ctx = container_of(handle, struct signal_ctx, handle); in signal_cb_one_shot()
124 struct timer_ctx* ctx = container_of(handle, struct timer_ctx, handle); in timer_cb()
|
| H A D | test-thread.c | 85 req = container_of(handle, struct getaddrinfo_req, handle); in getaddrinfo_cb()
102 struct fs_req* req = container_of(handle, struct fs_req, handle); in fs_cb()
|
| H A D | benchmark-fs-stat.c | 86 struct async_req* req = container_of(fs_req, struct async_req, fs_req); in stat_cb()
|
| H A D | test-ipc-heavy-traffic-deadlock-bug.c | 51 container_of(req, struct write_info, write_req); in write_cb()
|
| H A D | test-threadpool-cancel.c | 168 ci = container_of(handle, struct cancel_info, timer_handle); in timer_cb()
190 ri = container_of(req, struct random_info, random_req); in nop_random_cb()
|
| H A D | benchmark-udp-pummel.c | 85 s = container_of(req, struct sender_state, send_req); in send_cb()
|
| H A D | task.h | 78 #define container_of(ptr, type, member) \ macro
|
| /libuv/src/ |
| H A D | timer.c | 43 a = container_of(ha, uv_timer_t, node.heap); in timer_less_than()
44 b = container_of(hb, uv_timer_t, node.heap); in timer_less_than()
153 handle = container_of(heap_node, uv_timer_t, node.heap); in uv__next_timeout()
178 handle = container_of(heap_node, uv_timer_t, node.heap); in uv__run_timers()
190 handle = container_of(queue_node, uv_timer_t, node.queue); in uv__run_timers()
|
| H A D | random.c | 76 req = container_of(w, uv_random_t, work_req); in uv__random_work()
84 req = container_of(w, uv_random_t, work_req); in uv__random_done()
|
| H A D | threadpool.c | 316 loop = container_of(handle, uv_loop_t, wq_async); in uv__work_done()
327 w = container_of(q, struct uv__work, wq); in uv__work_done()
349 uv_work_t* req = container_of(w, uv_work_t, work_req); in uv__queue_work()
358 req = container_of(w, uv_work_t, work_req); in uv__queue_done()
|
| H A D | fs-poll.c | 175 ctx = container_of(timer, struct poll_ctx, timer_handle); in timer_cb()
191 ctx = container_of(req, struct poll_ctx, fs_req); in poll_cb()
240 ctx = container_of(timer, struct poll_ctx, timer_handle); in timer_close_cb()
|
| H A D | uv-common.h | 57 #define container_of(ptr, type, member) \ macro
|
| /libuv/src/unix/ |
| H A D | getnameinfo.c | 36 req = container_of(w, uv_getnameinfo_t, work_req); in uv__getnameinfo_work()
60 req = container_of(w, uv_getnameinfo_t, work_req); in uv__getnameinfo_done()
|
| H A D | getaddrinfo.c | 102 req = container_of(w, uv_getaddrinfo_t, work_req); in uv__getaddrinfo_work()
111 req = container_of(w, uv_getaddrinfo_t, work_req); in uv__getaddrinfo_done()
|
| H A D | poll.c | 34 handle = container_of(w, uv_poll_t, io_watcher); in uv__poll_io()
|
| H A D | stream.c | 239 s = container_of(handle, uv__stream_select_t, async); in uv__stream_osx_select_cb()
269 s = container_of(async, uv__stream_select_t, async); in uv__stream_osx_cb_close()
513 stream = container_of(w, uv_stream_t, io_watcher); in uv__server_io()
1192 stream = container_of(w, uv_stream_t, io_watcher); in uv__stream_io()
|
| H A D | kqueue.c | 509 handle = container_of(w, uv_fs_event_t, event_watcher); in uv__fs_event()
|
| H A D | os390.c | 849 stream= container_of(w, uv_stream_t, io_watcher); in uv__io_poll()
|
| H A D | fs.c | 1700 req = container_of(w, uv_fs_t, work_req); in uv__fs_work()
1770 req = container_of(w, uv_fs_t, work_req); in uv__fs_done()
|
| /libuv/src/win/ |
| H A D | getnameinfo.c | 48 req = container_of(w, uv_getnameinfo_t, work_req); in uv__getnameinfo_work()
84 req = container_of(w, uv_getnameinfo_t, work_req); in uv__getnameinfo_done()
|
| H A D | getaddrinfo.c | 87 req = container_of(w, uv_getaddrinfo_t, work_req); in uv__getaddrinfo_work()
105 uv_getaddrinfo_t* req = container_of(w, uv_getaddrinfo_t, work_req); in uv__getaddrinfo_done()
|
| H A D | req-inl.h | 86 return container_of(overlapped, uv_req_t, u.io.overlapped); in uv__overlapped_to_req()
|
