Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(852)

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: net/quic/chromium/quic_chromium_client_session_test.cc

Issue 2854833005: QUIC - stream id refactor for tests. (Closed)
Patch Set: rebase Created 3 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/quic/chromium/bidirectional_stream_quic_impl_unittest.cc ('k') | net/quic/chromium/quic_chromium_client_stream_test.cc » ('j') | net/quic/chromium/quic_network_transaction_unittest.cc » ('J')
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/quic/chromium/quic_chromium_client_session_test.cc
diff --git a/net/quic/chromium/quic_chromium_client_session_test.cc b/net/quic/chromium/quic_chromium_client_session_test.cc
index 2ac521305b457e265ea593dcd845e8d1fbf41ac8..50f37a3df00fe9455870d784121d8b044034ae73 100644
--- a/net/quic/chromium/quic_chromium_client_session_test.cc
+++ b/net/quic/chromium/quic_chromium_client_session_test.cc
@@ -157,6 +157,14 @@ class QuicChromiumClientSessionTest
return writer.release();
}
+ QuicStreamId GetNthClientInitiatedStreamId(int n) {
+ return QuicSpdySessionPeer::GetNthClientInitiatedStreamId(*session_, n);
+ }
+
+ QuicStreamId GetNthServerInitiatedStreamId(int n) {
+ return QuicSpdySessionPeer::GetNthServerInitiatedStreamId(*session_, n);
+ }
+
QuicCryptoClientConfig crypto_config_;
TestNetLog net_log_;
BoundTestNetLog bound_test_net_log_;
@@ -268,8 +276,8 @@ TEST_P(QuicChromiumClientSessionTest, StreamRequestBeforeConfirmation) {
TEST_P(QuicChromiumClientSessionTest, CancelStreamRequestBeforeRelease) {
MockQuicData quic_data;
quic_data.AddWrite(client_maker_.MakeInitialSettingsPacket(1, nullptr));
- quic_data.AddWrite(client_maker_.MakeRstPacket(2, true, kClientDataStreamId1,
- QUIC_STREAM_CANCELLED));
+ quic_data.AddWrite(client_maker_.MakeRstPacket(
+ 2, true, GetNthClientInitiatedStreamId(0), QUIC_STREAM_CANCELLED));
quic_data.AddRead(ASYNC, ERR_IO_PENDING);
quic_data.AddRead(ASYNC, OK); // EOF
quic_data.AddSocketDataToFactory(&socket_factory_);
@@ -292,8 +300,8 @@ TEST_P(QuicChromiumClientSessionTest, CancelStreamRequestBeforeRelease) {
TEST_P(QuicChromiumClientSessionTest, AsyncStreamRequest) {
MockQuicData quic_data;
quic_data.AddWrite(client_maker_.MakeInitialSettingsPacket(1, nullptr));
- quic_data.AddWrite(client_maker_.MakeRstPacket(2, true, kClientDataStreamId1,
- QUIC_RST_ACKNOWLEDGEMENT));
+ quic_data.AddWrite(client_maker_.MakeRstPacket(
+ 2, true, GetNthClientInitiatedStreamId(0), QUIC_RST_ACKNOWLEDGEMENT));
quic_data.AddRead(ASYNC, ERR_IO_PENDING);
quic_data.AddRead(ASYNC, OK); // EOF
quic_data.AddSocketDataToFactory(&socket_factory_);
@@ -316,7 +324,8 @@ TEST_P(QuicChromiumClientSessionTest, AsyncStreamRequest) {
ASSERT_EQ(ERR_IO_PENDING, stream_request->StartRequest(callback.callback()));
// Close a stream and ensure the stream request completes.
- QuicRstStreamFrame rst(kClientDataStreamId1, QUIC_STREAM_CANCELLED, 0);
+ QuicRstStreamFrame rst(GetNthClientInitiatedStreamId(0),
+ QUIC_STREAM_CANCELLED, 0);
session_->OnRstStream(rst);
ASSERT_TRUE(callback.have_result());
EXPECT_THAT(callback.WaitForResult(), IsOk());
@@ -330,8 +339,8 @@ TEST_P(QuicChromiumClientSessionTest, AsyncStreamRequest) {
TEST_P(QuicChromiumClientSessionTest, CancelPendingStreamRequest) {
MockQuicData quic_data;
quic_data.AddWrite(client_maker_.MakeInitialSettingsPacket(1, nullptr));
- quic_data.AddWrite(client_maker_.MakeRstPacket(2, true, kClientDataStreamId1,
- QUIC_RST_ACKNOWLEDGEMENT));
+ quic_data.AddWrite(client_maker_.MakeRstPacket(
+ 2, true, GetNthClientInitiatedStreamId(0), QUIC_RST_ACKNOWLEDGEMENT));
quic_data.AddRead(ASYNC, ERR_IO_PENDING);
quic_data.AddRead(ASYNC, OK); // EOF
quic_data.AddSocketDataToFactory(&socket_factory_);
@@ -357,7 +366,8 @@ TEST_P(QuicChromiumClientSessionTest, CancelPendingStreamRequest) {
stream_request.reset();
// Close a stream and ensure that no new stream is created.
- QuicRstStreamFrame rst(kClientDataStreamId1, QUIC_STREAM_CANCELLED, 0);
+ QuicRstStreamFrame rst(GetNthClientInitiatedStreamId(0),
+ QUIC_STREAM_CANCELLED, 0);
session_->OnRstStream(rst);
EXPECT_EQ(kMaxOpenStreams - 1, session_->GetNumOpenOutgoingStreams());
@@ -454,7 +464,7 @@ TEST_P(QuicChromiumClientSessionTest, MaxNumStreams) {
std::unique_ptr<QuicEncryptedPacket> settings_packet(
client_maker_.MakeInitialSettingsPacket(1, nullptr));
std::unique_ptr<QuicEncryptedPacket> client_rst(client_maker_.MakeRstPacket(
- 2, true, kClientDataStreamId1, QUIC_RST_ACKNOWLEDGEMENT));
+ 2, true, GetNthClientInitiatedStreamId(0), QUIC_RST_ACKNOWLEDGEMENT));
MockWrite writes[] = {
MockWrite(ASYNC, settings_packet->data(), settings_packet->length(), 1),
MockWrite(ASYNC, client_rst->data(), client_rst->length(), 2)};
@@ -493,7 +503,7 @@ TEST_P(QuicChromiumClientSessionTest, PushStreamTimedOutNoResponse) {
std::unique_ptr<QuicEncryptedPacket> settings_packet(
client_maker_.MakeInitialSettingsPacket(1, nullptr));
std::unique_ptr<QuicEncryptedPacket> client_rst(client_maker_.MakeRstPacket(
- 2, true, kServerDataStreamId1, QUIC_PUSH_STREAM_TIMED_OUT));
+ 2, true, GetNthServerInitiatedStreamId(0), QUIC_PUSH_STREAM_TIMED_OUT));
MockWrite writes[] = {
MockWrite(ASYNC, settings_packet->data(), settings_packet->length(), 1),
MockWrite(ASYNC, client_rst->data(), client_rst->length(), 2)};
@@ -520,11 +530,11 @@ TEST_P(QuicChromiumClientSessionTest, PushStreamTimedOutNoResponse) {
promise_headers[":path"] = "/pushed.jpg";
// Receive a PUSH PROMISE from the server.
- EXPECT_TRUE(session_->HandlePromised(stream->id(), kServerDataStreamId1,
- promise_headers));
+ EXPECT_TRUE(session_->HandlePromised(
+ stream->id(), GetNthServerInitiatedStreamId(0), promise_headers));
QuicClientPromisedInfo* promised =
- session_->GetPromisedById(kServerDataStreamId1);
+ session_->GetPromisedById(GetNthServerInitiatedStreamId(0));
EXPECT_TRUE(promised);
// Fire alarm to time out the push stream.
alarm_factory_.FireAlarm(QuicClientPromisedInfoPeer::GetAlarm(promised));
@@ -542,7 +552,7 @@ TEST_P(QuicChromiumClientSessionTest, PushStreamTimedOutWithResponse) {
std::unique_ptr<QuicEncryptedPacket> settings_packet(
client_maker_.MakeInitialSettingsPacket(1, nullptr));
std::unique_ptr<QuicEncryptedPacket> client_rst(client_maker_.MakeRstPacket(
- 2, true, kServerDataStreamId1, QUIC_PUSH_STREAM_TIMED_OUT));
+ 2, true, GetNthServerInitiatedStreamId(0), QUIC_PUSH_STREAM_TIMED_OUT));
MockWrite writes[] = {
MockWrite(ASYNC, settings_packet->data(), settings_packet->length(), 1),
MockWrite(ASYNC, client_rst->data(), client_rst->length(), 2)};
@@ -568,17 +578,19 @@ TEST_P(QuicChromiumClientSessionTest, PushStreamTimedOutWithResponse) {
promise_headers[":scheme"] = "https";
promise_headers[":path"] = "/pushed.jpg";
- session_->GetOrCreateStream(kServerDataStreamId1);
+ session_->GetOrCreateStream(GetNthServerInitiatedStreamId(0));
// Receive a PUSH PROMISE from the server.
- EXPECT_TRUE(session_->HandlePromised(stream->id(), kServerDataStreamId1,
- promise_headers));
- session_->OnInitialHeadersComplete(kServerDataStreamId1, SpdyHeaderBlock());
+ EXPECT_TRUE(session_->HandlePromised(
+ stream->id(), GetNthServerInitiatedStreamId(0), promise_headers));
+ session_->OnInitialHeadersComplete(GetNthServerInitiatedStreamId(0),
+ SpdyHeaderBlock());
// Read data on the pushed stream.
- QuicStreamFrame data(kServerDataStreamId1, false, 0, QuicStringPiece("SP"));
+ QuicStreamFrame data(GetNthServerInitiatedStreamId(0), false, 0,
+ QuicStringPiece("SP"));
session_->OnStreamFrame(data);
QuicClientPromisedInfo* promised =
- session_->GetPromisedById(kServerDataStreamId1);
+ session_->GetPromisedById(GetNthServerInitiatedStreamId(0));
EXPECT_TRUE(promised);
// Fire alarm to time out the push stream.
alarm_factory_.FireAlarm(QuicClientPromisedInfoPeer::GetAlarm(promised));
@@ -593,7 +605,7 @@ TEST_P(QuicChromiumClientSessionTest, CancelPushWhenPendingValidation) {
std::unique_ptr<QuicEncryptedPacket> settings_packet(
client_maker_.MakeInitialSettingsPacket(1, nullptr));
std::unique_ptr<QuicEncryptedPacket> client_rst(client_maker_.MakeRstPacket(
- 2, true, kClientDataStreamId1, QUIC_RST_ACKNOWLEDGEMENT));
+ 2, true, GetNthClientInitiatedStreamId(0), QUIC_RST_ACKNOWLEDGEMENT));
MockWrite writes[] = {
MockWrite(ASYNC, settings_packet->data(), settings_packet->length(), 1),
@@ -621,11 +633,11 @@ TEST_P(QuicChromiumClientSessionTest, CancelPushWhenPendingValidation) {
promise_headers[":path"] = "/pushed.jpg";
// Receive a PUSH PROMISE from the server.
- EXPECT_TRUE(session_->HandlePromised(stream->id(), kServerDataStreamId1,
- promise_headers));
+ EXPECT_TRUE(session_->HandlePromised(
+ stream->id(), GetNthServerInitiatedStreamId(0), promise_headers));
QuicClientPromisedInfo* promised =
- session_->GetPromisedById(kServerDataStreamId1);
+ session_->GetPromisedById(GetNthServerInitiatedStreamId(0));
EXPECT_TRUE(promised);
// Initiate rendezvous.
@@ -639,7 +651,7 @@ TEST_P(QuicChromiumClientSessionTest, CancelPushWhenPendingValidation) {
EXPECT_TRUE(session_->GetPromisedByUrl(pushed_url.spec()));
// Reset the stream now before tear down.
- session_->CloseStream(kClientDataStreamId1);
+ session_->CloseStream(GetNthClientInitiatedStreamId(0));
}
TEST_P(QuicChromiumClientSessionTest, CancelPushBeforeReceivingResponse) {
@@ -648,7 +660,7 @@ TEST_P(QuicChromiumClientSessionTest, CancelPushBeforeReceivingResponse) {
std::unique_ptr<QuicEncryptedPacket> settings_packet(
client_maker_.MakeInitialSettingsPacket(1, nullptr));
std::unique_ptr<QuicEncryptedPacket> client_rst(client_maker_.MakeRstPacket(
- 2, true, kServerDataStreamId1, QUIC_STREAM_CANCELLED));
+ 2, true, GetNthServerInitiatedStreamId(0), QUIC_STREAM_CANCELLED));
MockWrite writes[] = {
MockWrite(ASYNC, settings_packet->data(), settings_packet->length(), 1),
MockWrite(ASYNC, client_rst->data(), client_rst->length(), 2)};
@@ -675,11 +687,11 @@ TEST_P(QuicChromiumClientSessionTest, CancelPushBeforeReceivingResponse) {
promise_headers[":path"] = "/pushed.jpg";
// Receive a PUSH PROMISE from the server.
- EXPECT_TRUE(session_->HandlePromised(stream->id(), kServerDataStreamId1,
- promise_headers));
+ EXPECT_TRUE(session_->HandlePromised(
+ stream->id(), GetNthServerInitiatedStreamId(0), promise_headers));
QuicClientPromisedInfo* promised =
- session_->GetPromisedById(kServerDataStreamId1);
+ session_->GetPromisedById(GetNthServerInitiatedStreamId(0));
EXPECT_TRUE(promised);
// Cancel the push before receiving the response to the pushed request.
GURL pushed_url("https://www.example.org/pushed.jpg");
@@ -698,7 +710,7 @@ TEST_P(QuicChromiumClientSessionTest, CancelPushAfterReceivingResponse) {
std::unique_ptr<QuicEncryptedPacket> settings_packet(
client_maker_.MakeInitialSettingsPacket(1, nullptr));
std::unique_ptr<QuicEncryptedPacket> client_rst(client_maker_.MakeRstPacket(
- 2, true, kServerDataStreamId1, QUIC_STREAM_CANCELLED));
+ 2, true, GetNthServerInitiatedStreamId(0), QUIC_STREAM_CANCELLED));
MockWrite writes[] = {
MockWrite(ASYNC, settings_packet->data(), settings_packet->length(), 1),
MockWrite(ASYNC, client_rst->data(), client_rst->length(), 2)};
@@ -724,17 +736,19 @@ TEST_P(QuicChromiumClientSessionTest, CancelPushAfterReceivingResponse) {
promise_headers[":scheme"] = "https";
promise_headers[":path"] = "/pushed.jpg";
- session_->GetOrCreateStream(kServerDataStreamId1);
+ session_->GetOrCreateStream(GetNthServerInitiatedStreamId(0));
// Receive a PUSH PROMISE from the server.
- EXPECT_TRUE(session_->HandlePromised(stream->id(), kServerDataStreamId1,
- promise_headers));
- session_->OnInitialHeadersComplete(kServerDataStreamId1, SpdyHeaderBlock());
+ EXPECT_TRUE(session_->HandlePromised(
+ stream->id(), GetNthServerInitiatedStreamId(0), promise_headers));
+ session_->OnInitialHeadersComplete(GetNthServerInitiatedStreamId(0),
+ SpdyHeaderBlock());
// Read data on the pushed stream.
- QuicStreamFrame data(kServerDataStreamId1, false, 0, QuicStringPiece("SP"));
+ QuicStreamFrame data(GetNthServerInitiatedStreamId(0), false, 0,
+ QuicStringPiece("SP"));
session_->OnStreamFrame(data);
QuicClientPromisedInfo* promised =
- session_->GetPromisedById(kServerDataStreamId1);
+ session_->GetPromisedById(GetNthServerInitiatedStreamId(0));
EXPECT_TRUE(promised);
// Cancel the push after receiving data on the push stream.
GURL pushed_url("https://www.example.org/pushed.jpg");
@@ -752,7 +766,7 @@ TEST_P(QuicChromiumClientSessionTest, Priority) {
std::unique_ptr<QuicEncryptedPacket> settings_packet(
client_maker_.MakeInitialSettingsPacket(1, nullptr));
std::unique_ptr<QuicEncryptedPacket> client_rst(client_maker_.MakeRstPacket(
- 2, true, kClientDataStreamId1, QUIC_RST_ACKNOWLEDGEMENT));
+ 2, true, GetNthClientInitiatedStreamId(0), QUIC_RST_ACKNOWLEDGEMENT));
MockWrite writes[] = {
MockWrite(ASYNC, settings_packet->data(), settings_packet->length(), 1),
MockWrite(ASYNC, client_rst->data(), client_rst->length(), 2)};
@@ -781,7 +795,7 @@ TEST_P(QuicChromiumClientSessionTest, MaxNumStreamsViaRequest) {
std::unique_ptr<QuicEncryptedPacket> settings_packet(
client_maker_.MakeInitialSettingsPacket(1, nullptr));
std::unique_ptr<QuicEncryptedPacket> client_rst(client_maker_.MakeRstPacket(
- 2, true, kClientDataStreamId1, QUIC_RST_ACKNOWLEDGEMENT));
+ 2, true, GetNthClientInitiatedStreamId(0), QUIC_RST_ACKNOWLEDGEMENT));
MockWrite writes[] = {
MockWrite(ASYNC, settings_packet->data(), settings_packet->length(), 1),
MockWrite(ASYNC, client_rst->data(), client_rst->length(), 2)};
« no previous file with comments | « net/quic/chromium/bidirectional_stream_quic_impl_unittest.cc ('k') | net/quic/chromium/quic_chromium_client_stream_test.cc » ('j') | net/quic/chromium/quic_network_transaction_unittest.cc » ('J')

Powered by Google App Engine
This is Rietveld 408576698