| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_session_test.cc | 459 session_(connection_, &session_visitor_), in QuicSessionTestBase()
461 session_.config()->SetInitialStreamFlowControlWindowToSend( in QuicSessionTestBase()
463 session_.config()->SetInitialSessionFlowControlWindowToSend( in QuicSessionTestBase()
468 EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(false)).Times(1); in QuicSessionTestBase()
469 EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(true)).Times(1); in QuicSessionTestBase()
472 session_.config(), kDefaultMaxStreamsPerConnection); in QuicSessionTestBase()
474 session_.config(), kDefaultMaxStreamsPerConnection); in QuicSessionTestBase()
476 session_.config(), kMinimumFlowControlSendWindow); in QuicSessionTestBase()
478 session_.config(), kMinimumFlowControlSendWindow); in QuicSessionTestBase()
480 session_.config(), kMinimumFlowControlSendWindow); in QuicSessionTestBase()
[all …]
|
| D | quic_stream_test.cc | 110 session_ = std::make_unique<StrictMock<MockQuicSession>>(connection_); in Initialize()
111 session_->Initialize(); in Initialize()
116 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
118 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
120 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
122 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
123 QuicConfigPeer::SetReceivedMaxUnidirectionalStreams(session_->config(), 10); in Initialize()
124 session_->OnConfigNegotiated(); in Initialize()
126 stream_ = new StrictMock<TestStream>(kTestStreamId, session_.get(), in Initialize()
129 EXPECT_CALL(*session_, ShouldKeepConnectionAlive()) in Initialize()
[all …]
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_session_test.cc | 459 session_(connection_, &session_visitor_), in QuicSessionTestBase()
461 session_.config()->SetInitialStreamFlowControlWindowToSend( in QuicSessionTestBase()
463 session_.config()->SetInitialSessionFlowControlWindowToSend( in QuicSessionTestBase()
468 EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(false)).Times(1); in QuicSessionTestBase()
469 EXPECT_CALL(session_, OnCanCreateNewOutgoingStream(true)).Times(1); in QuicSessionTestBase()
472 session_.config(), kDefaultMaxStreamsPerConnection); in QuicSessionTestBase()
474 session_.config(), kDefaultMaxStreamsPerConnection); in QuicSessionTestBase()
476 session_.config(), kMinimumFlowControlSendWindow); in QuicSessionTestBase()
478 session_.config(), kMinimumFlowControlSendWindow); in QuicSessionTestBase()
480 session_.config(), kMinimumFlowControlSendWindow); in QuicSessionTestBase()
[all …]
|
| D | quic_stream_test.cc | 110 session_ = std::make_unique<StrictMock<MockQuicSession>>(connection_); in Initialize()
111 session_->Initialize(); in Initialize()
116 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
118 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
120 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
122 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
123 QuicConfigPeer::SetReceivedMaxUnidirectionalStreams(session_->config(), 10); in Initialize()
124 session_->OnConfigNegotiated(); in Initialize()
126 stream_ = new StrictMock<TestStream>(kTestStreamId, session_.get(), in Initialize()
129 EXPECT_CALL(*session_, ShouldKeepConnectionAlive()) in Initialize()
[all …]
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/http/ |
| D | quic_spdy_session_test.cc | 440 session_.emplace(connection_); in Initialize()
442 session_->set_qpack_maximum_dynamic_table_capacity( in Initialize()
447 session_->set_allow_extended_connect(allow_extended_connect_); in Initialize()
449 session_->Initialize(); in Initialize()
450 session_->config()->SetInitialStreamFlowControlWindowToSend( in Initialize()
452 session_->config()->SetInitialSessionFlowControlWindowToSend( in Initialize()
456 session_->config(), kHttp3StaticUnidirectionalStreamCount); in Initialize()
459 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
461 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
463 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
[all …]
|
| D | quic_server_session_base_test.cc | 167 session_ = std::make_unique<TestServerSession>( in QuicServerSessionBaseTest()
174 session_->Initialize(); in QuicServerSessionBaseTest()
176 session_->config(), kMinimumFlowControlSendWindow); in QuicServerSessionBaseTest()
177 session_->OnConfigNegotiated(); in QuicServerSessionBaseTest()
214 EXPECT_CALL(*session_, WriteControlFrame(_, _)); in InjectStopSendingFrame()
217 session_->OnStopSendingFrame(stop_sending); in InjectStopSendingFrame()
229 std::unique_ptr<TestServerSession> session_; member in quic::test::__anon508dc08d0111::QuicServerSessionBaseTest
254 EXPECT_EQ(session_->QuicSpdySession::GetSSLConfig(), QuicSSLConfig()); in TEST_P()
261 session_->OnStreamFrame(data1); in TEST_P()
262 EXPECT_EQ(1u, QuicSessionPeer::GetNumOpenDynamicStreams(session_.get())); in TEST_P()
[all …]
|
| D | quic_spdy_client_session_test.cc | 100 session_.reset(nullptr); in ~QuicSpdyClientSessionTest()
104 session_.reset(); in Initialize()
108 session_ = std::make_unique<TestQuicSpdyClientSession>( in Initialize()
111 session_->Initialize(); in Initialize()
116 session_->GetMutableCryptoStream()); in Initialize()
153 session_->CryptoConnect(); in CompleteCryptoHandshake()
172 session_ = std::make_unique<TestQuicSpdyClientSession>( in CreateConnection()
175 session_->Initialize(); in CreateConnection()
177 session_->GetMutableCryptoStream()); in CreateConnection()
182 EXPECT_FALSE(session_->GetCryptoStream()->IsResumption()); in CompleteFirstConnection()
[all …]
|
| D | quic_send_control_stream_test.cc | 81 session_(connection_) { in QuicSendControlStreamTest()
82 ON_CALL(session_, WritevData(_, _, _, _, _, _)) in QuicSendControlStreamTest()
83 .WillByDefault(Invoke(&session_, &MockQuicSpdySession::ConsumeData)); in QuicSendControlStreamTest()
87 EXPECT_CALL(session_, OnCongestionWindowChange(_)).Times(AnyNumber()); in Initialize()
88 session_.Initialize(); in Initialize()
92 send_control_stream_ = QuicSpdySessionPeer::GetSendControlStream(&session_); in Initialize()
94 session_.config(), kMinimumFlowControlSendWindow); in Initialize()
96 session_.config(), kMinimumFlowControlSendWindow); in Initialize()
97 QuicConfigPeer::SetReceivedMaxUnidirectionalStreams(session_.config(), 3); in Initialize()
98 session_.OnConfigNegotiated(); in Initialize()
[all …]
|
| D | quic_spdy_server_stream_base_test.cc | 39 : session_(new MockQuicConnection(&helper_, &alarm_factory_, in QuicSpdyServerStreamBaseTest()
41 session_.Initialize(); in QuicSpdyServerStreamBaseTest()
42 session_.connection()->SetEncrypter( in QuicSpdyServerStreamBaseTest()
44 std::make_unique<NullEncrypter>(session_.perspective())); in QuicSpdyServerStreamBaseTest()
47 session_.transport_version(), 0), in QuicSpdyServerStreamBaseTest()
48 &session_, BIDIRECTIONAL); in QuicSpdyServerStreamBaseTest()
49 session_.ActivateStream(absl::WrapUnique(stream_)); in QuicSpdyServerStreamBaseTest()
56 MockQuicSpdySession session_; member in quic::test::__anone19b77b40111::QuicSpdyServerStreamBaseTest
63 if (session_.version().UsesHttp3()) { in TEST_F()
64 EXPECT_CALL(session_, in TEST_F()
[all …]
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/http/ |
| D | quic_spdy_session_test.cc | 440 session_.emplace(connection_); in Initialize()
442 session_->set_qpack_maximum_dynamic_table_capacity( in Initialize()
447 session_->set_allow_extended_connect(allow_extended_connect_); in Initialize()
449 session_->Initialize(); in Initialize()
450 session_->config()->SetInitialStreamFlowControlWindowToSend( in Initialize()
452 session_->config()->SetInitialSessionFlowControlWindowToSend( in Initialize()
456 session_->config(), kHttp3StaticUnidirectionalStreamCount); in Initialize()
459 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
461 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
463 session_->config(), kMinimumFlowControlSendWindow); in Initialize()
[all …]
|
| D | quic_server_session_base_test.cc | 167 session_ = std::make_unique<TestServerSession>( in QuicServerSessionBaseTest()
174 session_->Initialize(); in QuicServerSessionBaseTest()
176 session_->config(), kMinimumFlowControlSendWindow); in QuicServerSessionBaseTest()
177 session_->OnConfigNegotiated(); in QuicServerSessionBaseTest()
214 EXPECT_CALL(*session_, WriteControlFrame(_, _)); in InjectStopSendingFrame()
217 session_->OnStopSendingFrame(stop_sending); in InjectStopSendingFrame()
229 std::unique_ptr<TestServerSession> session_; member in quic::test::__anon64ac54a90111::QuicServerSessionBaseTest
254 EXPECT_EQ(session_->QuicSpdySession::GetSSLConfig(), QuicSSLConfig()); in TEST_P()
261 session_->OnStreamFrame(data1); in TEST_P()
262 EXPECT_EQ(1u, QuicSessionPeer::GetNumOpenDynamicStreams(session_.get())); in TEST_P()
[all …]
|
| D | quic_spdy_client_session_test.cc | 100 session_.reset(nullptr); in ~QuicSpdyClientSessionTest()
104 session_.reset(); in Initialize()
108 session_ = std::make_unique<TestQuicSpdyClientSession>( in Initialize()
111 session_->Initialize(); in Initialize()
116 session_->GetMutableCryptoStream()); in Initialize()
153 session_->CryptoConnect(); in CompleteCryptoHandshake()
172 session_ = std::make_unique<TestQuicSpdyClientSession>( in CreateConnection()
175 session_->Initialize(); in CreateConnection()
177 session_->GetMutableCryptoStream()); in CreateConnection()
182 EXPECT_FALSE(session_->GetCryptoStream()->IsResumption()); in CompleteFirstConnection()
[all …]
|
| D | quic_send_control_stream_test.cc | 81 session_(connection_) { in QuicSendControlStreamTest()
82 ON_CALL(session_, WritevData(_, _, _, _, _, _)) in QuicSendControlStreamTest()
83 .WillByDefault(Invoke(&session_, &MockQuicSpdySession::ConsumeData)); in QuicSendControlStreamTest()
87 EXPECT_CALL(session_, OnCongestionWindowChange(_)).Times(AnyNumber()); in Initialize()
88 session_.Initialize(); in Initialize()
92 send_control_stream_ = QuicSpdySessionPeer::GetSendControlStream(&session_); in Initialize()
94 session_.config(), kMinimumFlowControlSendWindow); in Initialize()
96 session_.config(), kMinimumFlowControlSendWindow); in Initialize()
97 QuicConfigPeer::SetReceivedMaxUnidirectionalStreams(session_.config(), 3); in Initialize()
98 session_.OnConfigNegotiated(); in Initialize()
[all …]
|
| D | quic_spdy_server_stream_base_test.cc | 39 : session_(new MockQuicConnection(&helper_, &alarm_factory_, in QuicSpdyServerStreamBaseTest()
41 session_.Initialize(); in QuicSpdyServerStreamBaseTest()
42 session_.connection()->SetEncrypter( in QuicSpdyServerStreamBaseTest()
44 std::make_unique<NullEncrypter>(session_.perspective())); in QuicSpdyServerStreamBaseTest()
47 session_.transport_version(), 0), in QuicSpdyServerStreamBaseTest()
48 &session_, BIDIRECTIONAL); in QuicSpdyServerStreamBaseTest()
49 session_.ActivateStream(absl::WrapUnique(stream_)); in QuicSpdyServerStreamBaseTest()
56 MockQuicSpdySession session_; member in quic::test::__anon4cdeb9d00111::QuicSpdyServerStreamBaseTest
63 if (session_.version().UsesHttp3()) { in TEST_F()
64 EXPECT_CALL(session_, in TEST_F()
[all …]
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/http2/adapter/ |
| D | oghttp2_adapter.cc | 34 return session_->IsServerSession(); in IsServerSession()
38 return session_->ProcessBytes(bytes); in ProcessBytes()
42 session_->SubmitSettings(settings); in SubmitSettings()
48 session_->EnqueueFrame(std::make_unique<SpdyPriorityIR>( in SubmitPriorityForStream()
53 session_->EnqueueFrame(std::make_unique<SpdyPingIR>(ping_id)); in SubmitPing()
57 session_->StartGracefulShutdown(); in SubmitShutdownNotice()
63 session_->SubmitGoAway(last_accepted_stream_id, error_code, opaque_data); in SubmitGoAway()
68 session_->EnqueueFrame( in SubmitWindowUpdate()
77 session_->SubmitMetadata(stream_id, std::move(source)); in SubmitMetadata()
86 session_->SubmitMetadata(stream_id); in SubmitMetadata()
[all …]
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/http2/adapter/ |
| D | oghttp2_adapter.cc | 34 return session_->IsServerSession(); in IsServerSession()
38 return session_->ProcessBytes(bytes); in ProcessBytes()
42 session_->SubmitSettings(settings); in SubmitSettings()
48 session_->EnqueueFrame(std::make_unique<SpdyPriorityIR>( in SubmitPriorityForStream()
53 session_->EnqueueFrame(std::make_unique<SpdyPingIR>(ping_id)); in SubmitPing()
57 session_->StartGracefulShutdown(); in SubmitShutdownNotice()
63 session_->SubmitGoAway(last_accepted_stream_id, error_code, opaque_data); in SubmitGoAway()
68 session_->EnqueueFrame( in SubmitWindowUpdate()
77 session_->SubmitMetadata(stream_id, std::move(source)); in SubmitMetadata()
86 session_->SubmitMetadata(stream_id); in SubmitMetadata()
[all …]
|
| /external/webrtc/modules/video_coding/ |
| D | session_info_unittest.cc | 25 session_.Reset(); in SetUp()
58 VCMSessionInfo session_; member in webrtc::TestSessionInfo
71 EXPECT_GE(session_.SessionLength(), in VerifyNalu()
121 EXPECT_EQ(packet_buffer_size(), static_cast<size_t>(session_.InsertPacket( in TEST_F()
123 EXPECT_FALSE(session_.HaveLastPacket()); in TEST_F()
124 EXPECT_EQ(VideoFrameType::kVideoFrameKey, session_.FrameType()); in TEST_F()
129 EXPECT_EQ(packet_buffer_size(), static_cast<size_t>(session_.InsertPacket( in TEST_F()
131 EXPECT_TRUE(session_.HaveLastPacket()); in TEST_F()
132 EXPECT_EQ(packet_.seqNum, session_.HighSequenceNumber()); in TEST_F()
133 EXPECT_EQ(0xFFFE, session_.LowSequenceNumber()); in TEST_F()
[all …]
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/tools/ |
| D | quic_simple_server_session_test.cc | 209 session_ = std::make_unique<MockQuicSimpleServerSession>( in QuicSimpleServerSessionTest()
216 session_->Initialize(); in QuicSimpleServerSessionTest()
219 EXPECT_CALL(*session_, WriteControlFrame(_, _)) in QuicSimpleServerSessionTest()
222 session_->OnConfigNegotiated(); in QuicSimpleServerSessionTest()
255 session_->OnStopSendingFrame(stop_sending); in InjectStopSending()
267 std::unique_ptr<MockQuicSimpleServerSession> session_; member in quic::test::__anon3b9019b50211::QuicSimpleServerSessionTest
279 session_->OnStreamFrame(data1); in TEST_P()
280 EXPECT_EQ(1u, QuicSessionPeer::GetNumOpenDynamicStreams(session_.get())); in TEST_P()
287 EXPECT_CALL(*session_, WriteControlFrame(_, _)); in TEST_P()
295 session_->OnRstStream(rst1); in TEST_P()
[all …]
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/tools/ |
| D | quic_simple_server_session_test.cc | 209 session_ = std::make_unique<MockQuicSimpleServerSession>( in QuicSimpleServerSessionTest()
216 session_->Initialize(); in QuicSimpleServerSessionTest()
219 EXPECT_CALL(*session_, WriteControlFrame(_, _)) in QuicSimpleServerSessionTest()
222 session_->OnConfigNegotiated(); in QuicSimpleServerSessionTest()
255 session_->OnStopSendingFrame(stop_sending); in InjectStopSending()
267 std::unique_ptr<MockQuicSimpleServerSession> session_; member in quic::test::__anon8782f6d10211::QuicSimpleServerSessionTest
279 session_->OnStreamFrame(data1); in TEST_P()
280 EXPECT_EQ(1u, QuicSessionPeer::GetNumOpenDynamicStreams(session_.get())); in TEST_P()
287 EXPECT_CALL(*session_, WriteControlFrame(_, _)); in TEST_P()
295 session_->OnRstStream(rst1); in TEST_P()
[all …]
|
| /external/cronet/tot/net/quic/ |
| D | quic_chromium_client_session_test.cc | 179 session_ = std::make_unique<TestingQuicChromiumClientSession>( in Initialize()
209 session_->AddConnectivityObserver(connectivity_monitor_.get()); in Initialize()
216 session_->Initialize(); in Initialize()
218 session_->qpack_decoder()->set_qpack_stream_sender_delegate( in Initialize()
220 session_->StartReading(); in Initialize()
221 writer->set_delegate(session_.get()); in Initialize()
225 if (session_) { in TearDown()
227 session_->RemoveConnectivityObserver(connectivity_monitor_.get()); in TearDown()
229 session_->CloseSessionOnError( in TearDown()
236 ASSERT_THAT(session_->CryptoConnect(callback_.callback()), IsOk()); in CompleteCryptoHandshake()
[all …]
|
| D | quic_session_attempt.cc | 127 if (session_) { in PopulateNetErrorDetails()
129 session_->connection()->version()); in PopulateNetErrorDetails()
130 details->quic_connection_error = session_->error(); in PopulateNetErrorDetails()
201 dns_resolution_end_time_, net_log(), &session_, &network_, in DoCreateSession()
207 DCHECK(!session_); in DoCreateSession()
217 CHECK(!session_); in DoCreateSessionComplete()
222 if (!session_->connection()->connected()) { in DoCreateSessionComplete()
226 CHECK(session_); in DoCreateSessionComplete()
227 session_->StartReading(); in DoCreateSessionComplete()
228 if (!session_->connection()->connected()) { in DoCreateSessionComplete()
[all …]
|
| /external/cronet/stable/net/quic/ |
| D | quic_chromium_client_session_test.cc | 179 session_ = std::make_unique<TestingQuicChromiumClientSession>( in Initialize()
209 session_->AddConnectivityObserver(connectivity_monitor_.get()); in Initialize()
216 session_->Initialize(); in Initialize()
218 session_->qpack_decoder()->set_qpack_stream_sender_delegate( in Initialize()
220 session_->StartReading(); in Initialize()
221 writer->set_delegate(session_.get()); in Initialize()
225 if (session_) { in TearDown()
227 session_->RemoveConnectivityObserver(connectivity_monitor_.get()); in TearDown()
229 session_->CloseSessionOnError( in TearDown()
236 ASSERT_THAT(session_->CryptoConnect(callback_.callback()), IsOk()); in CompleteCryptoHandshake()
[all …]
|
| D | quic_session_attempt.cc | 127 if (session_) { in PopulateNetErrorDetails()
129 session_->connection()->version()); in PopulateNetErrorDetails()
130 details->quic_connection_error = session_->error(); in PopulateNetErrorDetails()
201 dns_resolution_end_time_, net_log(), &session_, &network_, in DoCreateSession()
207 DCHECK(!session_); in DoCreateSession()
217 CHECK(!session_); in DoCreateSessionComplete()
222 if (!session_->connection()->connected()) { in DoCreateSessionComplete()
226 CHECK(session_); in DoCreateSessionComplete()
227 session_->StartReading(); in DoCreateSessionComplete()
228 if (!session_->connection()->connected()) { in DoCreateSessionComplete()
[all …]
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/moqt/ |
| D | moqt_session.cc | 103 : session_(session), in MoqtSession()
115 webtransport::Stream* raw_stream = session_->GetStreamById(*control_stream_); in GetControlStream()
139 session_->OpenOutgoingBidirectionalStream(); in OnSessionReady()
174 session_->AcceptIncomingBidirectionalStream()) { in OnIncomingBidirectionalStreamAvailable()
185 session_->AcceptIncomingUnidirectionalStream()) { in OnIncomingUnidirectionalStreamAvailable()
234 session_->CloseSession(static_cast<uint64_t>(code), error); in Error()
388 if (fetch->session_->WriteObjectToStream( in OnCanWrite()
435 webtransport::Stream* stream = session_->GetStreamById(stream_id); in SubscribeIsDone()
503 if (!session_->CanOpenNextOutgoingUnidirectionalStream()) { in OpenOrQueueDataStream()
516 session_->OpenOutgoingUnidirectionalStream(); in OpenDataStream()
[all …]
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/moqt/ |
| D | moqt_session.cc | 103 : session_(session), in MoqtSession()
115 webtransport::Stream* raw_stream = session_->GetStreamById(*control_stream_); in GetControlStream()
139 session_->OpenOutgoingBidirectionalStream(); in OnSessionReady()
174 session_->AcceptIncomingBidirectionalStream()) { in OnIncomingBidirectionalStreamAvailable()
185 session_->AcceptIncomingUnidirectionalStream()) { in OnIncomingUnidirectionalStreamAvailable()
234 session_->CloseSession(static_cast<uint64_t>(code), error); in Error()
388 if (fetch->session_->WriteObjectToStream( in OnCanWrite()
435 webtransport::Stream* stream = session_->GetStreamById(stream_id); in SubscribeIsDone()
503 if (!session_->CanOpenNextOutgoingUnidirectionalStream()) { in OpenOrQueueDataStream()
516 session_->OpenOutgoingUnidirectionalStream(); in OpenDataStream()
[all …]
|