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/ |
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/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() 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 …]
|
D | pool.py | 94 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/ |
D | queues.py | 41 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 …]
|
D | pool.py | 100 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/ |
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/python/cpython3/Lib/asyncio/ |
D | streams.py | 280 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/ |
D | input_pipeline.py | 590 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()
|
D | test_utils.py | 59 self._reader = time_series_reader 63 features = self._reader.read_full()
|
/external/freetype/include/freetype/internal/ |
D | psaux.h | 279 #define T1_NEW_CALLBACK_FIELD( _ident, _reader, _dict ) \ argument 282 (T1_Field_ParseFunc)_reader, \
|
/external/python/cpython3/Lib/concurrent/futures/ |
D | process.py | 261 reader = result_queue._reader
|
/external/v8/tools/ |
D | grokdump.py | 2308 def print_region(_reader, start, size, _location): argument
|