| 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/test_tools/quic_test_utils.h" | 5 #include "net/quic/test_tools/quic_test_utils.h" |
| 6 | 6 |
| 7 #include "base/sha1.h" | 7 #include "base/sha1.h" |
| 8 #include "base/stl_util.h" | 8 #include "base/stl_util.h" |
| 9 #include "base/strings/string_number_conversions.h" | 9 #include "base/strings/string_number_conversions.h" |
| 10 #include "net/quic/crypto/crypto_framer.h" | 10 #include "net/quic/crypto/crypto_framer.h" |
| (...skipping 293 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 304 | 304 |
| 305 void PacketSavingConnection::SendOrQueuePacket(QueuedPacket packet) { | 305 void PacketSavingConnection::SendOrQueuePacket(QueuedPacket packet) { |
| 306 packets_.push_back(packet.serialized_packet.packet); | 306 packets_.push_back(packet.serialized_packet.packet); |
| 307 QuicEncryptedPacket* encrypted = QuicConnectionPeer::GetFramer(this)-> | 307 QuicEncryptedPacket* encrypted = QuicConnectionPeer::GetFramer(this)-> |
| 308 EncryptPacket(packet.encryption_level, | 308 EncryptPacket(packet.encryption_level, |
| 309 packet.serialized_packet.sequence_number, | 309 packet.serialized_packet.sequence_number, |
| 310 *packet.serialized_packet.packet); | 310 *packet.serialized_packet.packet); |
| 311 encrypted_packets_.push_back(encrypted); | 311 encrypted_packets_.push_back(encrypted); |
| 312 // Transfer ownership of the packet to the SentPacketManager and the | 312 // Transfer ownership of the packet to the SentPacketManager and the |
| 313 // ack notifier to the AckNotifierManager. | 313 // ack notifier to the AckNotifierManager. |
| 314 sent_packet_manager_.OnSerializedPacket(packet.serialized_packet); | 314 sent_packet_manager_.OnPacketSent( |
| 315 &packet.serialized_packet, 0, QuicTime::Zero(), 1000, |
| 316 NOT_RETRANSMISSION, HAS_RETRANSMITTABLE_DATA); |
| 315 } | 317 } |
| 316 | 318 |
| 317 MockSession::MockSession(QuicConnection* connection) | 319 MockSession::MockSession(QuicConnection* connection) |
| 318 : QuicSession(connection, DefaultQuicConfig()) { | 320 : QuicSession(connection, DefaultQuicConfig()) { |
| 319 InitializeSession(); | 321 InitializeSession(); |
| 320 ON_CALL(*this, WritevData(_, _, _, _, _, _)) | 322 ON_CALL(*this, WritevData(_, _, _, _, _, _)) |
| 321 .WillByDefault(testing::Return(QuicConsumedData(0, false))); | 323 .WillByDefault(testing::Return(QuicConsumedData(0, false))); |
| 322 } | 324 } |
| 323 | 325 |
| 324 MockSession::~MockSession() { | 326 MockSession::~MockSession() { |
| (...skipping 342 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 667 // different way, so TestWriterFactory::OnPacketSent might never be called. | 669 // different way, so TestWriterFactory::OnPacketSent might never be called. |
| 668 factory_->current_writer_ = this; | 670 factory_->current_writer_ = this; |
| 669 return QuicPerConnectionPacketWriter::WritePacket(buffer, | 671 return QuicPerConnectionPacketWriter::WritePacket(buffer, |
| 670 buf_len, | 672 buf_len, |
| 671 self_address, | 673 self_address, |
| 672 peer_address); | 674 peer_address); |
| 673 } | 675 } |
| 674 | 676 |
| 675 } // namespace test | 677 } // namespace test |
| 676 } // namespace net | 678 } // namespace net |
| OLD | NEW |