| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/quic/quic_session.h" | 5 #include "net/quic/quic_session.h" |
| 6 | 6 |
| 7 #include <set> | 7 #include <set> |
| 8 | 8 |
| 9 #include "base/basictypes.h" | 9 #include "base/basictypes.h" |
| 10 #include "base/containers/hash_tables.h" | 10 #include "base/containers/hash_tables.h" |
| (...skipping 365 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 376 | 376 |
| 377 session_.MarkWriteBlocked(stream2->id(), kSomeMiddlePriority); | 377 session_.MarkWriteBlocked(stream2->id(), kSomeMiddlePriority); |
| 378 session_.MarkWriteBlocked(stream6->id(), kSomeMiddlePriority); | 378 session_.MarkWriteBlocked(stream6->id(), kSomeMiddlePriority); |
| 379 session_.MarkWriteBlocked(stream4->id(), kSomeMiddlePriority); | 379 session_.MarkWriteBlocked(stream4->id(), kSomeMiddlePriority); |
| 380 | 380 |
| 381 EXPECT_CALL(*send_algorithm, TimeUntilSend(_, _, _)).WillRepeatedly( | 381 EXPECT_CALL(*send_algorithm, TimeUntilSend(_, _, _)).WillRepeatedly( |
| 382 Return(QuicTime::Delta::Zero())); | 382 Return(QuicTime::Delta::Zero())); |
| 383 EXPECT_CALL(*send_algorithm, GetCongestionWindow()) | 383 EXPECT_CALL(*send_algorithm, GetCongestionWindow()) |
| 384 .WillRepeatedly(Return(kMaxPacketSize * 10)); | 384 .WillRepeatedly(Return(kMaxPacketSize * 10)); |
| 385 EXPECT_CALL(*stream2, OnCanWrite()) | 385 EXPECT_CALL(*stream2, OnCanWrite()) |
| 386 .WillOnce(IgnoreResult(Invoke(CreateFunctor( | 386 .WillOnce(testing::IgnoreResult(Invoke(CreateFunctor( |
| 387 &session_, &TestSession::SendStreamData, stream2->id())))); | 387 &session_, &TestSession::SendStreamData, stream2->id())))); |
| 388 EXPECT_CALL(*stream4, OnCanWrite()) | 388 EXPECT_CALL(*stream4, OnCanWrite()) |
| 389 .WillOnce(IgnoreResult(Invoke(CreateFunctor( | 389 .WillOnce(testing::IgnoreResult(Invoke(CreateFunctor( |
| 390 &session_, &TestSession::SendStreamData, stream4->id())))); | 390 &session_, &TestSession::SendStreamData, stream4->id())))); |
| 391 EXPECT_CALL(*stream6, OnCanWrite()) | 391 EXPECT_CALL(*stream6, OnCanWrite()) |
| 392 .WillOnce(IgnoreResult(Invoke(CreateFunctor( | 392 .WillOnce(testing::IgnoreResult(Invoke(CreateFunctor( |
| 393 &session_, &TestSession::SendStreamData, stream6->id())))); | 393 &session_, &TestSession::SendStreamData, stream6->id())))); |
| 394 | 394 |
| 395 // Expect that we only send one packet, the writes from different streams | 395 // Expect that we only send one packet, the writes from different streams |
| 396 // should be bundled together. | 396 // should be bundled together. |
| 397 MockPacketWriter* writer = | 397 MockPacketWriter* writer = |
| 398 static_cast<MockPacketWriter*>( | 398 static_cast<MockPacketWriter*>( |
| 399 QuicConnectionPeer::GetWriter(session_.connection())); | 399 QuicConnectionPeer::GetWriter(session_.connection())); |
| 400 EXPECT_CALL(*writer, WritePacket(_, _, _, _)).WillOnce( | 400 EXPECT_CALL(*writer, WritePacket(_, _, _, _)).WillOnce( |
| 401 Return(WriteResult(WRITE_STATUS_OK, 0))); | 401 Return(WriteResult(WRITE_STATUS_OK, 0))); |
| 402 EXPECT_CALL(*send_algorithm, OnPacketSent(_, _, _, _, _)).Times(1); | 402 EXPECT_CALL(*send_algorithm, OnPacketSent(_, _, _, _, _)).Times(1); |
| (...skipping 581 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 984 EXPECT_TRUE(QuicSessionPeer::IsStreamImplicitlyCreated(&session_, 4)); | 984 EXPECT_TRUE(QuicSessionPeer::IsStreamImplicitlyCreated(&session_, 4)); |
| 985 ASSERT_TRUE(session_.GetIncomingDataStream(2) != nullptr); | 985 ASSERT_TRUE(session_.GetIncomingDataStream(2) != nullptr); |
| 986 ASSERT_TRUE(session_.GetIncomingDataStream(4) != nullptr); | 986 ASSERT_TRUE(session_.GetIncomingDataStream(4) != nullptr); |
| 987 // And 5 should be not implicitly created. | 987 // And 5 should be not implicitly created. |
| 988 EXPECT_FALSE(QuicSessionPeer::IsStreamImplicitlyCreated(&session_, 5)); | 988 EXPECT_FALSE(QuicSessionPeer::IsStreamImplicitlyCreated(&session_, 5)); |
| 989 } | 989 } |
| 990 | 990 |
| 991 } // namespace | 991 } // namespace |
| 992 } // namespace test | 992 } // namespace test |
| 993 } // namespace net | 993 } // namespace net |
| OLD | NEW |