chromium/services/network/socket_data_pump_unittest.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 <stdint.h>

#include <utility>
#include <vector>

#include "base/containers/span.h"
#include "base/functional/callback_helpers.h"
#include "base/location.h"
#include "base/run_loop.h"
#include "base/test/task_environment.h"
#include "mojo/public/cpp/system/simple_watcher.h"
#include "net/base/net_errors.h"
#include "net/base/test_completion_callback.h"
#include "net/socket/socket_test_util.h"
#include "net/traffic_annotation/network_traffic_annotation_test_helper.h"
#include "net/url_request/url_request_test_util.h"
#include "services/network/mojo_socket_test_util.h"
#include "services/network/public/mojom/network_service.mojom.h"
#include "services/network/public/mojom/udp_socket.mojom.h"
#include "services/network/socket_factory.h"
#include "services/network/tcp_connected_socket.h"
#include "services/network/tcp_server_socket.h"
#include "testing/gtest/include/gtest/gtest.h"

namespace network {

// Test delegate to wait on network read/write errors.
class TestSocketDataPumpDelegate : public SocketDataPump::Delegate { … };

class SocketDataPumpTest : public testing::Test,
                           public ::testing::WithParamInterface<net::IoMode> { … };

INSTANTIATE_TEST_SUITE_P(…);

TEST_P(SocketDataPumpTest, ReadAndWriteMultiple) { … }

TEST_P(SocketDataPumpTest, PartialStreamSocketWrite) { … }

TEST_P(SocketDataPumpTest, ReadEof) { … }

TEST_P(SocketDataPumpTest, ReadError) { … }

TEST_P(SocketDataPumpTest, WriteEof) { … }

TEST_P(SocketDataPumpTest, WriteError) { … }

TEST_P(SocketDataPumpTest, PipesShutdown) { … }

}  // namespace network