Home
last modified time | relevance | path

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

/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/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()
353 self._reader, self._writer = Pipe(duplex=False)
362 return not self._reader.poll()
366 return (self._reader, self._writer, self._rlock, self._wlock)
369 (self._reader, self._writer, self._rlock, self._wlock) = state
[all …]
Dpool.py94 outqueue._reader.close()
237 self._quick_get = self._outqueue._reader.recv
432 if not outqueue._reader.poll():
481 while task_handler.is_alive() and inqueue._reader.poll():
482 inqueue._reader.recv()
/external/python/cpython3/Lib/multiprocessing/
Dqueues.py41 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,
77 self._recv_bytes = self._reader.recv_bytes
78 self._poll = self._reader.poll
134 self._reader.close()
323 self._reader, self._writer = connection.Pipe(duplex=False)
325 self._poll = self._reader.poll
336 return (self._reader, self._writer, self._rlock, self._wlock)
339 (self._reader, self._writer, self._rlock, self._wlock) = state
[all …]
Dpool.py100 outqueue._reader.close()
246 self._quick_get = self._outqueue._reader.recv
472 if not outqueue._reader.poll():
521 while task_handler.is_alive() and inqueue._reader.poll():
522 inqueue._reader.recv()
/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/python/cpython3/Lib/asyncio/
Dstreams.py280 self._reader = reader
285 if self._reader is not None:
286 info.append('reader=%r' % self._reader)
320 if self._reader is not None:
321 exc = self._reader.exception()
/external/tensorflow/tensorflow/contrib/timeseries/python/timeseries/
Dinput_pipeline.py590 self._reader = time_series_reader
600 features = self._reader.read_full()
667 self._reader = time_series_reader
669 self._reader.check_dataset_size(minimum_dataset_size=self._window_size)
692 features = self._reader.read()
Dtest_utils.py59 self._reader = time_series_reader
63 features = self._reader.read_full()
/external/freetype/include/freetype/internal/
Dpsaux.h279 #define T1_NEW_CALLBACK_FIELD( _ident, _reader, _dict ) \ argument
282 (T1_Field_ParseFunc)_reader, \
/external/python/cpython3/Lib/concurrent/futures/
Dprocess.py261 reader = result_queue._reader
/external/v8/tools/
Dgrokdump.py2308 def print_region(_reader, start, size, _location): argument