Searched refs:write_queue_size (Results 1 – 23 of 23) 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()
89 stream->write_queue_size = 0; in uv__stream_init()459 assert(stream->write_queue_size == 0); in uv__stream_destroy()709 assert(req->handle->write_queue_size >= size); in uv__write_req_size()727 assert(n <= stream->write_queue_size); in uv__write_req_update()728 stream->write_queue_size -= n; in uv__write_req_update()951 stream->write_queue_size -= uv__write_req_size(req); in uv__write_callbacks()1414 empty_queue = (stream->write_queue_size == 0); in uv_write2()1434 stream->write_queue_size += uv__count_bufs(bufs, nbufs); in uv_write2()1490 if (stream->connect_req != NULL || stream->write_queue_size != 0) in uv_try_write2()
37 handle->write_queue_size = 0; in uv__stream_init()
1560 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()1582 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()1615 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()2033 assert(handle->write_queue_size >= req->u.io.queued_bytes); in uv__process_pipe_write_req()2034 handle->write_queue_size -= req->u.io.queued_bytes; in uv__process_pipe_write_req()
954 handle->write_queue_size += req->u.io.queued_bytes; in uv__tcp_write()1135 assert(handle->write_queue_size >= req->u.io.queued_bytes); in uv__process_tcp_write_req()1136 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;
307 uint32_t write_queue_size = wrap->stream()->write_queue_size; in GetWriteQueueSize() local308 info.GetReturnValue().Set(write_queue_size); in GetWriteQueueSize()
254 writer->json_keyvalue("writeQueueSize", handle->stream.write_queue_size); in WalkHandle()
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`.
1469 uint32_t write_queue_size = BIO_pending(wrap->enc_out_); in GetWriteQueueSize() local1470 info.GetReturnValue().Set(write_queue_size); in GetWriteQueueSize()
491 size_t write_queue_size; \
483 size_t write_queue_size; \