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 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
(...skipping 382 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
393 &session_, &TestSession::SendStreamData, stream4->id())))); | 393 &session_, &TestSession::SendStreamData, stream4->id())))); |
394 EXPECT_CALL(*stream6, OnCanWrite()) | 394 EXPECT_CALL(*stream6, OnCanWrite()) |
395 .WillOnce(IgnoreResult(Invoke(CreateFunctor( | 395 .WillOnce(IgnoreResult(Invoke(CreateFunctor( |
396 &session_, &TestSession::SendStreamData, stream6->id())))); | 396 &session_, &TestSession::SendStreamData, stream6->id())))); |
397 | 397 |
398 // Expect that we only send one packet, the writes from different streams | 398 // Expect that we only send one packet, the writes from different streams |
399 // should be bundled together. | 399 // should be bundled together. |
400 MockPacketWriter* writer = | 400 MockPacketWriter* writer = |
401 static_cast<MockPacketWriter*>( | 401 static_cast<MockPacketWriter*>( |
402 QuicConnectionPeer::GetWriter(session_.connection())); | 402 QuicConnectionPeer::GetWriter(session_.connection())); |
403 EXPECT_CALL(*writer, WritePacket(_, _, _, _)).WillOnce( | 403 EXPECT_CALL(*writer, WritePacket(_, _, _, _, _)).WillOnce( |
404 Return(WriteResult(WRITE_STATUS_OK, 0))); | 404 Return(WriteResult(WRITE_STATUS_OK, 0))); |
405 EXPECT_CALL(*send_algorithm, OnPacketSent(_, _, _, _, _)).Times(1); | 405 EXPECT_CALL(*send_algorithm, OnPacketSent(_, _, _, _, _)).Times(1); |
406 session_.OnCanWrite(); | 406 session_.OnCanWrite(); |
407 EXPECT_FALSE(session_.WillingAndAbleToWrite()); | 407 EXPECT_FALSE(session_.WillingAndAbleToWrite()); |
408 } | 408 } |
409 | 409 |
410 TEST_P(QuicSessionTest, OnCanWriteCongestionControlBlocks) { | 410 TEST_P(QuicSessionTest, OnCanWriteCongestionControlBlocks) { |
411 InSequence s; | 411 InSequence s; |
412 | 412 |
413 // Drive congestion control manually. | 413 // Drive congestion control manually. |
(...skipping 467 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
881 | 881 |
882 // Version 16 means all flow control is disabled. | 882 // Version 16 means all flow control is disabled. |
883 session_.OnSuccessfulVersionNegotiation(QUIC_VERSION_16); | 883 session_.OnSuccessfulVersionNegotiation(QUIC_VERSION_16); |
884 EXPECT_FALSE(session_.flow_controller()->IsEnabled()); | 884 EXPECT_FALSE(session_.flow_controller()->IsEnabled()); |
885 EXPECT_FALSE(stream->flow_controller()->IsEnabled()); | 885 EXPECT_FALSE(stream->flow_controller()->IsEnabled()); |
886 } | 886 } |
887 | 887 |
888 } // namespace | 888 } // namespace |
889 } // namespace test | 889 } // namespace test |
890 } // namespace net | 890 } // namespace net |
OLD | NEW |