/third_party/libuv/src/win/ |
H A D | stream-inl.h | 42 UV_REQ_INIT(&handle->read_req, UV_READ); in uv__stream_init() 43 handle->read_req.event_handle = NULL; in uv__stream_init() 44 handle->read_req.wait_handle = INVALID_HANDLE_VALUE; in uv__stream_init() 45 handle->read_req.data = handle; in uv__stream_init()
|
H A D | tcp.c | 257 if (handle->read_req.wait_handle != INVALID_HANDLE_VALUE) { in uv__tcp_endgame() 258 UnregisterWait(handle->read_req.wait_handle); in uv__tcp_endgame() 259 handle->read_req.wait_handle = INVALID_HANDLE_VALUE; in uv__tcp_endgame() 261 if (handle->read_req.event_handle != NULL) { in uv__tcp_endgame() 262 CloseHandle(handle->read_req.event_handle); in uv__tcp_endgame() 263 handle->read_req.event_handle = NULL; in uv__tcp_endgame() 474 req = &handle->read_req; in uv__tcp_queue_read() 708 handle->read_req.event_handle == NULL) { in uv__tcp_read_start() 709 handle->read_req.event_handle = CreateEvent(NULL, 0, 0, NULL); in uv__tcp_read_start() 710 if (handle->read_req in uv__tcp_read_start() [all...] |
H A D | pipe.c | 134 handle->read_req.data = handle; in uv__pipe_connection_init() 671 if (handle->read_req.wait_handle != INVALID_HANDLE_VALUE) { in uv__pipe_endgame() 672 UnregisterWait(handle->read_req.wait_handle); in uv__pipe_endgame() 673 handle->read_req.wait_handle = INVALID_HANDLE_VALUE; in uv__pipe_endgame() 675 if (handle->read_req.event_handle != NULL) { in uv__pipe_endgame() 676 CloseHandle(handle->read_req.event_handle); in uv__pipe_endgame() 677 handle->read_req.event_handle = NULL; in uv__pipe_endgame() 1012 r = CancelIoEx(handle->handle, &handle->read_req.u.io.overlapped); in uv__pipe_interrupt_read() 1388 req = &handle->read_req; in uv__pipe_queue_read() 1458 handle->read_req in uv__pipe_read_start() [all...] |
H A D | tty.c | 461 req = &handle->read_req; in uv__tty_queue_read_raw() 584 req = &handle->read_req; in uv__tty_queue_read_line() 1029 SET_REQ_SUCCESS(&handle->read_req); in uv__tty_read_start() 1030 uv__insert_pending_req(handle->loop, (uv_req_t*) &handle->read_req); in uv__tty_read_start()
|
/third_party/node/deps/uv/src/win/ |
H A D | stream-inl.h | 42 UV_REQ_INIT(&handle->read_req, UV_READ); in uv__stream_init() 43 handle->read_req.event_handle = NULL; in uv__stream_init() 44 handle->read_req.wait_handle = INVALID_HANDLE_VALUE; in uv__stream_init() 45 handle->read_req.data = handle; in uv__stream_init()
|
H A D | pipe.c | 126 handle->read_req.data = handle; in uv__pipe_connection_init() 663 if (handle->read_req.wait_handle != INVALID_HANDLE_VALUE) { in uv__pipe_endgame() 664 UnregisterWait(handle->read_req.wait_handle); in uv__pipe_endgame() 665 handle->read_req.wait_handle = INVALID_HANDLE_VALUE; in uv__pipe_endgame() 667 if (handle->read_req.event_handle != NULL) { in uv__pipe_endgame() 668 CloseHandle(handle->read_req.event_handle); in uv__pipe_endgame() 669 handle->read_req.event_handle = NULL; in uv__pipe_endgame() 918 r = CancelIoEx(handle->handle, &handle->read_req.u.io.overlapped); in uv__pipe_interrupt_read() 1293 req = &handle->read_req; in uv__pipe_queue_read() 1363 handle->read_req in uv__pipe_read_start() [all...] |
H A D | tcp.c | 266 if (handle->read_req.wait_handle != INVALID_HANDLE_VALUE) { in uv__tcp_endgame() 267 UnregisterWait(handle->read_req.wait_handle); in uv__tcp_endgame() 268 handle->read_req.wait_handle = INVALID_HANDLE_VALUE; in uv__tcp_endgame() 270 if (handle->read_req.event_handle != NULL) { in uv__tcp_endgame() 271 CloseHandle(handle->read_req.event_handle); in uv__tcp_endgame() 272 handle->read_req.event_handle = NULL; in uv__tcp_endgame() 484 req = &handle->read_req; in uv__tcp_queue_read() 738 handle->read_req.event_handle == NULL) { in uv__tcp_read_start() 739 handle->read_req.event_handle = CreateEvent(NULL, 0, 0, NULL); in uv__tcp_read_start() 740 if (handle->read_req in uv__tcp_read_start() [all...] |
H A D | tty.c | 466 req = &handle->read_req; in uv__tty_queue_read_raw() 590 req = &handle->read_req; in uv__tty_queue_read_line() 1040 SET_REQ_SUCCESS(&handle->read_req); in uv__tty_read_start() 1041 uv__insert_pending_req(handle->loop, (uv_req_t*) &handle->read_req); in uv__tty_read_start()
|
/third_party/libuv/test/ |
H A D | test-fs-open-flags.c | 43 static uv_fs_t read_req; variable 187 r = uv_fs_read(NULL, &read_req, open_req.result, &iov, 1, -1, NULL); in writeExpect() 189 ASSERT_EQ(read_req.result, size); in writeExpect() 191 uv_fs_req_cleanup(&read_req); in writeExpect() 232 r = uv_fs_read(NULL, &read_req, open_req.result, &iov, 1, -1, NULL); in readExpect() 234 ASSERT_EQ(read_req.result, size); in readExpect() 236 uv_fs_req_cleanup(&read_req); in readExpect() 252 r = uv_fs_read(NULL, &read_req, open_req.result, &iov, 1, -1, NULL); in readFail() 254 ASSERT_EQ(read_req.result, error); in readFail() 255 uv_fs_req_cleanup(&read_req); in readFail() [all...] |
H A D | test-fs.c | 107 static uv_fs_t read_req; variable 401 ASSERT_PTR_EQ(req, &read_req); in read_cb() 432 r = uv_fs_read(loop, &read_req, open_req1.result, &iov, 1, -1, in open_cb() 1013 r = uv_fs_read(NULL, &read_req, open_req1.result, &iov, 1, -1, NULL); in fs_file_sync() 1015 ASSERT_GE(read_req.result, 0); in fs_file_sync() 1017 uv_fs_req_cleanup(&read_req); in fs_file_sync() 1042 r = uv_fs_read(NULL, &read_req, open_req1.result, &iov, 1, -1, NULL); in fs_file_sync() 1044 ASSERT_GE(read_req.result, 0); in fs_file_sync() 1046 uv_fs_req_cleanup(&read_req); in fs_file_sync() 3089 r = uv_fs_read(NULL, &read_req, open_req in fs_file_open_append() [all...] |
H A D | test-eintr-handling.c | 37 static uv_fs_t read_req; variable 79 nread = uv_fs_read(loop, &read_req, pipe_fds[0], &iov, 1, -1, NULL); in TEST_IMPL()
|
/third_party/libuv/docs/code/uvcat/ |
H A D | main.c | 9 uv_fs_t read_req; variable 21 uv_fs_read(uv_default_loop(), &read_req, open_req.result, &iov, 1, -1, on_read); in on_write() local 46 uv_fs_read(uv_default_loop(), &read_req, req->result, in on_open() local 59 uv_fs_req_cleanup(&read_req); in main()
|
/third_party/ltp/testcases/kernel/fs/doio/ |
H A D | doio.h | 121 * read_req, reada_req, write_req, and writea_req structures and 134 struct read_req { struct 193 struct read_req read;
|
H A D | doio.c | 1286 struct read_req *readp = &ioreq->r_data.read; in format_rw() 1288 struct read_req *readap = &ioreq->r_data.read; in format_rw() 1418 * r_nbytes are at the same offset in the read_req and reada_req in do_read() 2542 * r_nbytes are at the same offset in the read_req and reada_req in sy_listio() 3079 * r_nbytes are at the same offset in the read_req and reada_req in do_rw() 3507 * r_nbytes are at the same offset in the read_req and reada_req in do_fcntl() 3608 * r_nbytes are at the same offset in the read_req and reada_req in do_sync()
|
/third_party/libuv/include/uv/ |
H A D | win.h | 440 uv_read_t read_req; \
|
/third_party/node/deps/uv/include/uv/ |
H A D | win.h | 436 uv_read_t read_req; \
|
/third_party/node/src/ |
H A D | node_file.cc | 1040 uv_fs_t read_req; in InternalModuleReadJSON() local 1041 numchars = uv_fs_read(loop, &read_req, fd, &buf, 1, offset, nullptr); in InternalModuleReadJSON() 1042 uv_fs_req_cleanup(&read_req); in InternalModuleReadJSON()
|