Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(112)

Unified Diff: net/quic/test_tools/quic_test_packet_maker.cc

Issue 992733002: Remove //net (except for Android test stuff) and sdch (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/quic/test_tools/quic_test_packet_maker.h ('k') | net/quic/test_tools/quic_test_utils.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/quic/test_tools/quic_test_packet_maker.cc
diff --git a/net/quic/test_tools/quic_test_packet_maker.cc b/net/quic/test_tools/quic_test_packet_maker.cc
deleted file mode 100644
index ecdd6bf882cc71d757ec6acb0b8e70ca26c3306d..0000000000000000000000000000000000000000
--- a/net/quic/test_tools/quic_test_packet_maker.cc
+++ /dev/null
@@ -1,260 +0,0 @@
-// Copyright 2013 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "net/quic/test_tools/quic_test_packet_maker.h"
-
-#include <list>
-
-#include "net/quic/quic_framer.h"
-#include "net/quic/quic_http_utils.h"
-#include "net/quic/quic_utils.h"
-#include "net/quic/test_tools/quic_test_utils.h"
-
-using std::make_pair;
-
-namespace net {
-namespace test {
-
-QuicTestPacketMaker::QuicTestPacketMaker(QuicVersion version,
- QuicConnectionId connection_id,
- MockClock* clock)
- : version_(version),
- connection_id_(connection_id),
- clock_(clock),
- spdy_request_framer_(version > QUIC_VERSION_23 ? SPDY4 : SPDY3),
- spdy_response_framer_(version > QUIC_VERSION_23 ? SPDY4 : SPDY3) {
-}
-
-QuicTestPacketMaker::~QuicTestPacketMaker() {
-}
-
-scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeRstPacket(
- QuicPacketSequenceNumber num,
- bool include_version,
- QuicStreamId stream_id,
- QuicRstStreamErrorCode error_code) {
- QuicPacketHeader header;
- header.public_header.connection_id = connection_id_;
- header.public_header.reset_flag = false;
- header.public_header.version_flag = include_version;
- header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
- header.packet_sequence_number = num;
- header.entropy_flag = false;
- header.fec_flag = false;
- header.fec_group = 0;
-
- QuicRstStreamFrame rst(stream_id, error_code, 0);
- return scoped_ptr<QuicEncryptedPacket>(MakePacket(header, QuicFrame(&rst)));
-}
-
-scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeAckAndRstPacket(
- QuicPacketSequenceNumber num,
- bool include_version,
- QuicStreamId stream_id,
- QuicRstStreamErrorCode error_code,
- QuicPacketSequenceNumber largest_received,
- QuicPacketSequenceNumber least_unacked,
- bool send_feedback) {
-
- QuicPacketHeader header;
- header.public_header.connection_id = connection_id_;
- header.public_header.reset_flag = false;
- header.public_header.version_flag = include_version;
- header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
- header.packet_sequence_number = num;
- header.entropy_flag = false;
- header.fec_flag = false;
- header.fec_group = 0;
-
- QuicAckFrame ack(MakeAckFrame(largest_received));
- ack.delta_time_largest_observed = QuicTime::Delta::Zero();
- for (QuicPacketSequenceNumber i = least_unacked; i <= largest_received; ++i) {
- ack.received_packet_times.push_back(make_pair(i, clock_->Now()));
- }
- QuicFrames frames;
- frames.push_back(QuicFrame(&ack));
-
- QuicStopWaitingFrame stop_waiting;
- stop_waiting.least_unacked = least_unacked;
- frames.push_back(QuicFrame(&stop_waiting));
-
- QuicRstStreamFrame rst(stream_id, error_code, 0);
- frames.push_back(QuicFrame(&rst));
-
- QuicFramer framer(SupportedVersions(version_), clock_->Now(), false);
- scoped_ptr<QuicPacket> packet(
- BuildUnsizedDataPacket(&framer, header, frames));
- return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
- ENCRYPTION_NONE, header.packet_sequence_number, *packet));
-}
-
-scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeConnectionClosePacket(
- QuicPacketSequenceNumber num) {
- QuicPacketHeader header;
- header.public_header.connection_id = connection_id_;
- header.public_header.reset_flag = false;
- header.public_header.version_flag = false;
- header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
- header.packet_sequence_number = num;
- header.entropy_flag = false;
- header.fec_flag = false;
- header.fec_group = 0;
-
- QuicConnectionCloseFrame close;
- close.error_code = QUIC_CRYPTO_VERSION_NOT_SUPPORTED;
- close.error_details = "Time to panic!";
- return scoped_ptr<QuicEncryptedPacket>(MakePacket(header, QuicFrame(&close)));
-}
-
-scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeAckPacket(
- QuicPacketSequenceNumber sequence_number,
- QuicPacketSequenceNumber largest_received,
- QuicPacketSequenceNumber least_unacked,
- bool send_feedback) {
- QuicPacketHeader header;
- header.public_header.connection_id = connection_id_;
- header.public_header.reset_flag = false;
- header.public_header.version_flag = false;
- header.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
- header.packet_sequence_number = sequence_number;
- header.entropy_flag = false;
- header.fec_flag = false;
- header.fec_group = 0;
-
- QuicAckFrame ack(MakeAckFrame(largest_received));
- ack.delta_time_largest_observed = QuicTime::Delta::Zero();
- for (QuicPacketSequenceNumber i = least_unacked; i <= largest_received; ++i) {
- ack.received_packet_times.push_back(make_pair(i, clock_->Now()));
- }
-
- QuicFramer framer(SupportedVersions(version_), clock_->Now(), false);
- QuicFrames frames;
- frames.push_back(QuicFrame(&ack));
-
- QuicStopWaitingFrame stop_waiting;
- stop_waiting.least_unacked = least_unacked;
- frames.push_back(QuicFrame(&stop_waiting));
-
- scoped_ptr<QuicPacket> packet(
- BuildUnsizedDataPacket(&framer, header, frames));
- return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
- ENCRYPTION_NONE, header.packet_sequence_number, *packet));
-}
-
-// Returns a newly created packet to send kData on stream 1.
-scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeDataPacket(
- QuicPacketSequenceNumber sequence_number,
- QuicStreamId stream_id,
- bool should_include_version,
- bool fin,
- QuicStreamOffset offset,
- base::StringPiece data) {
- InitializeHeader(sequence_number, should_include_version);
- QuicStreamFrame frame(stream_id, fin, offset, MakeIOVector(data));
- return MakePacket(header_, QuicFrame(&frame));
-}
-
-scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeRequestHeadersPacket(
- QuicPacketSequenceNumber sequence_number,
- QuicStreamId stream_id,
- bool should_include_version,
- bool fin,
- QuicPriority priority,
- const SpdyHeaderBlock& headers) {
- InitializeHeader(sequence_number, should_include_version);
- scoped_ptr<SpdySerializedFrame> spdy_frame;
- if (spdy_request_framer_.protocol_version() == SPDY3) {
- SpdySynStreamIR syn_stream(stream_id);
- syn_stream.set_name_value_block(headers);
- syn_stream.set_fin(fin);
- syn_stream.set_priority(priority);
- spdy_frame.reset(spdy_request_framer_.SerializeSynStream(syn_stream));
- } else {
- SpdyHeadersIR headers_frame(stream_id);
- headers_frame.set_name_value_block(headers);
- headers_frame.set_fin(fin);
- headers_frame.set_priority(priority);
- headers_frame.set_has_priority(true);
- spdy_frame.reset(spdy_request_framer_.SerializeFrame(headers_frame));
- }
- QuicStreamFrame frame(kHeadersStreamId, false, 0,
- MakeIOVector(base::StringPiece(spdy_frame->data(),
- spdy_frame->size())));
- return MakePacket(header_, QuicFrame(&frame));
-}
-
-scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakeResponseHeadersPacket(
- QuicPacketSequenceNumber sequence_number,
- QuicStreamId stream_id,
- bool should_include_version,
- bool fin,
- const SpdyHeaderBlock& headers) {
- InitializeHeader(sequence_number, should_include_version);
- scoped_ptr<SpdySerializedFrame> spdy_frame;
- if (spdy_request_framer_.protocol_version() == SPDY3) {
- SpdySynReplyIR syn_reply(stream_id);
- syn_reply.set_name_value_block(headers);
- syn_reply.set_fin(fin);
- spdy_frame.reset(spdy_response_framer_.SerializeSynReply(syn_reply));
- } else {
- SpdyHeadersIR headers_frame(stream_id);
- headers_frame.set_name_value_block(headers);
- headers_frame.set_fin(fin);
- spdy_frame.reset(spdy_request_framer_.SerializeFrame(headers_frame));
- }
- QuicStreamFrame frame(kHeadersStreamId, false, 0,
- MakeIOVector(base::StringPiece(spdy_frame->data(),
- spdy_frame->size())));
- return MakePacket(header_, QuicFrame(&frame));
-}
-
-SpdyHeaderBlock QuicTestPacketMaker::GetRequestHeaders(
- const std::string& method,
- const std::string& scheme,
- const std::string& path) {
- SpdyHeaderBlock headers;
- headers[":method"] = method;
- headers[":host"] = "www.google.com";
- headers[":path"] = path;
- headers[":scheme"] = scheme;
- headers[":version"] = "HTTP/1.1";
- return headers;
-}
-
-SpdyHeaderBlock QuicTestPacketMaker::GetResponseHeaders(
- const std::string& status) {
- SpdyHeaderBlock headers;
- headers[":status"] = status;
- headers[":version"] = "HTTP/1.1";
- headers["content-type"] = "text/plain";
- return headers;
-}
-
-scoped_ptr<QuicEncryptedPacket> QuicTestPacketMaker::MakePacket(
- const QuicPacketHeader& header,
- const QuicFrame& frame) {
- QuicFramer framer(SupportedVersions(version_), QuicTime::Zero(), false);
- QuicFrames frames;
- frames.push_back(frame);
- scoped_ptr<QuicPacket> packet(
- BuildUnsizedDataPacket(&framer, header, frames));
- return scoped_ptr<QuicEncryptedPacket>(framer.EncryptPacket(
- ENCRYPTION_NONE, header.packet_sequence_number, *packet));
-}
-
-void QuicTestPacketMaker::InitializeHeader(
- QuicPacketSequenceNumber sequence_number,
- bool should_include_version) {
- header_.public_header.connection_id = connection_id_;
- header_.public_header.reset_flag = false;
- header_.public_header.version_flag = should_include_version;
- header_.public_header.sequence_number_length = PACKET_1BYTE_SEQUENCE_NUMBER;
- header_.packet_sequence_number = sequence_number;
- header_.fec_group = 0;
- header_.entropy_flag = false;
- header_.fec_flag = false;
-}
-
-} // namespace test
-} // namespace net
« no previous file with comments | « net/quic/test_tools/quic_test_packet_maker.h ('k') | net/quic/test_tools/quic_test_utils.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698