| /third_party/gstreamer/gstplugins_bad/ext/mpeg2enc/ |
| D | gstmpeg2enc.cc | 206 enc->srcresult = GST_FLOW_FLUSHING; in gst_mpeg2enc_src_activate_mode()
218 enc->srcresult = GST_FLOW_OK; in gst_mpeg2enc_reset()
246 if (G_UNLIKELY (enc->srcresult != GST_FLOW_OK)) { in gst_mpeg2enc_start()
268 enc->srcresult = GST_FLOW_FLUSHING; in gst_mpeg2enc_stop()
513 enc->srcresult = GST_FLOW_OK; in gst_mpeg2enc_sink_event()
552 if (enc->srcresult != GST_FLOW_OK) { in gst_mpeg2enc_loop()
554 enc->srcresult = GST_FLOW_ERROR; in gst_mpeg2enc_loop()
600 enc->srcresult = GST_FLOW_NOT_NEGOTIATED; in gst_mpeg2enc_loop()
617 enc->srcresult = GST_FLOW_ERROR; in gst_mpeg2enc_loop()
623 if (enc->srcresult == GST_FLOW_OK) { in gst_mpeg2enc_loop()
[all …]
|
| D | gstmpeg2encstreamwriter.cc | 68 enc->srcresult = ret; in WriteOutBufferUpto()
|
| D | gstmpeg2enc.hh | 87 GstFlowReturn srcresult; member
|
| /third_party/gstreamer/gstreamer/plugins/elements/ |
| D | gstqueue.c | 139 if (q->srcresult != GST_FLOW_OK) \
152 if (q->srcresult != GST_FLOW_OK) { \
164 if (q->srcresult != GST_FLOW_OK) { \
462 queue->srcresult = GST_FLOW_FLUSHING; in gst_queue_init()
928 queue->srcresult = GST_FLOW_FLUSHING; in gst_queue_handle_sink_event()
953 queue->srcresult = GST_FLOW_OK; in gst_queue_handle_sink_event()
974 if (queue->srcresult == GST_FLOW_EOS in gst_queue_handle_sink_event()
977 queue->srcresult = GST_FLOW_OK; in gst_queue_handle_sink_event()
979 if (queue->srcresult != GST_FLOW_OK) { in gst_queue_handle_sink_event()
989 if (queue->srcresult == GST_FLOW_NOT_LINKED in gst_queue_handle_sink_event()
[all …]
|
| D | gstmultiqueue.c | 128 GstFlowReturn srcresult; member
1410 sq->srcresult = GST_FLOW_FLUSHING; in gst_single_queue_flush()
1430 sq->srcresult = GST_FLOW_OK; in gst_single_queue_flush()
1471 if (sq->is_eos || sq->is_segment_done || sq->srcresult == GST_FLOW_NOT_LINKED in get_buffering_level()
2003 GstFlowReturn result = sq->srcresult; in gst_single_queue_push_one()
2234 if (sq->srcresult == GST_FLOW_NOT_LINKED in gst_multi_queue_loop()
2238 gst_flow_get_name (sq->srcresult)); in gst_multi_queue_loop()
2258 if (sq->srcresult == GST_FLOW_NOT_LINKED) { in gst_multi_queue_loop()
2284 while (should_wait && sq->srcresult == GST_FLOW_NOT_LINKED) { in gst_multi_queue_loop()
2347 gst_flow_get_name (sq->srcresult)); in gst_multi_queue_loop()
[all …]
|
| D | gstdownloadbuffer.c | 323 dlbuf->srcresult = GST_FLOW_FLUSHING; in gst_download_buffer_init()
713 if (dlbuf->srcresult == GST_FLOW_FLUSHING) in gst_download_buffer_wait_for_data()
725 GST_DOWNLOAD_BUFFER_WAIT_ADD_CHECK (dlbuf, dlbuf->srcresult, wanted, in gst_download_buffer_wait_for_data()
1020 dlbuf->srcresult = GST_FLOW_FLUSHING; in gst_download_buffer_handle_sink_event()
1050 dlbuf->srcresult = GST_FLOW_OK; in gst_download_buffer_handle_sink_event()
1323 GST_DOWNLOAD_BUFFER_MUTEX_LOCK_CHECK (dlbuf, dlbuf->srcresult, out_flushing); in gst_download_buffer_loop()
1350 GST_DOWNLOAD_BUFFER_MUTEX_LOCK_CHECK (dlbuf, dlbuf->srcresult, out_flushing); in gst_download_buffer_loop()
1351 dlbuf->srcresult = ret; in gst_download_buffer_loop()
1362 GstFlowReturn ret = dlbuf->srcresult; in gst_download_buffer_loop()
1397 dlbuf->srcresult = GST_FLOW_FLUSHING; in gst_download_buffer_handle_src_event()
[all …]
|
| D | gstqueue2.c | 538 queue->srcresult = GST_FLOW_FLUSHING; in gst_queue2_init()
1027 if (queue->is_eos || queue->srcresult == GST_FLOW_NOT_LINKED) { in get_buffering_level()
1637 GST_QUEUE2_WAIT_ADD_CHECK (queue, queue->srcresult, out_flushing); in gst_queue2_create_read()
2608 queue->srcresult = GST_FLOW_FLUSHING; in gst_queue2_handle_sink_event()
2645 queue->srcresult = GST_FLOW_OK; in gst_queue2_handle_sink_event()
2701 if (queue->srcresult != GST_FLOW_OK) { in gst_queue2_handle_sink_event()
2710 if (queue->srcresult == GST_FLOW_NOT_LINKED in gst_queue2_handle_sink_event()
2711 || queue->srcresult < GST_FLOW_EOS) { in gst_queue2_handle_sink_event()
2712 GST_ELEMENT_FLOW_ERROR (queue, queue->srcresult); in gst_queue2_handle_sink_event()
2725 queue->srcresult = GST_FLOW_OK; in gst_queue2_handle_sink_event()
[all …]
|
| D | gstdownloadbuffer.h | 67 GstFlowReturn srcresult; member
|
| D | gstqueue.h | 106 GstFlowReturn srcresult; member
|
| D | gstqueue2.h | 96 GstFlowReturn srcresult; member
|
| /third_party/gstreamer/gstplugins_bad/ext/mplex/ |
| D | gstmplex.cc | 212 mplex->srcresult = GST_FLOW_CUSTOM_SUCCESS; in gst_mplex_reset()
281 if (mplex->srcresult != GST_FLOW_CUSTOM_SUCCESS) in gst_mplex_setcaps()
426 mplex->srcresult = GST_FLOW_ERROR; in gst_mplex_loop()
469 mplex->srcresult = GST_FLOW_FLUSHING; in gst_mplex_sink_event()
481 mplex->srcresult = GST_FLOW_OK; in gst_mplex_sink_event()
514 while (mplex->srcresult == GST_FLOW_OK && !mpad->needed) in gst_mplex_sink_event()
533 if (G_UNLIKELY (mplex->srcresult == GST_FLOW_CUSTOM_SUCCESS) in gst_mplex_start_task()
538 mplex->srcresult = GST_FLOW_OK; in gst_mplex_start_task()
566 if (G_UNLIKELY (mplex->srcresult != GST_FLOW_OK)) in gst_mplex_chain()
575 if (G_UNLIKELY (mplex->srcresult != GST_FLOW_OK)) in gst_mplex_chain()
[all …]
|
| D | gstmplexoutputstream.cc | 110 mplex->srcresult = gst_pad_push (pad, buf); in Write()
|
| D | gstmplex.hh | 111 GstFlowReturn srcresult; member
|
| /third_party/gstreamer/gst_libav/ext/libav/ |
| D | gstavprotocol.h | 63 GstFlowReturn srcresult; member
|
| D | gstavdemux.c | 1828 demux->ffpipe.srcresult = ret;
1934 ffpipe->srcresult = GST_FLOW_FLUSHING;
1954 ffpipe->srcresult = GST_FLOW_OK;
2028 if (G_UNLIKELY (ffpipe->srcresult != GST_FLOW_OK))
2041 if (G_UNLIKELY (ffpipe->srcresult != GST_FLOW_OK))
2061 gst_flow_get_name (ffpipe->srcresult));
2132 demux->ffpipe.srcresult = GST_FLOW_OK;
2141 demux->ffpipe.srcresult = GST_FLOW_FLUSHING;
|
| /third_party/gstreamer/gstplugins_good/gst/rtpmanager/ |
| D | gstrtpjitterbuffer.c | 200 if (G_UNLIKELY (priv->srcresult != GST_FLOW_OK)) \
237 if (G_UNLIKELY (priv->srcresult != GST_FLOW_OK)) \
244 if (G_UNLIKELY (priv->srcresult != GST_FLOW_OK)) \
255 if (G_UNLIKELY (priv->srcresult != GST_FLOW_OK)) \
262 if (G_UNLIKELY (priv->srcresult != GST_FLOW_OK)) \
382 GstFlowReturn srcresult; member
1563 priv->srcresult = GST_FLOW_FLUSHING; in gst_rtp_jitter_buffer_flush_start()
1582 priv->srcresult = GST_FLOW_OK; in gst_rtp_jitter_buffer_flush_stop()
1677 priv->srcresult = GST_FLOW_OK; in gst_rtp_jitter_buffer_change_state()
1716 priv->srcresult = GST_FLOW_FLUSHING; in gst_rtp_jitter_buffer_change_state()
[all …]
|
| /third_party/gstreamer/gstreamer/ |
| D | ChangeLog | 1109 The initial single queue srcresult is OK, it hasn't been
1118 After a flush for instance, sq->srcresult is reset to OK,
52362 Also improve locking a bit, srcresult must be protected by the
73634 srcresult was being rechecked in places it couldn't have changed.
|
| /third_party/gstreamer/gstplugins_good/ |
| D | ChangeLog | 3902 rtpjitterbuffer: Check srcresult before waiting on the condition variable too
|