Searched refs:_reader (Results 1 – 14 of 14) sorted by relevance
| /third_party/mindspore/mindspore/mindrecord/ |
| D | filereader.py | 56 self._reader = ShardReader()
57 self._reader.open(file_name, num_consumer, columns, operator)
58 self._header = ShardHeader(self._reader.get_header())
59 self._reader.launch()
71 iterator = self._reader.get_next()
75 iterator = self._reader.get_next()
79 self._reader.close()
|
| D | shardreader.py | 31 self._reader = ms.ShardReader()
56 ret = self._reader.open(file_name, load_dataset, num_consumer, columns, operator)
73 ret = self._reader.launch()
86 return self._reader.get_next()
95 return self._reader.get_blob_fields()
104 return self._reader.get_header()
108 self._reader.close()
|
| /third_party/python/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]
|
| /third_party/python/Lib/importlib/ |
| D | _adapters.py | 60 def _reader(self): member in DegenerateFiles
68 reader = self._reader
72 return getattr(self._reader, attr)
|
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/iomgr/ |
| D | socket.pyx.pxi | 29 self._reader = None
48 socket._reader = reader
70 self._reader, self._writer = await asyncio.open_connection(host, port)
91 assert not self._reader
102 inbound_buffer = await self._reader.read(n=length)
162 return self._reader and not self._reader._transport.is_closing()
|
| D | socket.pxd.pxi | 22 object _reader
|
| /third_party/python/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
|
| /third_party/python/Lib/asyncio/ |
| D | streams.py | 310 self._reader = reader
317 if self._reader is not None:
357 if self._reader is not None:
358 exc = self._reader.exception()
|
| /third_party/freetype/include/freetype/internal/ |
| D | psaux.h | 288 #define T1_NEW_CALLBACK_FIELD( _ident, _reader, _dict ) \ argument
291 (T1_Field_ParseFunc)_reader, \
|
| /third_party/skia/third_party/externals/freetype/include/freetype/internal/ |
| D | psaux.h | 288 #define T1_NEW_CALLBACK_FIELD( _ident, _reader, _dict ) \ argument
291 (T1_Field_ParseFunc)_reader, \
|
| /third_party/flutter/skia/third_party/externals/freetype/include/freetype/internal/ |
| D | psaux.h | 289 #define T1_NEW_CALLBACK_FIELD( _ident, _reader, _dict ) \ argument
292 (T1_Field_ParseFunc)_reader, \
|
| /third_party/python/Lib/test/ |
| D | _test_multiprocessing.py | 5416 self.assertTrue(queue._reader.closed)
|
| /third_party/json/ |
| D | ChangeLog.md | 1355 - string\_type in binary\_reader [\#941](https://github.com/nlohmann/json/issues/941)
1394 - Templatize std::string in binary\_reader \#941 [\#950](https://github.com/nlohmann/json/pull/950)…
|