mirror of
https://github.com/LadybirdBrowser/ladybird.git
synced 2024-11-22 23:50:19 +00:00
cc4b3cbacc
Some checks are pending
CI / Lagom (false, FUZZ, ubuntu-24.04, Linux, Clang) (push) Waiting to run
CI / Lagom (false, NO_FUZZ, macos-14, macOS, Clang) (push) Waiting to run
CI / Lagom (false, NO_FUZZ, ubuntu-24.04, Linux, GNU) (push) Waiting to run
CI / Lagom (true, NO_FUZZ, ubuntu-24.04, Linux, Clang) (push) Waiting to run
Package the js repl as a binary artifact / build-and-package (macos-14, macOS, macOS-universal2) (push) Waiting to run
Package the js repl as a binary artifact / build-and-package (ubuntu-24.04, Linux, Linux-x86_64) (push) Waiting to run
Run test262 and test-wasm / run_and_update_results (push) Waiting to run
Lint Code / lint (push) Waiting to run
Push notes / build (push) Waiting to run
49 lines
2.2 KiB
C++
49 lines
2.2 KiB
C++
/*
|
|
* Copyright (c) 2018-2020, Andreas Kling <andreas@ladybird.org>
|
|
*
|
|
* SPDX-License-Identifier: BSD-2-Clause
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <LibCore/SessionManagement.h>
|
|
#include <LibIPC/Connection.h>
|
|
|
|
namespace IPC {
|
|
|
|
#define IPC_CLIENT_CONNECTION(klass, socket_path) \
|
|
C_OBJECT_ABSTRACT(klass) \
|
|
public: \
|
|
template<typename Klass = klass, class... Args> \
|
|
static ErrorOr<NonnullRefPtr<klass>> try_create(Args&&... args) \
|
|
{ \
|
|
auto parsed_socket_path = TRY(Core::SessionManagement::parse_path_with_sid(socket_path)); \
|
|
auto socket = TRY(Core::LocalSocket::connect(move(parsed_socket_path))); \
|
|
/* We want to rate-limit our clients */ \
|
|
TRY(socket->set_blocking(true)); \
|
|
\
|
|
return adopt_nonnull_ref_or_enomem(new (nothrow) Klass(move(socket), forward<Args>(args)...)); \
|
|
}
|
|
|
|
template<typename ClientEndpoint, typename ServerEndpoint>
|
|
class ConnectionToServer : public IPC::Connection<ClientEndpoint, ServerEndpoint>
|
|
, public ClientEndpoint::Stub
|
|
, public ServerEndpoint::template Proxy<ClientEndpoint> {
|
|
public:
|
|
using ClientStub = typename ClientEndpoint::Stub;
|
|
using IPCProxy = typename ServerEndpoint::template Proxy<ClientEndpoint>;
|
|
|
|
ConnectionToServer(ClientStub& local_endpoint, NonnullOwnPtr<Core::LocalSocket> socket)
|
|
: Connection<ClientEndpoint, ServerEndpoint>(local_endpoint, move(socket))
|
|
, ServerEndpoint::template Proxy<ClientEndpoint>(*this, {})
|
|
{
|
|
}
|
|
|
|
virtual void die() override
|
|
{
|
|
// Override this function if you don't want your app to exit if it loses the connection.
|
|
exit(0);
|
|
}
|
|
};
|
|
|
|
}
|