Home
last modified time | relevance | path

Searched refs:ringbuffer (Results 1 – 25 of 103) sorted by relevance

12345

/third_party/vk-gl-cts/framework/delibs/destream/
DdeRingbuffer.c54 deRingbuffer* ringbuffer = (deRingbuffer*)deCalloc(sizeof(deRingbuffer)); in deRingbuffer_create() local
56 DE_ASSERT(ringbuffer); in deRingbuffer_create()
60 ringbuffer->blockSize = blockSize; in deRingbuffer_create()
61 ringbuffer->blockCount = blockCount; in deRingbuffer_create()
62 ringbuffer->buffer = (deUint8*)deMalloc(sizeof(deUint8) * (size_t)blockSize * (size_t)blockCount); in deRingbuffer_create()
63 ringbuffer->blockUsage = (deInt32*)deMalloc(sizeof(deUint32) * (size_t)blockCount); in deRingbuffer_create()
64 ringbuffer->emptyCount = deSemaphore_create(ringbuffer->blockCount, DE_NULL); in deRingbuffer_create()
65 ringbuffer->fullCount = deSemaphore_create(0, DE_NULL); in deRingbuffer_create()
67 if (!ringbuffer->buffer || in deRingbuffer_create()
68 !ringbuffer->blockUsage || in deRingbuffer_create()
[all …]
DdeThreadStream.c31 deRingbuffer* ringbuffer; member
41 deRingbuffer* ringbuffer; member
78 deRingbuffer_stop(threadStream->ringbuffer); in inStreamCopy()
110 deRingbuffer_stop(threadStream->ringbuffer); in threadStream_deinit()
118 deRingbuffer_destroy(threadStream->ringbuffer); in threadStream_deinit()
139 threadStream->ringbuffer = deRingbuffer_create(ringbufferBlockSize, ringbufferBlockCount); in deThreadInStream_init()
140 DE_ASSERT(threadStream->ringbuffer); in deThreadInStream_init()
144 deProducerStream_init(&(threadStream->producerStream), threadStream->ringbuffer); in deThreadInStream_init()
145 deConsumerStream_init(&(threadStream->consumerStream), threadStream->ringbuffer); in deThreadInStream_init()
197 threadStream->ringbuffer = deRingbuffer_create(ringbufferBlockSize, ringbufferBlockCount); in deThreadOutStream_init()
[all …]
/third_party/gstreamer/gstplugins_bad/sys/wasapi2/
Dgstwasapi2src.c285 if (asrc->ringbuffer) { in gst_wasapi2_src_change_state()
286 GstWasapi2RingBuffer *ringbuffer = in gst_wasapi2_src_change_state() local
287 GST_WASAPI2_RING_BUFFER (asrc->ringbuffer); in gst_wasapi2_src_change_state()
290 gst_wasapi2_ring_buffer_set_volume (ringbuffer, self->volume); in gst_wasapi2_src_change_state()
295 gst_wasapi2_ring_buffer_set_mute (ringbuffer, self->mute); in gst_wasapi2_src_change_state()
315 if (asrc->ringbuffer) { in gst_wasapi2_src_get_caps()
316 GstWasapi2RingBuffer *ringbuffer = in gst_wasapi2_src_get_caps() local
317 GST_WASAPI2_RING_BUFFER (asrc->ringbuffer); in gst_wasapi2_src_get_caps()
319 gst_object_ref (ringbuffer); in gst_wasapi2_src_get_caps()
323 caps = gst_wasapi2_ring_buffer_get_caps (ringbuffer); in gst_wasapi2_src_get_caps()
[all …]
Dgstwasapi2sink.c266 if (asink->ringbuffer) { in gst_wasapi2_sink_change_state()
267 GstWasapi2RingBuffer *ringbuffer = in gst_wasapi2_sink_change_state() local
268 GST_WASAPI2_RING_BUFFER (asink->ringbuffer); in gst_wasapi2_sink_change_state()
271 gst_wasapi2_ring_buffer_set_volume (ringbuffer, self->volume); in gst_wasapi2_sink_change_state()
276 gst_wasapi2_ring_buffer_set_mute (ringbuffer, self->mute); in gst_wasapi2_sink_change_state()
296 if (asink->ringbuffer) { in gst_wasapi2_sink_get_caps()
297 GstWasapi2RingBuffer *ringbuffer = in gst_wasapi2_sink_get_caps() local
298 GST_WASAPI2_RING_BUFFER (asink->ringbuffer); in gst_wasapi2_sink_get_caps()
300 gst_object_ref (ringbuffer); in gst_wasapi2_sink_get_caps()
304 caps = gst_wasapi2_ring_buffer_get_caps (ringbuffer); in gst_wasapi2_sink_get_caps()
[all …]
Dgstwasapi2ringbuffer.cpp111 GstWasapi2RingBuffer *ringbuffer; in Invoke() local
114 ringbuffer = (GstWasapi2RingBuffer *) g_weak_ref_get (&listener_); in Invoke()
115 if (!ringbuffer) { in Invoke()
121 hr = gst_wasapi2_ring_buffer_loopback_callback (ringbuffer); in Invoke()
123 hr = gst_wasapi2_ring_buffer_io_callback (ringbuffer); in Invoke()
124 gst_object_unref (ringbuffer); in Invoke()
450 GstAudioRingBuffer *ringbuffer = GST_AUDIO_RING_BUFFER_CAST (self); in gst_wasapi2_ring_buffer_read() local
457 GstAudioInfo *info = &ringbuffer->spec.info; in gst_wasapi2_ring_buffer_read()
500 if (!gst_audio_ring_buffer_prepare_read (ringbuffer, in gst_wasapi2_ring_buffer_read()
512 gst_audio_format_info_fill_silence (ringbuffer->spec.info.finfo, in gst_wasapi2_ring_buffer_read()
[all …]
/third_party/gstreamer/gstplugins_base/gst-libs/gst/audio/
Dgstaudiobasesrc.c254 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()
[all …]
Dgstaudiobasesink.c324 if (sink->ringbuffer) { in gst_audio_base_sink_dispose()
325 gst_object_unparent (GST_OBJECT_CAST (sink->ringbuffer)); in gst_audio_base_sink_dispose()
326 sink->ringbuffer = NULL; in gst_audio_base_sink_dispose()
342 if (sink->ringbuffer == NULL) in gst_audio_base_sink_provide_clock()
345 if (!gst_audio_ring_buffer_is_acquired (sink->ringbuffer)) in gst_audio_base_sink_provide_clock()
395 if (basesink->ringbuffer) { in gst_audio_base_sink_query_pad()
398 gst_audio_ring_buffer_convert (basesink->ringbuffer, src_fmt, in gst_audio_base_sink_query_pad()
440 if (!basesink->ringbuffer || !basesink->ringbuffer->spec.info.rate) { in gst_audio_base_sink_query()
448 spec = &basesink->ringbuffer->spec; in gst_audio_base_sink_query()
488 if (basesink->ringbuffer) { in gst_audio_base_sink_query()
[all …]
/third_party/gstreamer/gstplugins_good/sys/osxaudio/
Dgstosxaudiosink.c236 GstOsxAudioRingBuffer *ringbuffer; in gst_osx_audio_sink_change_state() local
254 ringbuffer = in gst_osx_audio_sink_change_state()
255 GST_OSX_AUDIO_RING_BUFFER (GST_AUDIO_BASE_SINK (osxsink)->ringbuffer); in gst_osx_audio_sink_change_state()
256 if (ringbuffer->core_audio->device_id != osxsink->device_id) { in gst_osx_audio_sink_change_state()
257 osxsink->device_id = ringbuffer->core_audio->device_id; in gst_osx_audio_sink_change_state()
325 buf = GST_AUDIO_BASE_SINK (sink)->ringbuffer; in gst_osx_audio_sink_getcaps()
446 if (RINGBUFFER_IS_SPDIF (sink->ringbuffer->spec.type)) { in gst_osx_audio_sink_sink_payload()
447 gint framesize = gst_audio_iec61937_frame_size (&sink->ringbuffer->spec); in gst_osx_audio_sink_sink_payload()
462 outmap.data, outmap.size, &sink->ringbuffer->spec, G_BIG_ENDIAN); in gst_osx_audio_sink_sink_payload()
484 GstOsxAudioRingBuffer *ringbuffer; in gst_osx_audio_sink_create_ringbuffer() local
[all …]
Dgstosxaudiosrc.c207 GstOsxAudioRingBuffer *ringbuffer; in gst_osx_audio_src_change_state() local
222 ringbuffer = in gst_osx_audio_src_change_state()
223 GST_OSX_AUDIO_RING_BUFFER (GST_AUDIO_BASE_SRC (osxsrc)->ringbuffer); in gst_osx_audio_src_change_state()
224 if (ringbuffer->core_audio->device_id != osxsrc->device_id) { in gst_osx_audio_src_change_state()
225 osxsrc->device_id = ringbuffer->core_audio->device_id; in gst_osx_audio_src_change_state()
249 buf = GST_AUDIO_BASE_SRC (src)->ringbuffer; in gst_osx_audio_src_get_caps()
305 GstOsxAudioRingBuffer *ringbuffer; in gst_osx_audio_src_create_ringbuffer() local
310 ringbuffer = g_object_new (GST_TYPE_OSX_AUDIO_RING_BUFFER, NULL); in gst_osx_audio_src_create_ringbuffer()
315 ringbuffer->core_audio->element = in gst_osx_audio_src_create_ringbuffer()
317 ringbuffer->core_audio->is_src = TRUE; in gst_osx_audio_src_create_ringbuffer()
[all …]
/third_party/gstreamer/gstplugins_base/tests/check/libs/
Daudiosink.c87 GstAudioRingBuffer *ringbuffer; in GST_START_TEST() local
97 ringbuffer = bsink->ringbuffer; in GST_START_TEST()
98 fail_unless (ringbuffer != NULL); in GST_START_TEST()
101 gst_audio_ring_buffer_clear_all (ringbuffer); in GST_START_TEST()
/third_party/node/deps/brotli/c/enc/
Dbackward_references_hq.c137 const uint8_t* ringbuffer, in ZopfliCostModelSetFromCommands() argument
166 histogram_literal[ringbuffer[(pos + j) & ringbuffer_mask]]++; in ZopfliCostModelSetFromCommands()
191 cost_literal[ringbuffer[(position + i) & ringbuffer_mask]]; in ZopfliCostModelSetFromCommands()
200 const uint8_t* ringbuffer, in ZopfliCostModelSetFromLiteralCosts() argument
209 ringbuffer, &literal_costs[1]); in ZopfliCostModelSetFromLiteralCosts()
404 const uint8_t* ringbuffer, const size_t ringbuffer_mask, in UpdateNodes() argument
453 uint8_t continuation = ringbuffer[cur_ix_masked + best_len]; in UpdateNodes()
469 continuation != ringbuffer[prev_ix + best_len]) { in UpdateNodes()
472 len = FindMatchLengthWithLimit(&ringbuffer[prev_ix], in UpdateNodes()
473 &ringbuffer[cur_ix_masked], in UpdateNodes()
[all …]
Dhistogram.c46 const BlockSplit* dist_split, const uint8_t* ringbuffer, size_t start_pos, in BrotliBuildHistogramsWithContext() argument
77 ringbuffer[pos & mask]); in BrotliBuildHistogramsWithContext()
79 prev_byte = ringbuffer[pos & mask]; in BrotliBuildHistogramsWithContext()
84 prev_byte2 = ringbuffer[(pos - 2) & mask]; in BrotliBuildHistogramsWithContext()
85 prev_byte = ringbuffer[(pos - 1) & mask]; in BrotliBuildHistogramsWithContext()
Dbackward_references_inc.h12 const uint8_t* ringbuffer, size_t ringbuffer_mask, in EXPORT_FN()
51 ringbuffer, ringbuffer_mask, dist_cache, position, max_length, in EXPORT_FN()
70 ringbuffer, ringbuffer_mask, dist_cache, position + 1, max_length, in EXPORT_FN()
118 FN(StoreRange)(privat, ringbuffer, ringbuffer_mask, range_start, in EXPORT_FN()
144 FN(Store)(privat, ringbuffer, ringbuffer_mask, position); in EXPORT_FN()
153 FN(Store)(privat, ringbuffer, ringbuffer_mask, position); in EXPORT_FN()
/third_party/skia/third_party/externals/brotli/c/enc/
Dbackward_references_hq.c137 const uint8_t* ringbuffer, in ZopfliCostModelSetFromCommands() argument
166 histogram_literal[ringbuffer[(pos + j) & ringbuffer_mask]]++; in ZopfliCostModelSetFromCommands()
191 cost_literal[ringbuffer[(position + i) & ringbuffer_mask]]; in ZopfliCostModelSetFromCommands()
200 const uint8_t* ringbuffer, in ZopfliCostModelSetFromLiteralCosts() argument
209 ringbuffer, &literal_costs[1]); in ZopfliCostModelSetFromLiteralCosts()
404 const uint8_t* ringbuffer, const size_t ringbuffer_mask, in UpdateNodes() argument
453 uint8_t continuation = ringbuffer[cur_ix_masked + best_len]; in UpdateNodes()
469 continuation != ringbuffer[prev_ix + best_len]) { in UpdateNodes()
472 len = FindMatchLengthWithLimit(&ringbuffer[prev_ix], in UpdateNodes()
473 &ringbuffer[cur_ix_masked], in UpdateNodes()
[all …]
Dhistogram.c46 const BlockSplit* dist_split, const uint8_t* ringbuffer, size_t start_pos, in BrotliBuildHistogramsWithContext() argument
77 ringbuffer[pos & mask]); in BrotliBuildHistogramsWithContext()
79 prev_byte = ringbuffer[pos & mask]; in BrotliBuildHistogramsWithContext()
84 prev_byte2 = ringbuffer[(pos - 2) & mask]; in BrotliBuildHistogramsWithContext()
85 prev_byte = ringbuffer[(pos - 1) & mask]; in BrotliBuildHistogramsWithContext()
Dbackward_references_inc.h12 const uint8_t* ringbuffer, size_t ringbuffer_mask, in EXPORT_FN()
51 ringbuffer, ringbuffer_mask, dist_cache, position, max_length, in EXPORT_FN()
70 ringbuffer, ringbuffer_mask, dist_cache, position + 1, max_length, in EXPORT_FN()
118 FN(StoreRange)(privat, ringbuffer, ringbuffer_mask, range_start, in EXPORT_FN()
144 FN(Store)(privat, ringbuffer, ringbuffer_mask, position); in EXPORT_FN()
153 FN(Store)(privat, ringbuffer, ringbuffer_mask, position); in EXPORT_FN()
/third_party/lz4/examples/
DblockStreaming_lineByLine.md93 Next (see (1)), read first line to ringbuffer and compress it by `LZ4_compress_continue()`.
96 After that, write {Out#1} to the file and forward ringbuffer offset.
102 Eventually, we'll reach end of ringbuffer at Line#X (see (4)).
103 This time, we should reset ringbuffer offset.
118 - Decompress it to the ringbuffer.
120 - Forward ringbuffer offset. If offset exceeds end of the ringbuffer, reset it.
/third_party/ffmpeg/libavfilter/
Daf_headphone.c62 float *ringbuffer[2]; member
131 float **ringbuffer; member
146 float *ringbuffer = td->ringbuffer[jobnr]; in headphone_convolute() local
162 buffer[l] = ringbuffer + l * buffer_length; in headphone_convolute()
217 float *ringbuffer = td->ringbuffer[jobnr]; in headphone_fast_convolute() local
239 dst[2 * j] = ringbuffer[wr]; in headphone_fast_convolute()
240 ringbuffer[wr] = 0.0; in headphone_fast_convolute()
291 *(ringbuffer + write_pos) += fft_acc[in->nb_samples + j].re * fft_scale; in headphone_fast_convolute()
333 td.ringbuffer = s->ringbuffer; td.temp_src = s->temp_src; in headphone_frame()
385 s->ringbuffer[0] = av_calloc(s->buffer_length, sizeof(float) * nb_input_channels); in convert_coeffs()
[all …]
Daf_sofalizer.c79 float *ringbuffer[2]; /* buffers input samples, length of one buffer: */ member
334 float **ringbuffer; member
350 float *ringbuffer = td->ringbuffer[jobnr]; in sofalizer_convolute() local
373 buffer[l] = ringbuffer + l * buffer_length; in sofalizer_convolute()
449 float *ringbuffer = td->ringbuffer[jobnr]; in sofalizer_fast_convolute() local
479 dst[mult * j] = ringbuffer[wr]; in sofalizer_fast_convolute()
480 ringbuffer[wr] = 0.0f; /* re-set read samples to zero */ in sofalizer_fast_convolute()
561 *(ringbuffer + write_pos) += fft_acc[in->nb_samples + j].re * fft_scale; in sofalizer_fast_convolute()
596 td.ringbuffer = s->ringbuffer; td.temp_src = s->temp_src; in filter_frame()
862 s->ringbuffer[0] = av_calloc(s->buffer_length, sizeof(float) * nb_input_channels); in load_data()
[all …]
/third_party/libwebsockets/minimal-examples/http-server/minimal-http-server-sse-ring/
DREADME.md1 # lws minimal http Server Side Events + ringbuffer
5 see the same data via a ringbuffer.
8 ringbuffer at random intervals.
26 the same content from the server ringbuffer.
/third_party/gstreamer/gstplugins_bad/sys/asio/
Dgstasiosink.cpp205 if (asink->ringbuffer) in gst_asio_sink_get_caps()
208 (asink->ringbuffer)); in gst_asio_sink_get_caps()
229 GstAsioRingBuffer *ringbuffer = nullptr; in gst_asio_sink_create_ringbuffer() local
337 ringbuffer = in gst_asio_sink_create_ringbuffer()
342 if (!ringbuffer) { in gst_asio_sink_create_ringbuffer()
347 if (!gst_asio_ring_buffer_configure (ringbuffer, channel_indices, in gst_asio_sink_create_ringbuffer()
350 gst_clear_object (&ringbuffer); in gst_asio_sink_create_ringbuffer()
360 return GST_AUDIO_RING_BUFFER_CAST (ringbuffer); in gst_asio_sink_create_ringbuffer()
Dgstasiosrc.cpp219 if (asrc->ringbuffer) in gst_asio_src_get_caps()
221 gst_asio_ring_buffer_get_caps (GST_ASIO_RING_BUFFER (asrc->ringbuffer)); in gst_asio_src_get_caps()
242 GstAsioRingBuffer *ringbuffer = nullptr; in gst_asio_src_create_ringbuffer() local
350 ringbuffer = in gst_asio_src_create_ringbuffer()
356 if (!ringbuffer) { in gst_asio_src_create_ringbuffer()
361 if (!gst_asio_ring_buffer_configure (ringbuffer, channel_indices, in gst_asio_src_create_ringbuffer()
364 gst_clear_object (&ringbuffer); in gst_asio_src_create_ringbuffer()
374 return GST_AUDIO_RING_BUFFER_CAST (ringbuffer); in gst_asio_src_create_ringbuffer()
/third_party/libwebsockets/minimal-examples/ws-server/minimal-ws-server-ring/
DREADME.md21 A ringbuffer holds up to 8 lines of text.
23 This also demonstrates how the ringbuffer can take action against lagging or
24 disconnected clients that cause the ringbuffer to fill.
/third_party/node/deps/brotli/c/dec/
Ddecode.c1128 uint32_t* ringbuffer = &s->block_type_rb[tree_type * 2]; in DecodeBlockTypeAndLength() local
1150 block_type = ringbuffer[1] + 1; in DecodeBlockTypeAndLength()
1152 block_type = ringbuffer[0]; in DecodeBlockTypeAndLength()
1159 ringbuffer[0] = ringbuffer[1]; in DecodeBlockTypeAndLength()
1160 ringbuffer[1] = block_type; in DecodeBlockTypeAndLength()
1271 s->ringbuffer + (s->partial_pos_out & (size_t)s->ringbuffer_mask); in WriteRingBuffer()
1314 memcpy(s->ringbuffer, s->ringbuffer_end, (size_t)s->pos); in WrapRingBuffer()
1328 uint8_t* old_ringbuffer = s->ringbuffer; in BrotliEnsureRingBuffer()
1333 s->ringbuffer = (uint8_t*)BROTLI_DECODER_ALLOC(s, in BrotliEnsureRingBuffer()
1335 if (s->ringbuffer == 0) { in BrotliEnsureRingBuffer()
[all …]
/third_party/skia/third_party/externals/brotli/c/dec/
Ddecode.c1128 uint32_t* ringbuffer = &s->block_type_rb[tree_type * 2]; in DecodeBlockTypeAndLength() local
1150 block_type = ringbuffer[1] + 1; in DecodeBlockTypeAndLength()
1152 block_type = ringbuffer[0]; in DecodeBlockTypeAndLength()
1159 ringbuffer[0] = ringbuffer[1]; in DecodeBlockTypeAndLength()
1160 ringbuffer[1] = block_type; in DecodeBlockTypeAndLength()
1271 s->ringbuffer + (s->partial_pos_out & (size_t)s->ringbuffer_mask); in WriteRingBuffer()
1314 memcpy(s->ringbuffer, s->ringbuffer_end, (size_t)s->pos); in WrapRingBuffer()
1328 uint8_t* old_ringbuffer = s->ringbuffer; in BrotliEnsureRingBuffer()
1333 s->ringbuffer = (uint8_t*)BROTLI_DECODER_ALLOC(s, in BrotliEnsureRingBuffer()
1335 if (s->ringbuffer == 0) { in BrotliEnsureRingBuffer()
[all …]

12345