Lines Matching refs:stream
602 assert(handle->stream.conn.write_reqs_pending == 0); in uv__pipe_shutdown()
1208 handle->stream.serv.connection_cb = cb; in uv__pipe_listen()
1229 handle->stream.serv.connection_cb = cb; in uv__pipe_listen()
1642 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data()
1648 if (handle->stream.conn.write_reqs_pending == 0) { in uv__pipe_write_data()
1690 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data()
1723 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data()
2210 handle->stream.conn.write_reqs_pending--; in uv__process_pipe_write_req()
2214 assert(handle->stream.conn.write_reqs_pending > 0); in uv__process_pipe_write_req()
2218 if (handle->stream.conn.write_reqs_pending == 0 && in uv__process_pipe_write_req()
2220 uv__pipe_shutdown(loop, handle, handle->stream.conn.shutdown_req); in uv__process_pipe_write_req()
2244 if (handle->stream.serv.connection_cb) { in uv__process_pipe_accept_req()
2245 handle->stream.serv.connection_cb((uv_stream_t*)handle, 0); in uv__process_pipe_accept_req()
2300 handle->stream.conn.shutdown_req = NULL; in uv__process_pipe_shutdown_req()