| /third_party/boost/boost/lockfree/ |
| D | spsc_queue.hpp | 74 static size_t read_available(size_t write_index, size_t read_index, size_t max_size) in read_available() argument
76 if (write_index >= read_index) in read_available()
77 return write_index - read_index; in read_available()
79 const size_t ret = write_index + max_size - read_index; in read_available()
83 static size_t write_available(size_t write_index, size_t read_index, size_t max_size) in write_available() argument
85 size_t ret = read_index - write_index - 1; in write_available()
86 if (write_index >= read_index) in write_available()
94 const size_t read_index = read_index_.load(memory_order_relaxed); in read_available() local
95 return read_available(write_index, read_index, max_size); in read_available()
101 const size_t read_index = read_index_.load(memory_order_acquire); in write_available() local
[all …]
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | memblockq.c | 52 int64_t read_index, write_index; member
82 bq->read_index = bq->write_index = idx; in pa_memblockq_new()
135 while (PA_UNLIKELY(bq->current_read->index > bq->read_index)) in fix_current_read()
143 … PA_UNLIKELY(bq->current_read->index + (int64_t) bq->current_read->chunk.length <= bq->read_index)) in fix_current_read()
217 boundary = bq->read_index - (int64_t) bq->maxrewind; in drop_backlog()
228 if (bq->read_index > bq->write_index) { in can_push()
229 int64_t d = bq->read_index - bq->write_index; in can_push()
241 if (bq->write_index + (int64_t) l - bq->read_index > (int64_t) bq->maxlength) in can_push()
269 delta = bq->read_index - old_read_index; in read_index_changed()
450 return bq->prebuf > 0 && bq->read_index >= bq->write_index; in pa_memblockq_prebuf_active()
[all …]
|
| D | protocol-native.c | 144 int64_t read_index, write_index; member
1420 s->read_index = pa_memblockq_get_read_index(s->memblockq); in sink_input_process_msg()
2908 pa_tagstruct_puts64(reply, s->read_index); in command_get_playback_latency()
|
| /third_party/ffmpeg/libavformat/ |
| D | ifv.c | 52 static int read_index(AVFormatContext *s, in read_index() function
168 ret = read_index(s, AVMEDIA_TYPE_VIDEO, 0); in ifv_read_header()
176 ret = read_index(s, AVMEDIA_TYPE_AUDIO, 0); in ifv_read_header()
232 ret = read_index(s, AVMEDIA_TYPE_VIDEO, ifv->next_video_index); in ifv_read_packet()
236 ret = read_index(s, AVMEDIA_TYPE_AUDIO, ifv->next_audio_index); in ifv_read_packet()
257 ret = read_index(s, AVMEDIA_TYPE_VIDEO, ifv->next_video_index); in ifv_read_packet()
|
| D | mvdec.c | 264 static void read_index(AVIOContext *pb, AVStream *st) in read_index() function
417 read_index(pb, ast); in mv_read_header()
420 read_index(pb, vst); in mv_read_header()
|
| /third_party/pulseaudio/src/modules/ |
| D | module-esound-sink.c | 98 size_t read_length, read_index; member
425 u->read_index = 0; in handle_response()
455 u->read_index = u->read_length = 0; in handle_response()
479 pa_assert(u->read_index < u->read_length); in do_read()
481 … pa_iochannel_read(u->io, (uint8_t*) u->read_data + u->read_index, u->read_length - u->read_index)… in do_read()
486 u->read_index += (size_t) r; in do_read()
487 pa_assert(u->read_index <= u->read_length); in do_read()
489 if (u->read_index == u->read_length) in do_read()
591 u->read_index = u->write_index = u->read_length = u->write_length = 0; in pa__init()
|
| D | module-tunnel.c | 778 int64_t write_index, read_index; in stream_get_latency_callback() local
800 pa_tagstruct_gets64(t, &read_index) < 0) { in stream_get_latency_callback()
849 if (write_index >= read_index) in stream_get_latency_callback()
850 delay += (int64_t) pa_bytes_to_usec((uint64_t) (write_index-read_index), ss); in stream_get_latency_callback()
852 delay -= (int64_t) pa_bytes_to_usec((uint64_t) (read_index-write_index), ss); in stream_get_latency_callback()
|
| /third_party/pulseaudio/src/pulse/ |
| D | simple.c | 45 size_t read_index, read_length; member
341 p->read_index = 0; in pa_simple_read()
345 memcpy(data, (const uint8_t*) p->read_data+p->read_index, l); in pa_simple_read()
350 p->read_index += l; in pa_simple_read()
359 p->read_index = 0; in pa_simple_read()
479 … already_read = pa_bytes_to_usec(p->read_index, pa_stream_get_sample_spec(p->stream)); in pa_simple_get_latency()
|
| D | def.h | 730 int64_t read_index; member
|
| D | stream.c | 1667 s->timing_info.read_index += (int64_t) s->peek_memchunk.length; in pa_stream_drop()
1748 …usec = pa_bytes_to_usec(s->timing_info.read_index < 0 ? 0 : (uint64_t) s->timing_info.read_index, … in calc_time()
1827 pa_tagstruct_gets64(t, &i->read_index) < 0) { in stream_get_timing_info_callback()
1929 i->read_index -= (int64_t) pa_memblockq_get_length(o->stream->record_memblockq); in stream_get_timing_info_callback()
2528 cindex = s->timing_info.read_index; in pa_stream_get_latency()
|
| /third_party/pulseaudio/src/modules/bluetooth/ |
| D | module-bluez5-device.c | 129 uint64_t read_index; member
386 u->read_index += (uint64_t) l; in sco_process_push()
404 …pa_smoother_put(u->read_smoother, tstamp, pa_bytes_to_usec(u->read_index, &u->decoder_sample_spec)… in sco_process_push()
626 u->read_index += (uint64_t) memchunk.length; in a2dp_process_push()
627 …pa_smoother_put(u->read_smoother, tstamp, pa_bytes_to_usec(u->read_index, &u->decoder_sample_spec)… in a2dp_process_push()
841 u->read_index = u->write_index = 0; in setup_stream()
881 ri = pa_bytes_to_usec(u->read_index, &u->decoder_sample_spec); in source_process_msg()
1412 if (have_sink && u->write_index == 0 && u->read_index <= 0) in thread_func()
|
| /third_party/gstreamer/gstplugins_good/ext/pulse/ |
| D | pulsesink.c | 746 (int) gst_util_uint64_scale_ceil (info->read_index, 1, in gst_pulsering_stream_latency_cb()
756 info->write_index, info->read_index_corrupt, info->read_index, in gst_pulsering_stream_latency_cb()
1689 info->read_index, offset); in gst_pulseringbuffer_commit()
1693 if (info->read_index + bufsize <= offset) { in gst_pulseringbuffer_commit()
|
| D | pulsesrc.c | 946 info->write_index, info->read_index_corrupt, info->read_index, in gst_pulsesrc_stream_latency_update_cb()
|
| /third_party/pulseaudio/vala/ |
| D | libpulse.vapi | 1180 int64 read_index;
|
| /third_party/ffmpeg/ |
| D | Changelog | 21 avformat/mvdec: Check for EOF in read_index()
|
| /third_party/gstreamer/gstplugins_good/ |
| D | ChangeLog | 106742 are writing too far away from the current read_index.
|