| 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_stream_factory.h" | 5 #include "net/quic/quic_stream_factory.h" |
| 6 | 6 |
| 7 #include "base/run_loop.h" | 7 #include "base/run_loop.h" |
| 8 #include "base/strings/string_util.h" | 8 #include "base/strings/string_util.h" |
| 9 #include "net/cert/cert_verifier.h" | 9 #include "net/cert/cert_verifier.h" |
| 10 #include "net/dns/mock_host_resolver.h" | 10 #include "net/dns/mock_host_resolver.h" |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 45 QuicPacketHeader header; | 45 QuicPacketHeader header; |
| 46 header.public_header.guid = 0xDEADBEEF; | 46 header.public_header.guid = 0xDEADBEEF; |
| 47 header.public_header.reset_flag = false; | 47 header.public_header.reset_flag = false; |
| 48 header.public_header.version_flag = true; | 48 header.public_header.version_flag = true; |
| 49 header.packet_sequence_number = num; | 49 header.packet_sequence_number = num; |
| 50 header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; | 50 header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER; |
| 51 header.entropy_flag = false; | 51 header.entropy_flag = false; |
| 52 header.fec_flag = false; | 52 header.fec_flag = false; |
| 53 header.fec_group = 0; | 53 header.fec_group = 0; |
| 54 | 54 |
| 55 QuicRstStreamFrame rst(stream_id, QUIC_SERVER_ERROR_PROCESSING_STREAM); | 55 QuicRstStreamFrame rst(stream_id, QUIC_ERROR_PROCESSING_STREAM); |
| 56 return scoped_ptr<QuicEncryptedPacket>( | 56 return scoped_ptr<QuicEncryptedPacket>( |
| 57 ConstructPacket(header, QuicFrame(&rst))); | 57 ConstructPacket(header, QuicFrame(&rst))); |
| 58 } | 58 } |
| 59 | 59 |
| 60 scoped_ptr<QuicEncryptedPacket> ConstructAckPacket( | 60 scoped_ptr<QuicEncryptedPacket> ConstructAckPacket( |
| 61 QuicPacketSequenceNumber largest_received, | 61 QuicPacketSequenceNumber largest_received, |
| 62 QuicPacketSequenceNumber least_unacked) { | 62 QuicPacketSequenceNumber least_unacked) { |
| 63 QuicPacketHeader header; | 63 QuicPacketHeader header; |
| 64 header.public_header.guid = 0xDEADBEEF; | 64 header.public_header.guid = 0xDEADBEEF; |
| 65 header.public_header.reset_flag = false; | 65 header.public_header.reset_flag = false; |
| (...skipping 299 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 365 stream.reset(); // Will reset stream 3. | 365 stream.reset(); // Will reset stream 3. |
| 366 | 366 |
| 367 EXPECT_TRUE(socket_data.at_read_eof()); | 367 EXPECT_TRUE(socket_data.at_read_eof()); |
| 368 EXPECT_TRUE(socket_data.at_write_eof()); | 368 EXPECT_TRUE(socket_data.at_write_eof()); |
| 369 EXPECT_TRUE(socket_data2.at_read_eof()); | 369 EXPECT_TRUE(socket_data2.at_read_eof()); |
| 370 EXPECT_TRUE(socket_data2.at_write_eof()); | 370 EXPECT_TRUE(socket_data2.at_write_eof()); |
| 371 } | 371 } |
| 372 | 372 |
| 373 } // namespace test | 373 } // namespace test |
| 374 } // namespace net | 374 } // namespace net |
| OLD | NEW |