Lines Matching refs:u
366 req->u.io.overlapped.InternalHigh, in post_completion()
368 &req->u.io.overlapped)) { in post_completion()
385 req->u.io.overlapped.InternalHigh, in post_write_completion()
387 &req->u.io.overlapped)) { in post_write_completion()
429 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_accept()
432 req->u.io.overlapped.hEvent = (HANDLE) ((ULONG_PTR) req->event_handle | 1); in uv__tcp_queue_accept()
442 &req->u.io.overlapped); in uv__tcp_queue_accept()
487 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_read()
494 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_read()
497 req->u.io.overlapped.hEvent = (HANDLE) ((ULONG_PTR) req->event_handle | 1); in uv__tcp_queue_read()
506 &req->u.io.overlapped, in uv__tcp_queue_read()
514 req->u.io.overlapped.InternalHigh = bytes; in uv__tcp_queue_read()
744 if (in6->sin6_addr.u.Word[i] != 0) in uv__is_loopback()
747 return in6->sin6_addr.u.Word[7] == htons(1); in uv__is_loopback()
832 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__tcp_try_connect()
848 &req->u.io.overlapped); in uv__tcp_try_connect()
905 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__tcp_write()
911 req->u.io.overlapped.hEvent = (HANDLE) ((ULONG_PTR) req->event_handle | 1); in uv__tcp_write()
920 &req->u.io.overlapped, in uv__tcp_write()
925 req->u.io.queued_bytes = 0; in uv__tcp_write()
932 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs); in uv__tcp_write()
936 handle->write_queue_size += req->u.io.queued_bytes; in uv__tcp_write()
946 req->u.io.queued_bytes = 0; in uv__tcp_write()
1017 if (req->u.io.overlapped.InternalHigh > 0) { in uv__process_tcp_read_req()
1020 req->u.io.overlapped.InternalHigh, in uv__process_tcp_read_req()
1023 if (req->u.io.overlapped.InternalHigh < handle->tcp.conn.read_buffer.len) { in uv__process_tcp_read_req()
1117 assert(handle->write_queue_size >= req->u.io.queued_bytes); in uv__process_tcp_write_req()
1118 handle->write_queue_size -= req->u.io.queued_bytes; in uv__process_tcp_write_req()
1406 CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped); in uv__tcp_try_cancel_reqs()
1436 CancelIoEx((HANDLE) socket, &tcp->read_req.u.io.overlapped); in uv__tcp_try_cancel_reqs()
