Lines Matching defs:loop
106 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) {
107 uv__stream_init(loop, (uv_stream_t*)handle, UV_NAMED_PIPE);
381 int uv__create_stdio_pipe_pair(uv_loop_t* loop,
421 loop->iocp,
450 static int uv__set_pipe_handle(uv_loop_t* loop,
513 loop->iocp,
528 static int pipe_alloc_accept(uv_loop_t* loop, uv_pipe_t* handle,
545 loop->iocp,
561 uv_loop_t* loop;
569 loop = handle->loop;
570 assert(loop);
575 POST_COMPLETION_FOR_REQ(loop, req);
581 void uv__pipe_shutdown(uv_loop_t* loop, uv_pipe_t* handle, uv_shutdown_t *req) {
593 uv__insert_pending_req(loop, (uv_req_t*) req);
607 uv__insert_pending_req(loop, (uv_req_t*) req);
614 uv__insert_pending_req(loop, (uv_req_t*) req);
625 uv__insert_pending_req(loop, (uv_req_t*) req);
631 void uv__pipe_endgame(uv_loop_t* loop, uv_pipe_t* handle) {
697 uv_loop_t* loop = handle->loop;
750 if (!pipe_alloc_accept(loop,
780 uv_loop_t* loop;
790 loop = handle->loop;
791 assert(loop);
813 POST_COMPLETION_FOR_REQ(loop, req);
821 uv_loop_t* loop = handle->loop;
870 REGISTER_HANDLE_REQ(loop, handle, req);
883 uv__insert_pending_req(loop, (uv_req_t*) req);
885 REGISTER_HANDLE_REQ(loop, handle, req);
899 uv__insert_pending_req(loop, (uv_req_t*) req);
901 REGISTER_HANDLE_REQ(loop, handle, req);
955 DECREASE_ACTIVE_COUNT(handle->loop, handle);
962 void uv__pipe_close(uv_loop_t* loop, uv_pipe_t* handle) {
968 DECREASE_ACTIVE_COUNT(loop, handle);
973 DECREASE_ACTIVE_COUNT(loop, handle);
1009 uv__want_endgame(loop, (uv_handle_t*) handle);
1013 static void uv__pipe_queue_accept(uv_loop_t* loop, uv_pipe_t* handle,
1017 if (!firstInstance && !pipe_alloc_accept(loop, handle, req, FALSE)) {
1019 uv__insert_pending_req(loop, (uv_req_t*) req);
1039 uv__insert_pending_req(loop, (uv_req_t*) req);
1050 uv_loop_t* loop = server->loop;
1099 uv__pipe_queue_accept(loop, server, req, FALSE);
1109 uv_loop_t* loop = handle->loop;
1133 INCREASE_ACTIVE_COUNT(loop, handle);
1140 uv__pipe_queue_accept(loop, handle, &handle->pipe.serv.accept_reqs[i], i == 0);
1150 uv_loop_t* loop = handle->loop;
1214 POST_COMPLETION_FOR_REQ(loop, req);
1225 uv_loop_t* loop = handle->loop;
1241 POST_COMPLETION_FOR_REQ(loop, req);
1256 if (!PostQueuedCompletionStatus(handle->loop->iocp,
1275 if (!PostQueuedCompletionStatus(handle->loop->iocp,
1284 static void uv__pipe_queue_read(uv_loop_t* loop, uv_pipe_t* handle) {
1343 uv__insert_pending_req(loop, (uv_req_t*)req);
1352 uv_loop_t* loop = handle->loop;
1355 INCREASE_ACTIVE_COUNT(loop, handle);
1369 uv__pipe_queue_read(loop, handle);
1484 static int uv__pipe_write_data(uv_loop_t* loop,
1546 REGISTER_HANDLE_REQ(loop, handle, req);
1549 POST_COMPLETION_FOR_REQ(loop, req);
1594 REGISTER_HANDLE_REQ(loop, handle, req);
1627 REGISTER_HANDLE_REQ(loop, handle, req);
1648 int uv__pipe_write_ipc(uv_loop_t* loop,
1739 err = uv__pipe_write_data(loop, req, handle, bufs, buf_count, cb, 1);
1750 int uv__pipe_write(uv_loop_t* loop,
1759 return uv__pipe_write_ipc(loop, req, handle, bufs, nbufs, send_handle, cb);
1763 return uv__pipe_write_data(loop, req, handle, bufs, nbufs, cb, 0);
1768 static void uv__pipe_read_eof(uv_loop_t* loop, uv_pipe_t* handle,
1780 static void uv__pipe_read_error(uv_loop_t* loop, uv_pipe_t* handle, int error,
1792 static void uv__pipe_read_error_or_eof(uv_loop_t* loop, uv_pipe_t* handle,
1795 uv__pipe_read_eof(loop, handle, buf);
1797 uv__pipe_read_error(loop, handle, error, buf);
1844 static DWORD uv__pipe_read_data(uv_loop_t* loop,
1856 return 0; /* Break out of read loop. */
1868 uv__pipe_read_error_or_eof(loop, handle, GetLastError(), buf);
1869 return 0; /* Break out of read loop. */
1879 static DWORD uv__pipe_read_ipc(uv_loop_t* loop, uv_pipe_t* handle) {
1886 uv__pipe_read_data(loop, handle, *data_remaining, *data_remaining);
1955 uv__pipe_read_error_or_eof(loop, handle, err, uv_null_buf_);
1956 return 0; /* Break out of read loop. */
1960 void uv__process_pipe_read_req(uv_loop_t* loop,
1983 uv__pipe_read_error_or_eof(loop, handle, err, uv_null_buf_);
1993 uv__pipe_read_error_or_eof(loop, handle, GetLastError(), uv_null_buf_);
2000 handle->ipc ? uv__pipe_read_ipc(loop, handle)
2001 : uv__pipe_read_data(loop, handle, avail, (DWORD) -1);
2004 * occurred, and break out of the read loop. */
2009 * available. To prevent `avail` from underflowing, break out of the loop
2022 uv__pipe_queue_read(loop, handle);
2027 void uv__process_pipe_write_req(uv_loop_t* loop, uv_pipe_t* handle,
2036 UNREGISTER_HANDLE_REQ(loop, handle, req);
2074 uv__pipe_shutdown(loop, handle, handle->stream.conn.shutdown_req);
2080 void uv__process_pipe_accept_req(uv_loop_t* loop, uv_pipe_t* handle,
2107 uv__pipe_queue_accept(loop, handle, req, FALSE);
2115 void uv__process_pipe_connect_req(uv_loop_t* loop, uv_pipe_t* handle,
2123 UNREGISTER_HANDLE_REQ(loop, handle, req);
2129 err = uv__set_pipe_handle(loop, handle, pipeHandle, -1, duplex_flags);
2144 void uv__process_pipe_shutdown_req(uv_loop_t* loop, uv_pipe_t* handle,
2153 UNREGISTER_HANDLE_REQ(loop, handle, req);
2196 r = uv_timer_init(pipe->loop, pipe->pipe.conn.eof_timer);
2224 uv_loop_t* loop = timer->loop;
2252 uv__pipe_read_eof(loop, pipe, uv_null_buf_);
2332 err = uv__set_pipe_handle(pipe->loop,