| /external/webrtc/modules/rtp_rtcp/source/ |
| D | flexfec_receiver_unittest.cc | 64 : receiver_(kFlexfecSsrc, kMediaSsrc, &recovered_packet_receiver_), in FlexfecReceiverTest()
78 FlexfecReceiverForTest receiver_; member in webrtc::FlexfecReceiverTest
118 receiver_.AddReceivedPacket(ParsePacket(*media_packet)); in TEST_F()
120 receiver_.ProcessReceivedPacket(*received_packet); in TEST_F()
134 receiver_.AddReceivedPacket(ParsePacket(*media_packet)); in TEST_F()
136 receiver_.ProcessReceivedPacket(*received_packet); in TEST_F()
137 received_packet = receiver_.AddReceivedPacket(ParsePacket(*fec_packet)); in TEST_F()
139 receiver_.ProcessReceivedPacket(*received_packet); in TEST_F()
155 receiver_.AddReceivedPacket(ParsePacket(*media_packet)); in TEST_F()
157 receiver_.ProcessReceivedPacket(*received_packet); in TEST_F()
[all …]
|
| D | rtp_rtcp_impl_unittest.cc | 54 : receiver_(nullptr), in SendTransport()
60 void SetRtpRtcpModule(ModuleRtpRtcpImpl* receiver) { receiver_ = receiver; } in SetRtpRtcpModule()
83 EXPECT_TRUE(receiver_); in SendRtcp()
84 receiver_->IncomingRtcpPacket(data, len); in SendRtcp()
89 ModuleRtpRtcpImpl* receiver_; member in webrtc::__anonc3f987650111::SendTransport
172 receiver_(&clock_, /*is_sender=*/false) {} in RtpRtcpImplTest()
194 EXPECT_EQ(0, receiver_.impl_->SetSendingStatus(false)); in SetUp()
195 receiver_.impl_->SetSendingMediaStatus(false); in SetUp()
197 sender_.transport_.SetRtpRtcpModule(receiver_.impl_.get()); in SetUp()
198 receiver_.transport_.SetRtpRtcpModule(sender_.impl_.get()); in SetUp()
[all …]
|
| D | rtp_rtcp_impl2_unittest.cc | 56 : receiver_(nullptr), in SendTransport()
62 void SetRtpRtcpModule(ModuleRtpRtcpImpl2* receiver) { receiver_ = receiver; } in SetRtpRtcpModule()
85 EXPECT_TRUE(receiver_); in SendRtcp()
86 receiver_->IncomingRtcpPacket(data, len); in SendRtcp()
93 ModuleRtpRtcpImpl2* receiver_; member in webrtc::__anon350570d70111::SendTransport
177 receiver_(&time_controller_, /*is_sender=*/false) {} in RtpRtcpImpl2Test()
199 EXPECT_EQ(0, receiver_.impl_->SetSendingStatus(false)); in SetUp()
200 receiver_.impl_->SetSendingMediaStatus(false); in SetUp()
202 sender_.transport_.SetRtpRtcpModule(receiver_.impl_.get()); in SetUp()
203 receiver_.transport_.SetRtpRtcpModule(sender_.impl_.get()); in SetUp()
[all …]
|
| /external/webrtc/modules/video_coding/ |
| D | video_coding_impl.cc | 47 receiver_(clock, timing_.get()) {} in VideoCodingModuleImpl()
52 int64_t receiver_time = receiver_.TimeUntilNextProcess(); in TimeUntilNextProcess()
57 void Process() override { receiver_.Process(); } in Process()
62 return receiver_.RegisterReceiveCodec(receiveCodec, numberOfCores, in RegisterReceiveCodec()
68 receiver_.RegisterExternalDecoder(externalDecoder, payloadType); in RegisterExternalDecoder()
74 return receiver_.RegisterReceiveCallback(receiveCallback); in RegisterReceiveCallback()
79 return receiver_.RegisterFrameTypeCallback(frameTypeCallback); in RegisterFrameTypeCallback()
85 return receiver_.RegisterPacketRequestCallback(callback); in RegisterPacketRequestCallback()
89 return receiver_.Decode(maxWaitTimeMs); in Decode()
96 return receiver_.IncomingPacket(incomingPayload, payloadLength, rtp_header, in IncomingPacket()
[all …]
|
| D | receiver_unittest.cc | 35 receiver_(&timing_, clock_.get()) { in TestVCMReceiver()
48 return receiver_.InsertPacket(packet); in InsertPacket()
57 return receiver_.InsertPacket(packet); in InsertPacketAndPop()
78 VCMEncodedFrame* frame = receiver_.FrameForDecoding(0, false); in DecodeNextFrame()
81 receiver_.ReleaseFrame(frame); in DecodeNextFrame()
87 VCMReceiver receiver_; member in webrtc::TestVCMReceiver
96 receiver_.SetNackSettings(kMaxNackListSize, kMaxPacketAgeToNack, in TEST_F()
103 std::vector<uint16_t> nack_list = receiver_.NackList(&request_key_frame); in TEST_F()
111 receiver_.SetNackSettings(kMaxNackListSize, kMaxPacketAgeToNack, in TEST_F()
118 std::vector<uint16_t> nack_list = receiver_.NackList(&request_key_frame); in TEST_F()
[all …]
|
| D | video_receiver_unittest.cc | 54 : clock_(0), timing_(&clock_), receiver_(&clock_, &timing_) {} in TestVideoReceiver()
58 receiver_.RegisterExternalDecoder(&decoder_, kUnusedPayloadType); in SetUp()
61 EXPECT_EQ(0, receiver_.RegisterReceiveCodec(&settings_, 1, true)); in SetUp()
66 receiver_.SetNackSettings(kMaxNackListSize, kMaxPacketAgeToNack, 0); in SetUp()
68 0, receiver_.RegisterPacketRequestCallback(&packet_request_callback_)); in SetUp()
75 receiver_.RegisterReceiveCallback(&receive_callback_); in SetUp()
99 EXPECT_EQ(0, receiver_.IncomingPacket(payload, 0, *header, video_header)); in InsertAndVerifyPaddingFrame()
102 receiver_.Process(); in InsertAndVerifyPaddingFrame()
104 EXPECT_EQ(VCM_FRAME_NOT_READY, receiver_.Decode(kMaxWaitTimeMs)); in InsertAndVerifyPaddingFrame()
112 receiver_.IncomingPacket(payload, length, *header, video_header)); in InsertAndVerifyDecodableFrame()
[all …]
|
| /external/webrtc/modules/audio_coding/acm2/ |
| D | acm_receiver_unittest.cc | 47 receiver_.reset(new AcmReceiver(config_)); in SetUp()
48 ASSERT_TRUE(receiver_.get() != NULL); in SetUp()
118 int ret_val = receiver_->InsertPacket( in SendData()
136 std::unique_ptr<AcmReceiver> receiver_; member in webrtc::acm2::AcmReceiverTestOldApi
153 receiver_->SetCodecs(codecs); in TEST_F()
163 EXPECT_EQ(0, receiver_->GetAudio(kOutSampleRateHz, &frame, &muted)); in TEST_F()
166 receiver_->last_output_sample_rate_hz()); in TEST_F()
185 receiver_->SetCodecs({{payload_type, codec}}); in RunVerifyAudioFrame()
205 EXPECT_EQ(0, receiver_->GetAudio(output_sample_rate_hz, &frame, &muted)); in RunVerifyAudioFrame()
212 receiver_->GetAudio(output_sample_rate_hz, &frame, &muted)); in RunVerifyAudioFrame()
[all …]
|
| D | audio_coding_module.cc | 164 acm2::AcmReceiver receiver_; // AcmReceiver has it's own internal lock. member in webrtc::__anon397f81ba0111::AudioCodingModuleImpl
211 receiver_(config), in AudioCodingModuleImpl()
544 receiver_.RemoveAllCodecs(); in InitializeReceiverSafe()
545 receiver_.FlushBuffers(); in InitializeReceiverSafe()
554 receiver_.SetCodecs(codecs); in SetReceiveCodecs()
562 return receiver_.InsertPacket( in IncomingPacket()
573 if (receiver_.GetAudio(desired_freq_hz, audio_frame, muted) != 0) { in PlayoutData10Ms()
587 receiver_.GetNetworkStatistics(statistics); in GetNetworkStatistics()
|
| /external/openscreen/cast/standalone_receiver/ |
| D | dummy_player.cc | 17 DummyPlayer::DummyPlayer(Receiver* receiver) : receiver_(receiver) { in DummyPlayer()
18 OSP_DCHECK(receiver_); in DummyPlayer()
19 receiver_->SetConsumer(this); in DummyPlayer()
23 receiver_->SetConsumer(nullptr); in ~DummyPlayer()
30 receiver_->ConsumeNextFrame(absl::Span<uint8_t>(buffer_)); in OnFramesReady()
36 receiver_->rtp_timebase()); in OnFramesReady()
37 OSP_LOG_INFO << "[SSRC " << receiver_->ssrc() << "] " in OnFramesReady()
|
| D | sdl_player_base.cc | 30 receiver_(receiver), in SDLPlayerBase()
37 OSP_DCHECK(receiver_); in SDLPlayerBase()
41 receiver_->SetConsumer(this); in SDLPlayerBase()
46 receiver_->SetConsumer(nullptr); in ~SDLPlayerBase()
55 receiver_->SetConsumer(nullptr); in OnFatalError()
74 .ToDuration<Clock::duration>(receiver_->rtp_timebase()); in ResyncAndDeterminePresentationTime()
105 EncodedFrame frame = receiver_->ConsumeNextFrame(buffer_.GetSpan()); in OnFramesReady()
140 receiver_->RequestKeyFrame(); in OnDecodeError()
220 receiver_->SetPlayerProcessingTime(recent_processing_time_); in RenderAndSchedulePresentation()
226 const int buffer_size = receiver_->AdvanceToNextFrame(); in ResumeDecoding()
|
| /external/openscreen/discovery/mdns/ |
| D | mdns_querier_unittest.cc | 59 receiver_(config_), in MdnsQuerierTest()
103 receiver_.Start();
107 return std::make_unique<MdnsQuerier>(&sender_, &receiver_, &task_runner_, in CreateQuerier()
170 MdnsReceiver receiver_; member in openscreen::discovery::MdnsQuerierTest
197 receiver_.OnRead(&socket_, CreatePacketWithRecord(record0_created_)); in TEST_F()
199 receiver_.OnRead(&socket_, CreatePacketWithRecord(record0_created_)); in TEST_F()
200 receiver_.OnRead(&socket_, CreatePacketWithRecord(record0_updated_)); in TEST_F()
201 receiver_.OnRead(&socket_, CreatePacketWithRecord(record0_deleted_)); in TEST_F()
220 receiver_.OnRead(&socket_, CreatePacketWithRecord(record1_created_)); in TEST_F()
221 receiver_.OnRead(&socket_, CreatePacketWithRecord(record1_deleted_)); in TEST_F()
[all …]
|
| D | mdns_service_impl.cc | 36 receiver_(config), in MdnsServiceImpl()
76 sender_.get(), &receiver_, task_runner_, now_function_, &random_delay_, in MdnsServiceImpl()
81 sender_.get(), &receiver_, &random_delay_, task_runner_, now_function_); in MdnsServiceImpl()
86 publisher_.get(), probe_manager_.get(), sender_.get(), &receiver_, in MdnsServiceImpl()
90 receiver_.Start(); in MdnsServiceImpl()
153 receiver_.OnRead(socket, std::move(packet)); in OnRead()
|
| D | mdns_probe.cc | 41 receiver_(receiver), in MdnsProbeImpl()
44 OSP_DCHECK(receiver_); in MdnsProbeImpl()
49 receiver_->AddResponseCallback(this); in MdnsProbeImpl()
86 receiver_->RemoveResponseCallback(this); in Stop()
|
| /external/webrtc/pc/ |
| D | video_rtp_receiver_unittest.cc | 54 receiver_(new VideoRtpReceiver(worker_thread_.get(), in VideoRtpReceiverTest()
58 receiver_->SetMediaChannel(&channel_);
62 return receiver_->streams()[0]->FindVideoTrack("receiver")->GetSource(); in Source()
67 rtc::scoped_refptr<VideoRtpReceiver> receiver_; member in webrtc::__anond821efe30111::VideoRtpReceiverTest
86 receiver_->SetMediaChannel(&channel2); in TEST_F()
94 receiver_->SetMediaChannel(&channel3); in TEST_F()
98 receiver_->SetMediaChannel(&channel4); in TEST_F()
123 receiver_->SetMediaChannel(&channel2); in TEST_F()
131 receiver_->SetMediaChannel(&channel3); in TEST_F()
157 receiver_->SetupMediaChannel(4711); in TEST_F()
[all …]
|
| /external/webrtc/modules/audio_coding/test/ |
| D | target_delay_unittest.cc | 27 : receiver_( in TargetDelayTest()
36 receiver_.SetCodecs(receive_codecs); in SetUp()
86 ASSERT_EQ(0, receiver_.InsertPacket(rtp_header_, in Push()
96 ASSERT_EQ(0, receiver_.GetAudio(-1, &frame, &muted)); in Pull()
123 return receiver_.SetMinimumDelay(delay_ms); in SetMinimumDelay()
127 return receiver_.SetMaximumDelay(delay_ms); in SetMaximumDelay()
132 receiver_.GetNetworkStatistics(&stats); in GetCurrentOptimalDelayMs()
136 acm2::AcmReceiver receiver_; member in webrtc::TargetDelayTest
|
| /external/openscreen/cast/sender/ |
| D | cast_app_discovery_service_impl_unittest.cc | 33 receiver_.v4_address = fake_cast_socket_pair_.remote_endpoint.address; in SetUp()
34 receiver_.port = fake_cast_socket_pair_.remote_endpoint.port; in SetUp()
35 receiver_.unique_id = "deviceId1"; in SetUp()
36 receiver_.friendly_name = "Some Name"; in SetUp()
75 AddOrUpdateReceiver(receiver_, socket_id_); in StartSourceA1Query()
94 ServiceInfo receiver_; member in openscreen::cast::CastAppDiscoveryServiceImplTest
118 platform_client_.RemoveReceiver(receiver_); in TEST_F()
119 app_discovery_service_.RemoveReceiver(receiver_); in TEST_F()
163 receiver_.friendly_name = "New Name"; in TEST_F()
165 AddOrUpdateReceiver(receiver_, socket_id_); in TEST_F()
[all …]
|
| D | cast_platform_client_unittest.cc | 35 receiver_.v4_address = IPAddress{192, 168, 0, 17}; in SetUp()
36 receiver_.port = 4434; in SetUp()
37 receiver_.unique_id = "deviceId1"; in SetUp()
38 platform_client_.AddOrUpdateReceiver(receiver_, socket_->socket_id()); in SetUp()
54 ServiceInfo receiver_; member in openscreen::cast::CastPlatformClientTest
|
| /external/webrtc/test/scenario/ |
| D | audio_stream.cc | 177 : receiver_(receiver), config_(config) { in ReceiveAudioStream()
179 recv_config.rtp.local_ssrc = receiver_->GetNextAudioLocalSsrc(); in ReceiveAudioStream()
188 receiver_->AddExtensions(recv_config.rtp.extensions); in ReceiveAudioStream()
193 receiver_->SendTask([&] { in ReceiveAudioStream()
194 receive_stream_ = receiver_->call_->CreateAudioReceiveStream(recv_config); in ReceiveAudioStream()
198 receiver_->SendTask( in ~ReceiveAudioStream()
199 [&] { receiver_->call_->DestroyAudioReceiveStream(receive_stream_); }); in ~ReceiveAudioStream()
203 receiver_->SendTask([&] { in Start()
205 receiver_->call_->SignalChannelNetworkState(MediaType::AUDIO, kNetworkUp); in Start()
210 receiver_->SendTask([&] { receive_stream_->Stop(); }); in Stop()
[all …]
|
| D | video_stream.cc | 539 : receiver_(receiver), config_(config) { in ReceiveVideoStream()
560 std::make_unique<DecodedFrameTap>(receiver_->clock_, matcher, i)); in ReceiveVideoStream()
565 receiver_->GetNextVideoLocalSsrc(), send_stream->ssrcs_[i], in ReceiveVideoStream()
574 receiver_->ssrc_media_types_[flexfec.remote_ssrc] = MediaType::VIDEO; in ReceiveVideoStream()
576 receiver_->SendTask([this, &flexfec] { in ReceiveVideoStream()
577 flecfec_stream_ = receiver_->call_->CreateFlexfecReceiveStream(flexfec); in ReceiveVideoStream()
580 receiver_->ssrc_media_types_[recv_config.rtp.remote_ssrc] = in ReceiveVideoStream()
583 receiver_->ssrc_media_types_[recv_config.rtp.rtx_ssrc] = MediaType::VIDEO; in ReceiveVideoStream()
584 receiver_->SendTask([this, &recv_config] { in ReceiveVideoStream()
586 receiver_->call_->CreateVideoReceiveStream(std::move(recv_config))); in ReceiveVideoStream()
[all …]
|
| /external/webrtc/video/ |
| D | rtp_video_stream_receiver_frame_transformer_delegate.cc | 75 : receiver_(receiver), in RtpVideoStreamReceiverFrameTransformerDelegate()
90 receiver_ = nullptr; in Reset()
114 if (!receiver_) in ManageFrame()
118 receiver_->ManageFrame(std::move(*transformed_frame).ExtractFrame()); in ManageFrame()
|
| /external/webrtc/media/base/ |
| D | rtp_data_engine_unittest.cc | 60 receiver_.reset(new FakeDataReceiver()); in SetUp()
79 channel->SignalDataReceived.connect(receiver_.get(), in CreateChannel()
84 FakeDataReceiver* receiver() { return receiver_.get(); } in receiver()
86 bool HasReceivedData() { return receiver_->has_received_data(); } in HasReceivedData()
88 std::string GetReceivedData() { return receiver_->last_received_data(); } in GetReceivedData()
90 size_t GetReceivedDataLen() { return receiver_->last_received_data_len(); } in GetReceivedDataLen()
93 return receiver_->last_received_data_params(); in GetReceivedDataParams()
121 std::unique_ptr<FakeDataReceiver> receiver_; member in RtpDataMediaChannelTest
|
| /external/openscreen/cast/common/discovery/e2e_test/ |
| D | tests.cc | 172 receiver_ = std::make_unique<ServiceReceiver>(dnssd_service_.get()); in SetUpService()
183 task_runner_->PostTask([this]() { receiver_->StartDiscovery(); }); in StartDiscovery()
274 std::unique_ptr<ServiceReceiver> receiver_; member in openscreen::cast::__anon5cbb65430111::DiscoveryE2ETest
301 if (!receiver_->IsServiceFound(service_info)) { in CheckForPublishedService()
497 task_runner_->PostTask([this]() { receiver_->StopDiscovery(); }); in TEST_F()
559 task_runner_->PostTask([this]() { receiver_->EraseReceivedServices(); }); in TEST_F()
564 task_runner_->PostTask([this]() { receiver_->ForceRefresh(); }); in TEST_F()
574 task_runner_->PostTask([this]() { receiver_->EraseReceivedServices(); }); in TEST_F()
579 task_runner_->PostTask([this]() { receiver_->DiscoverNow(); }); in TEST_F()
|
| /external/webrtc/call/ |
| D | fake_network_pipe.cc | 92 receiver_(receiver), in FakeNetworkPipe()
106 receiver_(nullptr), in FakeNetworkPipe()
126 receiver_ = receiver; in SetReceiver()
332 RTC_DCHECK(!receiver_); in DeliverNetworkPacket()
343 } else if (receiver_) { in DeliverNetworkPacket()
351 receiver_->DeliverPacket(packet->media_type(), in DeliverNetworkPacket()
368 return receiver_ != nullptr; in HasReceiver()
|
| /external/libchrome/mojo/public/js/lib/ |
| D | control_message_proxy.js | 75 this.receiver_ = receiver;
84 return sendRunMessage(this.receiver_, runMessageParams).then(function(
95 this.receiver_.accept(message);
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | control_message_proxy.cc | 126 : receiver_(receiver) { in ControlMessageProxy()
135 SendRunMessage(receiver_, std::move(input_ptr), in QueryVersion()
144 SendRunOrClosePipeMessage(receiver_, std::move(input_ptr)); in RequireVersion()
156 receiver_, std::move(input_ptr), in FlushForTesting()
|