mirror of
https://github.com/LadybirdBrowser/ladybird.git
synced 2025-12-08 06:09:58 +00:00
005e965380
The system uses ssize_t so it can return -1 in case of an error. But in our case, we will transform that to an AK::Error, thus we never return -1. Let's return size_t instead.
68 lines
1.6 KiB
C++
68 lines
1.6 KiB
C++
/*
|
|
* Copyright (c) 2025, ayeteadoe <ayeteadoe@gmail.com>
|
|
*
|
|
* SPDX-License-Identifier: BSD-2-Clause
|
|
*/
|
|
|
|
#include <LibCore/SocketAddress.h>
|
|
#include <LibCore/System.h>
|
|
#include <RequestServer/RequestPipe.h>
|
|
|
|
#if defined(AK_OS_WINDOWS)
|
|
# include <AK/Windows.h>
|
|
#endif
|
|
|
|
namespace RequestServer {
|
|
|
|
RequestPipe::RequestPipe(int const reader_fd, int const writer_fd)
|
|
: m_reader_fd(reader_fd)
|
|
, m_writer_fd(writer_fd)
|
|
{
|
|
VERIFY(m_reader_fd >= 0);
|
|
VERIFY(m_writer_fd >= 0);
|
|
}
|
|
|
|
RequestPipe::RequestPipe(RequestPipe&& other)
|
|
: m_reader_fd(exchange(other.m_reader_fd, -1))
|
|
, m_writer_fd(exchange(other.m_writer_fd, -1))
|
|
{
|
|
}
|
|
|
|
RequestPipe& RequestPipe::operator=(RequestPipe&& other)
|
|
{
|
|
m_reader_fd = exchange(other.m_reader_fd, -1);
|
|
m_writer_fd = exchange(other.m_writer_fd, -1);
|
|
return *this;
|
|
}
|
|
|
|
RequestPipe::~RequestPipe()
|
|
{
|
|
if (m_writer_fd != -1)
|
|
MUST(Core::System::close(m_writer_fd));
|
|
}
|
|
|
|
ErrorOr<RequestPipe> RequestPipe::create()
|
|
{
|
|
#if defined(AK_OS_WINDOWS)
|
|
int socket_fds[2] {};
|
|
TRY(Core::System::socketpair(AF_LOCAL, SOCK_STREAM, 0, socket_fds));
|
|
int option = 1;
|
|
TRY(Core::System::ioctl(socket_fds[0], FIONBIO, option));
|
|
TRY(Core::System::ioctl(socket_fds[1], FIONBIO, option));
|
|
return RequestPipe(socket_fds[0], socket_fds[1]);
|
|
#else
|
|
auto fds = TRY(Core::System::pipe2(O_NONBLOCK));
|
|
return RequestPipe(fds[0], fds[1]);
|
|
#endif
|
|
}
|
|
|
|
ErrorOr<size_t> RequestPipe::write(ReadonlyBytes bytes)
|
|
{
|
|
#if defined(AK_OS_WINDOWS)
|
|
return Core::System::send(m_writer_fd, bytes, 0);
|
|
#else
|
|
return Core::System::write(m_writer_fd, bytes);
|
|
#endif
|
|
}
|
|
|
|
}
|