chromium/chrome/test/chromedriver/net/test_http_server.cc

// Copyright 2013 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "chrome/test/chromedriver/net/test_http_server.h"

#include <memory>
#include <utility>

#include "base/base64.h"
#include "base/functional/bind.h"
#include "base/location.h"
#include "base/message_loop/message_pump_type.h"
#include "base/strings/string_util.h"
#include "base/strings/stringprintf.h"
#include "base/task/single_thread_task_runner.h"
#include "base/time/time.h"
#include "net/base/ip_endpoint.h"
#include "net/base/net_errors.h"
#include "net/log/net_log_source.h"
#include "net/server/http_server_request_info.h"
#include "net/socket/tcp_server_socket.h"
#include "net/traffic_annotation/network_traffic_annotation_test_helper.h"
#include "testing/gtest/include/gtest/gtest.h"

const int kBufferSize = …;  // 100 MB

TestHttpServer::TestHttpServer()
    : … { … }

TestHttpServer::~TestHttpServer() = default;

bool TestHttpServer::Start() { … }

void TestHttpServer::Stop() { … }

bool TestHttpServer::WaitForConnectionsToClose() { … }

void TestHttpServer::SetRequestAction(WebSocketRequestAction action) { … }

void TestHttpServer::SetMessageAction(WebSocketMessageAction action) { … }

void TestHttpServer::SetMessageCallback(base::OnceClosure callback) { … }

GURL TestHttpServer::http_url() const { … }

GURL TestHttpServer::web_socket_url() const { … }

void TestHttpServer::OnConnect(int connection_id) { … }

void TestHttpServer::OnHttpRequest(int connection_id,
                                   const net::HttpServerRequestInfo& info) { … }

void TestHttpServer::OnWebSocketRequest(
    int connection_id,
    const net::HttpServerRequestInfo& info) { … }

void TestHttpServer::OnWebSocketMessage(int connection_id, std::string data) { … }

void TestHttpServer::OnClose(int connection_id) { … }

void TestHttpServer::StartOnServerThread(bool* success,
                                         base::WaitableEvent* event) { … }

void TestHttpServer::StopOnServerThread(base::WaitableEvent* event) { … }

void TestHttpServer::SetDataForPath(std::string path, std::string data) { … }

void TestHttpServer::SetDataForPathOnServerThread(std::string path,
                                                  std::string data,
                                                  base::WaitableEvent* event) { … }