| /libuv/src/win/ |
| H A D | winsock.c | 297 if (!((intptr_t) overlapped->hEvent & 1)) { in uv__wsarecv_workaround()
298 apc_context = (void*) overlapped; in uv__wsarecv_workaround()
307 overlapped->hEvent, in uv__wsarecv_workaround()
366 int* addr_len, WSAOVERLAPPED *overlapped, in uv__wsarecvfrom_workaround() argument
395 if (!((intptr_t) overlapped->hEvent & 1)) { in uv__wsarecvfrom_workaround()
396 apc_context = (void*) overlapped; in uv__wsarecvfrom_workaround()
405 overlapped->hEvent, in uv__wsarecvfrom_workaround()
470 if (overlapped != NULL) { in uv__msafd_poll()
473 event = overlapped->hEvent; in uv__msafd_poll()
480 apc_context = overlapped; in uv__msafd_poll()
[all …]
|
| H A D | req-inl.h | 32 (req)->u.io.overlapped.Internal = (ULONG_PTR) (status)
44 ((NTSTATUS) (req)->u.io.overlapped.Internal)
80 &((req)->u.io.overlapped))) { \
85 INLINE static uv_req_t* uv__overlapped_to_req(OVERLAPPED* overlapped) { in uv__overlapped_to_req() argument
86 return container_of(overlapped, uv_req_t, u.io.overlapped); in uv__overlapped_to_req()
|
| H A D | tcp.c | 368 &req->u.io.overlapped)) { in post_completion()
387 &req->u.io.overlapped)) { in post_write_completion()
429 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_accept()
487 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_read()
494 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_read()
506 &req->u.io.overlapped, in uv__tcp_queue_read()
514 req->u.io.overlapped.InternalHigh = bytes; in uv__tcp_queue_read()
832 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__tcp_try_connect()
905 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__tcp_write()
920 &req->u.io.overlapped, in uv__tcp_write()
[all …]
|
| H A D | fs-event.c | 41 memset(&(handle->req.u.io.overlapped), 0, in uv__fs_event_queue_readdirchanges()
42 sizeof(handle->req.u.io.overlapped)); in uv__fs_event_queue_readdirchanges()
56 &handle->req.u.io.overlapped, in uv__fs_event_queue_readdirchanges()
295 memset(&(handle->req.u.io.overlapped), 0, in uv_fs_event_start()
296 sizeof(handle->req.u.io.overlapped)); in uv_fs_event_start()
311 &handle->req.u.io.overlapped, in uv_fs_event_start()
443 if (req->u.io.overlapped.InternalHigh > 0) { in uv__process_fs_event_req()
|
| H A D | pipe.c | 1121 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__pipe_queue_accept()
1354 &req->u.io.overlapped)) { in post_completion_read_wait()
1373 &req->u.io.overlapped)) { in post_completion_write_wait()
1400 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__pipe_queue_read()
1411 &req->u.io.overlapped); in uv__pipe_queue_read()
1601 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__pipe_write_data()
1661 &req->u.io.overlapped); in uv__pipe_write_data()
1697 &req->u.io.overlapped); in uv__pipe_write_data()
1929 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__pipe_read_exactly()
1935 &req->u.io.overlapped)) { in uv__pipe_read_exactly()
[all …]
|
| H A D | poll.c | 125 memset(&req->u.io.overlapped, 0, sizeof req->u.io.overlapped); in uv__fast_poll_submit_poll_req()
130 &req->u.io.overlapped); in uv__fast_poll_submit_poll_req()
331 req->u.io.overlapped.InternalHigh = (DWORD) reported_events; in uv__slow_poll_thread_proc()
393 int events = req->u.io.overlapped.InternalHigh & handle->events & ~mask_events; in uv__slow_poll_process_poll_req()
|
| H A D | core.c | 430 OVERLAPPED* overlapped; in uv__poll_wine() local
464 &overlapped, in uv__poll_wine()
468 if (overlapped && timeout == 0) in uv__poll_wine()
481 if (overlapped) { in uv__poll_wine()
485 req = uv__overlapped_to_req(overlapped); in uv__poll_wine()
|
| H A D | udp.c | 278 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__udp_queue_recv()
291 &req->u.io.overlapped, in uv__udp_queue_recv()
297 req->u.io.overlapped.InternalHigh = bytes; in uv__udp_queue_recv()
367 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__send()
376 &req->u.io.overlapped, in uv__send()
442 req->u.io.overlapped.InternalHigh, in uv__process_udp_recv_req()
|
| H A D | internal.h | 305 DWORD buffer_count, DWORD* bytes, DWORD* flags, WSAOVERLAPPED *overlapped,
309 int* addr_len, WSAOVERLAPPED *overlapped,
313 AFD_POLL_INFO* info_out, OVERLAPPED* overlapped);
|
| H A D | tty.c | 462 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__tty_queue_read_raw()
518 req->u.io.overlapped.InternalHigh = 0; in uv_tty_line_read_thread()
536 req->u.io.overlapped.InternalHigh = (DWORD) read_bytes; in uv_tty_line_read_thread()
585 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__tty_queue_read_line()
973 req->u.io.overlapped.InternalHigh != 0) { in uv_process_tty_read_line_req()
975 DWORD bytes = req->u.io.overlapped.InternalHigh; in uv_process_tty_read_line_req()
|
| H A D | fs.c | 806 OVERLAPPED overlapped, *overlapped_ptr; in fs__read() local
834 memset(&overlapped, 0, sizeof overlapped); in fs__read()
835 overlapped_ptr = &overlapped; in fs__read()
851 overlapped.Offset = offset_.LowPart; in fs__read()
852 overlapped.OffsetHigh = offset_.HighPart; in fs__read()
1012 OVERLAPPED overlapped, *overlapped_ptr; in fs__write() local
1039 memset(&overlapped, 0, sizeof overlapped); in fs__write()
1040 overlapped_ptr = &overlapped; in fs__write()
1056 overlapped.Offset = offset_.LowPart; in fs__write()
1057 overlapped.OffsetHigh = offset_.HighPart; in fs__write()
|
| /libuv/test/ |
| H A D | runner-win.c | 246 OVERLAPPED overlapped; in process_read_last_line() local
259 memset(&overlapped, 0, sizeof overlapped); in process_read_last_line()
261 overlapped.Offset = size - buffer_len - 1; in process_read_last_line()
263 if (!ReadFile(p->stdio_out, buffer, buffer_len - 1, &read, &overlapped)) in process_read_last_line()
|
| H A D | test-stdio-over-pipes.c | 119 static void test_stdio_over_pipes(int overlapped) { in test_stdio_over_pipes() argument
133 (overlapped ? UV_OVERLAPPED_PIPE : 0); in test_stdio_over_pipes()
136 (overlapped ? UV_OVERLAPPED_PIPE : 0); in test_stdio_over_pipes()
|
| /libuv/include/uv/ |
| H A D | win.h | 191 LPWSAOVERLAPPED overlapped,
202 LPWSAOVERLAPPED overlapped,
379 OVERLAPPED overlapped; \
|
| /libuv/src/ |
| H A D | uv-common.h | 338 (req)->u.io.overlapped.Internal = 0; /* SET_REQ_SUCCESS() */ \
|
| /libuv/ |
| H A D | ChangeLog | 1744 * win,pipe: consolidate overlapped initialization (Elliot Saba)
2631 * win,process: allow child pipe handles to be opened in overlapped mode (Björn
2724 * win, pipe: stop read for overlapped pipe (Bartosz Sosnowski)
|
