Home
last modified time | relevance | path

Searched refs:sender_ (Results 1 – 25 of 55) sorted by relevance

123

/external/webrtc/modules/rtp_rtcp/source/
Drtp_rtcp_impl_unittest.cc171 sender_(&clock_, /*is_sender=*/true), in RtpRtcpImplTest()
176 EXPECT_EQ(0, sender_.impl_->SetSendingStatus(true)); in SetUp()
177 sender_.impl_->SetSendingMediaStatus(true); in SetUp()
178 sender_.impl_->SetSequenceNumber(kSequenceNumber); in SetUp()
179 sender_.impl_->SetStorePacketsStatus(true, 100); in SetUp()
184 video_config.rtp_sender = sender_.impl_->RtpSender(); in SetUp()
197 sender_.transport_.SetRtpRtcpModule(receiver_.impl_.get()); in SetUp()
198 receiver_.transport_.SetRtpRtcpModule(sender_.impl_.get()); in SetUp()
202 RtpRtcpModule sender_; member in webrtc::RtpRtcpImplTest
247 EXPECT_EQ(0, sender_.RtpSent()); in TEST_F()
[all …]
Drtp_rtcp_impl2_unittest.cc176 sender_(&time_controller_, /*is_sender=*/true), in RtpRtcpImpl2Test()
181 EXPECT_EQ(0, sender_.impl_->SetSendingStatus(true)); in SetUp()
182 sender_.impl_->SetSendingMediaStatus(true); in SetUp()
183 sender_.impl_->SetSequenceNumber(kSequenceNumber); in SetUp()
184 sender_.impl_->SetStorePacketsStatus(true, 100); in SetUp()
189 video_config.rtp_sender = sender_.impl_->RtpSender(); in SetUp()
202 sender_.transport_.SetRtpRtcpModule(receiver_.impl_.get()); in SetUp()
203 receiver_.transport_.SetRtpRtcpModule(sender_.impl_.get()); in SetUp()
213 RtpRtcpModule sender_; member in webrtc::RtpRtcpImpl2Test
258 EXPECT_EQ(0, sender_.RtpSent()); in TEST_F()
[all …]
Drtp_sender_video_frame_transformer_delegate.cc97 : sender_(sender), in RTPSenderVideoFrameTransformerDelegate()
134 if (!sender_) in OnTransformedFrame()
147 if (!sender_) in SendVideo()
151 sender_->SendVideo( in SendVideo()
164 RTC_CHECK(sender_); in SetVideoStructureUnderLock()
165 sender_->SetVideoStructureUnderLock(video_structure); in SetVideoStructureUnderLock()
173 sender_ = nullptr; in Reset()
/external/openscreen/discovery/mdns/
Dmdns_publisher_unittest.cc80 sender_(&socket_), in MdnsPublisherTest()
81 publisher_(&sender_, in MdnsPublisherTest()
153 EXPECT_CALL(sender_, SendMulticast(_)) in TestUniqueRecordRegistrationWorkflow()
159 testing::Mock::VerifyAndClearExpectations(&sender_); in TestUniqueRecordRegistrationWorkflow()
166 testing::Mock::VerifyAndClearExpectations(&sender_); in TestUniqueRecordRegistrationWorkflow()
173 testing::Mock::VerifyAndClearExpectations(&sender_); in TestUniqueRecordRegistrationWorkflow()
178 EXPECT_CALL(sender_, SendMulticast(_)) in TestUniqueRecordRegistrationWorkflow()
184 testing::Mock::VerifyAndClearExpectations(&sender_); in TestUniqueRecordRegistrationWorkflow()
189 EXPECT_CALL(sender_, SendMulticast(_)) in TestUniqueRecordRegistrationWorkflow()
195 testing::Mock::VerifyAndClearExpectations(&sender_); in TestUniqueRecordRegistrationWorkflow()
[all …]
Dmdns_probe_unittest.cc49 sender_(&socket_), in MdnsProbeTests()
58 return std::make_unique<MdnsProbeImpl>(&sender_, &receiver_, &random_, in CreateProbe()
81 StrictMock<MockMdnsSender> sender_; member in openscreen::discovery::MdnsProbeTests
96 EXPECT_CALL(sender_, SendMulticast(_)); in TEST_F()
99 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
101 EXPECT_CALL(sender_, SendMulticast(_)); in TEST_F()
104 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
106 EXPECT_CALL(sender_, SendMulticast(_)); in TEST_F()
109 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
124 EXPECT_CALL(sender_, SendMulticast(_)); in TEST_F()
[all …]
Dmdns_trackers_unittest.cc76 sender_(&socket_), in MdnsTrackerTest()
107 record, type, &sender_, &task_runner_, &FakeClock::now, &random_, in CreateRecordTracker()
122 return std::make_unique<MdnsQuestionTracker>(question, &sender_, in CreateQuestionTracker()
179 StrictMock<MockMdnsSender> sender_; member in openscreen::discovery::MdnsTrackerTest
207 EXPECT_CALL(sender_, SendMulticast(_)).Times(2); in TEST_F()
210 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
216 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
221 EXPECT_CALL(sender_, SendMulticast(_)).Times(4); in TEST_F()
223 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
229 EXPECT_CALL(sender_, SendMulticast(_)).Times(8); in TEST_F()
[all …]
Dmdns_responder_unittest.cc129 sender_(&socket_), in MdnsResponderTest()
133 &sender_, in MdnsResponderTest()
182 EXPECT_CALL(sender_, SendMulticast(_)) in QueryForRecordTypeWhenNonePresent()
215 StrictMock<MockMdnsSender> sender_; member in openscreen::discovery::MdnsResponderTest
236 EXPECT_CALL(sender_, SendMulticast(_)).Times(1); in TEST_F()
238 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
242 EXPECT_CALL(sender_, SendMulticast(_)).Times(0); in TEST_F()
253 EXPECT_CALL(sender_, SendMulticast(_)).Times(0); in TEST_F()
255 testing::Mock::VerifyAndClearExpectations(&sender_); in TEST_F()
259 EXPECT_CALL(sender_, SendMulticast(_)).Times(1); in TEST_F()
[all …]
Dmdns_service_impl.cc73 sender_ = std::make_unique<MdnsSender>(socket_ptr); 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()
83 std::make_unique<MdnsPublisher>(sender_.get(), probe_manager_.get(), in MdnsServiceImpl()
86 publisher_.get(), probe_manager_.get(), sender_.get(), &receiver_, in MdnsServiceImpl()
149 sender_->OnSendError(socket, error); in OnSendError()
Dmdns_probe.cc40 sender_(sender), in MdnsProbeImpl()
43 OSP_DCHECK(sender_); in MdnsProbeImpl()
71 sender_->SendMulticast(probe_query); in ProbeOnce()
/external/webrtc/test/scenario/
Daudio_stream.cc75 : sender_(sender), config_(config) { in SendAudioStream()
130 sender_->SendTask([&] { in SendAudioStream()
131 send_stream_ = sender_->call_->CreateAudioSendStream(send_config); in SendAudioStream()
134 sender_->transport_->packet_overhead().bytes()); in SendAudioStream()
140 sender_->SendTask( in ~SendAudioStream()
141 [this] { sender_->call_->DestroyAudioSendStream(send_stream_); }); in ~SendAudioStream()
145 sender_->SendTask([this] { in Start()
147 sender_->call_->SignalChannelNetworkState(MediaType::AUDIO, kNetworkUp); in Start()
152 sender_->SendTask([this] { send_stream_->Stop(); }); in Stop()
156 sender_->SendTask([this, mute] { send_stream_->SetMuted(mute); }); in SetMuted()
[all …]
Dvideo_stream.cc363 : sender_(sender), config_(config) { in SendVideoStream()
365 sender_->clock_, CreateFrameGenerator(sender_->clock_, config.source), in SendVideoStream()
379 encoder = std::make_unique<test::FakeVp8Encoder>(sender_->clock_); in SendVideoStream()
381 encoder = std::make_unique<test::FakeEncoder>(sender_->clock_); in SendVideoStream()
414 sender_->SendTask([&] { in SendVideoStream()
416 send_stream_ = sender_->call_->CreateVideoSendStream( in SendVideoStream()
420 send_stream_ = sender_->call_->CreateVideoSendStream( in SendVideoStream()
426 sender_->clock_, matcher, video_capturer_.get()); in SendVideoStream()
437 sender_->SendTask( in ~SendVideoStream()
438 [this] { sender_->call_->DestroyVideoSendStream(send_stream_); }); in ~SendVideoStream()
[all …]
/external/libchrome/ipc/
Dipc_message_pipe_reader.cc30 sender_(std::move(sender)), in MessagePipeReader()
32 sender_.set_connection_error_handler( in MessagePipeReader()
47 sender_.reset(); in Close()
63 if (!sender_) in Send()
66 sender_->Receive(MessageView(*message, std::move(handles))); in Send()
74 if (!sender_.is_bound()) in GetRemoteInterface()
76 sender_->GetAssociatedInterface( in GetRemoteInterface()
Dipc_test_channel_listener.h24 TestChannelListener() : sender_(NULL), messages_left_(50) {} in TestChannelListener()
31 sender_ = s; in Init()
40 Sender* sender_;
Dipc_message_pipe_reader.h78 bool IsValid() { return sender_.is_bound(); } in COMPONENT_EXPORT()
88 mojom::ChannelAssociatedPtr& sender() { return sender_; } in COMPONENT_EXPORT()
104 mojom::ChannelAssociatedPtr sender_; in COMPONENT_EXPORT() local
Dipc_logging.cc51 sender_(NULL), in Logging()
100 if (!sender_) in OnSendLogs()
107 sender_->Send(msg); in OnSendLogs()
111 sender_ = sender; in SetIPCSender()
232 if (sender_) { in Log()
259 ANSIEscape(sender_ ? ANSI_COLOR_BLUE : ANSI_COLOR_CYAN), in Log()
Dipc_cpu_perftest.cc101 DCHECK(!sender_); in Init()
102 sender_ = sender; in Init()
117 CHECK(sender_); in OnMessageReceived()
143 sender_->Send(new TestMsg_SyncPing(payload_, &response)); in StartPingPong()
190 void SendPong() { sender_->Send(new TestMsg_Ping(payload_)); } in SendPong()
193 Sender* sender_ = nullptr; member in IPC::__anon4c13cc8a0111::ChannelSteadyPingPongListener
Dipc_mojo_bootstrap_unittest.cc29 bootstrap_->Connect(&sender_, &receiver_); in Connection()
30 sender_->SetPeerPid(sender_id); in Connection()
37 IPC::mojom::ChannelAssociatedPtr& GetSender() { return sender_; } in GetSender()
40 IPC::mojom::ChannelAssociatedPtr sender_; member in __anon52896f670111::Connection
/external/openscreen/cast/standalone_sender/
Dstreaming_opus_encoder.cc36 sender_(sender), in StreamingOpusEncoder()
44 OSP_DCHECK(sender_); in StreamingOpusEncoder()
108 OSP_LOG_FATAL << "AUDIO[" << sender_->ssrc() in EncodeAndSend()
114 frame_.frame_id = sender_->GetNextFrameId(); in EncodeAndSend()
121 switch (sender_->EnqueueFrame(frame_)) { in EncodeAndSend()
128 OSP_LOG_WARN << "AUDIO[" << sender_->ssrc() in EncodeAndSend()
132 OSP_LOG_INFO << "AUDIO[" << sender_->ssrc() in EncodeAndSend()
Dstreaming_vp8_encoder.cc57 sender_(sender), in StreamingVp8Encoder()
68 OSP_DCHECK(sender_);
150 reference_time - start_time_, sender_->rtp_timebase()); in EncodeAndSend()
152 OSP_LOG_WARN << "VIDEO[" << sender_->ssrc() in EncodeAndSend()
158 if (sender_->GetInFlightMediaDuration(work_unit.rtp_timestamp) > in EncodeAndSend()
159 sender_->GetMaxInFlightMediaDuration()) { in EncodeAndSend()
160 OSP_LOG_WARN << "VIDEO[" << sender_->ssrc() in EncodeAndSend()
177 .ToDuration<Clock::duration>(sender_->rtp_timebase()); in EncodeAndSend()
188 const bool force_key_frame = sender_->NeedsKeyFrame(); in EncodeAndSend()
422 frame.frame_id = sender_->GetNextFrameId(); in SendEncodedFrame()
[all …]
Dstreaming_opus_encoder.h40 int sample_rate() const { return sender_->rtp_timebase(); } in sample_rate()
87 Sender* const sender_; variable
/external/libbrillo/brillo/dbus/
Ddbus_method_response.h37 : sender_(std::exchange( in DBusMethodResponseBase()
38 other.sender_, in DBusMethodResponseBase()
80 ResponseSender sender_;
Ddbus_method_response.cc14 : sender_(sender), method_call_(method_call) { in DBusMethodResponseBase()
48 sender_.Run(std::move(response)); in SendRawResponse()
/external/google-breakpad/src/client/mac/crash_generation/
Dcrash_generation_client.h40 : sender_(mach_port_name) { in CrashGenerationClient()
56 MachPortSender sender_;
/external/libchrome/mojo/public/cpp/bindings/tests/
Dbindings_perftest.cc141 PingPongPaddle(MessageReceiver* sender) : sender_(sender) {} in PingPongPaddle()
143 void set_sender(MessageReceiver* sender) { sender_ = sender; } in set_sender()
157 bool result = sender_->Accept(&reply); in Accept()
177 bool result = sender_->Accept(&message); in Serve()
189 MessageReceiver* sender_; member in mojo::__anoncc2752cd0111::PingPongPaddle
/external/webrtc/p2p/base/
Dpseudo_tcp_unittest.cc347 sender_(NULL), in PseudoTcpTestPingPong()
355 sender_ = &local_; in TestPingPong()
400 receiver_ = sender_; in OnTcpReadable()
401 sender_ = tmp; in OnTcpReadable()
404 OnTcpWriteable(sender_); in OnTcpReadable()
408 if (tcp != sender_) in OnTcpWriteable()
437 sent = sender_->Send(block, tosend); in WriteData()
454 PseudoTcp* sender_; member in PseudoTcpTestPingPong

123