Lines Matching refs:ostream
378 GstSyncStream *stream, *ostream; in gst_stream_synchronizer_sink_event() local
408 ostream = l->data; in gst_stream_synchronizer_sink_event()
410 if (ostream != stream && ostream->stream_start_seqnum == seqnum in gst_stream_synchronizer_sink_event()
411 && !ostream->wait) { in gst_stream_synchronizer_sink_event()
420 stream->stream_number, ostream->stream_number); in gst_stream_synchronizer_sink_event()
438 GstSyncStream *ostream = l->data; in gst_stream_synchronizer_sink_event() local
440 all_wait = all_wait && ((ostream->flags & GST_STREAM_FLAG_SPARSE) in gst_stream_synchronizer_sink_event()
441 || (ostream->wait && (!have_group_id in gst_stream_synchronizer_sink_event()
442 || ostream->group_id == group_id))); in gst_stream_synchronizer_sink_event()
460 GstSyncStream *ostream = l->data; in gst_stream_synchronizer_sink_event() local
464 ostream->wait = FALSE; in gst_stream_synchronizer_sink_event()
466 if (ostream->segment.format == GST_FORMAT_TIME) { in gst_stream_synchronizer_sink_event()
467 if (ostream->segment.rate > 0) in gst_stream_synchronizer_sink_event()
469 gst_segment_to_running_time (&ostream->segment, in gst_stream_synchronizer_sink_event()
470 GST_FORMAT_TIME, ostream->segment.stop); in gst_stream_synchronizer_sink_event()
473 gst_segment_to_running_time (&ostream->segment, in gst_stream_synchronizer_sink_event()
474 GST_FORMAT_TIME, ostream->segment.start); in gst_stream_synchronizer_sink_event()
477 gst_segment_to_running_time (&ostream->segment, in gst_stream_synchronizer_sink_event()
478 GST_FORMAT_TIME, ostream->segment.position); in gst_stream_synchronizer_sink_event()
483 if (ostream->segment.rate > 0) in gst_stream_synchronizer_sink_event()
485 gst_segment_to_running_time (&ostream->segment, in gst_stream_synchronizer_sink_event()
486 GST_FORMAT_TIME, ostream->segment.start); in gst_stream_synchronizer_sink_event()
489 gst_segment_to_running_time (&ostream->segment, in gst_stream_synchronizer_sink_event()
490 GST_FORMAT_TIME, ostream->segment.stop); in gst_stream_synchronizer_sink_event()
504 GstSyncStream *ostream = l->data; in gst_stream_synchronizer_sink_event() local
505 ostream->wait = FALSE; in gst_stream_synchronizer_sink_event()
506 g_cond_broadcast (&ostream->stream_finish_cond); in gst_stream_synchronizer_sink_event()
596 GstSyncStream *ostream = l->data; in gst_stream_synchronizer_sink_event() local
599 if (ostream == stream || ostream->flushing) in gst_stream_synchronizer_sink_event()
602 if (ostream->segment.format == GST_FORMAT_TIME) { in gst_stream_synchronizer_sink_event()
603 if (ostream->segment.rate > 0) in gst_stream_synchronizer_sink_event()
605 gst_segment_to_running_time (&ostream->segment, in gst_stream_synchronizer_sink_event()
606 GST_FORMAT_TIME, ostream->segment.start); in gst_stream_synchronizer_sink_event()
609 gst_segment_to_running_time (&ostream->segment, in gst_stream_synchronizer_sink_event()
610 GST_FORMAT_TIME, ostream->segment.stop); in gst_stream_synchronizer_sink_event()
674 GstSyncStream *ostream = l->data; in gst_stream_synchronizer_sink_event() local
676 all_eos = all_eos && ostream->is_eos; in gst_stream_synchronizer_sink_event()
685 GstSyncStream *ostream = l->data; in gst_stream_synchronizer_sink_event() local
687 gst_object_ref (ostream->srcpad); in gst_stream_synchronizer_sink_event()
688 pads = g_slist_prepend (pads, ostream->srcpad); in gst_stream_synchronizer_sink_event()
694 GstSyncStream *ostream; in gst_stream_synchronizer_sink_event() local
700 ostream = gst_streamsync_pad_get_stream (pad); in gst_stream_synchronizer_sink_event()
701 g_cond_broadcast (&ostream->stream_finish_cond); in gst_stream_synchronizer_sink_event()
702 gst_syncstream_unref (ostream); in gst_stream_synchronizer_sink_event()
849 GstSyncStream *ostream = l->data; in gst_stream_synchronizer_sink_chain() local
852 if (!ostream->is_eos || ostream->eos_sent || in gst_stream_synchronizer_sink_chain()
853 ostream->segment.format != GST_FORMAT_TIME) in gst_stream_synchronizer_sink_chain()
856 if (ostream->segment.position != -1) in gst_stream_synchronizer_sink_chain()
857 position = ostream->segment.position; in gst_stream_synchronizer_sink_chain()
859 position = ostream->segment.start; in gst_stream_synchronizer_sink_chain()
868 GST_DEBUG_OBJECT (ostream->sinkpad, in gst_stream_synchronizer_sink_chain()
870 GST_TIME_FORMAT, ostream->stream_number, GST_TIME_ARGS (position), in gst_stream_synchronizer_sink_chain()
873 ostream->segment.position = new_start; in gst_stream_synchronizer_sink_chain()
875 ostream->send_gap_event = TRUE; in gst_stream_synchronizer_sink_chain()
876 ostream->gap_duration = new_start - position; in gst_stream_synchronizer_sink_chain()
877 g_cond_broadcast (&ostream->stream_finish_cond); in gst_stream_synchronizer_sink_chain()
1086 GstSyncStream *ostream = l->data; in gst_stream_synchronizer_change_state() local
1087 g_cond_broadcast (&ostream->stream_finish_cond); in gst_stream_synchronizer_change_state()