Lines Matching defs:stream
28 #include "stream-inl.h"
200 void uv__process_tcp_shutdown_req(uv_loop_t* loop, uv_tcp_t* stream, uv_shutdown_t *req) {
204 assert(stream->stream.conn.write_reqs_pending == 0);
205 assert(!(stream->flags & UV_HANDLE_SHUT));
206 assert(stream->flags & UV_HANDLE_CONNECTION);
208 stream->stream.conn.shutdown_req = NULL;
209 UNREGISTER_HANDLE_REQ(loop, stream, req);
212 if (stream->flags & UV_HANDLE_CLOSING)
213 /* The user destroyed the stream before we got to do the shutdown. */
215 else if (shutdown(stream->socket, SD_SEND) == SOCKET_ERROR)
218 stream->flags |= UV_HANDLE_SHUT;
223 DECREASE_PENDING_REQ_COUNT(stream);
545 handle->stream.serv.connection_cb = cb;
580 handle->stream.serv.connection_cb = cb;
915 handle->stream.conn.write_reqs_pending++;
922 handle->stream.conn.write_reqs_pending++;
936 handle->stream.conn.write_reqs_pending++;
952 if (handle->stream.conn.write_reqs_pending > 0)
1130 handle->stream.conn.write_reqs_pending--;
1131 if (handle->stream.conn.write_reqs_pending == 0) {
1139 handle->stream.conn.shutdown_req);
1160 if (handle->stream.serv.connection_cb) {
1162 handle->stream.serv.connection_cb((uv_stream_t*)handle,
1176 if (handle->stream.serv.connection_cb) {
1177 handle->stream.serv.connection_cb((uv_stream_t*)handle, 0);
1387 writing = tcp->stream.conn.write_reqs_pending > 0;
1467 tcp->stream.conn.write_reqs_pending == 0) {