Home
last modified time | relevance | path

Searched refs:queued (Results 1 – 25 of 190) sorted by relevance

12345678

/third_party/mesa3d/src/gallium/drivers/virgl/
Dvirgl_transfer_queue.c37 struct virgl_transfer *queued; member
41 typedef bool (*compare_transfers_t)(struct virgl_transfer *queued,
155 static bool transfers_intersect(struct virgl_transfer *queued, in transfers_intersect() argument
158 return transfer_overlap(queued, current->hw_res, current->base.level, in transfers_intersect()
163 struct virgl_transfer *queued) in remove_transfer() argument
165 list_del(&queued->queue_link); in remove_transfer()
166 virgl_resource_destroy_transfer(queue->vctx, queued); in remove_transfer()
173 struct virgl_transfer *queued = args->queued; in replace_unmapped_transfer() local
175 u_box_union_2d(&current->base.box, &current->base.box, &queued->base.box); in replace_unmapped_transfer()
178 remove_transfer(queue, queued); in replace_unmapped_transfer()
[all …]
/third_party/gstreamer/gstplugins_bad/gst/mpegpsmux/
Dmpegpsmux.c385 g_assert (ps_data->queued.buf == NULL); in mpegpsmux_queue_buffer_for_stream()
391 ps_data->queued.buf = buf; in mpegpsmux_queue_buffer_for_stream()
397 gst_buffer_unref (ps_data->queued.buf); in mpegpsmux_queue_buffer_for_stream()
398 ps_data->queued.buf = buf; in mpegpsmux_queue_buffer_for_stream()
400 buf = ps_data->queued.buf; in mpegpsmux_queue_buffer_for_stream()
404 ps_data->queued.pts = GST_BUFFER_PTS (buf); in mpegpsmux_queue_buffer_for_stream()
405 if (GST_CLOCK_TIME_IS_VALID (ps_data->queued.pts)) { in mpegpsmux_queue_buffer_for_stream()
406 ps_data->queued.pts = gst_segment_to_running_time (&c_data->segment, in mpegpsmux_queue_buffer_for_stream()
407 GST_FORMAT_TIME, ps_data->queued.pts); in mpegpsmux_queue_buffer_for_stream()
410 ps_data->queued.dts = GST_BUFFER_DTS (buf); in mpegpsmux_queue_buffer_for_stream()
[all …]
/third_party/ffmpeg/libavfilter/
Dframequeue.c40 av_assert0(fq->queued == fq->total_frames_head - fq->total_frames_tail); in check_consistency()
41 for (i = 0; i < fq->queued; i++) in check_consistency()
55 while (fq->queued) { in ff_framequeue_free()
68 if (fq->queued == fq->allocated) { in ff_framequeue_add()
82 if (fq->tail + fq->queued > fq->allocated) in ff_framequeue_add()
84 (fq->tail + fq->queued - fq->allocated) * sizeof(*nq)); in ff_framequeue_add()
89 b = bucket(fq, fq->queued); in ff_framequeue_add()
91 fq->queued++; in ff_framequeue_add()
103 av_assert1(fq->queued); in ff_framequeue_take()
105 fq->queued--; in ff_framequeue_take()
[all …]
Dframequeue.h74 size_t queued; member
148 return fq->queued; in ff_framequeue_queued_frames()
/third_party/gstreamer/gstplugins_bad/sys/ipcpipeline/
Dgstipcpipelinesrc.c197 src->queued = NULL; in gst_ipc_pipeline_src_init()
288 GList *queued; in gst_ipc_pipeline_src_log_queue() local
291 queued = src->queued; in gst_ipc_pipeline_src_log_queue()
294 g_list_length (queued)); in gst_ipc_pipeline_src_log_queue()
295 while (queued) { in gst_ipc_pipeline_src_log_queue()
296 void *object = queued->data; in gst_ipc_pipeline_src_log_queue()
307 queued = queued->next; in gst_ipc_pipeline_src_log_queue()
315 GList *queued; in gst_ipc_pipeline_src_cancel_queued() local
319 queued = src->queued; in gst_ipc_pipeline_src_cancel_queued()
320 src->queued = NULL; in gst_ipc_pipeline_src_cancel_queued()
[all …]
/third_party/node/deps/nghttp2/lib/
Dnghttp2_stream.c96 stream->queued = 0; in nghttp2_stream_init()
150 for (; dep_stream && !stream->queued; in stream_obq_push()
165 stream->queued = 1; in stream_obq_push()
181 if (!stream->queued) { in stream_obq_remove()
191 assert(stream->queued); in stream_obq_remove()
193 stream->queued = 0; in stream_obq_remove()
213 if (!stream->queued) { in stream_obq_move()
221 stream->queued = 0; in stream_obq_move()
229 assert(stream->queued); in nghttp2_stream_reschedule()
269 if (!stream->queued) { in nghttp2_stream_change_weight()
[all …]
/third_party/nghttp2/lib/
Dnghttp2_stream.c96 stream->queued = 0; in nghttp2_stream_init()
150 for (; dep_stream && !stream->queued; in stream_obq_push()
165 stream->queued = 1; in stream_obq_push()
181 if (!stream->queued) { in stream_obq_remove()
191 assert(stream->queued); in stream_obq_remove()
193 stream->queued = 0; in stream_obq_remove()
213 if (!stream->queued) { in stream_obq_move()
221 stream->queued = 0; in stream_obq_move()
229 assert(stream->queued); in nghttp2_stream_reschedule()
269 if (!stream->queued) { in nghttp2_stream_change_weight()
[all …]
/third_party/node/deps/undici/src/docs/api/
Dapi-lifecycle.md10 … transitions the `Client` to the **pending** state where requests can be queued prior to processin…
14 …* If requests are queued, the *close* event transitions to the **processing** state; otherwise, it…
18 …fter all queued requests are completed, the *keepalive* event transitions the `Client` back to the…
19 …* If the *close* event is fired while the `Client` still has queued requests, the `Client` transit…
21 … `Client` from the **processing** state to the **destroyed** state, destroying any queued requests.
32 … underlying socket connection will not be established until a request is queued using [`Client.dis…
34 …*destroyed**](#destroyed) state since the `Client` instance will have no queued requests in this s…
40 …clientclosecallback) with queued requests, transitions the `Client` to the [**processing**](#proce…
50 …queued requests are being processed in a FIFO order. If a request body requires draining, the *nee…
58 …queued requests and the [`Client.close()`](Client.md#clientclosecallback) method is called. In thi…
DPoolStats.md25 ### `PoolStats.queued`
27 Number of queued requests across all clients in this pool.
35 Number of active, pending, or queued requests across all clients in this pool.
/third_party/skia/third_party/externals/abseil-cpp/absl/strings/internal/
Dcharconv_bigint.cc233 uint32_t queued = 0; in ReadDigits() local
258 queued = 10 * queued + digit; in ReadDigits()
262 AddWithCarry(0, queued); in ReadDigits()
263 queued = digits_queued = 0; in ReadDigits()
269 AddWithCarry(0, queued); in ReadDigits()
/third_party/gstreamer/gstplugins_good/gst/rtpmanager/
Drtptimerqueue.c326 g_return_if_fail (timer->queued == FALSE); in rtp_timer_free()
347 copy->queued = FALSE; in rtp_timer_dup()
406 g_return_val_if_fail (timer->queued == FALSE, FALSE); in rtp_timer_queue_insert()
421 timer->queued = TRUE; in rtp_timer_queue_insert()
442 g_return_val_if_fail (timer->queued == TRUE, FALSE); in rtp_timer_queue_reschedule()
488 g_return_if_fail (timer->queued == TRUE); in rtp_timer_queue_unschedule()
492 timer->queued = FALSE; in rtp_timer_queue_unschedule()
582 if (!timer->queued || timer->seqnum != seqnum) { in rtp_timer_queue_set_timer()
603 if (timer->queued) in rtp_timer_queue_set_timer()
712 if (timer->queued) { in rtp_timer_queue_update_timer()
[all …]
/third_party/mesa3d/src/gallium/drivers/radeonsi/
Dsi_pm4.c128 if (sctx->queued.array[idx] == state) { in si_pm4_free_state()
129 sctx->queued.array[idx] = NULL; in si_pm4_free_state()
161 struct si_pm4_state *state = sctx->queued.array[i]; in si_pm4_reset_emitted()
174 if (sctx->queued.array[i]) in si_pm4_reset_emitted()
Dsi_state_draw.cpp67 struct si_state_rasterizer *rs = sctx->queued.named.rasterizer; in si_emit_spi_map()
220 sctx->vs_uses_base_instance = sctx->queued.named.hs->uses_base_instance; in si_update_shaders()
233 key.u.hs_wave32 = sctx->queued.named.hs->wave_size == 32; in si_update_shaders()
335 scratch_size = MAX2(scratch_size, sctx->queued.named.hs->config.scratch_bytes_per_wave); in si_update_shaders()
515 si_prefetch_shader_async<GFX_VERSION>(sctx, sctx->queued.named.hs); in si_prefetch_shaders()
522 si_prefetch_shader_async<GFX_VERSION>(sctx, sctx->queued.named.gs); in si_prefetch_shaders()
525 si_prefetch_shader_async<GFX_VERSION>(sctx, sctx->queued.named.gs); in si_prefetch_shaders()
534 si_prefetch_shader_async<GFX_VERSION>(sctx, sctx->queued.named.hs); in si_prefetch_shaders()
541 si_prefetch_shader_async<GFX_VERSION>(sctx, sctx->queued.named.gs); in si_prefetch_shaders()
543 si_prefetch_shader_async<GFX_VERSION>(sctx, sctx->queued.named.vs); in si_prefetch_shaders()
[all …]
Dsi_state_binning.c179 struct si_state_dsa *dsa = sctx->queued.named.dsa; in si_get_depth_bin_size()
389 struct si_state_dsa *dsa = sctx->queued.named.dsa; in gfx10_get_bin_sizes()
445 struct si_state_blend *blend = sctx->queued.named.blend; in si_emit_dpbb_state()
446 struct si_state_dsa *dsa = sctx->queued.named.dsa; in si_emit_dpbb_state()
Dsi_state_viewport.c49 float line_width = sctx->queued.named.rasterizer->line_width; in si_get_small_prim_cull_info()
68 if (!sctx->queued.named.rasterizer->half_pixel_center) { in si_get_small_prim_cull_info()
160 if (!ctx->queued.named.rasterizer->scissor_enable) in si_set_scissor_states()
264 const struct si_state_rasterizer *rs = ctx->queued.named.rasterizer; in si_emit_guardband()
403 bool scissor_enabled = ctx->queued.named.rasterizer->scissor_enable; in si_emit_scissors()
550 bool clip_halfz = ctx->queued.named.rasterizer->clip_halfz; in si_emit_depth_ranges()
/third_party/libwebsockets/lib/core-net/
DREADME.md31 The user code does not know which wsi was first or is queued, it just waits for
37 helper. This helper sees if anything else is queued, and if so, migrates assets
47 does not attempt to send the headers for the next queued child before the
50 The process of moving the SSL context and fd etc between the queued wsi continues
56 but once it is made all the queued connections join the network connection as
/third_party/curl/docs/examples/
Dmulti-double.c67 int queued; in main() local
78 msg = curl_multi_info_read(multi_handle, &queued); in main()
/third_party/node/test/parallel/
Dtest-stream-pipe-await-drain-manual-resume.js56 for (const queued of queue)
57 queued.cb();
/third_party/python/Doc/library/
Dtermios.rst47 immediately, :const:`TCSADRAIN` to change after transmitting all queued output,
48 or :const:`TCSAFLUSH` to change after transmitting all queued output and
49 discarding all queued input.
65 Discard queued data on file descriptor *fd*. The *queue* selector specifies
/third_party/gstreamer/gstplugins_bad/ext/openal/
Dgstopenalsink.c970 ALint processed, queued, state; in gst_openal_sink_write() local
983 alGetSourcei (sink->default_source, AL_BUFFERS_QUEUED, &queued); in gst_openal_sink_write()
992 if (processed > 0 || queued < sink->buffer_count) in gst_openal_sink_write()
1007 queued -= processed; in gst_openal_sink_write()
1023 queued++; in gst_openal_sink_write()
1025 if (state != AL_PLAYING && queued == sink->buffer_count) in gst_openal_sink_write()
1045 ALint queued, state, offset, delay; in gst_openal_sink_delay() local
1055 alGetSourcei (sink->default_source, AL_BUFFERS_QUEUED, &queued); in gst_openal_sink_delay()
1067 ((queued * sink->buffer_length) - in gst_openal_sink_delay()
/third_party/nghttp2/tests/
Dnghttp2_session_test.c8871 CU_ASSERT(c->queued); in test_nghttp2_session_stream_dep_all_your_stream_are_belong_to_us()
8872 CU_ASSERT(a->queued); in test_nghttp2_session_stream_dep_all_your_stream_are_belong_to_us()
8873 CU_ASSERT(b->queued); in test_nghttp2_session_stream_dep_all_your_stream_are_belong_to_us()
8874 CU_ASSERT(!d->queued); in test_nghttp2_session_stream_dep_all_your_stream_are_belong_to_us()
8919 CU_ASSERT(c->queued); in test_nghttp2_session_stream_dep_all_your_stream_are_belong_to_us()
8920 CU_ASSERT(a->queued); in test_nghttp2_session_stream_dep_all_your_stream_are_belong_to_us()
8921 CU_ASSERT(b->queued); in test_nghttp2_session_stream_dep_all_your_stream_are_belong_to_us()
8922 CU_ASSERT(!d->queued); in test_nghttp2_session_stream_dep_all_your_stream_are_belong_to_us()
8961 CU_ASSERT(a->queued); in test_nghttp2_session_stream_attach_item()
8962 CU_ASSERT(b->queued); in test_nghttp2_session_stream_attach_item()
[all …]
/third_party/node/deps/v8/src/compiler/
Dloop-variable-optimizer.cc38 NodeMarker<bool> queued(graph(), 2); in Run() local
42 queued.Set(node, false); in Run()
68 } else if (!queued.Get(use)) { in Run()
70 queued.Set(use, true); in Run()
/third_party/libwebsockets/READMEs/
DREADME.lws_sequencer.md41 If the sequencer timeout expires, then the sequencer receives a queued
43 or schedule a retry of the step. This message is queued and sent normally
90 meaning and are queued on the sequencer by user code for eventual consumption
101 Normally the sequencer callback receives a queued message that
142 `LWSSEQ_WSI_CONN_CLOSE` message may have been queued but since they are
/third_party/jsframework/runtime/main/reactivity/
Dwatcher.js56 this.queued = this.shallow = false;
138 this.queued = this.shallow = false;
/third_party/gstreamer/gstplugins_good/gst/videomixer/
Dvideomixer2.c142 GstBuffer *queued; /* buffer for which we don't know the end time yet */ member
910 || (mixcol->queued in gst_videomixer2_fill_queues()
911 && start_time < GST_BUFFER_TIMESTAMP (mixcol->queued))) { in gst_videomixer2_fill_queues()
920 if (mixcol->queued) { in gst_videomixer2_fill_queues()
921 end_time = start_time - GST_BUFFER_TIMESTAMP (mixcol->queued); in gst_videomixer2_fill_queues()
922 start_time = GST_BUFFER_TIMESTAMP (mixcol->queued); in gst_videomixer2_fill_queues()
924 buf = gst_buffer_ref (mixcol->queued); in gst_videomixer2_fill_queues()
930 mixcol->queued = buf; in gst_videomixer2_fill_queues()
946 if (buf == mixcol->queued) { in gst_videomixer2_fill_queues()
948 gst_buffer_replace (&mixcol->queued, NULL); in gst_videomixer2_fill_queues()
[all …]

12345678