Home
last modified time | relevance | path

Searched refs:_reader (Results 1 – 22 of 22) sorted by relevance

/external/javaparser/javaparser-core/generated-sources/javacc/com/github/javaparser/
DStreamProvider.java37 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/
DStreamProvider.java29 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/
Dwire_format_derive.rs65 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/
Dqueues.py42 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 …]
Dpool.py106 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/
Dqueues.py62 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 …]
Dpool.py94 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/
DRTCFileVideoCapturer.m38 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/
Dlog.py30 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/
Dusbpd_GFU.py135 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/
Ddebug_events_reader.py932 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/
Dftrace_controller.h97 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/
Dprocess.py69 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/
Dstreams.py325 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/
Dmod.rs45 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/
DReaderBasedJsonParser.java54 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/
Dpsaux.h288 #define T1_NEW_CALLBACK_FIELD( _ident, _reader, _dict ) \ argument
291 (T1_Field_ParseFunc)_reader, \
/external/javaparser/javaparser-symbol-solver-testing/src/test/resources/
Djavaparser-core-3.0.0-alpha.2.jarMETA-INF/MANIFEST.MF META-INF/ com/ com/github/ com/ ...
/external/guice/extensions/struts2/lib/
Djetty-6.1.0.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/mortbay/ org/ ...
/external/python/cpython3/Lib/test/
D_test_multiprocessing.py5281 self.assertTrue(queue._reader.closed)
/external/guice/extensions/persist/lib/
Ddb4o-6.4.14.8131-java5.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/db4o/ com/ ...
/external/javaparser/javaparser-symbol-solver-testing/src/test/test_sourcecode/javasymbolsolver_0_6_0/lib/
Djavaparser-core-3.3.0.jarMETA-INF/MANIFEST.MF META-INF/ com/ com/github/ com/ ...