Lines Matching refs:stream
206 void uv__process_tcp_shutdown_req(uv_loop_t* loop, uv_tcp_t* stream, uv_shutdown_t *req) { in uv__process_tcp_shutdown_req() argument
210 assert(stream->stream.conn.write_reqs_pending == 0); in uv__process_tcp_shutdown_req()
211 assert(!(stream->flags & UV_HANDLE_SHUT)); in uv__process_tcp_shutdown_req()
212 assert(stream->flags & UV_HANDLE_CONNECTION); in uv__process_tcp_shutdown_req()
214 stream->stream.conn.shutdown_req = NULL; in uv__process_tcp_shutdown_req()
215 UNREGISTER_HANDLE_REQ(loop, stream); in uv__process_tcp_shutdown_req()
218 if (stream->flags & UV_HANDLE_CLOSING) in uv__process_tcp_shutdown_req()
221 else if (shutdown(stream->socket, SD_SEND) == SOCKET_ERROR) in uv__process_tcp_shutdown_req()
224 stream->flags |= UV_HANDLE_SHUT; in uv__process_tcp_shutdown_req()
229 DECREASE_PENDING_REQ_COUNT(stream); in uv__process_tcp_shutdown_req()
557 handle->stream.serv.connection_cb = cb; in uv__tcp_listen()
592 handle->stream.serv.connection_cb = cb; in uv__tcp_listen()
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()
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()
1172 if (handle->stream.serv.connection_cb) { in uv__process_tcp_accept_req()
1174 handle->stream.serv.connection_cb((uv_stream_t*)handle, in uv__process_tcp_accept_req()
1188 if (handle->stream.serv.connection_cb) { in uv__process_tcp_accept_req()
1189 handle->stream.serv.connection_cb((uv_stream_t*)handle, 0); in uv__process_tcp_accept_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()
