Home
last modified time | relevance | path

Searched refs:recv_stream (Results 1 – 11 of 11) sorted by relevance

/external/webrtc/audio/
Daudio_receive_stream_unittest.cc241 auto recv_stream = helper.CreateAudioReceiveStream(); in TEST() local
249 auto recv_stream = helper.CreateAudioReceiveStream(); in TEST() local
262 recv_stream->OnRtpPacket(parsed_packet); in TEST()
270 auto recv_stream = helper.CreateAudioReceiveStream(); in TEST() local
275 recv_stream->DeliverRtcp(&rtcp_packet[0], rtcp_packet.size()); in TEST()
282 auto recv_stream = helper.CreateAudioReceiveStream(); in TEST() local
284 AudioReceiveStream::Stats stats = recv_stream->GetStats(); in TEST()
345 auto recv_stream = helper.CreateAudioReceiveStream(); in TEST() local
348 recv_stream->SetGain(0.765f); in TEST()
386 auto recv_stream = helper.CreateAudioReceiveStream(); in TEST() local
[all …]
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc532 grpc_core::OrphanablePtr<grpc_core::ByteStream> recv_stream; in BM_TransportStreamRecv() local
571 op.payload->recv_message.recv_message = &recv_stream; in BM_TransportStreamRecv()
578 if (recv_stream == nullptr) { in BM_TransportStreamRecv()
587 if (received == recv_stream->length()) { in BM_TransportStreamRecv()
588 recv_stream.reset(); in BM_TransportStreamRecv()
592 } while (recv_stream->Next(recv_stream->length() - received, in BM_TransportStreamRecv()
594 GRPC_ERROR_NONE == recv_stream->Pull(&recv_slice) && in BM_TransportStreamRecv()
600 recv_stream->Pull(&recv_slice); in BM_TransportStreamRecv()
/external/tensorflow/tensorflow/core/common_runtime/gpu/
Dgpu_util.cc217 auto recv_stream = in DeviceToDeviceCopy() local
219 if (recv_stream == nullptr) { in DeviceToDeviceCopy()
228 send_device_to_device_stream->ThenWaitFor(recv_stream); in DeviceToDeviceCopy()
305 se::Stream* recv_stream = nullptr; in CopyCPUTensorToGPU() local
307 &dev_info, &recv_stream); in CopyCPUTensorToGPU()
322 recv_host_to_device_stream->ThenWaitFor(recv_stream); in CopyCPUTensorToGPU()
/external/webrtc/call/
Dcall_unittest.cc188 AudioReceiveStream* recv_stream = in TEST() local
190 EXPECT_NE(recv_stream, nullptr); in TEST()
199 static_cast<internal::AudioReceiveStream*>(recv_stream); in TEST()
207 call->DestroyAudioReceiveStream(recv_stream); in TEST()
227 AudioReceiveStream* recv_stream = in TEST() local
229 EXPECT_NE(recv_stream, nullptr); in TEST()
232 static_cast<internal::AudioReceiveStream*>(recv_stream); in TEST()
236 call->DestroyAudioReceiveStream(recv_stream); in TEST()
/external/webrtc/media/engine/
Dwebrtc_video_engine_unittest.cc2571 FakeVideoReceiveStream* recv_stream = in TestSetRecvRtpHeaderExtensions() local
2575 ASSERT_EQ(1u, recv_stream->GetConfig().rtp.extensions.size()); in TestSetRecvRtpHeaderExtensions()
2576 EXPECT_EQ(id, recv_stream->GetConfig().rtp.extensions[0].id); in TestSetRecvRtpHeaderExtensions()
2577 EXPECT_EQ(ext_uri, recv_stream->GetConfig().rtp.extensions[0].uri); in TestSetRecvRtpHeaderExtensions()
2590 recv_stream = fake_call_->GetVideoReceiveStreams()[0]; in TestSetRecvRtpHeaderExtensions()
2591 EXPECT_TRUE(recv_stream->GetConfig().rtp.extensions.empty()); in TestSetRecvRtpHeaderExtensions()
2596 recv_stream = fake_call_->GetVideoReceiveStreams()[0]; in TestSetRecvRtpHeaderExtensions()
2597 ASSERT_EQ(1u, recv_stream->GetConfig().rtp.extensions.size()); in TestSetRecvRtpHeaderExtensions()
2598 EXPECT_EQ(id, recv_stream->GetConfig().rtp.extensions[0].id); in TestSetRecvRtpHeaderExtensions()
2599 EXPECT_EQ(ext_uri, recv_stream->GetConfig().rtp.extensions[0].uri); in TestSetRecvRtpHeaderExtensions()
[all …]
Dwebrtc_voice_engine_unittest.cc294 const auto* recv_stream = call_.GetAudioReceiveStream(ssrc); in GetRecvStream() local
295 EXPECT_TRUE(recv_stream); in GetRecvStream()
296 return *recv_stream; in GetRecvStream()
/external/webrtc/test/scenario/
Dvideo_stream.cc593 for (auto* recv_stream : receive_streams_) in ~ReceiveVideoStream() local
594 receiver_->call_->DestroyVideoReceiveStream(recv_stream); in ~ReceiveVideoStream()
602 for (auto* recv_stream : receive_streams_) in Start() local
603 recv_stream->Start(); in Start()
610 for (auto* recv_stream : receive_streams_) in Stop() local
611 recv_stream->Stop(); in Stop()
/external/webrtc/video/
Dvideo_analyzer.h65 void SetAudioReceiveStream(AudioReceiveStream* recv_stream);
Dvideo_analyzer.cc194 void VideoAnalyzer::SetAudioReceiveStream(AudioReceiveStream* recv_stream) { in SetAudioReceiveStream() argument
197 audio_receive_stream_ = recv_stream; in SetAudioReceiveStream()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc103 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> recv_stream; member
556 receiver->recv_stream.Init(&receiver->recv_message, 0); in message_transfer_locked()
558 receiver->recv_stream.get()); in message_transfer_locked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc258 grpc_core::ManualConstructor<grpc_core::SliceBufferByteStream> recv_stream; member
566 receiver->recv_stream.Init(&receiver->recv_message, 0); in message_transfer_locked()
568 receiver->recv_stream.get()); in message_transfer_locked()