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/chromium/quic_http_stream.h" | 5 #include "net/quic/chromium/quic_http_stream.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include <memory> | 9 #include <memory> |
10 #include <utility> | 10 #include <utility> |
(...skipping 262 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
273 | 273 |
274 std::unique_ptr<MockUDPClientSocket> socket(new MockUDPClientSocket( | 274 std::unique_ptr<MockUDPClientSocket> socket(new MockUDPClientSocket( |
275 socket_data_.get(), net_log_.bound().net_log())); | 275 socket_data_.get(), net_log_.bound().net_log())); |
276 socket->Connect(peer_addr_); | 276 socket->Connect(peer_addr_); |
277 runner_ = new TestTaskRunner(&clock_); | 277 runner_ = new TestTaskRunner(&clock_); |
278 send_algorithm_ = new MockSendAlgorithm(); | 278 send_algorithm_ = new MockSendAlgorithm(); |
279 EXPECT_CALL(*send_algorithm_, InRecovery()).WillRepeatedly(Return(false)); | 279 EXPECT_CALL(*send_algorithm_, InRecovery()).WillRepeatedly(Return(false)); |
280 EXPECT_CALL(*send_algorithm_, InSlowStart()).WillRepeatedly(Return(false)); | 280 EXPECT_CALL(*send_algorithm_, InSlowStart()).WillRepeatedly(Return(false)); |
281 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) | 281 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) |
282 .WillRepeatedly(Return(true)); | 282 .WillRepeatedly(Return(true)); |
283 EXPECT_CALL(*send_algorithm_, RetransmissionDelay()) | |
284 .WillRepeatedly(Return(QuicTime::Delta::Zero())); | |
285 EXPECT_CALL(*send_algorithm_, GetCongestionWindow()) | 283 EXPECT_CALL(*send_algorithm_, GetCongestionWindow()) |
286 .WillRepeatedly(Return(kMaxPacketSize)); | 284 .WillRepeatedly(Return(kMaxPacketSize)); |
287 EXPECT_CALL(*send_algorithm_, PacingRate(_)) | 285 EXPECT_CALL(*send_algorithm_, PacingRate(_)) |
288 .WillRepeatedly(Return(QuicBandwidth::Zero())); | 286 .WillRepeatedly(Return(QuicBandwidth::Zero())); |
289 EXPECT_CALL(*send_algorithm_, TimeUntilSend(_, _)) | 287 EXPECT_CALL(*send_algorithm_, TimeUntilSend(_, _)) |
290 .WillRepeatedly(Return(QuicTime::Delta::Zero())); | 288 .WillRepeatedly(Return(QuicTime::Delta::Zero())); |
291 EXPECT_CALL(*send_algorithm_, BandwidthEstimate()) | 289 EXPECT_CALL(*send_algorithm_, BandwidthEstimate()) |
292 .WillRepeatedly(Return(QuicBandwidth::Zero())); | 290 .WillRepeatedly(Return(QuicBandwidth::Zero())); |
293 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _)).Times(AnyNumber()); | 291 EXPECT_CALL(*send_algorithm_, SetFromConfig(_, _)).Times(AnyNumber()); |
294 helper_.reset( | 292 helper_.reset( |
(...skipping 1767 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2062 EXPECT_TRUE(AtEof()); | 2060 EXPECT_TRUE(AtEof()); |
2063 | 2061 |
2064 // QuicHttpStream::GetTotalSent/ReceivedBytes includes only headers. | 2062 // QuicHttpStream::GetTotalSent/ReceivedBytes includes only headers. |
2065 EXPECT_EQ(static_cast<int64_t>(spdy_request_headers_frame_length), | 2063 EXPECT_EQ(static_cast<int64_t>(spdy_request_headers_frame_length), |
2066 stream_->GetTotalSentBytes()); | 2064 stream_->GetTotalSentBytes()); |
2067 EXPECT_EQ(0, stream_->GetTotalReceivedBytes()); | 2065 EXPECT_EQ(0, stream_->GetTotalReceivedBytes()); |
2068 } | 2066 } |
2069 | 2067 |
2070 } // namespace test | 2068 } // namespace test |
2071 } // namespace net | 2069 } // namespace net |
OLD | NEW |