Home
last modified time | relevance | path

Searched refs:read_req (Results 1 – 9 of 9) sorted by relevance

/libuv/src/win/
H A Dstream-inl.h42 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 Dtcp.c263 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 Dpipe.c134 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 Dtty.c461 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 Dmain.c9 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 Dtest-fs-open-flags.c43 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 Dtest-fs.c108 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 Dtest-eintr-handling.c37 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 Dwin.h439 uv_read_t read_req; \

Completed in 43 milliseconds