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_http_stream.h" | 5 #include "net/quic/quic_http_stream.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "net/base/net_errors.h" | 9 #include "net/base/net_errors.h" |
10 #include "net/base/test_completion_callback.h" | 10 #include "net/base/test_completion_callback.h" |
(...skipping 144 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
155 socket_data_.reset(new StaticSocketDataProvider(NULL, 0, mock_writes_.get(), | 155 socket_data_.reset(new StaticSocketDataProvider(NULL, 0, mock_writes_.get(), |
156 writes_.size())); | 156 writes_.size())); |
157 | 157 |
158 MockUDPClientSocket* socket = new MockUDPClientSocket(socket_data_.get(), | 158 MockUDPClientSocket* socket = new MockUDPClientSocket(socket_data_.get(), |
159 net_log_.net_log()); | 159 net_log_.net_log()); |
160 socket->Connect(peer_addr_); | 160 socket->Connect(peer_addr_); |
161 runner_ = new TestTaskRunner(&clock_); | 161 runner_ = new TestTaskRunner(&clock_); |
162 scheduler_ = new MockScheduler(); | 162 scheduler_ = new MockScheduler(); |
163 collector_ = new TestCollector(NULL); | 163 collector_ = new TestCollector(NULL); |
164 EXPECT_CALL(*scheduler_, TimeUntilSend(_)). | 164 EXPECT_CALL(*scheduler_, TimeUntilSend(_)). |
165 WillRepeatedly(testing::Return(QuicTime::Delta())); | 165 WillRepeatedly(testing::Return(QuicTime::Delta::Zero())); |
166 helper_ = new QuicConnectionHelper(runner_.get(), &clock_, | 166 helper_ = new QuicConnectionHelper(runner_.get(), &clock_, |
167 &random_generator_, socket); | 167 &random_generator_, socket); |
168 connection_ = new TestQuicConnection(guid_, peer_addr_, helper_); | 168 connection_ = new TestQuicConnection(guid_, peer_addr_, helper_); |
169 connection_->set_visitor(&visitor_); | 169 connection_->set_visitor(&visitor_); |
170 connection_->SetScheduler(scheduler_); | 170 connection_->SetScheduler(scheduler_); |
171 connection_->SetCollector(collector_); | 171 connection_->SetCollector(collector_); |
172 session_.reset(new QuicClientSession(connection_, helper_, NULL)); | 172 session_.reset(new QuicClientSession(connection_, helper_, NULL)); |
173 CryptoHandshakeMessage message; | 173 CryptoHandshakeMessage message; |
174 message.tag = kSHLO; | 174 message.tag = kSHLO; |
175 session_->GetCryptoStream()->OnHandshakeMessage(message); | 175 session_->GetCryptoStream()->OnHandshakeMessage(message); |
(...skipping 274 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
450 | 450 |
451 // In the course of processing this packet, the QuicHttpStream close itself. | 451 // In the course of processing this packet, the QuicHttpStream close itself. |
452 ProcessPacket(*resp); | 452 ProcessPacket(*resp); |
453 | 453 |
454 EXPECT_TRUE(AtEof()); | 454 EXPECT_TRUE(AtEof()); |
455 } | 455 } |
456 | 456 |
457 } // namespace test | 457 } // namespace test |
458 | 458 |
459 } // namespace net | 459 } // namespace net |
OLD | NEW |