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

// Copyright 2023 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/pipe_reader_posix.h"

#include <errno.h>

#include <memory>
#include <utility>

#include "base/files/file_util.h"
#include "base/functional/bind.h"
#include "base/functional/callback_helpers.h"
#include "base/logging.h"
#include "base/task/current_thread.h"
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"

#if BUILDFLAG(IS_FUCHSIA)
#include <poll.h>
#include <sys/ioctl.h>
#endif  // BUILDFLAG(IS_FUCHSIA)

PipeReaderPosix::PipeReaderPosix()
    : … { … }

PipeReaderPosix::~PipeReaderPosix() { … }

int PipeReaderPosix::Bind(base::ScopedFD fd) { … }

bool PipeReaderPosix::IsConnected() const { … }

int PipeReaderPosix::Read(net::IOBuffer* buf,
                          int buf_len,
                          net::CompletionOnceCallback callback) { … }

int PipeReaderPosix::ReadIfReady(net::IOBuffer* buf,
                                 int buf_len,
                                 net::CompletionOnceCallback callback) { … }

int PipeReaderPosix::CancelReadIfReady() { … }

void PipeReaderPosix::Close() { … }

void PipeReaderPosix::DetachFromThread() { … }

void PipeReaderPosix::OnFileCanReadWithoutBlocking(int fd) { … }

void PipeReaderPosix::OnFileCanWriteWithoutBlocking(int fd) { … }

int PipeReaderPosix::DoRead(net::IOBuffer* buf, int buf_len) { … }

void PipeReaderPosix::RetryRead(int rv) { … }