Lines Matching refs:ringbuffer
254 if (src->ringbuffer) { in gst_audio_base_src_dispose()
255 gst_object_unparent (GST_OBJECT_CAST (src->ringbuffer)); in gst_audio_base_src_dispose()
256 src->ringbuffer = NULL; in gst_audio_base_src_dispose()
272 if (src->ringbuffer == NULL) in gst_audio_base_src_provide_clock()
275 if (gst_audio_ring_buffer_is_flushing (src->ringbuffer)) in gst_audio_base_src_provide_clock()
308 GstAudioRingBuffer *ringbuffer; in gst_audio_base_src_get_time() local
311 ringbuffer = src->ringbuffer; in gst_audio_base_src_get_time()
312 if (!ringbuffer) in gst_audio_base_src_get_time()
315 rate = ringbuffer->spec.info.rate; in gst_audio_base_src_get_time()
319 raw = samples = gst_audio_ring_buffer_samples_done (ringbuffer); in gst_audio_base_src_get_time()
323 delay = gst_audio_ring_buffer_delay (ringbuffer); in gst_audio_base_src_get_time()
466 if (src->ringbuffer && src->ringbuffer->acquired) in gst_audio_base_src_get_property()
467 g_value_set_int64 (value, src->ringbuffer->spec.buffer_time); in gst_audio_base_src_get_property()
474 if (src->ringbuffer && src->ringbuffer->acquired) in gst_audio_base_src_get_property()
475 g_value_set_int64 (value, src->ringbuffer->spec.latency_time); in gst_audio_base_src_get_property()
519 spec = &src->ringbuffer->spec; in gst_audio_base_src_setcaps()
521 if (G_UNLIKELY (gst_audio_ring_buffer_is_acquired (src->ringbuffer) in gst_audio_base_src_setcaps()
529 gst_audio_ring_buffer_release (src->ringbuffer); in gst_audio_base_src_setcaps()
555 if (!gst_audio_ring_buffer_acquire (src->ringbuffer, spec)) in gst_audio_base_src_setcaps()
610 if (G_UNLIKELY (src->ringbuffer == NULL in gst_audio_base_src_query()
611 || src->ringbuffer->spec.info.rate == 0)) { in gst_audio_base_src_query()
616 spec = &src->ringbuffer->spec; in gst_audio_base_src_query()
673 gst_audio_ring_buffer_pause (src->ringbuffer); in gst_audio_base_src_event()
674 gst_audio_ring_buffer_clear_all (src->ringbuffer); in gst_audio_base_src_event()
680 gst_audio_ring_buffer_clear_all (src->ringbuffer); in gst_audio_base_src_event()
709 sps = src->ringbuffer->samples_per_seg; in gst_audio_base_src_get_offset()
710 segtotal = src->ringbuffer->spec.segtotal; in gst_audio_base_src_get_offset()
713 segdone = g_atomic_int_get (&src->ringbuffer->segdone) in gst_audio_base_src_get_offset()
714 - src->ringbuffer->segbase; in gst_audio_base_src_get_offset()
758 GstAudioRingBuffer *ringbuffer; in gst_audio_base_src_create() local
767 ringbuffer = src->ringbuffer; in gst_audio_base_src_create()
768 spec = &ringbuffer->spec; in gst_audio_base_src_create()
770 if (G_UNLIKELY (!gst_audio_ring_buffer_is_acquired (ringbuffer))) in gst_audio_base_src_create()
814 gst_audio_ring_buffer_read (ringbuffer, sample, ptr, samples, &tmp_ts); in gst_audio_base_src_create()
824 if (g_atomic_int_get (&ringbuffer->state) == in gst_audio_base_src_create()
887 segments_written = g_atomic_int_get (&ringbuffer->segdone); in gst_audio_base_src_create()
892 last_written_segment = segments_written - ringbuffer->segbase - 1; in gst_audio_base_src_create()
895 sps = ringbuffer->samples_per_seg; in gst_audio_base_src_create()
944 if ((segment_skew >= ringbuffer->spec.segtotal) || in gst_audio_base_src_create()
954 gst_audio_ring_buffer_advance (ringbuffer, segment_diff); in gst_audio_base_src_create()
958 g_atomic_int_get (&ringbuffer->segdone) - ringbuffer->segbase; in gst_audio_base_src_create()
1125 src->ringbuffer = rb; in gst_audio_base_src_change_state()
1128 if (!gst_audio_ring_buffer_open_device (src->ringbuffer)) { in gst_audio_base_src_change_state()
1130 gst_object_unparent (GST_OBJECT_CAST (src->ringbuffer)); in gst_audio_base_src_change_state()
1131 src->ringbuffer = NULL; in gst_audio_base_src_change_state()
1140 gst_audio_ring_buffer_set_flushing (src->ringbuffer, FALSE); in gst_audio_base_src_change_state()
1141 gst_audio_ring_buffer_may_start (src->ringbuffer, FALSE); in gst_audio_base_src_change_state()
1154 gst_audio_ring_buffer_may_start (src->ringbuffer, TRUE); in gst_audio_base_src_change_state()
1158 gst_audio_ring_buffer_may_start (src->ringbuffer, FALSE); in gst_audio_base_src_change_state()
1159 gst_audio_ring_buffer_pause (src->ringbuffer); in gst_audio_base_src_change_state()
1171 gst_audio_ring_buffer_set_flushing (src->ringbuffer, TRUE); in gst_audio_base_src_change_state()
1182 gst_audio_ring_buffer_release (src->ringbuffer); in gst_audio_base_src_change_state()
1186 gst_audio_ring_buffer_close_device (src->ringbuffer); in gst_audio_base_src_change_state()
1188 gst_object_unparent (GST_OBJECT_CAST (src->ringbuffer)); in gst_audio_base_src_change_state()
1189 src->ringbuffer = NULL; in gst_audio_base_src_change_state()
1220 if (GST_MESSAGE_TYPE (message) == GST_MESSAGE_ERROR && src->ringbuffer) { in gst_audio_base_src_post_message()
1221 GstAudioRingBuffer *ringbuffer; in gst_audio_base_src_post_message() local
1225 ringbuffer = gst_object_ref (src->ringbuffer); in gst_audio_base_src_post_message()
1232 g_atomic_int_set (&ringbuffer->state, GST_AUDIO_RING_BUFFER_STATE_ERROR); in gst_audio_base_src_post_message()
1233 GST_AUDIO_RING_BUFFER_SIGNAL (ringbuffer); in gst_audio_base_src_post_message()
1234 gst_object_unref (ringbuffer); in gst_audio_base_src_post_message()