| /third_party/gstreamer/gstreamer/plugins/elements/ |
| D | gstcapsfilter.c | 270 g_list_free_full (filter->pending_events, (GDestroyNotify) gst_event_unref); in gst_capsfilter_dispose()
271 filter->pending_events = NULL; in gst_capsfilter_dispose()
417 GList *pending_events = filter->pending_events; in gst_capsfilter_prepare_buf() local
421 filter->pending_events = NULL; in gst_capsfilter_prepare_buf()
437 if (pending_events) { in gst_capsfilter_prepare_buf()
438 gst_capsfilter_push_pending_events (filter, pending_events); in gst_capsfilter_prepare_buf()
439 pending_events = NULL; in gst_capsfilter_prepare_buf()
445 gst_capsfilter_push_pending_events (filter, pending_events); in gst_capsfilter_prepare_buf()
446 pending_events = NULL; in gst_capsfilter_prepare_buf()
449 g_list_free_full (pending_events, (GDestroyNotify) gst_event_unref); in gst_capsfilter_prepare_buf()
[all …]
|
| D | gstcapsfilter.h | 72 GList *pending_events; member
|
| /third_party/gstreamer/gstplugins_good/gst/interleave/ |
| D | deinterleave.c | 157 if (self->pending_events) { in gst_deinterleave_finalize()
158 g_list_foreach (self->pending_events, (GFunc) gst_mini_object_unref, NULL); in gst_deinterleave_finalize()
159 g_list_free (self->pending_events); in gst_deinterleave_finalize()
160 self->pending_events = NULL; in gst_deinterleave_finalize()
708 self->pending_events = g_list_append (self->pending_events, event); in gst_deinterleave_sink_event()
846 GList *pending_events, *l; in gst_deinterleave_process() local
850 pending_events = self->pending_events; in gst_deinterleave_process()
851 self->pending_events = NULL; in gst_deinterleave_process()
854 if (pending_events) { in gst_deinterleave_process()
858 for (l = pending_events; l; l = l->next) { in gst_deinterleave_process()
[all …]
|
| D | deinterleave.h | 61 GList *pending_events; member
|
| /third_party/gstreamer/gstplugins_base/gst/encoding/ |
| D | gststreamsplitter.c | 89 g_list_foreach (stream_splitter->pending_events, (GFunc) gst_event_unref, in gst_stream_splitter_dispose()
91 g_list_free (stream_splitter->pending_events); in gst_stream_splitter_dispose()
92 stream_splitter->pending_events = NULL; in gst_stream_splitter_dispose()
114 for (tmp = splitter->pending_events; tmp; tmp = tmp->next) { in gst_stream_splitter_push_pending_events()
118 g_list_free (splitter->pending_events); in gst_stream_splitter_push_pending_events()
119 splitter->pending_events = NULL; in gst_stream_splitter_push_pending_events()
137 if (G_UNLIKELY (stream_splitter->pending_events)) in gst_stream_splitter_chain()
202 stream_splitter->pending_events = _flush_events (stream_splitter->current, in gst_stream_splitter_sink_event()
203 stream_splitter->pending_events); in gst_stream_splitter_sink_event()
211 if (G_UNLIKELY (stream_splitter->pending_events)) { in gst_stream_splitter_sink_event()
[all …]
|
| D | gststreamsplitter.h | 46 GList *pending_events; member
|
| /third_party/gstreamer/gstplugins_good/ext/gdk_pixbuf/ |
| D | gstgdkpixbufdec.c | 337 for (l = filter->pending_events; l; l = l->next) in gst_gdk_pixbuf_dec_flush()
339 g_list_free (filter->pending_events); in gst_gdk_pixbuf_dec_flush()
340 filter->pending_events = NULL; in gst_gdk_pixbuf_dec_flush()
432 g_list_free_full (pixbuf->pending_events, in gst_gdk_pixbuf_dec_sink_event()
434 pixbuf->pending_events = NULL; in gst_gdk_pixbuf_dec_sink_event()
473 pixbuf->pending_events = g_list_prepend (pixbuf->pending_events, event); in gst_gdk_pixbuf_dec_sink_event()
566 g_list_free_full (dec->pending_events, (GDestroyNotify) gst_event_unref); in gst_gdk_pixbuf_dec_change_state()
567 dec->pending_events = NULL; in gst_gdk_pixbuf_dec_change_state()
|
| D | gstgdkpixbufdec.h | 47 GList *pending_events; member
|
| /third_party/grpc/src/core/lib/surface/ |
| D | completion_queue.cc | 250 if (pending_events.Load(grpc_core::MemoryOrder::ACQUIRE) != 0) { in ~cq_next_data()
265 grpc_core::Atomic<intptr_t> pending_events{1}; member
281 if (pending_events.Load(grpc_core::MemoryOrder::ACQUIRE) != 0) { in ~cq_pluck_data()
293 grpc_core::Atomic<intptr_t> pending_events{1}; member
319 if (pending_events.Load(grpc_core::MemoryOrder::ACQUIRE) != 0) { in ~cq_callback_data()
329 grpc_core::Atomic<intptr_t> pending_events{1}; member
470 if (cqd->pending_events.FetchSub(1, grpc_core::MemoryOrder::ACQ_REL) == 1) { in grpc_completion_queue_thread_local_cache_flush()
661 return cqd->pending_events.IncrementIfNonzero();
666 return cqd->pending_events.IncrementIfNonzero();
671 return cqd->pending_events.IncrementIfNonzero();
[all …]
|
| /third_party/gstreamer/gstplugins_base/gst-libs/gst/audio/ |
| D | gstaudioencoder.c | 241 GList *pending_events; member
502 g_list_foreach (enc->priv->pending_events, (GFunc) gst_event_unref, NULL); in gst_audio_encoder_reset()
503 g_list_free (enc->priv->pending_events); in gst_audio_encoder_reset()
504 enc->priv->pending_events = NULL; in gst_audio_encoder_reset()
605 if (priv->pending_events) { in gst_audio_encoder_push_pending_events()
606 GList *pending_events, *l; in gst_audio_encoder_push_pending_events() local
608 pending_events = priv->pending_events; in gst_audio_encoder_push_pending_events()
609 priv->pending_events = NULL; in gst_audio_encoder_push_pending_events()
612 for (l = pending_events; l; l = l->next) in gst_audio_encoder_push_pending_events()
614 g_list_free (pending_events); in gst_audio_encoder_push_pending_events()
[all …]
|
| D | gstaudiodecoder.c | 271 GList *pending_events; member
546 g_list_foreach (dec->priv->pending_events, (GFunc) gst_event_unref, NULL); in gst_audio_decoder_reset()
547 g_list_free (dec->priv->pending_events); in gst_audio_decoder_reset()
548 dec->priv->pending_events = NULL; in gst_audio_decoder_reset()
678 if (dec->priv->pending_events) { in gst_audio_decoder_negotiate_default()
679 GList **pending_events, *l; in gst_audio_decoder_negotiate_default() local
681 pending_events = &dec->priv->pending_events; in gst_audio_decoder_negotiate_default()
684 for (l = *pending_events; l;) { in gst_audio_decoder_negotiate_default()
692 *pending_events = g_list_delete_link (*pending_events, tmp); in gst_audio_decoder_negotiate_default()
1148 GList *pending_events, *l; in send_pending_events() local
[all …]
|
| /third_party/gstreamer/gstplugins_base/gst/adder/ |
| D | gstadder.c | 816 if (adder->pending_events) { in gst_adder_sink_event()
817 g_list_foreach (adder->pending_events, (GFunc) gst_event_unref, NULL); in gst_adder_sink_event()
818 g_list_free (adder->pending_events); in gst_adder_sink_event()
819 adder->pending_events = NULL; in gst_adder_sink_event()
824 adder->pending_events = g_list_append (adder->pending_events, event); in gst_adder_sink_event()
928 if (adder->pending_events) { in gst_adder_dispose()
929 g_list_foreach (adder->pending_events, (GFunc) gst_event_unref, NULL); in gst_adder_dispose()
930 g_list_free (adder->pending_events); in gst_adder_dispose()
931 adder->pending_events = NULL; in gst_adder_dispose()
1440 if (G_UNLIKELY (adder->pending_events)) { in gst_adder_collected()
[all …]
|
| D | gstadder.h | 66 GList *pending_events; member
|
| /third_party/python/Lib/xml/dom/ |
| D | pulldom.py | 31 self.pending_events = []
138 self.pending_events.append(event)
147 self.pending_events.append(event)
173 for e in self.pending_events:
185 self.pending_events = None
|
| /third_party/gstreamer/gstplugins_bad/ext/rsvg/ |
| D | gstrsvgdec.h | 54 GList *pending_events; member
|
| /third_party/gstreamer/gstreamer/libs/gst/base/ |
| D | gstbasesrc.c | 249 GList *pending_events; /* OBJECT_LOCK */ member
498 if (basesrc->priv->pending_events) { in gst_base_src_finalize()
499 g_list_foreach (basesrc->priv->pending_events, (GFunc) gst_event_unref, in gst_base_src_finalize()
501 g_list_free (basesrc->priv->pending_events); in gst_base_src_finalize()
1986 src->priv->pending_events = in gst_base_src_send_event()
1987 g_list_append (src->priv->pending_events, event); in gst_base_src_send_event()
2837 GList *pending_events = NULL, *tmp; in gst_base_src_loop() local
2937 pending_events = src->priv->pending_events; in gst_base_src_loop()
2938 src->priv->pending_events = NULL; in gst_base_src_loop()
2944 if (G_UNLIKELY (pending_events != NULL)) { in gst_base_src_loop()
[all …]
|
| D | gstbaseparse.c | 308 GList *pending_events; member
510 g_list_foreach (parse->priv->pending_events, (GFunc) gst_event_unref, NULL); in gst_base_parse_clear_queues()
511 g_list_free (parse->priv->pending_events); in gst_base_parse_clear_queues()
512 parse->priv->pending_events = NULL; in gst_base_parse_clear_queues()
867 g_list_foreach (parse->priv->pending_events, (GFunc) gst_mini_object_unref, in gst_base_parse_reset()
869 g_list_free (parse->priv->pending_events); in gst_base_parse_reset()
870 parse->priv->pending_events = NULL; in gst_base_parse_reset()
980 parse->priv->pending_events = in gst_base_parse_queue_tag_event_update()
981 g_list_prepend (parse->priv->pending_events, in gst_base_parse_queue_tag_event_update()
1477 for (l = parse->priv->pending_events; l; l = l->next) { in gst_base_parse_sink_event_default()
[all …]
|
| /third_party/gstreamer/gstplugins_base/gst-libs/gst/tag/ |
| D | gsttagdemux.c | 108 GList *pending_events; member
269 g_list_foreach (tagdemux->priv->pending_events, in gst_tag_demux_reset()
271 g_list_free (tagdemux->priv->pending_events); in gst_tag_demux_reset()
272 tagdemux->priv->pending_events = NULL; in gst_tag_demux_reset()
792 demux->priv->pending_events = in gst_tag_demux_sink_event()
793 g_list_append (demux->priv->pending_events, event); in gst_tag_demux_sink_event()
1811 events = demux->priv->pending_events; in gst_tag_demux_send_pending_events()
1812 demux->priv->pending_events = NULL; in gst_tag_demux_send_pending_events()
|
| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/adaptivedemux/ |
| D | gstadaptivedemux.c | 1671 if (stream->pending_events) { in gst_adaptive_demux_stream_free()
1672 g_list_free_full (stream->pending_events, (GDestroyNotify) gst_event_unref); in gst_adaptive_demux_stream_free()
1673 stream->pending_events = NULL; in gst_adaptive_demux_stream_free()
2563 stream->pending_events = g_list_append (stream->pending_events, event); in gst_adaptive_demux_stream_queue_event()
2689 GList *pending_events = NULL; in gst_adaptive_demux_stream_push_buffer() local
2803 if (G_UNLIKELY (stream->pending_events)) { in gst_adaptive_demux_stream_push_buffer()
2804 pending_events = stream->pending_events; in gst_adaptive_demux_stream_push_buffer()
2805 stream->pending_events = NULL; in gst_adaptive_demux_stream_push_buffer()
2826 while (pending_events != NULL) { in gst_adaptive_demux_stream_push_buffer()
2827 GstEvent *event = pending_events->data; in gst_adaptive_demux_stream_push_buffer()
[all …]
|
| D | gstadaptivedemux.h | 147 GList *pending_events; member
|
| /third_party/gstreamer/gstplugins_base/gst-libs/gst/video/ |
| D | gstvideodecoder.c | 382 GList *pending_events; member
1534 events = decoder->priv->pending_events; in gst_video_decoder_sink_event_default()
1536 decoder->priv->pending_events = NULL; in gst_video_decoder_sink_event_default()
2397 g_list_free_full (priv->pending_events, (GDestroyNotify) gst_event_unref); in gst_video_decoder_reset()
2398 priv->pending_events = NULL; in gst_video_decoder_reset()
2723 dec->priv->pending_events = in gst_video_decoder_flush_parse()
2724 g_list_append (dec->priv->pending_events, event); in gst_video_decoder_flush_parse()
3077 decoder->priv->pending_events = in gst_video_decoder_prepare_finish_frame()
3078 g_list_concat (events, decoder->priv->pending_events); in gst_video_decoder_prepare_finish_frame()
3080 gst_video_decoder_push_event_list (decoder, decoder->priv->pending_events); in gst_video_decoder_prepare_finish_frame()
[all …]
|
| /third_party/gstreamer/gstplugins_base/ |
| D | ChangeLog | 70321 They end up stored in the 'pending_events' list and should be
96973 audioencoder: protect pending_events with proper lock
123975 tag events received from upstream into the pending_events list
|
| /third_party/gstreamer/gstreamer/ |
| D | ChangeLog | 37766 tests: capsfilter: add test for pending_events pushing
39869 capsfilter: Delete link directly in pending_events.
|