Lines Matching refs:pipeHandle
140 HANDLE pipeHandle; in open_named_pipe() local
146 pipeHandle = CreateFileW(name, in open_named_pipe()
153 if (pipeHandle != INVALID_HANDLE_VALUE) { in open_named_pipe()
155 return pipeHandle; in open_named_pipe()
164 pipeHandle = CreateFileW(name, in open_named_pipe()
172 if (pipeHandle != INVALID_HANDLE_VALUE) { in open_named_pipe()
174 return pipeHandle; in open_named_pipe()
179 pipeHandle = CreateFileW(name, in open_named_pipe()
187 if (pipeHandle != INVALID_HANDLE_VALUE) { in open_named_pipe()
189 return pipeHandle; in open_named_pipe()
212 HANDLE pipeHandle; in uv__pipe_server() local
218 pipeHandle = CreateNamedPipeA(name, in uv__pipe_server()
223 if (pipeHandle != INVALID_HANDLE_VALUE) { in uv__pipe_server()
237 *pipeHandle_ptr = pipeHandle; in uv__pipe_server()
242 if (pipeHandle != INVALID_HANDLE_VALUE) in uv__pipe_server()
243 CloseHandle(pipeHandle); in uv__pipe_server()
465 HANDLE pipeHandle, in uv__set_pipe_handle() argument
482 if (!SetNamedPipeHandleState(pipeHandle, &mode, NULL, NULL)) { in uv__set_pipe_handle()
491 if (!GetNamedPipeHandleState(pipeHandle, ¤t_mode, NULL, NULL, in uv__set_pipe_handle()
508 nt_status = pNtQueryInformationFile(pipeHandle, in uv__set_pipe_handle()
525 if (CreateIoCompletionPort(pipeHandle, in uv__set_pipe_handle()
533 handle->handle = pipeHandle; in uv__set_pipe_handle()
543 assert(req->pipeHandle == INVALID_HANDLE_VALUE); in pipe_alloc_accept()
545 req->pipeHandle = in pipe_alloc_accept()
552 if (req->pipeHandle == INVALID_HANDLE_VALUE) { in pipe_alloc_accept()
557 if (CreateIoCompletionPort(req->pipeHandle, in pipe_alloc_accept()
567 handle->handle = req->pipeHandle; in pipe_alloc_accept()
765 req->pipeHandle = INVALID_HANDLE_VALUE; in uv_pipe_bind2()
818 HANDLE pipeHandle = INVALID_HANDLE_VALUE; in pipe_connect_thread_proc() local
832 pipeHandle = open_named_pipe(req->u.connect.name, &duplex_flags); in pipe_connect_thread_proc()
833 if (pipeHandle != INVALID_HANDLE_VALUE) in pipe_connect_thread_proc()
841 if (pipeHandle != INVALID_HANDLE_VALUE) { in pipe_connect_thread_proc()
843 req->u.connect.pipeHandle = pipeHandle; in pipe_connect_thread_proc()
885 HANDLE pipeHandle = INVALID_HANDLE_VALUE; in uv_pipe_connect2() local
893 req->u.connect.pipeHandle = INVALID_HANDLE_VALUE; in uv_pipe_connect2()
941 pipeHandle = open_named_pipe(handle->name, &duplex_flags); in uv_pipe_connect2()
942 if (pipeHandle == INVALID_HANDLE_VALUE) { in uv_pipe_connect2()
972 req->u.connect.pipeHandle = pipeHandle; in uv_pipe_connect2()
988 if (pipeHandle != INVALID_HANDLE_VALUE) in uv_pipe_connect2()
989 CloseHandle(pipeHandle); in uv_pipe_connect2()
1058 HANDLE pipeHandle; in uv__pipe_close() local
1083 pipeHandle = handle->pipe.serv.accept_reqs[i].pipeHandle; in uv__pipe_close()
1084 if (pipeHandle != INVALID_HANDLE_VALUE) { in uv__pipe_close()
1085 CloseHandle(pipeHandle); in uv__pipe_close()
1086 handle->pipe.serv.accept_reqs[i].pipeHandle = INVALID_HANDLE_VALUE; in uv__pipe_close()
1118 assert(req->pipeHandle != INVALID_HANDLE_VALUE); in uv__pipe_queue_accept()
1123 if (!ConnectNamedPipe(req->pipeHandle, &req->u.io.overlapped) && in uv__pipe_queue_accept()
1128 CloseHandle(req->pipeHandle); in uv__pipe_queue_accept()
1129 req->pipeHandle = INVALID_HANDLE_VALUE; in uv__pipe_queue_accept()
1184 pipe_client->handle = req->pipeHandle; in uv__pipe_accept()
1190 req->pipeHandle = INVALID_HANDLE_VALUE; in uv__pipe_accept()
1232 assert(handle->pipe.serv.accept_reqs[0].pipeHandle != INVALID_HANDLE_VALUE); in uv__pipe_listen()
2234 assert(req->pipeHandle == INVALID_HANDLE_VALUE); in uv__process_pipe_accept_req()
2240 assert(req->pipeHandle != INVALID_HANDLE_VALUE); in uv__process_pipe_accept_req()
2248 if (req->pipeHandle != INVALID_HANDLE_VALUE) { in uv__process_pipe_accept_req()
2249 CloseHandle(req->pipeHandle); in uv__process_pipe_accept_req()
2250 req->pipeHandle = INVALID_HANDLE_VALUE; in uv__process_pipe_accept_req()
2263 HANDLE pipeHandle; in uv__process_pipe_connect_req() local
2273 pipeHandle = req->u.connect.pipeHandle; in uv__process_pipe_connect_req()
2278 err = uv__set_pipe_handle(loop, handle, pipeHandle, -1, duplex_flags); in uv__process_pipe_connect_req()
2280 CloseHandle(pipeHandle); in uv__process_pipe_connect_req()