Searched refs:read_req (Results 1 – 9 of 9) sorted by relevance
/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 | 263 if (handle->read_req.wait_handle != INVALID_HANDLE_VALUE) { in uv__tcp_endgame() 264 UnregisterWait(handle->read_req.wait_handle); in uv__tcp_endgame() 265 handle->read_req.wait_handle = INVALID_HANDLE_VALUE; in uv__tcp_endgame() 267 if (handle->read_req.event_handle != NULL) { in uv__tcp_endgame() 268 CloseHandle(handle->read_req.event_handle); in uv__tcp_endgame() 269 handle->read_req.event_handle = NULL; in uv__tcp_endgame() 486 req = &handle->read_req; in uv__tcp_queue_read() 720 handle->read_req.event_handle == NULL) { in uv__tcp_read_start() 722 if (handle->read_req.event_handle == NULL) { in uv__tcp_read_start() 1406 CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped); in uv__tcp_try_cancel_reqs() [all …]
|
H A D | pipe.c | 134 handle->read_req.data = handle; in uv__pipe_connection_init() 676 if (handle->read_req.event_handle != NULL) { in uv__pipe_endgame() 677 CloseHandle(handle->read_req.event_handle); in uv__pipe_endgame() 678 handle->read_req.event_handle = NULL; in uv__pipe_endgame() 1388 req = &handle->read_req; in uv__pipe_queue_read() 1453 if (handle->read_req.event_handle == NULL) { in uv__pipe_read_start() 1455 if (handle->read_req.event_handle == NULL) { in uv__pipe_read_start() 1928 req = &handle->read_req; in uv__pipe_read_exactly() 1997 req = &handle->read_req; in uv__pipe_read_data() 2129 UnregisterWait(handle->read_req.wait_handle); in uv__process_pipe_read_req() [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()
|
/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() 46 uv_fs_read(uv_default_loop(), &read_req, req->result, in on_open() 59 uv_fs_req_cleanup(&read_req); in main()
|
/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() 254 ASSERT_EQ(read_req.result, error); in readFail() 255 uv_fs_req_cleanup(&read_req); in readFail() 260 ASSERT_EQ(read_req.result, error); in readFail() [all …]
|
H A D | test-fs.c | 108 static uv_fs_t read_req; variable 402 ASSERT_PTR_EQ(req, &read_req); in read_cb() 1018 uv_fs_req_cleanup(&read_req); in fs_file_sync() 1047 uv_fs_req_cleanup(&read_req); in fs_file_sync() 3334 ASSERT_OK(read_req.result); in fs_read_file_eof() 3404 ASSERT_OK(read_req.result); in fs_write_multiple_bufs() 3429 ASSERT_OK(read_req.result); in fs_write_multiple_bufs() 3529 &read_req, in fs_write_alotof_bufs() 3536 ASSERT_OK(read_req.result); in fs_write_alotof_bufs() 3645 &read_req, in fs_write_alotof_bufs_with_offset() [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()
|
/libuv/include/uv/ |
H A D | win.h | 439 uv_read_t read_req; \
|
Completed in 63 milliseconds