Home
last modified time | relevance | path

Searched refs:queued_bytes (Results 1 – 13 of 13) sorted by relevance

/third_party/libuv/src/win/
Dudp.c431 req->u.io.queued_bytes = 0; in uv__send()
433 handle->send_queue_size += req->u.io.queued_bytes; in uv__send()
439 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs); in uv__send()
441 handle->send_queue_size += req->u.io.queued_bytes; in uv__send()
570 assert(handle->send_queue_size >= req->u.io.queued_bytes); in uv__process_udp_send_req()
572 handle->send_queue_size -= req->u.io.queued_bytes; in uv__process_udp_send_req()
Dpipe.c1543 req->u.io.queued_bytes = 0; in uv__pipe_write_data()
1559 req->u.io.queued_bytes = write_buf.len; in uv__pipe_write_data()
1560 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()
1578 req->u.io.queued_bytes = 0; in uv__pipe_write_data()
1581 req->u.io.queued_bytes = write_buf.len; in uv__pipe_write_data()
1582 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()
1611 req->u.io.queued_bytes = 0; in uv__pipe_write_data()
1614 req->u.io.queued_bytes = write_buf.len; 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()
[all …]
Dtcp.c943 req->u.io.queued_bytes = 0; in uv__tcp_write()
950 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs); in uv__tcp_write()
954 handle->write_queue_size += req->u.io.queued_bytes; in uv__tcp_write()
964 req->u.io.queued_bytes = 0; 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()
Dtty.c2199 req->u.io.queued_bytes = 0;
2232 handle->write_queue_size -= req->u.io.queued_bytes;
/third_party/node/deps/uv/src/win/
Dudp.c431 req->u.io.queued_bytes = 0; in uv__send()
433 handle->send_queue_size += req->u.io.queued_bytes; in uv__send()
439 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs); in uv__send()
441 handle->send_queue_size += req->u.io.queued_bytes; in uv__send()
570 assert(handle->send_queue_size >= req->u.io.queued_bytes); in uv__process_udp_send_req()
572 handle->send_queue_size -= req->u.io.queued_bytes; in uv__process_udp_send_req()
Dpipe.c1543 req->u.io.queued_bytes = 0; in uv__pipe_write_data()
1559 req->u.io.queued_bytes = write_buf.len; in uv__pipe_write_data()
1560 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()
1578 req->u.io.queued_bytes = 0; in uv__pipe_write_data()
1581 req->u.io.queued_bytes = write_buf.len; in uv__pipe_write_data()
1582 handle->write_queue_size += req->u.io.queued_bytes; in uv__pipe_write_data()
1611 req->u.io.queued_bytes = 0; in uv__pipe_write_data()
1614 req->u.io.queued_bytes = write_buf.len; 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()
[all …]
Dtcp.c943 req->u.io.queued_bytes = 0; in uv__tcp_write()
950 req->u.io.queued_bytes = uv__count_bufs(bufs, nbufs); in uv__tcp_write()
954 handle->write_queue_size += req->u.io.queued_bytes; in uv__tcp_write()
964 req->u.io.queued_bytes = 0; 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()
Dtty.c2199 req->u.io.queued_bytes = 0;
2232 handle->write_queue_size -= req->u.io.queued_bytes;
/third_party/gstreamer/gstplugins_base/gst-libs/gst/app/
Dgstappsrc.c176 guint64 queued_bytes, queued_buffers; member
801 priv->queued_bytes = 0; in gst_app_src_flush_queued()
1429 priv->queued_bytes -= buf_size; in gst_app_src_update_queued_pop()
1473 " buffers, %" GST_TIME_FORMAT, priv->queued_bytes, in gst_app_src_update_queued_pop()
1526 priv->queued_bytes += buf_size; in gst_app_src_update_queued_push()
1577 " buffers, %" GST_TIME_FORMAT, priv->queued_bytes, priv->queued_buffers, in gst_app_src_update_queued_push()
1775 && priv->queued_bytes * 100 / priv->max_bytes <= in gst_app_src_create()
2158 queued = priv->queued_bytes; in gst_app_src_get_current_level_bytes()
2574 if ((priv->max_bytes && priv->queued_bytes >= priv->max_bytes) || in gst_app_src_push_internal()
2582 priv->queued_bytes, priv->max_bytes, priv->queued_buffers, in gst_app_src_push_internal()
/third_party/gstreamer/gstplugins_good/gst/multifile/
Dgstsplitmuxsink.c2334 guint64 queued_bytes) in need_new_fragment() argument
2398 if (thresh_bytes > 0 && queued_bytes > thresh_bytes) { in need_new_fragment()
2400 "queued bytes %" G_GUINT64_FORMAT " overruns byte limit", queued_bytes); in need_new_fragment()
2504 guint64 queued_bytes; in handle_gathered_gop() local
2515 queued_bytes = splitmux->fragment_total_bytes + gop->total_bytes; in handle_gathered_gop()
2524 GST_LOG_OBJECT (splitmux, " queued_bytes %" G_GUINT64_FORMAT, queued_bytes); in handle_gathered_gop()
2528 GST_STIME_ARGS (queued_time), queued_bytes, in handle_gathered_gop()
2542 queued_bytes += (queued_bytes * splitmux->mux_overhead); in handle_gathered_gop()
2546 if (need_new_fragment (splitmux, queued_time, queued_gop_time, queued_bytes)) { in handle_gathered_gop()
/third_party/node/deps/uv/include/uv/
Dwin.h378 size_t queued_bytes; \
/third_party/libuv/include/uv/
Dwin.h379 size_t queued_bytes; \
/third_party/gstreamer/gstplugins_base/
DChangeLog128060 Reset queued_bytes counter when flushing