Home
last modified time | relevance | path

Searched refs:read_idx (Results 1 – 21 of 21) sorted by relevance

/external/pigweed/pw_ring_buffer/
Dprefixed_entry_ring_buffer.cc32 reader.read_idx = 0; in Clear()
59 reader.read_idx = write_idx_; in AttachReader()
70 reader.read_idx = 0; in DetachReader()
179 size_t data_read_idx = reader.read_idx; in InternalRead()
238 if (reader.read_idx < write_idx_) { in GetSlowestReader()
240 reader.read_idx < slowest_reader_before_writer->read_idx) { in GetSlowestReader()
245 reader.read_idx < slowest_reader_after_writer->read_idx) { in GetSlowestReader()
261 if (slowest_reader->read_idx == 0) { in Dering()
267 buffer_span.begin() + slowest_reader->read_idx, in Dering()
272 if (write_idx_ < slowest_reader->read_idx) { in Dering()
[all …]
/external/webrtc/logging/rtc_event_log/encoder/
Dblob_encoding.cc61 size_t read_idx = 0; in DecodeBlobs() local
66 if (read_idx >= encoded_blobs.length()) { in DecodeBlobs()
67 RTC_DCHECK_EQ(read_idx, encoded_blobs.length()); in DecodeBlobs()
73 DecodeVarInt(encoded_blobs.substr(read_idx), &lengths[i]); in DecodeBlobs()
79 read_idx += read_bytes; in DecodeBlobs()
83 RTC_DCHECK_LE(read_idx, encoded_blobs.length()); in DecodeBlobs()
89 if (read_idx + lengths[i] < read_idx) { // Wrap-around detection. in DecodeBlobs()
94 if (read_idx + lengths[i] > encoded_blobs.length()) { in DecodeBlobs()
99 blobs[i] = encoded_blobs.substr(read_idx, lengths[i]); in DecodeBlobs()
100 read_idx += lengths[i]; in DecodeBlobs()
[all …]
/external/adhd/cras/src/common/
Dbyte_buffer.h15 unsigned int read_idx; member
52 if (buf->write_idx < buf->read_idx) in buf_writable()
53 return buf->read_idx - buf->write_idx; in buf_writable()
63 if (buf->read_idx < buf->write_idx) in buf_readable()
64 return buf->write_idx - buf->read_idx; in buf_readable()
66 return buf->used_size - buf->read_idx; in buf_readable()
74 buf->write_idx = (buf->read_idx + buf->level) % buf->used_size; in buf_adjust_readable()
90 return &buf->bytes[buf->read_idx]; in buf_read_pointer()
103 buf->read_idx += inc; in buf_increment_read()
104 buf->read_idx %= buf->used_size; in buf_increment_read()
[all …]
/external/webrtc/test/fuzzers/
Dresidual_echo_detector_fuzzer.cc39 size_t read_idx = 0; in FuzzOneInput() local
42 memcpy(&call_order_int, &data[read_idx], 2); in FuzzOneInput()
43 read_idx += 2; in FuzzOneInput()
52 RTC_DCHECK_LE(read_idx + sizeof(float), size); in FuzzOneInput()
53 memcpy(input.data(), &data[read_idx], sizeof(float)); in FuzzOneInput()
54 read_idx += sizeof(float); in FuzzOneInput()
/external/libvpx/libvpx/vp8/encoder/
Dlookahead.c21 unsigned int read_idx; /* Read index */ member
153 buf = pop(ctx, &ctx->read_idx); in vp8_lookahead_pop()
166 index += ctx->read_idx; in vp8_lookahead_peek()
173 if (ctx->read_idx == 0) { in vp8_lookahead_peek()
176 index = ctx->read_idx - index; in vp8_lookahead_peek()
/external/mesa3d/src/util/
Du_queue.c297 job = queue->jobs[queue->read_idx]; in util_queue_thread_func()
298 memset(&queue->jobs[queue->read_idx], 0, sizeof(struct util_queue_job)); in util_queue_thread_func()
299 queue->read_idx = (queue->read_idx + 1) % queue->max_jobs; in util_queue_thread_func()
318 for (unsigned i = queue->read_idx; i != queue->write_idx; in util_queue_thread_func()
325 queue->read_idx = queue->write_idx; in util_queue_thread_func()
568 unsigned i = queue->read_idx; in util_queue_add_job()
579 queue->read_idx = 0; in util_queue_add_job()
624 for (unsigned i = queue->read_idx; i != queue->write_idx; in util_queue_drop_job()
Du_queue.h215 int write_idx, read_idx; /* ring buffer pointers */ member
/external/crosvm/devices/src/virtio/input/
Devent_source.rs48 read_idx: usize, field
65 .read(&mut self.read_buffer[self.read_idx..]) in receive_events()
67 let buff_size = read + self.read_idx; in receive_events()
85 self.read_idx = remainder; in receive_events()
126 read_idx: 0, in new()
/external/libvpx/libvpx/vp9/encoder/
Dvp9_lookahead.c206 buf = pop(ctx, &ctx->read_idx); in vp9_lookahead_pop()
219 index += ctx->read_idx; in vp9_lookahead_peek()
226 index += ctx->read_idx; in vp9_lookahead_peek()
Dvp9_lookahead.h38 int read_idx; /* Read index */ member
/external/adhd/cras/src/server/
Dfloat_buffer.h96 offset = offset + b->buf->read_idx - b->buf->max_size; in float_buffer_read_pointer()
100 offset += b->buf->read_idx; in float_buffer_read_pointer()
/external/libaom/libaom/av1/encoder/
Dlookahead.c152 buf = pop(ctx, &read_ctx->read_idx); in av1_lookahead_pop()
172 index += read_ctx->read_idx; in av1_lookahead_peek()
179 index += (int)(read_ctx->read_idx); in av1_lookahead_peek()
Dlookahead.h41 int read_idx; /* Read index */ member
/external/pigweed/pw_ring_buffer/public/pw_ring_buffer/
Dprefixed_entry_ring_buffer.h60 constexpr Reader() : buffer(nullptr), read_idx(0), entry_count(0) {} in Reader()
135 size_t read_idx; variable
/external/adhd/cras/src/libcras/
Dcras_client.c3248 int cras_client_read_atlog(struct cras_client *client, uint64_t *read_idx, in cras_client_read_atlog() argument
3263 if (sync_write_pos <= *read_idx) in cras_client_read_atlog()
3267 for (i = sync_write_pos - 1; i >= *read_idx; --i) { in cras_client_read_atlog()
3274 if (*read_idx) in cras_client_read_atlog()
3275 *missing = i - *read_idx + 1; in cras_client_read_atlog()
3276 *read_idx = i + 1; in cras_client_read_atlog()
3286 if ((sync_write_pos - 1) % log.len < *read_idx % log.len) { in cras_client_read_atlog()
3287 len = log.len - *read_idx % log.len; in cras_client_read_atlog()
3288 memcpy(buf->log, &log.log[*read_idx % log.len], in cras_client_read_atlog()
3293 len = sync_write_pos - *read_idx; in cras_client_read_atlog()
[all …]
Dcras_client.h523 int cras_client_read_atlog(struct cras_client *client, uint64_t *read_idx,
/external/mesa3d/include/drm-uapi/
Detnaviv_drm.h176 __u32 read_idx; /* in, index of read_bo buffer */ member
/external/igt-gpu-tools/include/drm-uapi/
Detnaviv_drm.h170 __u32 read_idx; /* in, index of read_bo buffer */ member
/external/kernel-headers/original/uapi/drm/
Detnaviv_drm.h176 __u32 read_idx; /* in, index of read_bo buffer */ member
/external/libdrm/etnaviv/
Detnaviv_cmd_stream.c276 pmr->read_idx = bo2idx(stream, p->bo, ETNA_SUBMIT_BO_READ | ETNA_SUBMIT_BO_WRITE); in etna_cmd_stream_perf()
/external/mesa3d/src/etnaviv/drm/
Detnaviv_cmd_stream.c308 pmr->read_idx = bo2idx(stream, p->bo, ETNA_SUBMIT_BO_READ | ETNA_SUBMIT_BO_WRITE); in etna_cmd_stream_perf()