Searched refs:write_queue_size (Results 1 – 16 of 16) sorted by relevance
81 pipe->write_queue_size++; in TEST_IMPL()83 pipe->write_queue_size--; in TEST_IMPL()
52 ASSERT(client.write_queue_size == 0); in incoming_close_cb()
82 ASSERT(req->handle->write_queue_size == 0); in shutdown_cb()
74 ASSERT(tcp->write_queue_size == 0); in shutdown_cb()
88 stream->write_queue_size = 0; in uv__stream_init()468 assert(stream->write_queue_size == 0); in uv__stream_destroy()711 assert(req->handle->write_queue_size >= size); in uv__write_req_size()729 assert(n <= stream->write_queue_size); in uv__write_req_update()730 stream->write_queue_size -= n; in uv__write_req_update()954 stream->write_queue_size -= uv__write_req_size(req); in uv__write_callbacks()1459 empty_queue = (stream->write_queue_size == 0); in uv_write2()1479 stream->write_queue_size += uv__count_bufs(bufs, nbufs); in uv_write2()1535 if (stream->connect_req != NULL || stream->write_queue_size != 0) in uv_try_write2()
37 handle->write_queue_size = 0; in uv__stream_init()
1585 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()1607 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()1640 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()2058 assert(handle->write_queue_size >= req->u.io.queued_bytes); in uv__process_pipe_write_req()2059 handle->write_queue_size -= req->u.io.queued_bytes; in uv__process_pipe_write_req()
951 handle->write_queue_size += req->u.io.queued_bytes; in uv__tcp_write()1132 assert(handle->write_queue_size >= req->u.io.queued_bytes); in uv__process_tcp_write_req()1133 handle->write_queue_size -= req->u.io.queued_bytes; in uv__process_tcp_write_req()
2232 handle->write_queue_size -= req->u.io.queued_bytes;
286 uint32_t write_queue_size = wrap->stream()->write_queue_size; in GetWriteQueueSize() local287 info.GetReturnValue().Set(write_queue_size); in GetWriteQueueSize()
259 writer->json_keyvalue("writeQueueSize", handle->stream.write_queue_size); in WalkHandle()
1251 uint32_t write_queue_size = BIO_pending(wrap->enc_out_); in GetWriteQueueSize() local1252 info.GetReturnValue().Set(write_queue_size); in GetWriteQueueSize()
78 return stream->write_queue_size; in uv_stream_get_write_queue_size()
81 .. c:member:: size_t uv_stream_t.write_queue_size254 Returns `stream->write_queue_size`.
491 size_t write_queue_size; \
483 size_t write_queue_size; \