chromium/services/network/socket_data_pump.cc

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

#include "services/network/socket_data_pump.h"

#include <optional>
#include <utility>

#include "base/check_op.h"
#include "base/functional/bind.h"
#include "base/memory/ptr_util.h"
#include "base/memory/scoped_refptr.h"
#include "base/numerics/safe_conversions.h"
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"
#include "net/log/net_log.h"
#include "net/socket/client_socket_factory.h"
#include "net/socket/client_socket_handle.h"
#include "services/network/tls_client_socket.h"

namespace network {

SocketDataPump::SocketDataPump(
    net::StreamSocket* socket,
    Delegate* delegate,
    mojo::ScopedDataPipeProducerHandle receive_pipe_handle,
    mojo::ScopedDataPipeConsumerHandle send_pipe_handle,
    const net::NetworkTrafficAnnotationTag& traffic_annotation)
    : … { … }

SocketDataPump::~SocketDataPump() { … }

void SocketDataPump::ReceiveMore() { … }

void SocketDataPump::OnReceiveStreamClosed(MojoResult result) { … }

void SocketDataPump::OnReceiveStreamWritable(MojoResult result) { … }

void SocketDataPump::OnNetworkReadIfReadyCompleted(int result) { … }

void SocketDataPump::ShutdownReceive() { … }

void SocketDataPump::SendMore() { … }

void SocketDataPump::OnSendStreamReadable(MojoResult result) { … }

void SocketDataPump::OnNetworkWriteCompleted(int result) { … }

void SocketDataPump::ShutdownSend() { … }

void SocketDataPump::MaybeNotifyDelegate() { … }

}  // namespace network