Searched refs:stream_reader (Results 1 – 12 of 12) sorted by relevance
| /external/pytorch/torch/csrc/jit/serialization/ |
| D | import_read.cpp | 15 caffe2::serialize::PyTorchStreamReader& stream_reader, in readArchiveAndTensors() argument
21 std::tie(pickle_ptr, pickle_size) = stream_reader.getRecord(picklename); in readArchiveAndTensors()
42 return std::get<0>(stream_reader.getRecord(ss)); in readArchiveAndTensors()
54 unpickler.set_version(stream_reader.version()); in readArchiveAndTensors()
|
| D | import_read.h | 19 caffe2::serialize::PyTorchStreamReader& stream_reader,
|
| /external/rust/android-crates-io/crates/tokio-util/src/io/ |
| D | mod.rs | 18 mod stream_reader; module
30 pub use self::stream_reader::StreamReader;
|
| /external/python/cpython3/Lib/asyncio/ |
| D | streams.py | 191 def __init__(self, stream_reader, client_connected_cb=None, loop=None): argument
193 if stream_reader is not None:
194 self._stream_reader_wr = weakref.ref(stream_reader)
195 self._source_traceback = stream_reader._source_traceback
202 self._strong_reader = stream_reader
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_windows_events.py | 138 stream_reader = asyncio.StreamReader(loop=self.loop)
139 protocol = asyncio.StreamReaderProtocol(stream_reader,
145 clients.append((stream_reader, trans))
|
| /external/pytorch/torch/csrc/jit/mobile/compatibility/ |
| D | model_compatibility.cpp | 32 PyTorchStreamReader& stream_reader) { in readArchive() argument
49 (archive_name == "bytecode" && !isTensorInBytecodeArchive(stream_reader)); in readArchive()
58 stream_reader, in readArchive()
|
| D | model_compatibility.h | 46 caffe2::serialize::PyTorchStreamReader& stream_reader);
|
| /external/python/portpicker/src/ |
| D | portserver.py | 128 stream_reader = asyncio.StreamReader()
130 stream_reader, client_connected_cb)
|
| /external/pytorch/torch/csrc/jit/mobile/ |
| D | import.h | 89 caffe2::serialize::PyTorchStreamReader& stream_reader);
|
| D | import.cpp | 162 caffe2::serialize::PyTorchStreamReader& stream_reader) { in isTensorInBytecodeArchive() argument
163 auto records = stream_reader.getAllRecords(); in isTensorInBytecodeArchive()
|
| /external/scapy/scapy/layers/ |
| D | http.py | 363 reader = zstandard.ZstdDecompressor().stream_reader(bio)
|
| /external/python/cpython3/Doc/whatsnew/ |
| D | 2.0.rst | 207 4-element tuple: ``(encode_func, decode_func, stream_reader, stream_writer)``.
219 * *stream_reader* is a class that supports decoding input from a stream.
220 *stream_reader(file_obj)* returns an object that supports the :meth:`!read`,
|