| /external/pytorch/torch/distributed/checkpoint/ |
| D | filesystem.py | 274 create_stream: Callable,
318 with create_stream(file_name, "wb") as stream:
344 def create_stream( member in FileSystemBase
385 def create_stream( member in FileSystem
540 self.fs.create_stream,
553 create_stream=self.fs.create_stream,
583 with self.fs.create_stream(tmp_path, "wb") as metadata_file:
643 with self.fs.create_stream(new_path, "rb") as stream:
679 with self.fs.create_stream(path, "rb") as metadata_file:
|
| D | _fsspec_filesystem.py | 32 def create_stream( member in FileSystem
|
| /external/pytorch/torch/cuda/ |
| D | _sanitizer.py | 223 self.create_stream(DEFAULT_STREAM_ID)
233 self.create_stream(stream)
256 def create_stream(self, stream: StreamId) -> None: member in StreamSynchronizations
448 self.syncs.create_stream(stream)
|
| /external/tensorflow/tensorflow/c/experimental/stream_executor/ |
| D | stream_executor_test.cc | 268 se_.create_stream = [](const SP_Device* const device, SP_Stream* stream, in TEST_F()
384 se_.create_stream = [](const SP_Device* const device, SP_Stream* stream, in TEST_F()
529 se_.create_stream = [](const SP_Device* const device, SP_Stream* stream, in TEST_F()
677 se_.create_stream = [](const SP_Device* const device, SP_Stream* stream, in TEST_F()
808 se_.create_stream = [](const SP_Device* const device, SP_Stream* stream, in TEST_F()
835 se_.create_stream = [](const SP_Device* const device, SP_Stream* stream, in TEST_F()
|
| D | stream_executor_internal.h | 115 stream_executor_->create_stream(device_, &stream_handle_, c_status.get()); in Create()
|
| D | stream_executor_test_util.cc | 108 se->create_stream = CreateStream; in PopulateDefaultStreamExecutor()
|
| D | stream_executor.h | 285 void (*create_stream)(const SP_Device* device, SP_Stream* stream, member
|
| D | stream_executor.cc | 126 TF_VALIDATE_NOT_NULL(SP_StreamExecutor, se, create_stream); in ValidateSPStreamExecutor()
|
| /external/python/bumble/tests/ |
| D | a2dp_test.py | 228 stream = await client.create_stream(source, remote_sink)
253 stream = await client.create_stream(source, remote_sink)
|
| /external/python/bumble/examples/ |
| D | run_a2dp_source.py | 105 stream = await protocol.create_stream(source, sink)
|
| /external/cronet/stable/net/quic/ |
| D | quic_session_pool_test_base.cc | 528 bool create_stream) const { in StreamCancellationQpackDecoderInstruction()
534 if (create_stream) { in StreamCancellationQpackDecoderInstruction()
|
| D | quic_session_pool_test_base.h | 244 bool create_stream) const;
|
| D | quic_network_transaction_unittest.cc | 961 bool create_stream) const { in StreamCancellationQpackDecoderInstruction()
967 if (create_stream) { in StreamCancellationQpackDecoderInstruction()
|
| /external/cronet/tot/net/quic/ |
| D | quic_session_pool_test_base.cc | 528 bool create_stream) const { in StreamCancellationQpackDecoderInstruction()
534 if (create_stream) { in StreamCancellationQpackDecoderInstruction()
|
| D | quic_session_pool_test_base.h | 244 bool create_stream) const;
|
| D | quic_network_transaction_unittest.cc | 961 bool create_stream) const { in StreamCancellationQpackDecoderInstruction()
967 if (create_stream) { in StreamCancellationQpackDecoderInstruction()
|
| /external/crosvm/devices/src/virtio/video/decoder/ |
| D | mod.rs | 476 fn create_stream( in create_stream() method
976 } => self.create_stream( in process_cmd()
|
| /external/python/bumble/bumble/ |
| D | avdtp.py | 1334 async def create_stream( member in Protocol
|