Lines Matching refs:conn
120 handle->pipe.conn.ipc_remote_pid = 0; in uv_pipe_init()
121 handle->pipe.conn.ipc_data_frame.payload_remaining = 0; in uv_pipe_init()
122 uv__queue_init(&handle->pipe.conn.ipc_xfer_queue); in uv_pipe_init()
123 handle->pipe.conn.ipc_xfer_queue_length = 0; in uv_pipe_init()
125 handle->pipe.conn.non_overlapped_writes_tail = NULL; in uv_pipe_init()
135 handle->pipe.conn.eof_timer = NULL; in uv__pipe_connection_init()
521 handle->pipe.conn.readfile_thread_handle = NULL; in uv__set_pipe_handle()
522 InitializeCriticalSection(&handle->pipe.conn.readfile_thread_lock); in uv__set_pipe_handle()
602 assert(handle->stream.conn.write_reqs_pending == 0); in uv__pipe_shutdown()
653 while (!uv__queue_empty(&handle->pipe.conn.ipc_xfer_queue)) { in uv__pipe_endgame()
657 q = uv__queue_head(&handle->pipe.conn.ipc_xfer_queue); in uv__pipe_endgame()
673 handle->pipe.conn.ipc_xfer_queue_length = 0; in uv__pipe_endgame()
682 DeleteCriticalSection(&handle->pipe.conn.readfile_thread_lock); in uv__pipe_endgame()
1018 volatile HANDLE* thread_ptr = &handle->pipe.conn.readfile_thread_handle; in uv__pipe_interrupt_read()
1020 EnterCriticalSection(&handle->pipe.conn.readfile_thread_lock); in uv__pipe_interrupt_read()
1039 LeaveCriticalSection(&handle->pipe.conn.readfile_thread_lock); in uv__pipe_interrupt_read()
1152 if (uv__queue_empty(&server->pipe.conn.ipc_xfer_queue)) { in uv__pipe_accept()
1157 q = uv__queue_head(&server->pipe.conn.ipc_xfer_queue); in uv__pipe_accept()
1159 server->pipe.conn.ipc_xfer_queue_length--; in uv__pipe_accept()
1246 volatile HANDLE* thread_ptr = &handle->pipe.conn.readfile_thread_handle; in uv_pipe_zero_readfile_thread_proc()
1247 CRITICAL_SECTION* lock = &handle->pipe.conn.readfile_thread_lock; in uv_pipe_zero_readfile_thread_proc()
1391 handle->pipe.conn.readfile_thread_handle = NULL; /* Reset cancellation. */ in uv__pipe_queue_read()
1473 if (handle->pipe.conn.non_overlapped_writes_tail) { in uv__insert_non_overlapped_write_req()
1475 handle->pipe.conn.non_overlapped_writes_tail->next_req; in uv__insert_non_overlapped_write_req()
1476 handle->pipe.conn.non_overlapped_writes_tail->next_req = (uv_req_t*)req; in uv__insert_non_overlapped_write_req()
1477 handle->pipe.conn.non_overlapped_writes_tail = req; in uv__insert_non_overlapped_write_req()
1480 handle->pipe.conn.non_overlapped_writes_tail = req; in uv__insert_non_overlapped_write_req()
1488 if (handle->pipe.conn.non_overlapped_writes_tail) { in uv_remove_non_overlapped_write_req()
1489 req = (uv_write_t*)handle->pipe.conn.non_overlapped_writes_tail->next_req; in uv_remove_non_overlapped_write_req()
1491 if (req == handle->pipe.conn.non_overlapped_writes_tail) { in uv_remove_non_overlapped_write_req()
1492 handle->pipe.conn.non_overlapped_writes_tail = NULL; in uv_remove_non_overlapped_write_req()
1494 handle->pipe.conn.non_overlapped_writes_tail->next_req = in uv_remove_non_overlapped_write_req()
1642 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data()
1648 if (handle->stream.conn.write_reqs_pending == 0) { in uv__pipe_write_data()
1690 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data()
1723 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data()
1730 DWORD* pid = &handle->pipe.conn.ipc_remote_pid; in uv__pipe_get_ipc_remote_pid()
1913 uv__queue_insert_tail(&handle->pipe.conn.ipc_xfer_queue, &item->member); in uv__pipe_queue_ipc_xfer_info()
1914 handle->pipe.conn.ipc_xfer_queue_length++; in uv__pipe_queue_ipc_xfer_info()
2035 data_remaining = &handle->pipe.conn.ipc_data_frame.payload_remaining; in uv__pipe_read_ipc()
2214 handle->stream.conn.write_reqs_pending--; in uv__process_pipe_write_req()
2217 handle->pipe.conn.non_overlapped_writes_tail) { in uv__process_pipe_write_req()
2218 assert(handle->stream.conn.write_reqs_pending > 0); in uv__process_pipe_write_req()
2222 if (handle->stream.conn.write_reqs_pending == 0 && in uv__process_pipe_write_req()
2224 uv__pipe_shutdown(loop, handle, handle->stream.conn.shutdown_req); in uv__process_pipe_write_req()
2304 handle->stream.conn.shutdown_req = NULL; in uv__process_pipe_shutdown_req()
2343 assert(pipe->pipe.conn.eof_timer == NULL); in eof_timer_init()
2346 pipe->pipe.conn.eof_timer = (uv_timer_t*) uv__malloc(sizeof *pipe->pipe.conn.eof_timer); in eof_timer_init()
2348 r = uv_timer_init(pipe->loop, pipe->pipe.conn.eof_timer); in eof_timer_init()
2351 pipe->pipe.conn.eof_timer->data = pipe; in eof_timer_init()
2352 uv_unref((uv_handle_t*) pipe->pipe.conn.eof_timer); in eof_timer_init()
2359 if (pipe->pipe.conn.eof_timer != NULL) { in eof_timer_start()
2360 uv_timer_start(pipe->pipe.conn.eof_timer, eof_timer_cb, eof_timeout, 0); in eof_timer_start()
2368 if (pipe->pipe.conn.eof_timer != NULL) { in eof_timer_stop()
2369 uv_timer_stop(pipe->pipe.conn.eof_timer); in eof_timer_stop()
2411 if (pipe->pipe.conn.eof_timer) { in eof_timer_destroy()
2412 uv_close((uv_handle_t*) pipe->pipe.conn.eof_timer, eof_timer_close_cb); in eof_timer_destroy()
2413 pipe->pipe.conn.eof_timer = NULL; in eof_timer_destroy()
2497 GetNamedPipeClientProcessId(os_handle, &pipe->pipe.conn.ipc_remote_pid); in uv_pipe_open()
2498 if (pipe->pipe.conn.ipc_remote_pid == GetCurrentProcessId()) { in uv_pipe_open()
2499 GetNamedPipeServerProcessId(os_handle, &pipe->pipe.conn.ipc_remote_pid); in uv_pipe_open()
2501 assert(pipe->pipe.conn.ipc_remote_pid != (DWORD)(uv_pid_t) -1); in uv_pipe_open()
2604 return handle->pipe.conn.ipc_xfer_queue_length; in uv_pipe_pending_count()
2642 if (handle->pipe.conn.ipc_xfer_queue_length == 0) in uv_pipe_pending_type()
