Home
last modified time | relevance | path

Searched refs:transport_ (Results 1 – 25 of 34) sorted by relevance

12

/external/webrtc/webrtc/p2p/base/
Dtransport_unittest.cc37 : transport_(new FakeTransport("test content name")), channel_(NULL) {} in TransportTest()
39 transport_->DestroyAllChannels(); in ~TransportTest()
47 transport_->CreateChannel(component)); in CreateChannel()
50 transport_->DestroyChannel(1); in DestroyChannel()
55 rtc::scoped_ptr<FakeTransport> transport_; member in TransportTest
63 transport_->SetIceRole(cricket::ICEROLE_CONTROLLING); in TEST_F()
64 transport_->SetIceTiebreaker(99U); in TEST_F()
66 ASSERT_TRUE(transport_->SetLocalTransportDescription(local_desc, in TEST_F()
69 EXPECT_EQ(cricket::ICEROLE_CONTROLLING, transport_->ice_role()); in TEST_F()
77 ASSERT_TRUE(transport_->SetRemoteTransportDescription(remote_desc, in TEST_F()
[all …]
Ddtlstransportchannel_unittest.cc68 ASSERT(!transport_); in SetupMaxProtocolVersion()
72 transport_.reset(new cricket::DtlsTransport<cricket::FakeTransport>( in SetupChannels()
74 transport_->SetAsync(true); in SetupChannels()
75 transport_->SetIceRole(role); in SetupChannels()
76 transport_->SetIceTiebreaker( in SetupChannels()
82 transport_->CreateChannel(i)); in SetupChannels()
99 cricket::Transport* transport() { return transport_.get(); } in transport()
102 cricket::TransportChannelImpl* ch = transport_->GetChannel(component); in GetFakeChannel()
176 ASSERT_TRUE(transport_->SetLocalTransportDescription( in Negotiate()
178 ASSERT_EQ(expect_success, transport_->SetRemoteTransportDescription( in Negotiate()
[all …]
Ddtlstransportchannel.h162 Transport* GetTransport() override { return transport_; } in GetTransport()
221 Transport* transport_; // The transport_ that created us. variable
Dp2ptransportchannel.h75 Transport* GetTransport() override { return transport_; } in GetTransport()
267 P2PTransport* transport_; variable
Dfaketransportcontroller.h52 transport_(transport), in FakeTransportChannel()
70 Transport* GetTransport() override { return transport_; } in GetTransport()
316 Transport* transport_; variable
/external/libbrillo/brillo/http/
Dhttp_request_unittest.cc45 transport_ = std::make_shared<MockTransport>(); in SetUp()
46 connection_ = std::make_shared<MockConnection>(transport_); in SetUp()
59 testing::Mock::VerifyAndClearExpectations(transport_.get()); in TearDown()
60 transport_.reset(); in TearDown()
64 std::shared_ptr<MockTransport> transport_; member in brillo::http::HttpRequestTest
69 Request request{"http://www.foo.bar", request_type::kPost, transport_}; in TEST_F()
77 Request request2{"http://www.foo.bar/baz", request_type::kGet, transport_}; in TEST_F()
83 Request request{"http://www.foo.bar", request_type::kPost, transport_}; in TEST_F()
89 Request request{"http://www.foo.bar", request_type::kPost, transport_}; in TEST_F()
95 Request request{"http://www.foo.bar", request_type::kPost, transport_}; in TEST_F()
[all …]
Dhttp_transport_curl_unittest.cc33 transport_ = std::make_shared<Transport>(curl_api_); in SetUp()
47 transport_.reset(); in TearDown()
53 std::shared_ptr<Transport> transport_; member in brillo::http::curl::HttpCurlTransportTest
69 auto connection = transport_->CreateConnection("http://foo.bar/get", in TEST_F()
87 auto connection = transport_->CreateConnection( in TEST_F()
101 auto connection = transport_->CreateConnection( in TEST_F()
117 auto connection = transport_->CreateConnection( in TEST_F()
137 auto connection = transport_->CreateConnection( in TEST_F()
155 auto connection = transport_->CreateConnection( in TEST_F()
168 transport_ = std::make_shared<Transport>(curl_api_); in SetUp()
[all …]
Dhttp_request.cc110 : transport_(transport), request_url_(url), method_(method) { in Request()
112 if (!transport_) in Request()
113 transport_ = http::Transport::CreateDefault(); in Request()
121 DCHECK(transport_) << "Request already sent"; in AddRange()
130 DCHECK(transport_) << "Request already sent"; in AddRange()
140 transport_.reset(); // Indicate that the response has been received in GetResponseAndBlock()
148 transport_->RunCallbackAsync( in GetResponse()
155 transport_.reset(); // Indicate that the request has been dispatched. in GetResponse()
160 DCHECK(transport_) << "Request already sent"; in SetAccept()
169 DCHECK(transport_) << "Request already sent"; in SetContentType()
[all …]
Dhttp_connection.h47 : transport_(transport) {} in Connection()
99 std::shared_ptr<Transport> transport_;
Dhttp_connection_curl_unittest.cc154 transport_ = std::make_shared<MockTransport>(); in SetUp()
158 handle_, request_type::kPost, curl_api_, transport_); in SetUp()
165 transport_.reset(); in TearDown()
171 std::shared_ptr<MockTransport> transport_; member in brillo::http::curl::HttpCurlConnectionTest
215 EXPECT_CALL(*transport_, StartAsyncTransfer(connection_.get(), _, _)) in TEST_F()
Dhttp_connection_fake.cc45 fake::Transport* transport = static_cast<fake::Transport*>(transport_.get()); in FinishRequest()
69 transport_->RunCallbackAsync(FROM_HERE, base::Bind(callback)); in FinishRequestAsync()
Dhttp_transport_curl.cc42 transport_(transport), in SocketPollData()
70 transport_->ProcessAsyncCurlMessages(); in OnSocketReady()
78 Transport* transport_; member in brillo::http::curl::Transport::SocketPollData
/external/webrtc/webrtc/modules/rtp_rtcp/source/
Drtp_sender_unittest.cc126 transport_(), in RtpSenderTest()
135 rtp_sender_.reset(new RTPSender(false, &fake_clock_, &transport_, nullptr, in SetUpRtpSender()
146 LoopbackTransportTest transport_; member in webrtc::RtpSenderTest
652 EXPECT_EQ(0, transport_.packets_sent_); in TEST_F()
660 EXPECT_EQ(1, transport_.packets_sent_); in TEST_F()
661 EXPECT_EQ(rtp_length, transport_.last_sent_packet_len_); in TEST_F()
663 webrtc::RtpUtility::RtpHeaderParser rtp_parser(transport_.last_sent_packet_, in TEST_F()
704 EXPECT_EQ(0, transport_.packets_sent_); in TEST_F()
714 EXPECT_EQ(0, transport_.packets_sent_); in TEST_F()
719 EXPECT_EQ(1, transport_.packets_sent_); in TEST_F()
[all …]
Dnack_rtx_unittest.cc172 transport_(kTestSsrc + 1), in RtpRtcpRtxNackTest()
184 configuration.outgoing_transport = &transport_; in SetUp()
200 transport_.SetSendModule(rtp_rtcp_module_, &rtp_payload_registry_, in SetUp()
251 transport_.expected_sequence_numbers_.size() && in ExpectedPacketsReceived()
253 transport_.expected_sequence_numbers_.begin()); in ExpectedPacketsReceived()
260 transport_.DropEveryNthPacket(loss); in RunRtxTest()
287 RtxLoopBackTransport transport_; member in webrtc::RtpRtcpRtxNackTest
305 transport_.DropConsecutivePackets(2, kNumPacketsToDrop); in TEST_F()
317 EXPECT_FALSE(transport_.expected_sequence_numbers_.empty()); in TEST_F()
338 EXPECT_EQ(kTestNumberOfRtxPackets, transport_.count_rtx_ssrc_); in TEST_F()
Drtp_rtcp_impl_unittest.cc106 config.outgoing_transport = &transport_; in RtpRtcpModule()
114 transport_.SimulateNetworkDelay(kOneWayNetworkDelayMs, clock); in RtpRtcpModule()
120 SendTransport transport_; member in webrtc::__anonf22de6b40111::RtpRtcpModule
146 return transport_.rtp_packets_sent_; in RtpSent()
149 return transport_.last_rtp_header_.sequenceNumber; in LastRtpSequenceNumber()
152 return transport_.last_nack_list_; in LastNackListSent()
187 sender_.transport_.SetRtpRtcpModule(receiver_.impl_.get()); in RtpRtcpImplTest()
188 receiver_.transport_.SetRtpRtcpModule(sender_.impl_.get()); in RtpRtcpImplTest()
355 sender_.transport_.SimulateNetworkDelay(0, &clock_); in TEST_F()
356 receiver_.transport_.SimulateNetworkDelay(0, &clock_); in TEST_F()
[all …]
Drtcp_sender.cc87 : transport_(transport), bytes_sent_(0) {} in PacketContainer()
94 if (transport_->SendRtcp(data, length)) in OnPacketReady()
104 Transport* transport_; member in webrtc::PacketContainer
150 transport_(outgoing_transport), in RTCPSender()
182 RTC_DCHECK(transport_ != nullptr); in RTCPSender()
803 PacketContainer container(transport_); in SendCompoundRTCP()
1046 : transport_(transport), send_failure_(false) {} in SendFeedbackPacket()
1049 if (!transport_->SendRtcp(data, length)) in SendFeedbackPacket()
1053 Transport* const transport_; in SendFeedbackPacket() member in webrtc::RTCPSender::SendFeedbackPacket::Sender
1055 } sender(transport_); in SendFeedbackPacket()
/external/webrtc/webrtc/voice_engine/test/auto_test/fixtures/
Dbefore_streaming_fixture.cc15 transport_(NULL) { in BeforeStreamingFixture()
31 delete transport_; in ~BeforeStreamingFixture()
60 transport_->WaitForTransmittedPackets(packet_count); in WaitForTransmittedPackets()
64 transport_ = new LoopBackTransport(voe_network_, channel_); in SetUpLocalPlayback()
65 EXPECT_EQ(0, voe_network_->RegisterExternalTransport(channel_, *transport_)); in SetUpLocalPlayback()
Dbefore_streaming_fixture.h50 LoopBackTransport* transport_; variable
/external/webrtc/webrtc/call/
Dtransport_adapter.cc19 : transport_(transport), enabled_(0) { in TransportAdapter()
29 return transport_->SendRtp(packet, length, options); in SendRtp()
36 return transport_->SendRtcp(packet, length); in SendRtcp()
Dtransport_adapter.h33 Transport *transport_;
/external/webrtc/webrtc/voice_engine/test/auto_test/standard/
Drtp_rtcp_test.cc66 transport_ = new LoopBackTransport(voe_network_, second_channel_); in SetUp()
68 *transport_)); in SetUp()
82 delete transport_; in TearDown()
86 LoopBackTransport* transport_; member in RtpRtcpTest
Dmixing_test.cc38 transport_ = new LoopBackTransport(voe_network_, 0); in SetUp()
41 delete transport_; in TearDown()
184 EXPECT_EQ(0, voe_network_->RegisterExternalTransport(stream, *transport_)); in StartRemoteStream()
187 transport_->AddChannel(stream, stream); in StartRemoteStream()
219 LoopBackTransport* transport_; member in webrtc::MixingTest
/external/webrtc/webrtc/modules/rtp_rtcp/test/testAPI/
Dtest_api_video.cc44 transport_ = new LoopBackTransport(); in SetUp()
50 configuration.outgoing_transport = transport_; in SetUp()
62 transport_->SetSendModule(video_module_, &rtp_payload_registry_, in SetUp()
125 delete transport_; in TearDown()
134 LoopBackTransport* transport_; member in webrtc::RtpRtcpVideoTest
/external/webrtc/webrtc/voice_engine/
Dvoe_network_unittest.cc38 EXPECT_EQ(0, network_->RegisterExternalTransport(channelID, transport_)); in CreateChannelAndRegisterExternalTransport()
52 0, network_->RegisterExternalTransport(kNonExistingChannel, transport_)); in TEST_F()
Dvoice_engine_fixture.h30 MockTransport transport_; variable

12