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 562 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
573 } | 573 } |
574 ValueRestore<bool> old_flag(&FLAGS_enable_quic_stream_flow_control, true); | 574 ValueRestore<bool> old_flag(&FLAGS_enable_quic_stream_flow_control, true); |
575 | 575 |
576 // Ensure that Writev consumes all the data it is given (simulate no socket | 576 // Ensure that Writev consumes all the data it is given (simulate no socket |
577 // blocking). | 577 // blocking). |
578 session_.set_writev_consumes_all_data(true); | 578 session_.set_writev_consumes_all_data(true); |
579 | 579 |
580 // Create a stream, and send enough data to make it flow control blocked. | 580 // Create a stream, and send enough data to make it flow control blocked. |
581 TestStream* stream2 = session_.CreateOutgoingDataStream(); | 581 TestStream* stream2 = session_.CreateOutgoingDataStream(); |
582 string body(kDefaultFlowControlSendWindow, '.'); | 582 string body(kDefaultFlowControlSendWindow, '.'); |
583 EXPECT_FALSE(stream2->IsFlowControlBlocked()); | 583 EXPECT_FALSE(stream2->flow_controller()->IsBlocked()); |
584 stream2->SendBody(body, false); | 584 stream2->SendBody(body, false); |
585 EXPECT_TRUE(stream2->IsFlowControlBlocked()); | 585 EXPECT_TRUE(stream2->flow_controller()->IsBlocked()); |
586 | 586 |
587 // Now complete the crypto handshake, resulting in an increased flow control | 587 // Now complete the crypto handshake, resulting in an increased flow control |
588 // send window. | 588 // send window. |
589 CryptoHandshakeMessage msg; | 589 CryptoHandshakeMessage msg; |
590 session_.GetCryptoStream()->OnHandshakeMessage(msg); | 590 session_.GetCryptoStream()->OnHandshakeMessage(msg); |
591 | 591 |
592 // Stream is now unblocked. | 592 // Stream is now unblocked. |
593 EXPECT_FALSE(stream2->IsFlowControlBlocked()); | 593 EXPECT_FALSE(stream2->flow_controller()->IsBlocked()); |
594 } | 594 } |
595 | 595 |
596 TEST_P(QuicSessionTest, InvalidFlowControlWindowInHandshake) { | 596 TEST_P(QuicSessionTest, InvalidFlowControlWindowInHandshake) { |
597 // Test that receipt of an invalid (< default) flow control window from peer | 597 // Test that receipt of an invalid (< default) flow control window from peer |
598 // results in the connection being torn down. | 598 // results in the connection being torn down. |
599 if (version() < QUIC_VERSION_17) { | 599 if (version() < QUIC_VERSION_17) { |
600 return; | 600 return; |
601 } | 601 } |
602 ValueRestore<bool> old_flag(&FLAGS_enable_quic_stream_flow_control, true); | 602 ValueRestore<bool> old_flag(&FLAGS_enable_quic_stream_flow_control, true); |
603 | 603 |
(...skipping 10 matching lines...) Expand all Loading... |
614 EXPECT_CALL(*connection_, SendConnectionClose(QUIC_FLOW_CONTROL_ERROR)); | 614 EXPECT_CALL(*connection_, SendConnectionClose(QUIC_FLOW_CONTROL_ERROR)); |
615 string expected_error("Peer sent us an invalid flow control send window: "); | 615 string expected_error("Peer sent us an invalid flow control send window: "); |
616 expected_error.append(reinterpret_cast<const char*>(&kInvalidWindow), | 616 expected_error.append(reinterpret_cast<const char*>(&kInvalidWindow), |
617 sizeof(kInvalidWindow)); | 617 sizeof(kInvalidWindow)); |
618 EXPECT_DFATAL(session_.OnConfigNegotiated(), expected_error); | 618 EXPECT_DFATAL(session_.OnConfigNegotiated(), expected_error); |
619 } | 619 } |
620 | 620 |
621 } // namespace | 621 } // namespace |
622 } // namespace test | 622 } // namespace test |
623 } // namespace net | 623 } // namespace net |
OLD | NEW |