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()
309 if (G_UNLIKELY (src->ringbuffer == NULL in gst_audio_base_src_get_time()
310 || src->ringbuffer->spec.info.rate == 0)) in gst_audio_base_src_get_time()
313 raw = samples = gst_audio_ring_buffer_samples_done (src->ringbuffer); in gst_audio_base_src_get_time()
317 delay = gst_audio_ring_buffer_delay (src->ringbuffer); in gst_audio_base_src_get_time()
322 src->ringbuffer->spec.info.rate); in gst_audio_base_src_get_time()
461 if (src->ringbuffer && src->ringbuffer->acquired) in gst_audio_base_src_get_property()
462 g_value_set_int64 (value, src->ringbuffer->spec.buffer_time); in gst_audio_base_src_get_property()
469 if (src->ringbuffer && src->ringbuffer->acquired) in gst_audio_base_src_get_property()
470 g_value_set_int64 (value, src->ringbuffer->spec.latency_time); in gst_audio_base_src_get_property()
514 spec = &src->ringbuffer->spec; in gst_audio_base_src_setcaps()
523 gst_audio_ring_buffer_release (src->ringbuffer); in gst_audio_base_src_setcaps()
549 if (!gst_audio_ring_buffer_acquire (src->ringbuffer, spec)) in gst_audio_base_src_setcaps()
604 if (G_UNLIKELY (src->ringbuffer == NULL in gst_audio_base_src_query()
605 || src->ringbuffer->spec.info.rate == 0)) { in gst_audio_base_src_query()
610 spec = &src->ringbuffer->spec; in gst_audio_base_src_query()
667 gst_audio_ring_buffer_pause (src->ringbuffer); in gst_audio_base_src_event()
668 gst_audio_ring_buffer_clear_all (src->ringbuffer); in gst_audio_base_src_event()
674 gst_audio_ring_buffer_clear_all (src->ringbuffer); in gst_audio_base_src_event()
703 sps = src->ringbuffer->samples_per_seg; in gst_audio_base_src_get_offset()
704 segtotal = src->ringbuffer->spec.segtotal; in gst_audio_base_src_get_offset()
707 segdone = g_atomic_int_get (&src->ringbuffer->segdone) in gst_audio_base_src_get_offset()
708 - src->ringbuffer->segbase; in gst_audio_base_src_get_offset()
752 GstAudioRingBuffer *ringbuffer; in gst_audio_base_src_create() local
761 ringbuffer = src->ringbuffer; in gst_audio_base_src_create()
762 spec = &ringbuffer->spec; in gst_audio_base_src_create()
764 if (G_UNLIKELY (!gst_audio_ring_buffer_is_acquired (ringbuffer))) in gst_audio_base_src_create()
808 gst_audio_ring_buffer_read (ringbuffer, sample, ptr, samples, &tmp_ts); in gst_audio_base_src_create()
818 if (g_atomic_int_get (&ringbuffer->state) == in gst_audio_base_src_create()
881 segments_written = g_atomic_int_get (&ringbuffer->segdone); in gst_audio_base_src_create()
886 last_written_segment = segments_written - ringbuffer->segbase - 1; in gst_audio_base_src_create()
889 sps = ringbuffer->samples_per_seg; in gst_audio_base_src_create()
938 if ((segment_skew >= ringbuffer->spec.segtotal) || in gst_audio_base_src_create()
948 gst_audio_ring_buffer_advance (ringbuffer, segment_diff); in gst_audio_base_src_create()
952 g_atomic_int_get (&ringbuffer->segdone) - ringbuffer->segbase; in gst_audio_base_src_create()
1119 src->ringbuffer = rb; in gst_audio_base_src_change_state()
1122 if (!gst_audio_ring_buffer_open_device (src->ringbuffer)) { in gst_audio_base_src_change_state()
1124 gst_object_unparent (GST_OBJECT_CAST (src->ringbuffer)); in gst_audio_base_src_change_state()
1125 src->ringbuffer = NULL; in gst_audio_base_src_change_state()
1134 gst_audio_ring_buffer_set_flushing (src->ringbuffer, FALSE); in gst_audio_base_src_change_state()
1135 gst_audio_ring_buffer_may_start (src->ringbuffer, FALSE); in gst_audio_base_src_change_state()
1148 gst_audio_ring_buffer_may_start (src->ringbuffer, TRUE); in gst_audio_base_src_change_state()
1152 gst_audio_ring_buffer_may_start (src->ringbuffer, FALSE); in gst_audio_base_src_change_state()
1153 gst_audio_ring_buffer_pause (src->ringbuffer); in gst_audio_base_src_change_state()
1165 gst_audio_ring_buffer_set_flushing (src->ringbuffer, TRUE); in gst_audio_base_src_change_state()
1176 gst_audio_ring_buffer_release (src->ringbuffer); in gst_audio_base_src_change_state()
1180 gst_audio_ring_buffer_close_device (src->ringbuffer); in gst_audio_base_src_change_state()
1182 gst_object_unparent (GST_OBJECT_CAST (src->ringbuffer)); in gst_audio_base_src_change_state()
1183 src->ringbuffer = NULL; in gst_audio_base_src_change_state()
1214 if (GST_MESSAGE_TYPE (message) == GST_MESSAGE_ERROR && src->ringbuffer) { in gst_audio_base_src_post_message()
1215 GstAudioRingBuffer *ringbuffer; in gst_audio_base_src_post_message() local
1219 ringbuffer = gst_object_ref (src->ringbuffer); in gst_audio_base_src_post_message()
1226 g_atomic_int_set (&ringbuffer->state, GST_AUDIO_RING_BUFFER_STATE_ERROR); in gst_audio_base_src_post_message()
1227 GST_AUDIO_RING_BUFFER_SIGNAL (ringbuffer); in gst_audio_base_src_post_message()
1228 gst_object_unref (ringbuffer); in gst_audio_base_src_post_message()