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

Unified Diff: net/quic/quic_connection_test.cc

Issue 11958018: Queueing QUIC frames to be resent instead of packets and packing RST frames with acks and congestio… (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 11 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
Index: net/quic/quic_connection_test.cc
diff --git a/net/quic/quic_connection_test.cc b/net/quic/quic_connection_test.cc
index c85a15efb79dd4867c825d7fbfec22a376012d9a..4f0bf6ea39eaa0b97326794ec5766fdd859d86a8 100644
--- a/net/quic/quic_connection_test.cc
+++ b/net/quic/quic_connection_test.cc
@@ -903,50 +903,50 @@ TEST_F(QuicConnectionTest, TimeoutAfterSend) {
// TODO(ianswett): Add scheduler tests when resend is false.
TEST_F(QuicConnectionTest, SendScheduler) {
// Test that if we send a packet without delay, it is not queued.
- scoped_ptr<QuicPacket> packet(ConstructDataPacket(1, 0));
+ QuicPacket* packet = ConstructDataPacket(1, 0);
EXPECT_CALL(*scheduler_, TimeUntilSend(false)).WillOnce(testing::Return(
QuicTime::Delta()));
EXPECT_CALL(*scheduler_, SentPacket(_, _, _));
- connection_.SendPacket(1, packet.get(), true, false, false);
+ connection_.SendPacket(1, packet, true, false, false);
EXPECT_EQ(0u, connection_.NumQueuedPackets());
}
TEST_F(QuicConnectionTest, SendSchedulerDelay) {
// Test that if we send a packet with a delay, it ends up queued.
- scoped_ptr<QuicPacket> packet(ConstructDataPacket(1, 0));
+ QuicPacket* packet = ConstructDataPacket(1, 0);
EXPECT_CALL(*scheduler_, TimeUntilSend(false)).WillOnce(testing::Return(
QuicTime::Delta::FromMicroseconds(1)));
EXPECT_CALL(*scheduler_, SentPacket(1, _, _)).Times(0);
- connection_.SendPacket(1, packet.get(), true, false, false);
+ connection_.SendPacket(1, packet, true, false, false);
EXPECT_EQ(1u, connection_.NumQueuedPackets());
}
TEST_F(QuicConnectionTest, SendSchedulerForce) {
// Test that if we force send a packet, it is not queued.
- scoped_ptr<QuicPacket> packet(ConstructDataPacket(1, 0));
+ QuicPacket* packet = ConstructDataPacket(1, 0);
EXPECT_CALL(*scheduler_, TimeUntilSend(true)).Times(0);
EXPECT_CALL(*scheduler_, SentPacket(_, _, _));
- connection_.SendPacket(1, packet.get(), true, true, false);
+ connection_.SendPacket(1, packet, true, true, false);
EXPECT_EQ(0u, connection_.NumQueuedPackets());
}
// TODO(rch): Enable after we get non-blocking sockets.
TEST_F(QuicConnectionTest, DISABLED_SendSchedulerEAGAIN) {
- scoped_ptr<QuicPacket> packet(ConstructDataPacket(1, 0));
+ QuicPacket* packet = ConstructDataPacket(1, 0);
helper_->set_blocked(true);
EXPECT_CALL(*scheduler_, TimeUntilSend(false)).WillOnce(testing::Return(
QuicTime::Delta()));
EXPECT_CALL(*scheduler_, SentPacket(1, _, _)).Times(0);
- connection_.SendPacket(1, packet.get(), true, false, false);
+ connection_.SendPacket(1, packet, true, false, false);
EXPECT_EQ(1u, connection_.NumQueuedPackets());
}
TEST_F(QuicConnectionTest, SendSchedulerDelayThenSend) {
// Test that if we send a packet with a delay, it ends up queued.
- scoped_ptr<QuicPacket> packet(ConstructDataPacket(1, 0));
+ QuicPacket* packet = ConstructDataPacket(1, 0);
EXPECT_CALL(*scheduler_, TimeUntilSend(false)).WillOnce(testing::Return(
QuicTime::Delta::FromMicroseconds(1)));
- connection_.SendPacket(1, packet.get(), true, false, false);
+ connection_.SendPacket(1, packet, true, false, false);
EXPECT_EQ(1u, connection_.NumQueuedPackets());
// Advance the clock to fire the alarm, and configure the scheduler
@@ -962,10 +962,10 @@ TEST_F(QuicConnectionTest, SendSchedulerDelayThenSend) {
TEST_F(QuicConnectionTest, SendSchedulerDelayThenRetransmit) {
// Test that if we send a retransmit with a delay, it ends up queued.
- scoped_ptr<QuicPacket> packet(ConstructDataPacket(1, 0));
+ QuicPacket* packet = ConstructDataPacket(1, 0);
EXPECT_CALL(*scheduler_, TimeUntilSend(true)).WillOnce(testing::Return(
QuicTime::Delta::FromMicroseconds(1)));
- connection_.SendPacket(1, packet.get(), true, false, true);
+ connection_.SendPacket(1, packet, true, false, true);
EXPECT_EQ(1u, connection_.NumQueuedPackets());
// Advance the clock to fire the alarm, and configure the scheduler
@@ -982,22 +982,23 @@ TEST_F(QuicConnectionTest, SendSchedulerDelayThenRetransmit) {
}
TEST_F(QuicConnectionTest, SendSchedulerDelayAndQueue) {
- scoped_ptr<QuicPacket> packet(ConstructDataPacket(1, 0));
+ QuicPacket* packet = ConstructDataPacket(1, 0);
EXPECT_CALL(*scheduler_, TimeUntilSend(false)).WillOnce(testing::Return(
QuicTime::Delta::FromMicroseconds(1)));
- connection_.SendPacket(1, packet.get(), true, false, false);
+ connection_.SendPacket(1, packet, true, false, false);
EXPECT_EQ(1u, connection_.NumQueuedPackets());
// Attempt to send another packet and make sure that it gets queued.
- connection_.SendPacket(2, packet.get(), true, false, false);
+ packet = ConstructDataPacket(2, 0);
+ connection_.SendPacket(2, packet, true, false, false);
EXPECT_EQ(2u, connection_.NumQueuedPackets());
}
TEST_F(QuicConnectionTest, SendSchedulerDelayThenAckAndSend) {
- scoped_ptr<QuicPacket> packet(ConstructDataPacket(1, 0));
+ QuicPacket* packet = ConstructDataPacket(1, 0);
EXPECT_CALL(*scheduler_, TimeUntilSend(false)).WillOnce(testing::Return(
QuicTime::Delta::FromMicroseconds(10)));
- connection_.SendPacket(1, packet.get(), true, false, false);
+ connection_.SendPacket(1, packet, true, false, false);
EXPECT_EQ(1u, connection_.NumQueuedPackets());
// Now send non-retransmitting information, that we're not going to resend 3.
@@ -1015,10 +1016,10 @@ TEST_F(QuicConnectionTest, SendSchedulerDelayThenAckAndSend) {
}
TEST_F(QuicConnectionTest, SendSchedulerDelayThenAckAndHold) {
- scoped_ptr<QuicPacket> packet(ConstructDataPacket(1, 0));
+ QuicPacket* packet = ConstructDataPacket(1, 0);
EXPECT_CALL(*scheduler_, TimeUntilSend(false)).WillOnce(testing::Return(
QuicTime::Delta::FromMicroseconds(10)));
- connection_.SendPacket(1, packet.get(), true, false, false);
+ connection_.SendPacket(1, packet, true, false, false);
EXPECT_EQ(1u, connection_.NumQueuedPackets());
// Now send non-resending information, that we're not going to resend 3.
@@ -1032,10 +1033,10 @@ TEST_F(QuicConnectionTest, SendSchedulerDelayThenAckAndHold) {
}
TEST_F(QuicConnectionTest, SendSchedulerDelayThenOnCanWrite) {
- scoped_ptr<QuicPacket> packet(ConstructDataPacket(1, 0));
+ QuicPacket* packet = ConstructDataPacket(1, 0);
EXPECT_CALL(*scheduler_, TimeUntilSend(false)).WillOnce(testing::Return(
QuicTime::Delta::FromMicroseconds(10)));
- connection_.SendPacket(1, packet.get(), true, false, false);
+ connection_.SendPacket(1, packet, true, false, false);
EXPECT_EQ(1u, connection_.NumQueuedPackets());
// OnCanWrite should not send the packet (because of the delay)

Powered by Google App Engine
This is Rietveld 408576698