Home
last modified time | relevance | path

Searched refs:CreateStream (Results 1 – 25 of 50) sorted by relevance

12

/external/libbrillo/brillo/streams/
Dfake_stream_test.cc31 void CreateStream(Stream::AccessMode mode) { in CreateStream() function in brillo::FakeStreamTest
70 CreateStream(Stream::AccessMode::READ); in TEST_F()
82 CreateStream(Stream::AccessMode::WRITE); in TEST_F()
94 CreateStream(Stream::AccessMode::READ_WRITE); in TEST_F()
106 CreateStream(Stream::AccessMode::READ); in TEST_F()
115 CreateStream(Stream::AccessMode::READ); in TEST_F()
129 CreateStream(Stream::AccessMode::READ); in TEST_F()
147 CreateStream(Stream::AccessMode::READ); in TEST_F()
180 CreateStream(Stream::AccessMode::READ); in TEST_F()
205 CreateStream(Stream::AccessMode::READ); in TEST_F()
[all …]
Dfile_stream_test.cc158 CreateStream(S_IFREG, Stream::AccessMode::READ_WRITE); in SetUp()
165 void CreateStream(mode_t file_mode, Stream::AccessMode access_mode) { in CreateStream() function in brillo::FileStreamTest
214 CreateStream(S_IFREG, Stream::AccessMode::READ_WRITE); in TEST_F()
218 CreateStream(S_IFREG, Stream::AccessMode::READ); in TEST_F()
220 CreateStream(S_IFREG, Stream::AccessMode::WRITE); in TEST_F()
225 CreateStream(S_IFREG, Stream::AccessMode::READ_WRITE); in TEST_F()
229 CreateStream(S_IFREG, Stream::AccessMode::READ); in TEST_F()
231 CreateStream(S_IFREG, Stream::AccessMode::WRITE); in TEST_F()
236 CreateStream(S_IFBLK, Stream::AccessMode::READ_WRITE); in TEST_F()
238 CreateStream(S_IFDIR, Stream::AccessMode::READ_WRITE); in TEST_F()
[all …]
/external/webrtc/net/dcsctp/tx/
Dstream_scheduler_test.cc82 stream_ = scheduler.CreateStream(&producer_, stream_id, priority); in TestStream()
106 scheduler.CreateStream(&producer, StreamID(1), StreamPriority(2)); in TEST()
125 scheduler.CreateStream(&producer, StreamID(1), StreamPriority(2)); in TEST()
147 scheduler.CreateStream(&producer1, StreamID(1), StreamPriority(2)); in TEST()
161 scheduler.CreateStream(&producer2, StreamID(2), StreamPriority(2)); in TEST()
208 scheduler.CreateStream(&producer1, StreamID(1), StreamPriority(2)); in TEST()
222 scheduler.CreateStream(&producer2, StreamID(2), StreamPriority(2)); in TEST()
249 scheduler.CreateStream(&producer1, StreamID(1), StreamPriority(2)); in TEST()
277 scheduler.CreateStream(&producer1, StreamID(1), StreamPriority(2)); in TEST()
306 scheduler.CreateStream(&producer1, StreamID(1), StreamPriority(2)); in TEST()
[all …]
Dstream_scheduler.h164 std::unique_ptr<Stream> CreateStream(StreamProducer* producer, in CreateStream() function
Drr_send_queue.h146 scheduler_stream_(scheduler->CreateStream(this, stream_id, priority)),
/external/cronet/net/websockets/
Dwebsocket_basic_stream_test.cc168 void CreateStream(base::span<const MockRead> reads, in CreateStream() function in net::__anonb5c7d3550111::WebSocketBasicStreamSocketTest
196 CreateStream(reads_, base::span<MockWrite>()); in CreateRead()
239 CreateStream(reads_, base::span<MockWrite>()); in CreateChunkedRead()
291 CreateStream(base::span<MockRead>(), base::span<MockWrite>()); in TEST_F()
340 CreateStream(reads, base::span<MockWrite>()); in TEST_F()
354 CreateStream(reads, base::span<MockWrite>()); in TEST_F()
390 CreateStream(reads, base::span<MockWrite>()); in TEST_F()
576 CreateStream(reads, base::span<MockWrite>()); in TEST_F()
588 CreateStream(reads, base::span<MockWrite>()); in TEST_F()
611 CreateStream(reads, base::span<MockWrite>()); in TEST_F()
[all …]
/external/cronet/net/quic/
Dquic_stream_factory_test.cc347 std::unique_ptr<HttpStream> CreateStream(QuicStreamRequest* request) { in CreateStream() function in net::test::QuicStreamFactoryTestBase
440 std::unique_ptr<HttpStream> stream = CreateStream(&request); in GetSourcePortForNewSessionInner()
590 std::unique_ptr<HttpStream> stream = CreateStream(&request); in VerifyServerMigration()
1038 std::unique_ptr<HttpStream> stream = CreateStream(&request); in TEST_P()
1052 stream = CreateStream(&request2); in TEST_P()
1066 stream = CreateStream(&request3); // Will reset stream 5. in TEST_P()
1093 std::unique_ptr<HttpStream> stream = CreateStream(&request); in TEST_P()
1107 stream = CreateStream(&request2); in TEST_P()
1121 stream = CreateStream(&request3); // Will reset stream 5. in TEST_P()
1158 std::unique_ptr<HttpStream> stream = CreateStream(&request); in TEST_P()
[all …]
/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
Dquic_test_server.h45 virtual QuicSimpleServerStream* CreateStream(
49 virtual QuicSimpleServerStream* CreateStream(
Dquic_test_server.cc45 stream_factory_->CreateStream(id, this, server_backend()); in CreateIncomingStream()
/external/openscreen/cast/streaming/
Dsender_session.cc34 AudioStream CreateStream(int index, in CreateStream() function
53 VideoStream CreateStream(int index, in CreateStream() function
91 CreateStream(i + offset_index, configs[i], use_android_rtp_hack)); in CreateStreamList()
118 CreateStream(0, audio_config, use_android_rtp_hack); in CreateRemotingOffer()
125 CreateStream(1, video_config, use_android_rtp_hack); in CreateRemotingOffer()
/external/crosvm/tools/audio_streams_conformance_test/src/
Derror.rs18 CreateStream(BoxError), enumerator
Dmain.rs44 .map_err(Error::CreateStream)?; in run_playback()
/external/tensorflow/tensorflow/compiler/xla/stream_executor/gpu/
Dgpu_stream.cc26 if (!GpuDriver::CreateStream(parent_->gpu_context(), &gpu_stream_, in Init()
/external/tensorflow/tensorflow/c/experimental/stream_executor/
Dstream_executor_test_util.cc39 void CreateStream(const SP_Device* const device, SP_Stream* stream, in CreateStream() function
108 se->create_stream = CreateStream; in PopulateDefaultStreamExecutor()
/external/tensorflow/tensorflow/core/util/
Dmkl_util.h228 inline dnnl::stream* CreateStream(MklDnnThreadPool* eigen_tp, in CreateStream() function
616 cpu_stream.reset(CreateStream(&eigen_tp, cpu_engine));
618 cpu_stream.reset(CreateStream(nullptr, cpu_engine));
1546 cpu_stream.reset(CreateStream(&eigen_tp, prim->GetEngine()));
1548 cpu_stream.reset(CreateStream(nullptr, prim->GetEngine()));
1613 cpu_stream.reset(CreateStream(&eigen_tp, prim->GetEngine()));
1615 cpu_stream.reset(CreateStream(nullptr, prim->GetEngine()));
1724 cpu_stream.reset(CreateStream(&eigen_tp, prim->GetEngine()));
1726 cpu_stream.reset(CreateStream(nullptr, prim->GetEngine()));
/external/tensorflow/tensorflow/core/kernels/mkl/
Dmkl_avgpooling_op.cc130 fwd_cpu_stream.reset(CreateStream(&eigen_tp, pooling_fwd->GetEngine())); in Compute()
264 bwd_cpu_stream.reset(CreateStream(&eigen_tp, pooling_bwd->GetEngine())); in Compute()
Dmkl_maxpooling_op.cc152 fwd_cpu_stream.reset(CreateStream(&eigen_tp, pooling_fwd->GetEngine())); in Compute()
314 bwd_cpu_stream.reset(CreateStream(&eigen_tp, pooling_bwd->GetEngine())); in Compute()
Dmkl_transpose_op.cc88 transpose_stream.reset(CreateStream(&eigen_tp, prim->GetEngine())); in MKLTransposeND()
Dmkl_dequantize_op.cc76 reorder_stream.reset(CreateStream(&eigen_tp, cpu_engine)); in Compute()
Dmkl_requantize_per_channel_op.cc143 reorder_stream.reset(CreateStream(&eigen_tp, cpu_engine_)); in Compute()
Dmkl_aggregate_ops.cc178 fwd_cpu_stream.reset(CreateStream(&eigen_tp, cpu_engine)); in Compute()
Dmkl_einsum_op.cc123 cpu_stream.reset(CreateStream(&eigen_tp, matmul_prim->GetEngine())); in MKLContractOperands()
/external/crosvm/devices/src/virtio/snd/sys/
Dunix.rs145 .map_err(Error::CreateStream)? in set_up_async_playback_stream()
Dwindows.rs120 .map_err(Error::CreateStream)?; in set_up_async_playback_stream()
/external/crosvm/devices/src/pci/ac97_bus_master/sys/
Dunix.rs59 CreateStream(BoxError), enumerator
216 .map_err(AudioError::CreateStream)?; in create_audio_worker()

12