| Index: net/tools/quic/quic_client_bin.cc
|
| diff --git a/net/tools/quic/quic_client_bin.cc b/net/tools/quic/quic_client_bin.cc
|
| deleted file mode 100644
|
| index 38009448e29febf677a81fe7990035331397f0aa..0000000000000000000000000000000000000000
|
| --- a/net/tools/quic/quic_client_bin.cc
|
| +++ /dev/null
|
| @@ -1,280 +0,0 @@
|
| -// Copyright (c) 2012 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.
|
| -
|
| -// A binary wrapper for QuicClient.
|
| -// Connects to a host using QUIC, sends a request to the provided URL, and
|
| -// displays the response.
|
| -//
|
| -// Some usage examples:
|
| -//
|
| -// TODO(rtenneti): make --host optional by getting IP Address of URL's host.
|
| -//
|
| -// Get IP address of the www.google.com
|
| -// IP=`dig www.google.com +short | head -1`
|
| -//
|
| -// Standard request/response:
|
| -// quic_client http://www.google.com --host=${IP}
|
| -// quic_client http://www.google.com --quiet --host=${IP}
|
| -// quic_client https://www.google.com --port=443 --host=${IP}
|
| -//
|
| -// Use a specific version:
|
| -// quic_client http://www.google.com --version=23 --host=${IP}
|
| -//
|
| -// Send a POST instead of a GET:
|
| -// quic_client http://www.google.com --body="this is a POST body" --host=${IP}
|
| -//
|
| -// Append additional headers to the request:
|
| -// quic_client http://www.google.com --host=${IP}
|
| -// --headers="Header-A: 1234; Header-B: 5678"
|
| -//
|
| -// Connect to a host different to the URL being requested:
|
| -// Get IP address of the www.google.com
|
| -// IP=`dig www.google.com +short | head -1`
|
| -// quic_client mail.google.com --host=${IP}
|
| -//
|
| -// Try to connect to a host which does not speak QUIC:
|
| -// Get IP address of the www.example.com
|
| -// IP=`dig www.example.com +short | head -1`
|
| -// quic_client http://www.example.com --host=${IP}
|
| -
|
| -#include <iostream>
|
| -
|
| -#include "base/at_exit.h"
|
| -#include "base/command_line.h"
|
| -#include "base/logging.h"
|
| -#include "base/strings/string_number_conversions.h"
|
| -#include "base/strings/string_split.h"
|
| -#include "base/strings/string_util.h"
|
| -#include "net/base/ip_endpoint.h"
|
| -#include "net/base/privacy_mode.h"
|
| -#include "net/cert/cert_verifier.h"
|
| -#include "net/http/transport_security_state.h"
|
| -#include "net/quic/crypto/proof_verifier_chromium.h"
|
| -#include "net/quic/quic_protocol.h"
|
| -#include "net/quic/quic_server_id.h"
|
| -#include "net/quic/quic_utils.h"
|
| -#include "net/tools/epoll_server/epoll_server.h"
|
| -#include "net/tools/quic/quic_client.h"
|
| -#include "net/tools/quic/spdy_utils.h"
|
| -#include "url/gurl.h"
|
| -
|
| -using base::StringPiece;
|
| -using net::CertVerifier;
|
| -using net::ProofVerifierChromium;
|
| -using net::TransportSecurityState;
|
| -using std::cout;
|
| -using std::cerr;
|
| -using std::map;
|
| -using std::string;
|
| -using std::vector;
|
| -using std::endl;
|
| -
|
| -// The IP or hostname the quic client will connect to.
|
| -string FLAGS_host = "";
|
| -// The port to connect to.
|
| -int32 FLAGS_port = 80;
|
| -// If set, send a POST with this body.
|
| -string FLAGS_body = "";
|
| -// A semicolon separated list of key:value pairs to add to request headers.
|
| -string FLAGS_headers = "";
|
| -// Set to true for a quieter output experience.
|
| -bool FLAGS_quiet = false;
|
| -// QUIC version to speak, e.g. 21. If not set, then all available versions are
|
| -// offered in the handshake.
|
| -int32 FLAGS_quic_version = -1;
|
| -// If true, a version mismatch in the handshake is not considered a failure.
|
| -// Useful for probing a server to determine if it speaks any version of QUIC.
|
| -bool FLAGS_version_mismatch_ok = false;
|
| -// If true, an HTTP response code of 3xx is considered to be a successful
|
| -// response, otherwise a failure.
|
| -bool FLAGS_redirect_is_success = true;
|
| -
|
| -int main(int argc, char *argv[]) {
|
| - base::CommandLine::Init(argc, argv);
|
| - base::CommandLine* line = base::CommandLine::ForCurrentProcess();
|
| - const base::CommandLine::StringVector& urls = line->GetArgs();
|
| -
|
| - logging::LoggingSettings settings;
|
| - settings.logging_dest = logging::LOG_TO_SYSTEM_DEBUG_LOG;
|
| - CHECK(logging::InitLogging(settings));
|
| -
|
| - if (line->HasSwitch("h") || line->HasSwitch("help") || urls.empty()) {
|
| - const char* help_str =
|
| - "Usage: quic_client [options] <url>\n"
|
| - "\n"
|
| - "<url> with scheme must be provided (e.g. http://www.google.com)\n\n"
|
| - "Options:\n"
|
| - "-h, --help show this help message and exit\n"
|
| - "--host=<host> specify the IP address of the hostname to "
|
| - "connect to\n"
|
| - "--port=<port> specify the port to connect to\n"
|
| - "--body=<body> specify the body to post\n"
|
| - "--headers=<headers> specify a semicolon separated list of "
|
| - "key:value pairs to add to request headers\n"
|
| - "--quiet specify for a quieter output experience\n"
|
| - "--quic-version=<quic version> specify QUIC version to speak\n"
|
| - "--version_mismatch_ok if specified a version mismatch in the "
|
| - "handshake is not considered a failure\n"
|
| - "--redirect_is_success if specified an HTTP response code of 3xx "
|
| - "is considered to be a successful response, otherwise a failure\n";
|
| - cout << help_str;
|
| - exit(0);
|
| - }
|
| - if (line->HasSwitch("host")) {
|
| - FLAGS_host = line->GetSwitchValueASCII("host");
|
| - }
|
| - if (line->HasSwitch("port")) {
|
| - int port;
|
| - if (base::StringToInt(line->GetSwitchValueASCII("port"), &port)) {
|
| - FLAGS_port = port;
|
| - }
|
| - }
|
| - if (line->HasSwitch("body")) {
|
| - FLAGS_body = line->GetSwitchValueASCII("body");
|
| - }
|
| - if (line->HasSwitch("headers")) {
|
| - FLAGS_headers = line->GetSwitchValueASCII("headers");
|
| - }
|
| - if (line->HasSwitch("quiet")) {
|
| - FLAGS_quiet = true;
|
| - }
|
| - if (line->HasSwitch("quic-version")) {
|
| - int quic_version;
|
| - if (base::StringToInt(line->GetSwitchValueASCII("quic-version"),
|
| - &quic_version)) {
|
| - FLAGS_quic_version = quic_version;
|
| - }
|
| - }
|
| - if (line->HasSwitch("version_mismatch_ok")) {
|
| - FLAGS_version_mismatch_ok = true;
|
| - }
|
| - if (line->HasSwitch("redirect_is_success")) {
|
| - FLAGS_redirect_is_success = true;
|
| - }
|
| -
|
| - VLOG(1) << "server host: " << FLAGS_host << " port: " << FLAGS_port
|
| - << " body: " << FLAGS_body << " headers: " << FLAGS_headers
|
| - << " quiet: " << FLAGS_quiet
|
| - << " quic-version: " << FLAGS_quic_version
|
| - << " version_mismatch_ok: " << FLAGS_version_mismatch_ok
|
| - << " redirect_is_success: " << FLAGS_redirect_is_success;
|
| -
|
| - base::AtExitManager exit_manager;
|
| -
|
| - // Determine IP address to connect to from supplied hostname.
|
| - net::IPAddressNumber ip_addr;
|
| -
|
| - // TODO(rtenneti): GURL's doesn't support default_protocol argument, thus
|
| - // protocol is required in the URL.
|
| - GURL url(urls[0]);
|
| - string host = FLAGS_host;
|
| - // TODO(rtenneti): get ip_addr from hostname by doing host resolution.
|
| - CHECK(!host.empty());
|
| - net::ParseIPLiteralToNumber(host, &ip_addr);
|
| -
|
| - string host_port = net::IPAddressToStringWithPort(ip_addr, FLAGS_port);
|
| - VLOG(1) << "Resolved " << host << " to " << host_port << endl;
|
| -
|
| - // Build the client, and try to connect.
|
| - bool is_https = (FLAGS_port == 443);
|
| - net::EpollServer epoll_server;
|
| - net::QuicServerId server_id(host, FLAGS_port, is_https,
|
| - net::PRIVACY_MODE_DISABLED);
|
| - net::QuicVersionVector versions = net::QuicSupportedVersions();
|
| - if (FLAGS_quic_version != -1) {
|
| - versions.clear();
|
| - versions.push_back(static_cast<net::QuicVersion>(FLAGS_quic_version));
|
| - }
|
| - net::tools::QuicClient client(net::IPEndPoint(ip_addr, FLAGS_port), server_id,
|
| - versions, &epoll_server);
|
| - scoped_ptr<CertVerifier> cert_verifier;
|
| - scoped_ptr<TransportSecurityState> transport_security_state;
|
| - if (is_https) {
|
| - // For secure QUIC we need to verify the cert chain.a
|
| - cert_verifier.reset(CertVerifier::CreateDefault());
|
| - transport_security_state.reset(new TransportSecurityState);
|
| - // TODO(rtenneti): Fix "Proof invalid: Missing context" error.
|
| - client.SetProofVerifier(new ProofVerifierChromium(
|
| - cert_verifier.get(), transport_security_state.get()));
|
| - }
|
| - if (!client.Initialize()) {
|
| - cerr << "Failed to initialize client." << endl;
|
| - return 1;
|
| - }
|
| - if (!client.Connect()) {
|
| - net::QuicErrorCode error = client.session()->error();
|
| - if (FLAGS_version_mismatch_ok && error == net::QUIC_INVALID_VERSION) {
|
| - cout << "Server talks QUIC, but none of the versions supoorted by "
|
| - << "this client: " << QuicVersionVectorToString(versions) << endl;
|
| - // Version mismatch is not deemed a failure.
|
| - return 0;
|
| - }
|
| - cerr << "Failed to connect to " << host_port
|
| - << ". Error: " << net::QuicUtils::ErrorToString(error) << endl;
|
| - return 1;
|
| - }
|
| - cout << "Connected to " << host_port << endl;
|
| -
|
| - // Construct a GET or POST request for supplied URL.
|
| - net::BalsaHeaders headers;
|
| - headers.SetRequestFirstlineFromStringPieces(
|
| - FLAGS_body.empty() ? "GET" : "POST", url.spec(), "HTTP/1.1");
|
| -
|
| - // Append any additional headers supplied on the command line.
|
| - vector<string> headers_tokenized;
|
| - Tokenize(FLAGS_headers, ";", &headers_tokenized);
|
| - for (size_t i = 0; i < headers_tokenized.size(); ++i) {
|
| - string sp;
|
| - base::TrimWhitespaceASCII(headers_tokenized[i], base::TRIM_ALL, &sp);
|
| - if (sp.empty()) {
|
| - continue;
|
| - }
|
| - vector<string> kv;
|
| - base::SplitString(sp, ':', &kv);
|
| - CHECK_EQ(2u, kv.size());
|
| - string key;
|
| - base::TrimWhitespaceASCII(kv[0], base::TRIM_ALL, &key);
|
| - string value;
|
| - base::TrimWhitespaceASCII(kv[1], base::TRIM_ALL, &value);
|
| - headers.AppendHeader(key, value);
|
| - }
|
| -
|
| - // Make sure to store the response, for later output.
|
| - client.set_store_response(true);
|
| -
|
| - // Send the request.
|
| - map<string, string> header_block =
|
| - net::tools::SpdyUtils::RequestHeadersToSpdy4Headers(headers);
|
| - client.SendRequestAndWaitForResponse(headers, FLAGS_body, /*fin=*/true);
|
| -
|
| - // Print request and response details.
|
| - if (!FLAGS_quiet) {
|
| - cout << "Request:" << endl;
|
| - cout << "headers:" << endl;
|
| - for (const std::pair<string, string>& kv : header_block) {
|
| - cout << " " << kv.first << ": " << kv.second << endl;
|
| - }
|
| - cout << "body: " << FLAGS_body << endl;
|
| - cout << endl << "Response:";
|
| - cout << "headers: " << client.latest_response_headers() << endl;
|
| - cout << "body: " << client.latest_response_body() << endl;
|
| - }
|
| -
|
| - size_t response_code = client.latest_response_code();
|
| - if (response_code >= 200 && response_code < 300) {
|
| - cout << "Request succeeded (" << response_code << ")." << endl;
|
| - return 0;
|
| - } else if (response_code >= 300 && response_code < 400) {
|
| - if (FLAGS_redirect_is_success) {
|
| - cout << "Request succeeded (redirect " << response_code << ")." << endl;
|
| - return 0;
|
| - } else {
|
| - cout << "Request failed (redirect " << response_code << ")." << endl;
|
| - return 1;
|
| - }
|
| - } else {
|
| - cerr << "Request failed (" << response_code << ")." << endl;
|
| - return 1;
|
| - }
|
| -}
|
|
|