Lines Matching refs:u
198 assert(pipe->u.fd == -1 || pipe->u.fd > 2); in close_pipe()
199 if (pipe->u.fd == -1) in close_pipe()
202 _close(pipe->u.fd); in close_pipe()
204 pipe->u.fd = -1; in close_pipe()
534 handle->u.fd = fd; in uv__set_pipe_handle()
830 while (WaitNamedPipeW(req->u.connect.name, 30000)) { in pipe_connect_thread_proc()
832 pipeHandle = open_named_pipe(req->u.connect.name, &duplex_flags); in pipe_connect_thread_proc()
839 uv__free(req->u.connect.name); in pipe_connect_thread_proc()
840 req->u.connect.name = NULL; in pipe_connect_thread_proc()
843 req->u.connect.pipeHandle = pipeHandle; in pipe_connect_thread_proc()
844 req->u.connect.duplex_flags = duplex_flags; in pipe_connect_thread_proc()
893 req->u.connect.pipeHandle = INVALID_HANDLE_VALUE; in uv_pipe_connect2()
894 req->u.connect.duplex_flags = 0; in uv_pipe_connect2()
895 req->u.connect.name = NULL; in uv_pipe_connect2()
945 req->u.connect.name = uv__malloc(nameSize); in uv_pipe_connect2()
946 if (!req->u.connect.name) { in uv_pipe_connect2()
950 memcpy(req->u.connect.name, handle->name, nameSize); in uv_pipe_connect2()
956 uv__free(req->u.connect.name); in uv_pipe_connect2()
957 req->u.connect.name = NULL; in uv_pipe_connect2()
972 req->u.connect.pipeHandle = pipeHandle; in uv_pipe_connect2()
973 req->u.connect.duplex_flags = duplex_flags; in uv_pipe_connect2()
1012 r = CancelIoEx(handle->handle, &handle->read_req.u.io.overlapped); in uv__pipe_interrupt_read()
1121 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__pipe_queue_accept()
1123 if (!ConnectNamedPipe(req->pipeHandle, &req->u.io.overlapped) && in uv__pipe_queue_accept()
1352 req->u.io.overlapped.InternalHigh, in post_completion_read_wait()
1354 &req->u.io.overlapped)) { in post_completion_read_wait()
1371 req->u.io.overlapped.InternalHigh, in post_completion_write_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()
1403 req->u.io.overlapped.hEvent = (HANDLE) ((uintptr_t) req->event_handle | 1); 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()
1607 req->u.io.overlapped.hEvent = (HANDLE) ((uintptr_t) req->event_handle | 1); in uv__pipe_write_data()
1637 req->u.io.queued_bytes = 0; in uv__pipe_write_data()
1653 req->u.io.queued_bytes = write_buf.len; in uv__pipe_write_data()
1654 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()
1661 &req->u.io.overlapped); in uv__pipe_write_data()
1672 req->u.io.queued_bytes = 0; in uv__pipe_write_data()
1675 req->u.io.queued_bytes = write_buf.len; in uv__pipe_write_data()
1676 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()
1697 &req->u.io.overlapped); in uv__pipe_write_data()
1705 req->u.io.queued_bytes = 0; in uv__pipe_write_data()
1708 req->u.io.queued_bytes = write_buf.len; in uv__pipe_write_data()
1709 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()
1929 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__pipe_read_exactly()
1930 req->u.io.overlapped.hEvent = (HANDLE) ((uintptr_t) req->event_handle | 1); in uv__pipe_read_exactly()
1935 &req->u.io.overlapped)) { in uv__pipe_read_exactly()
1938 if (!GetOverlappedResult(handle->handle, &req->u.io.overlapped, &bytes_read_now, TRUE)) in uv__pipe_read_exactly()
1998 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__pipe_read_data()
1999 req->u.io.overlapped.hEvent = (HANDLE) ((uintptr_t) req->event_handle | 1); in uv__pipe_read_data()
2000 if (ReadFile(handle->handle, buf.base, max_bytes, bytes_read, &req->u.io.overlapped)) { in uv__pipe_read_data()
2006 r = CancelIoEx(handle->handle, &req->u.io.overlapped); in uv__pipe_read_data()
2008 if (GetOverlappedResult(handle->handle, &req->u.io.overlapped, bytes_read, TRUE)) { in uv__pipe_read_data()
2181 assert(handle->write_queue_size >= req->u.io.queued_bytes); in uv__process_pipe_write_req()
2182 handle->write_queue_size -= req->u.io.queued_bytes; in uv__process_pipe_write_req()
2273 pipeHandle = req->u.connect.pipeHandle; in uv__process_pipe_connect_req()
2274 duplex_flags = req->u.connect.duplex_flags; in uv__process_pipe_connect_req()
2387 HasOverlappedIoCompleted(&pipe->read_req.u.io.overlapped)) { in eof_timer_cb()
