Lines Matching defs:loop
81 static int uv__tcp_set_socket(uv_loop_t* loop,
105 loop->iocp,
154 int uv_tcp_init_ex(uv_loop_t* loop, uv_tcp_t* handle, unsigned int flags) {
165 uv__stream_init(loop, (uv_stream_t*) handle, UV_TCP);
190 err = uv__tcp_set_socket(handle->loop, handle, sock, domain, 0);
203 int uv_tcp_init(uv_loop_t* loop, uv_tcp_t* handle) {
204 return uv_tcp_init_ex(loop, handle, AF_UNSPEC);
208 void uv__process_tcp_shutdown_req(uv_loop_t* loop, uv_tcp_t* stream, uv_shutdown_t *req) {
218 UNREGISTER_HANDLE_REQ(loop, stream, req);
236 void uv__tcp_endgame(uv_loop_t* loop, uv_tcp_t* handle) {
277 loop->active_tcp_streams--;
311 err = uv__tcp_set_socket(handle->loop, handle, sock, addr->sa_family, 0);
363 if (!PostQueuedCompletionStatus(handle->loop->iocp,
382 if (!PostQueuedCompletionStatus(handle->loop->iocp,
392 uv_loop_t* loop = handle->loop;
412 uv__insert_pending_req(loop, (uv_req_t*)req);
420 uv__insert_pending_req(loop, (uv_req_t*)req);
446 uv__insert_pending_req(loop, (uv_req_t*)req);
457 uv__insert_pending_req(loop, (uv_req_t*)req);
462 uv__insert_pending_req(loop, (uv_req_t*)req);
475 static void uv__tcp_queue_read(uv_loop_t* loop, uv_tcp_t* handle) {
491 if (loop->active_tcp_streams < uv_active_tcp_streams_threshold) {
530 uv__insert_pending_req(loop, (uv_req_t*)req);
539 uv__insert_pending_req(loop, (uv_req_t*)req);
544 uv__insert_pending_req(loop, (uv_req_t*)req);
608 INCREASE_ACTIVE_COUNT(loop, handle);
657 uv_loop_t* loop = server->loop;
678 err = uv__tcp_set_socket(client->loop,
719 loop->active_tcp_streams++;
727 uv_loop_t* loop = handle->loop;
732 INCREASE_ACTIVE_COUNT(loop, handle);
744 uv__tcp_queue_read(loop, handle);
790 uv_loop_t* loop = handle->loop;
855 REGISTER_HANDLE_REQ(loop, handle, req);
856 uv__insert_pending_req(loop, (uv_req_t*)req);
871 REGISTER_HANDLE_REQ(loop, handle, req);
872 uv__insert_pending_req(loop, (uv_req_t*)req);
876 REGISTER_HANDLE_REQ(loop, handle, req);
909 int uv__tcp_write(uv_loop_t* loop,
946 REGISTER_HANDLE_REQ(loop, handle, req);
947 uv__insert_pending_req(loop, (uv_req_t*) req);
953 REGISTER_HANDLE_REQ(loop, handle, req);
960 uv__insert_pending_req(loop, (uv_req_t*)req);
967 REGISTER_HANDLE_REQ(loop, handle, req);
969 uv__insert_pending_req(loop, (uv_req_t*) req);
1000 void uv__process_tcp_read_req(uv_loop_t* loop, uv_tcp_t* handle,
1015 DECREASE_ACTIVE_COUNT(loop, handle);
1048 DECREASE_ACTIVE_COUNT(loop, handle);
1087 DECREASE_ACTIVE_COUNT(loop, handle);
1100 DECREASE_ACTIVE_COUNT(loop, handle);
1121 uv__tcp_queue_read(loop, handle);
1129 void uv__process_tcp_write_req(uv_loop_t* loop, uv_tcp_t* handle,
1138 UNREGISTER_HANDLE_REQ(loop, handle, req);
1167 uv__process_tcp_shutdown_req(loop,
1176 void uv__process_tcp_accept_req(uv_loop_t* loop, uv_tcp_t* handle,
1189 DECREASE_ACTIVE_COUNT(loop, handle);
1224 void uv__process_tcp_connect_req(uv_loop_t* loop, uv_tcp_t* handle,
1230 UNREGISTER_HANDLE_REQ(loop, handle, req);
1251 loop->active_tcp_streams++;
1320 tcp->loop, tcp, socket, xfer_info->socket_info.iAddressFamily, 1);
1334 tcp->loop->active_tcp_streams++;
1463 void uv__tcp_close(uv_loop_t* loop, uv_tcp_t* tcp) {
1487 DECREASE_ACTIVE_COUNT(loop, tcp);
1505 uv__want_endgame(loop, (uv_handle_t*) tcp);
1526 err = uv__tcp_set_socket(handle->loop,