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 "base/basictypes.h" | 7 #include "base/basictypes.h" |
8 #include "base/bind.h" | 8 #include "base/bind.h" |
9 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
10 #include "net/base/net_errors.h" | 10 #include "net/base/net_errors.h" |
(...skipping 2393 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2404 connection_.SetDefaultEncryptionLevel(ENCRYPTION_NONE); | 2404 connection_.SetDefaultEncryptionLevel(ENCRYPTION_NONE); |
2405 | 2405 |
2406 SendStreamDataToPeer(1, "foo", 0, !kFin, NULL); | 2406 SendStreamDataToPeer(1, "foo", 0, !kFin, NULL); |
2407 | 2407 |
2408 connection_.SetEncrypter(ENCRYPTION_INITIAL, new TaggingEncrypter(0x02)); | 2408 connection_.SetEncrypter(ENCRYPTION_INITIAL, new TaggingEncrypter(0x02)); |
2409 connection_.SetDefaultEncryptionLevel(ENCRYPTION_INITIAL); | 2409 connection_.SetDefaultEncryptionLevel(ENCRYPTION_INITIAL); |
2410 | 2410 |
2411 SendStreamDataToPeer(2, "bar", 0, !kFin, NULL); | 2411 SendStreamDataToPeer(2, "bar", 0, !kFin, NULL); |
2412 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(1); | 2412 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(1); |
2413 | 2413 |
2414 connection_.RetransmitUnackedPackets(INITIAL_ENCRYPTION_ONLY); | 2414 connection_.RetransmitUnackedPackets(ALL_INITIAL_RETRANSMISSION); |
2415 } | 2415 } |
2416 | 2416 |
2417 TEST_P(QuicConnectionTest, BufferNonDecryptablePackets) { | 2417 TEST_P(QuicConnectionTest, BufferNonDecryptablePackets) { |
2418 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); | 2418 EXPECT_CALL(visitor_, OnSuccessfulVersionNegotiation(_)); |
2419 use_tagging_decrypter(); | 2419 use_tagging_decrypter(); |
2420 | 2420 |
2421 const uint8 tag = 0x07; | 2421 const uint8 tag = 0x07; |
2422 framer_.SetEncrypter(ENCRYPTION_INITIAL, new TaggingEncrypter(tag)); | 2422 framer_.SetEncrypter(ENCRYPTION_INITIAL, new TaggingEncrypter(tag)); |
2423 | 2423 |
2424 // Process an encrypted packet which can not yet be decrypted | 2424 // Process an encrypted packet which can not yet be decrypted |
(...skipping 1470 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3895 QuicBlockedFrame blocked; | 3895 QuicBlockedFrame blocked; |
3896 blocked.stream_id = 3; | 3896 blocked.stream_id = 3; |
3897 EXPECT_CALL(visitor_, OnBlockedFrames(_)); | 3897 EXPECT_CALL(visitor_, OnBlockedFrames(_)); |
3898 ProcessFramePacket(QuicFrame(&blocked)); | 3898 ProcessFramePacket(QuicFrame(&blocked)); |
3899 EXPECT_TRUE(ack_alarm->IsSet()); | 3899 EXPECT_TRUE(ack_alarm->IsSet()); |
3900 } | 3900 } |
3901 | 3901 |
3902 } // namespace | 3902 } // namespace |
3903 } // namespace test | 3903 } // namespace test |
3904 } // namespace net | 3904 } // namespace net |
OLD | NEW |