Lines Matching refs:conn
169 handle->tcp.conn.func_connectex = NULL; in uv_tcp_init_ex()
210 assert(stream->stream.conn.write_reqs_pending == 0); in uv__process_tcp_shutdown_req()
214 stream->stream.conn.shutdown_req = NULL; in uv__process_tcp_shutdown_req()
802 if (!handle->tcp.conn.func_connectex) { in uv__tcp_try_connect()
803 if (!uv__get_connectex_function(handle->socket, &handle->tcp.conn.func_connectex)) { in uv__tcp_try_connect()
842 success = handle->tcp.conn.func_connectex(handle->socket, in uv__tcp_try_connect()
927 handle->stream.conn.write_reqs_pending++; in uv__tcp_write()
934 handle->stream.conn.write_reqs_pending++; in uv__tcp_write()
948 handle->stream.conn.write_reqs_pending++; in uv__tcp_write()
964 if (handle->stream.conn.write_reqs_pending > 0) in uv__tcp_try_write()
999 uv_buf_init(NULL, 0) : handle->tcp.conn.read_buffer; in uv__process_tcp_read_req()
1021 &handle->tcp.conn.read_buffer); 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()
1035 handle->read_cb((uv_stream_t*)handle, UV_EOF, &handle->tcp.conn.read_buffer); in uv__process_tcp_read_req()
1142 handle->stream.conn.write_reqs_pending--; in uv__process_tcp_write_req()
1143 if (handle->stream.conn.write_reqs_pending == 0) { in uv__process_tcp_write_req()
1151 handle->stream.conn.shutdown_req); in uv__process_tcp_write_req()
1399 writing = tcp->stream.conn.write_reqs_pending > 0; in uv__tcp_try_cancel_reqs()
1479 tcp->stream.conn.write_reqs_pending == 0) { in uv__tcp_close()
