Lines Matching refs:stream
28 #include "stream-inl.h"
208 void uv__process_tcp_shutdown_req(uv_loop_t* loop, uv_tcp_t* stream, uv_shutdown_t *req) {
212 assert(stream->stream.conn.write_reqs_pending == 0);
213 assert(!(stream->flags & UV_HANDLE_SHUT));
214 assert(stream->flags & UV_HANDLE_CONNECTION);
216 stream->stream.conn.shutdown_req = NULL;
217 stream->flags &= ~UV_HANDLE_SHUTTING;
218 UNREGISTER_HANDLE_REQ(loop, stream, req);
221 if (stream->flags & UV_HANDLE_CLOSING)
222 /* The user destroyed the stream before we got to do the shutdown. */
224 else if (shutdown(stream->socket, SD_SEND) == SOCKET_ERROR)
227 stream->flags |= UV_HANDLE_SHUT;
232 DECREASE_PENDING_REQ_COUNT(stream);
572 handle->stream.serv.connection_cb = cb;
607 handle->stream.serv.connection_cb = cb;
945 handle->stream.conn.write_reqs_pending++;
952 handle->stream.conn.write_reqs_pending++;
966 handle->stream.conn.write_reqs_pending++;
982 if (handle->stream.conn.write_reqs_pending > 0)
1160 handle->stream.conn.write_reqs_pending--;
1161 if (handle->stream.conn.write_reqs_pending == 0) {
1169 handle->stream.conn.shutdown_req);
1190 if (handle->stream.serv.connection_cb) {
1192 handle->stream.serv.connection_cb((uv_stream_t*)handle,
1206 if (handle->stream.serv.connection_cb) {
1207 handle->stream.serv.connection_cb((uv_stream_t*)handle, 0);
1419 writing = tcp->stream.conn.write_reqs_pending > 0;
1499 tcp->stream.conn.write_reqs_pending == 0) {