| /external/javaparser/javaparser-core/generated-sources/javacc/com/github/javaparser/ |
| D | StreamProvider.java | 37 Reader _reader; field in StreamProvider
40 _reader = reader; in StreamProvider()
44 _reader = new BufferedReader(new InputStreamReader(stream)); in StreamProvider()
48 _reader = new BufferedReader(new InputStreamReader(stream, charsetName)); in StreamProvider()
53 int result = _reader.read(buffer, off, len); in read()
73 _reader.close(); in close()
|
| /external/javaparser/javaparser-symbol-solver-testing/src/test/test_sourcecode/javaparser_new_src/javaparser-generated-sources/com/github/javaparser/ |
| D | StreamProvider.java | 29 Reader _reader; field in StreamProvider
32 _reader = reader; in StreamProvider()
36 _reader = new BufferedReader(new InputStreamReader(stream)); in StreamProvider()
40 _reader = new BufferedReader(new InputStreamReader(stream, charsetName)); in StreamProvider()
45 int result = _reader.read(buffer, off, len); in read()
65 _reader.close(); in close()
|
| /external/vm_tools/p9/wire_format_derive/ |
| D | wire_format_derive.rs | 65 fn decode<R: io::Read>(_reader: &mut R) -> io::Result<Self> { in p9_wire_format_inner()
129 let #field = WireFormat::decode(_reader)?; in decode_wire_format()
214 let ident = WireFormat::decode(_reader)?; in decode()
215 let with_underscores = WireFormat::decode(_reader)?; in decode()
216 let other = WireFormat::decode(_reader)?; in decode()
276 fn decode<R: io::Read>(_reader: &mut R) -> io::Result<Self> { in end_to_end()
277 let a = WireFormat::decode(_reader)?; in end_to_end()
278 let b = WireFormat::decode(_reader)?; in end_to_end()
279 let c = WireFormat::decode(_reader)?; in end_to_end()
280 let d = WireFormat::decode(_reader)?; in end_to_end()
[all …]
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | queues.py | 42 self._reader, self._writer = connection.Pipe(duplex=False)
59 return (self._ignore_epipe, self._maxsize, self._reader, self._writer,
63 (self._ignore_epipe, self._maxsize, self._reader, self._writer,
83 self._recv_bytes = self._reader.recv_bytes
84 self._poll = self._reader.poll
143 self._reader.close()
341 self._reader, self._writer = connection.Pipe(duplex=False)
343 self._poll = self._reader.poll
350 self._reader.close()
358 return (self._reader, self._writer, self._rlock, self._wlock)
[all …]
|
| D | pool.py | 106 outqueue._reader.close()
277 task_queue_sentinels = [self._outqueue._reader]
278 self_notifier_sentinels = [self._change_notifier._reader]
346 self._quick_get = self._outqueue._reader.recv
621 if not outqueue._reader.poll():
673 while task_handler.is_alive() and inqueue._reader.poll():
674 inqueue._reader.recv()
936 return [self._change_notifier._reader]
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | queues.py | 62 self._reader, self._writer = Pipe(duplex=False)
78 return (self._maxsize, self._reader, self._writer,
82 (self._maxsize, self._reader, self._writer,
96 self._recv = self._reader.recv
97 self._poll = self._reader.poll
160 self._reader.close()
351 self._reader, self._writer = Pipe(duplex=False)
360 return not self._reader.poll()
364 return (self._reader, self._writer, self._rlock, self._wlock)
367 (self._reader, self._writer, self._rlock, self._wlock) = state
[all …]
|
| D | pool.py | 94 outqueue._reader.close()
239 self._quick_get = self._outqueue._reader.recv
437 if not outqueue._reader.poll():
486 while task_handler.is_alive() and inqueue._reader.poll():
487 inqueue._reader.recv()
|
| /external/webrtc/sdk/objc/components/capturer/ |
| D | RTCFileVideoCapturer.m | 38 AVAssetReader *_reader;
86 _reader = [[AVAssetReader alloc] initWithAsset:asset error:&error];
97 [_reader addOutput:_outTrack];
99 [_reader startReading];
133 [_reader cancelReading];
134 _reader = nil;
138 if (_reader.status == AVAssetReaderStatusCompleted) {
139 [_reader cancelReading];
140 _reader = nil;
|
| /external/python/cpython2/Lib/hotshot/ |
| D | log.py | 30 self._reader = _hotshot.logreader(logfn)
31 self._nextitem = self._reader.next
32 self._info = self._reader.info
48 self._reader.close()
52 return self._reader.fileno()
|
| /external/autotest/client/site_tests/usbpd_GFU/ |
| D | usbpd_GFU.py | 135 msg = self._reader.get_last_msg([r'%s.*is in RO' % port.index,
168 self._reader.set_start_by_current()
180 self._reader.set_start_by_current()
181 msg = self._reader.get_last_msg([fw_up_re],
245 self._reader = cros_logging.LogReader()
|
| /external/tensorflow/tensorflow/python/debug/lib/ |
| D | debug_events_reader.py | 932 self._reader = DebugEventsReader(dump_root)
960 source_files_iter = self._reader.source_files_iterator()
976 stack_frames_iter = self._reader.stack_frames_iterator()
998 graphs_iter = self._reader.graphs_iterator()
1038 self._reader.graph_execution_traces_iterators()):
1103 execution_iter = self._reader.execution_iterator()
1139 return list(self._reader.read_source_files_event(offset).source_file.lines)
1147 return self._reader.starting_wall_time()
1158 return self._reader.tensorflow_version()
1162 return self._reader.tfdbg_run_id()
[all …]
|
| /external/perfetto/src/traced/probes/ftrace/ |
| D | ftrace_controller.h | 97 PerCpuState(std::unique_ptr<CpuReader> _reader, size_t _period_page_quota) in PerCpuState()
98 : reader(std::move(_reader)), period_page_quota(_period_page_quota) {} in PerCpuState()
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | process.py | 69 self._reader, self._writer = mp.Pipe(duplex=False)
75 self._reader.close()
83 while self._reader.poll():
84 self._reader.recv_bytes()
372 result_reader = self.result_queue._reader
374 wakeup_reader = self.thread_wakeup._reader
|
| /external/python/cpython3/Lib/asyncio/ |
| D | streams.py | 325 self._reader = reader
332 if self._reader is not None:
372 if self._reader is not None:
373 exc = self._reader.exception()
|
| /external/rust/crates/futures-util/src/io/ |
| D | mod.rs | 45 unsafe fn initialize<R: AsyncRead>(_reader: &R, buf: &mut [u8]) { in initialize()
48 if !_reader.initializer().should_initialize() { in initialize()
|
| /external/jackson-core/src/main/java/com/fasterxml/jackson/core/json/ |
| D | ReaderBasedJsonParser.java | 54 protected Reader _reader; field in ReaderBasedJsonParser
134 _reader = r; in ReaderBasedJsonParser()
152 _reader = r; in ReaderBasedJsonParser()
187 @Override public Object getInputSource() { return _reader; } in getInputSource()
212 if (_reader != null) { in _closeInput()
214 _reader.close(); in _closeInput()
216 _reader = null; in _closeInput()
254 if (_reader != null) { in _loadMore()
255 int count = _reader.read(_inputBuffer, 0, _inputBuffer.length); in _loadMore()
|
| /external/freetype/include/freetype/internal/ |
| D | psaux.h | 288 #define T1_NEW_CALLBACK_FIELD( _ident, _reader, _dict ) \ argument
291 (T1_Field_ParseFunc)_reader, \
|
| /external/python/cpython3/Lib/test/ |
| D | _test_multiprocessing.py | 5281 self.assertTrue(queue._reader.closed)
|