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/reliable_quic_stream.h" | 5 #include "net/quic/reliable_quic_stream.h" |
6 | 6 |
7 #include "net/quic/quic_ack_notifier.h" | 7 #include "net/quic/quic_ack_notifier.h" |
8 #include "net/quic/quic_connection.h" | 8 #include "net/quic/quic_connection.h" |
9 #include "net/quic/quic_flags.h" | 9 #include "net/quic/quic_flags.h" |
10 #include "net/quic/quic_utils.h" | 10 #include "net/quic/quic_utils.h" |
(...skipping 103 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
114 session_.reset(new StrictMock<MockSession>(connection_)); | 114 session_.reset(new StrictMock<MockSession>(connection_)); |
115 | 115 |
116 // New streams rely on having the peer's flow control receive window | 116 // New streams rely on having the peer's flow control receive window |
117 // negotiated in the config. | 117 // negotiated in the config. |
118 QuicConfigPeer::SetReceivedInitialFlowControlWindow( | 118 QuicConfigPeer::SetReceivedInitialFlowControlWindow( |
119 session_->config(), initial_flow_control_window_bytes_); | 119 session_->config(), initial_flow_control_window_bytes_); |
120 | 120 |
121 stream_.reset(new TestStream(kHeadersStreamId, session_.get(), | 121 stream_.reset(new TestStream(kHeadersStreamId, session_.get(), |
122 stream_should_process_data)); | 122 stream_should_process_data)); |
123 write_blocked_list_ = | 123 write_blocked_list_ = |
124 QuicSessionPeer::GetWriteblockedStreams(session_.get()); | 124 QuicSessionPeer::GetWriteBlockedStreams(session_.get()); |
125 } | 125 } |
126 | 126 |
127 bool fin_sent() { return ReliableQuicStreamPeer::FinSent(stream_.get()); } | 127 bool fin_sent() { return ReliableQuicStreamPeer::FinSent(stream_.get()); } |
128 bool rst_sent() { return ReliableQuicStreamPeer::RstSent(stream_.get()); } | 128 bool rst_sent() { return ReliableQuicStreamPeer::RstSent(stream_.get()); } |
129 | 129 |
130 void set_initial_flow_control_window_bytes(uint32 val) { | 130 void set_initial_flow_control_window_bytes(uint32 val) { |
131 initial_flow_control_window_bytes_ = val; | 131 initial_flow_control_window_bytes_ = val; |
132 } | 132 } |
133 | 133 |
134 bool HasWriteBlockedStreams() { | 134 bool HasWriteBlockedStreams() { |
(...skipping 413 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
548 | 548 |
549 // Handle the acks. | 549 // Handle the acks. |
550 proxy_delegate->OnAckNotification(1, 2, 3, 4, zero_); | 550 proxy_delegate->OnAckNotification(1, 2, 3, 4, zero_); |
551 EXPECT_CALL(*delegate, OnAckNotification(11, 22, 33, 44, zero_)); | 551 EXPECT_CALL(*delegate, OnAckNotification(11, 22, 33, 44, zero_)); |
552 proxy_delegate->OnAckNotification(10, 20, 30, 40, zero_); | 552 proxy_delegate->OnAckNotification(10, 20, 30, 40, zero_); |
553 } | 553 } |
554 | 554 |
555 } // namespace | 555 } // namespace |
556 } // namespace test | 556 } // namespace test |
557 } // namespace net | 557 } // namespace net |
OLD | NEW |