| 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_connection.h" | 5 #include "net/quic/quic_connection.h" |
| 6 | 6 |
| 7 #include <ostream> | 7 #include <ostream> |
| 8 | 8 |
| 9 #include "base/basictypes.h" | 9 #include "base/basictypes.h" |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 783 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 794 QuicFrames frames; | 794 QuicFrames frames; |
| 795 frames.push_back(frame); | 795 frames.push_back(frame); |
| 796 scoped_ptr<QuicPacket> packet(ConstructPacket(header, frames)); | 796 scoped_ptr<QuicPacket> packet(ConstructPacket(header, frames)); |
| 797 | 797 |
| 798 char buffer[kMaxPacketSize]; | 798 char buffer[kMaxPacketSize]; |
| 799 size_t encrypted_length = | 799 size_t encrypted_length = |
| 800 framer_.EncryptPayload(level, number, *packet, buffer, kMaxPacketSize); | 800 framer_.EncryptPayload(level, number, *packet, buffer, kMaxPacketSize); |
| 801 connection_.ProcessUdpPacket( | 801 connection_.ProcessUdpPacket( |
| 802 kSelfAddress, kPeerAddress, | 802 kSelfAddress, kPeerAddress, |
| 803 QuicEncryptedPacket(buffer, encrypted_length, false)); | 803 QuicEncryptedPacket(buffer, encrypted_length, false)); |
| 804 return encrypted_length; | 804 return base::checked_cast<QuicPacketEntropyHash>(encrypted_length); |
| 805 } | 805 } |
| 806 | 806 |
| 807 size_t ProcessDataPacket(QuicPacketNumber number, | 807 size_t ProcessDataPacket(QuicPacketNumber number, |
| 808 QuicFecGroupNumber fec_group, | 808 QuicFecGroupNumber fec_group, |
| 809 bool entropy_flag) { | 809 bool entropy_flag) { |
| 810 return ProcessDataPacketAtLevel(number, fec_group, entropy_flag, | 810 return ProcessDataPacketAtLevel(number, fec_group, entropy_flag, |
| 811 ENCRYPTION_NONE); | 811 ENCRYPTION_NONE); |
| 812 } | 812 } |
| 813 | 813 |
| 814 size_t ProcessDataPacketAtLevel(QuicPacketNumber number, | 814 size_t ProcessDataPacketAtLevel(QuicPacketNumber number, |
| (...skipping 4627 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5442 EXPECT_EQ(1u, writer_->stream_frames().size()); | 5442 EXPECT_EQ(1u, writer_->stream_frames().size()); |
| 5443 EXPECT_TRUE(connection_.GetSendAlarm()->IsSet()); | 5443 EXPECT_TRUE(connection_.GetSendAlarm()->IsSet()); |
| 5444 EXPECT_EQ(clock_.Now().Add(QuicTime::Delta::FromMilliseconds(2)), | 5444 EXPECT_EQ(clock_.Now().Add(QuicTime::Delta::FromMilliseconds(2)), |
| 5445 connection_.GetSendAlarm()->deadline()); | 5445 connection_.GetSendAlarm()->deadline()); |
| 5446 writer_->Reset(); | 5446 writer_->Reset(); |
| 5447 } | 5447 } |
| 5448 | 5448 |
| 5449 } // namespace | 5449 } // namespace |
| 5450 } // namespace test | 5450 } // namespace test |
| 5451 } // namespace net | 5451 } // namespace net |
| OLD | NEW |