| /external/adhd/cras/src/tests/ |
| D | float_buffer_unittest.cc | 11 unsigned int readable = 10; in TEST() local
19 float_buffer_read_pointer(b, 0, &readable); in TEST()
20 EXPECT_EQ(8, readable); in TEST()
23 readable = 10; in TEST()
24 float_buffer_read_pointer(b, 3, &readable); in TEST()
25 EXPECT_EQ(5, readable); in TEST()
36 readable = 10; in TEST()
38 float_buffer_read_pointer(b, 0, &readable); in TEST()
39 EXPECT_EQ(4, readable); in TEST()
41 readable = 10; in TEST()
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | io_async_fd.rs | 181 _ = afd_a.readable().fuse() => panic!("Unexpected readable state"), in initially_writable()
182 _ = afd_b.readable().fuse() => panic!("Unexpected readable state"), in initially_writable()
192 let readable = afd_a.readable(); in reset_readable() localVariable
193 tokio::pin!(readable); in reset_readable()
196 _ = readable.as_mut() => panic!(), in reset_readable()
202 let mut guard = readable.await.unwrap(); in reset_readable()
211 afd_a.readable().await.unwrap().retain_ready(); in reset_readable()
216 let readable = afd_a.readable(); in reset_readable() localVariable
217 tokio::pin!(readable); in reset_readable()
220 _ = readable.as_mut() => panic!(), in reset_readable()
[all …]
|
| D | tcp_stream.rs | 46 let mut readable = task::spawn(server.readable()); in try_read_write() localVariable
47 assert_pending!(readable.poll()); in try_read_write()
54 while !readable.is_woken() { in try_read_write()
83 server.readable().await.unwrap(); in try_read_write()
119 stream.readable().await.unwrap(); in buffer_not_included_in_future()
253 let mut readable = task::spawn(server.readable()); in try_read_buf() localVariable
254 assert_pending!(readable.poll()); in try_read_buf()
261 while !readable.is_woken() { in try_read_buf()
290 server.readable().await.unwrap(); in try_read_buf()
|
| D | uds_stream.rs | 81 let mut readable = task::spawn(server.readable()); in try_read_write() localVariable
82 assert_pending!(readable.poll()); in try_read_write()
89 while !readable.is_woken() { in try_read_write()
118 server.readable().await?; in try_read_write()
273 let mut readable = task::spawn(server.readable()); in try_read_buf() localVariable
274 assert_pending!(readable.poll()); in try_read_buf()
281 while !readable.is_woken() { in try_read_buf()
310 server.readable().await?; in try_read_buf()
|
| /external/libchrome/mojo/public/cpp/system/tests/ |
| D | handle_signal_tracker_unittest.cc | 45 EXPECT_FALSE(tracker.last_known_state().readable()); in TEST_F()
56 EXPECT_TRUE(tracker.last_known_state().readable()); in TEST_F()
63 EXPECT_FALSE(tracker.last_known_state().readable()); in TEST_F()
68 EXPECT_TRUE(tracker.last_known_state().readable()); in TEST_F()
74 EXPECT_FALSE(tracker.last_known_state().readable()); in TEST_F()
83 EXPECT_FALSE(readable_tracker.last_known_state().readable()); in TEST_F()
89 EXPECT_TRUE(readable_tracker.last_known_state().readable()); in TEST_F()
108 EXPECT_FALSE(readable_tracker.last_known_state().readable()); in TEST_F()
112 EXPECT_TRUE(peer_closed_tracker.last_known_state().readable()); in TEST_F()
|
| D | wait_unittest.cc | 97 EXPECT_TRUE(hss.readable() && hss.writable() && !hss.peer_closed()); in TEST_F()
109 EXPECT_TRUE(hss.readable() && hss.peer_closed() && !hss.writable()); in TEST_F()
120 EXPECT_TRUE(hss.peer_closed() && !hss.readable() && !hss.writable()); in TEST_F()
140 EXPECT_TRUE(hss.readable() && hss.writable() && !hss.peer_closed()); in TEST_F()
160 EXPECT_TRUE(!hss.readable() && !hss.writable() && hss.peer_closed()); in TEST_F()
204 EXPECT_TRUE(!hss[0].readable() && hss[0].writable() && !hss[0].peer_closed()); in TEST_F()
207 EXPECT_TRUE(hss[1].readable() && hss[1].writable() && !hss[1].peer_closed()); in TEST_F()
224 EXPECT_TRUE(!hss[0].readable() && !hss[0].writable() && hss[0].peer_closed()); in TEST_F()
270 EXPECT_TRUE(!hss[0].readable() && hss[0].writable() && !hss[0].peer_closed()); in TEST_F()
273 EXPECT_TRUE(hss[1].readable() && hss[1].writable() && !hss[1].peer_closed()); in TEST_F()
[all …]
|
| /external/guava/android/guava/src/com/google/common/io/ |
| D | LineReader.java | 41 private final Readable readable; field in LineReader
56 public LineReader(Readable readable) { in LineReader() argument
57 this.readable = checkNotNull(readable); in LineReader()
58 this.reader = (readable instanceof Reader) ? (Reader) readable : null; in LineReader()
76 int read = (reader != null) ? reader.read(buf, 0, buf.length) : readable.read(cbuf); in readLine()
|
| D | CharStreams.java | 218 public static <T> T readLines(Readable readable, LineProcessor<T> processor) throws IOException { in readLines() argument
219 checkNotNull(readable); in readLines()
222 LineReader lineReader = new LineReader(readable); in readLines()
240 public static long exhaust(Readable readable) throws IOException { in exhaust() argument
244 while ((read = readable.read(buf)) != -1) { in exhaust()
|
| D | CharSink.java | 149 public long writeFrom(Readable readable) throws IOException { in writeFrom() argument
150 checkNotNull(readable); in writeFrom()
155 long written = CharStreams.copy(readable, out); in writeFrom()
|
| /external/guava/guava/src/com/google/common/io/ |
| D | LineReader.java | 41 private final Readable readable; field in LineReader
56 public LineReader(Readable readable) { in LineReader() argument
57 this.readable = checkNotNull(readable); in LineReader()
58 this.reader = (readable instanceof Reader) ? (Reader) readable : null; in LineReader()
76 int read = (reader != null) ? reader.read(buf, 0, buf.length) : readable.read(cbuf); in readLine()
|
| D | CharStreams.java | 218 public static <T> T readLines(Readable readable, LineProcessor<T> processor) throws IOException { in readLines() argument
219 checkNotNull(readable); in readLines()
222 LineReader lineReader = new LineReader(readable); in readLines()
240 public static long exhaust(Readable readable) throws IOException { in exhaust() argument
244 while ((read = readable.read(buf)) != -1) { in exhaust()
|
| D | CharSink.java | 175 public long writeFrom(Readable readable) throws IOException { in writeFrom() argument
176 checkNotNull(readable); in writeFrom()
181 long written = CharStreams.copy(readable, out); in writeFrom()
|
| /external/adhd/cras/src/server/ |
| D | float_buffer.h | 85 unsigned int *readable) in float_buffer_read_pointer() argument
92 *readable = 0; in float_buffer_read_pointer()
97 *readable = MIN(*readable, b->buf->write_idx - offset); in float_buffer_read_pointer()
99 *readable = MIN(*readable, nread - offset); in float_buffer_read_pointer()
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | reduction.py | 167 return rebuild_connection, (rh, conn.readable, conn.writable)
169 def rebuild_connection(reduced_handle, readable, writable): argument
172 handle, readable=readable, writable=writable
207 return rebuild_pipe_connection, (rh, conn.readable, conn.writable)
209 def rebuild_pipe_connection(reduced_handle, readable, writable): argument
212 handle, readable=readable, writable=writable
|
| /external/webrtc/common_audio/ |
| D | wav_header.cc | 168 WavHeaderReader* readable, in FindWaveChunk() argument
172 if (readable->Read(chunk_header, sizeof(*chunk_header)) != in FindWaveChunk()
178 if (!readable->SeekForward(chunk_header->Size)) in FindWaveChunk()
183 bool ReadFmtChunkData(FmtPcmSubchunk* fmt_subchunk, WavHeaderReader* readable) { in ReadFmtChunkData() argument
185 if (readable->Read(&(fmt_subchunk->AudioFormat), kFmtPcmSubchunkSize) != in ReadFmtChunkData()
195 if (readable->Read(&ext_size, sizeof(ext_size)) != sizeof(ext_size)) in ReadFmtChunkData()
375 bool ReadWavHeader(WavHeaderReader* readable, in ReadWavHeader() argument
386 if (readable->Read(&header.riff, sizeof(header.riff)) != sizeof(header.riff)) in ReadWavHeader()
397 if (!FindWaveChunk(&header.fmt.header, readable, "fmt ")) { in ReadWavHeader()
401 if (!ReadFmtChunkData(&header.fmt, readable)) { in ReadWavHeader()
[all …]
|
| /external/python/cpython2/Lib/ |
| D | pprint.py | 129 s, readable, recursive = self.format(object, {}, 0, 0)
130 return readable and not recursive
225 repr, readable, recursive = self.format(object, context.copy(),
227 if not readable:
274 readable = True
284 readable = readable and kreadable and vreadable
288 return "{%s}" % _commajoin(components), readable, recursive
308 readable = True
317 readable = False
321 return format % _commajoin(components), readable, recursive
|
| /external/llvm-project/lld/test/ELF/linkerscript/ |
| D | sections-constraint.s | 13 # BASE: .readable 00000004
27 # NO1: .readable 00000004
38 .section .readable, "a"
39 readable: label
|
| /external/apache-commons-compress/src/main/java/org/apache/commons/compress/compressors/lz77support/ |
| D | AbstractLZ77CompressorInputStream.java | 252 final int readable = Math.min(len, available()); in readFromBuffer() local
253 if (readable > 0) { in readFromBuffer()
254 System.arraycopy(buf, readIndex, b, off, readable); in readFromBuffer()
255 readIndex += readable; in readFromBuffer()
260 size += readable; in readFromBuffer()
261 return readable; in readFromBuffer()
|
| /external/python/cpython3/Lib/test/ |
| D | test_winconsoleio.py | 41 self.assertTrue(f.readable())
53 self.assertFalse(f.readable())
65 self.assertFalse(f.readable())
75 self.assertTrue(f.readable())
82 self.assertTrue(f.readable())
89 self.assertFalse(f.readable())
|
| /external/snakeyaml/src/main/java/org/yaml/snakeyaml/introspector/ |
| D | MethodProperty.java | 34 private final boolean readable; field in MethodProperty
42 this.readable = property.getReadMethod() != null; in MethodProperty()
69 return readable; in isReadable()
|
| /external/adhd/cras/src/common/ |
| D | byte_buffer.h | 71 size_t readable) in buf_adjust_readable() argument
73 buf->level = MIN(readable, buf->used_size); in buf_adjust_readable()
94 unsigned int *readable) in buf_read_pointer_size() argument
96 *readable = buf_readable(buf); in buf_read_pointer_size()
|
| D | cras_util.c | 236 int readable; in wait_for_dev_input_access() local
242 readable = access(pathname, R_OK); in wait_for_dev_input_access()
251 if (readable == 0 || (readable == -1 && errno == ENOENT)) { in wait_for_dev_input_access()
255 if (readable != -1 || errno != EACCES) { in wait_for_dev_input_access()
|
| /external/python/cpython3/Modules/_io/ |
| D | fileio.c | 61 unsigned int readable : 1; member
183 self->readable = 0; in fileio_new()
310 self->readable = 1;
332 self->readable = self->writable = 1;
345 if (self->readable && self->writable)
347 else if (self->readable)
575 return PyBool_FromLong((long) self->readable);
636 if (!self->readable)
794 if (!self->readable)
1056 if (self->readable)
[all …]
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | connection.py | 122 def __init__(self, handle, readable=True, writable=True): argument
126 if not readable and not writable:
130 self._readable = readable
164 def readable(self): member in _ConnectionBase
534 c2 = Connection(fd2, readable=False)
576 c2 = PipeConnection(h2, readable=duplex)
955 return rebuild_connection, (ds, conn.readable, conn.writable)
956 def rebuild_connection(ds, readable, writable): argument
958 return Connection(sock.detach(), readable, writable)
962 access = ((_winapi.FILE_GENERIC_READ if conn.readable else 0) |
[all …]
|
| /external/python/cpython2/Modules/_io/ |
| D | fileio.c | 51 unsigned int readable : 1; member
129 self->readable = 0; in fileio_new()
309 self->readable = 1; in fileio_init()
331 self->readable = self->writable = 1; in fileio_init()
344 if (self->readable && self->writable) in fileio_init()
346 else if (self->readable) in fileio_init()
471 return PyBool_FromLong((long) self->readable); in fileio_readable()
508 if (!self->readable) in fileio_readinto()
661 if (!self->readable) in fileio_read()
939 if (self->readable) in mode_string()
[all …]
|