| /external/sl4a/Utils/src/com/trilead/ssh2/ |
| D | StreamGobbler.java | 60 int avail = is.read(buffer, write_pos, buffer.length - write_pos); in run()
68 write_pos += avail; in run()
70 int space_available = buffer.length - write_pos; in run()
77 write_pos -= read_pos; in run()
80 write_pos = 0; in run()
112 private int write_pos = 0; field in StreamGobbler
149 while (read_pos == write_pos) { in read()
177 return write_pos - read_pos; in available()
218 while (read_pos == write_pos) { in read()
233 int avail = write_pos - read_pos; in read()
|
| /external/adhd/cras/src/server/ |
| D | audio_thread_log.h | 57 log->log[log->write_pos].tag_sec = in audio_thread_event_log_data()
59 log->log[log->write_pos].nsec = now.tv_nsec; in audio_thread_event_log_data()
60 log->log[log->write_pos].data1 = data1; in audio_thread_event_log_data()
61 log->log[log->write_pos].data2 = data2; in audio_thread_event_log_data()
62 log->log[log->write_pos].data3 = data3; in audio_thread_event_log_data()
64 log->write_pos++; in audio_thread_event_log_data()
65 log->write_pos %= AUDIO_THREAD_EVENT_LOG_SIZE; in audio_thread_event_log_data()
|
| /external/webrtc/webrtc/common_audio/ |
| D | ring_buffer.c | 27 size_t write_pos; member
95 self->write_pos = 0; in WebRtc_InitBuffer()
173 const size_t margin = self->element_count - self->write_pos; in WebRtc_WriteBuffer()
177 memcpy(self->data + self->write_pos * self->element_size, in WebRtc_WriteBuffer()
179 self->write_pos = 0; in WebRtc_WriteBuffer()
183 memcpy(self->data + self->write_pos * self->element_size, in WebRtc_WriteBuffer()
186 self->write_pos += n; in WebRtc_WriteBuffer()
235 return self->write_pos - self->read_pos; in WebRtc_available_read()
237 return self->element_count - self->read_pos + self->write_pos; in WebRtc_available_read()
|
| /external/perfetto/src/profiling/memory/ |
| D | shared_ring_buffer.h | 128 uint64_t write_pos; member
137 uint64_t write_pos; member
158 pos.write_pos = meta_->write_pos; in GetPointerPositions()
168 PERFETTO_DCHECK(pos.write_pos >= pos.read_pos); in read_avail()
169 auto res = static_cast<size_t>(pos.write_pos - pos.read_pos); in read_avail()
|
| D | shared_ring_buffer.cc | 200 uint8_t* wr_ptr = at(pos.write_pos); in BeginWrite()
204 meta_->write_pos += size_with_header; in BeginWrite()
257 size, avail_read, pos.read_pos, pos.write_pos); in BeginRead()
278 if (pos.write_pos < pos.read_pos || pos.write_pos - pos.read_pos > size_ || in IsCorrupt()
279 pos.write_pos % kAlignment || pos.read_pos % kAlignment) { in IsCorrupt()
282 pos.read_pos, pos.write_pos, size_); in IsCorrupt()
|
| /external/python/cpython3/Modules/_io/ |
| D | bufferedio.c | 229 Py_off_t write_pos; member
1762 self->write_pos = 0; in _bufferedwriter_reset_buf()
1860 if (!VALID_WRITE_BUFFER(self) || self->write_pos == self->write_end) in _bufferedwriter_flush_unlocked()
1863 rewind = RAW_OFFSET(self) + (self->pos - self->write_pos); in _bufferedwriter_flush_unlocked()
1871 while (self->write_pos < self->write_end) { in _bufferedwriter_flush_unlocked()
1873 self->buffer + self->write_pos, in _bufferedwriter_flush_unlocked()
1874 Py_SAFE_DOWNCAST(self->write_end - self->write_pos, in _bufferedwriter_flush_unlocked()
1884 self->write_pos += n; in _bufferedwriter_flush_unlocked()
1885 self->raw_pos = self->write_pos; in _bufferedwriter_flush_unlocked()
1946 if (!VALID_WRITE_BUFFER(self) || self->write_pos > self->pos) { in _io_BufferedWriter_write_impl()
[all …]
|
| /external/python/cpython2/Modules/_io/ |
| D | bufferedio.c | 219 Py_off_t write_pos; member
1660 self->write_pos = 0; in _bufferedwriter_reset_buf()
1760 if (!VALID_WRITE_BUFFER(self) || self->write_pos == self->write_end) in _bufferedwriter_flush_unlocked()
1763 rewind = RAW_OFFSET(self) + (self->pos - self->write_pos); in _bufferedwriter_flush_unlocked()
1771 while (self->write_pos < self->write_end) { in _bufferedwriter_flush_unlocked()
1773 self->buffer + self->write_pos, in _bufferedwriter_flush_unlocked()
1774 Py_SAFE_DOWNCAST(self->write_end - self->write_pos, in _bufferedwriter_flush_unlocked()
1784 self->write_pos += n; in _bufferedwriter_flush_unlocked()
1785 self->raw_pos = self->write_pos; in _bufferedwriter_flush_unlocked()
1835 if (!VALID_WRITE_BUFFER(self) || self->write_pos > self->pos) { in bufferedwriter_write()
[all …]
|
| /external/libopus/src/ |
| D | analysis.c | 248 curr_lookahead = tonal->write_pos-tonal->read_pos; in tonality_get_info()
253 if (len > tonal->Fs/50 && pos != tonal->write_pos) in tonality_get_info()
259 if (pos == tonal->write_pos) in tonality_get_info()
275 if (pos == tonal->write_pos) in tonality_get_info()
290 if (pos == tonal->write_pos) in tonality_get_info()
351 if (mpos == tonal->write_pos) in tonality_get_info()
356 if (vpos == tonal->write_pos) in tonality_get_info()
499 info = &tonal->info[tonal->write_pos++]; in tonality_analysis()
500 if (tonal->write_pos>=DETECT_SIZE) in tonality_analysis()
501 tonal->write_pos-=DETECT_SIZE; in tonality_analysis()
|
| D | analysis.h | 73 int write_pos; member
|
| /external/webrtc/webrtc/base/ |
| D | stream.cc | 1073 size_t count, read_pos, write_pos; in Flow() local
1099 write_pos = 0; in Flow()
1100 while (write_pos < read_pos) { in Flow()
1101 result = sink->Write(buffer + write_pos, read_pos - write_pos, in Flow()
1105 *data_len = read_pos - write_pos; in Flow()
1106 if (write_pos > 0) { in Flow()
1107 memmove(buffer, buffer + write_pos, *data_len); in Flow()
1112 write_pos += count; in Flow()
|
| /external/adhd/cras/src/common/ |
| D | cras_types.h | 239 uint32_t write_pos; member
|
| /external/adhd/cras/src/tests/ |
| D | cras_test_client.c | 617 j = info->log.write_pos; in print_audio_debug_info()
|