#include "net/test/embedded_test_server/http1_connection.h"
#include <string_view>
#include <utility>
#include "base/functional/bind.h"
#include "base/functional/callback_forward.h"
#include "base/functional/callback_helpers.h"
#include "base/strings/stringprintf.h"
#include "net/base/completion_once_callback.h"
#include "net/base/net_errors.h"
#include "net/base/test_completion_callback.h"
#include "net/socket/stream_socket.h"
#include "net/test/embedded_test_server/embedded_test_server.h"
#include "net/test/embedded_test_server/http_response.h"
#include "net/traffic_annotation/network_traffic_annotation_test_helper.h"
namespace net::test_server {
Http1Connection::Http1Connection(
std::unique_ptr<StreamSocket> socket,
EmbeddedTestServerConnectionListener* connection_listener,
EmbeddedTestServer* server_delegate)
: … { … }
Http1Connection::~Http1Connection() { … }
void Http1Connection::OnSocketReady() { … }
std::unique_ptr<StreamSocket> Http1Connection::TakeSocket() { … }
StreamSocket* Http1Connection::Socket() { … }
base::WeakPtr<HttpConnection> Http1Connection::GetWeakPtr() { … }
void Http1Connection::ReadData() { … }
void Http1Connection::OnReadCompleted(int rv) { … }
bool Http1Connection::HandleReadResult(int rv) { … }
void Http1Connection::AddResponse(std::unique_ptr<HttpResponse> response) { … }
void Http1Connection::SendResponseHeaders(HttpStatusCode status,
const std::string& status_reason,
const base::StringPairs& headers) { … }
void Http1Connection::SendRawResponseHeaders(const std::string& headers) { … }
void Http1Connection::SendContents(const std::string& contents,
base::OnceClosure callback) { … }
void Http1Connection::FinishResponse() { … }
void Http1Connection::SendContentsAndFinish(const std::string& contents) { … }
void Http1Connection::SendHeadersContentAndFinish(
HttpStatusCode status,
const std::string& status_reason,
const base::StringPairs& headers,
const std::string& contents) { … }
void Http1Connection::SendInternal(base::OnceClosure callback,
scoped_refptr<DrainableIOBuffer> buf) { … }
void Http1Connection::OnSendInternalDone(base::OnceClosure callback,
scoped_refptr<DrainableIOBuffer> buf,
int rv) { … }
}