diff options
author | Itamar <itamar8910@gmail.com> | 2022-02-25 12:18:30 +0200 |
---|---|---|
committer | Andreas Kling <kling@serenityos.org> | 2022-02-25 22:35:12 +0100 |
commit | 3a71748e5d16a244c21aaf28ca3c4220c47f484e (patch) | |
tree | ea2751b9752bf299a2b3e3cdd613c7f8a36b7db1 /Userland/Libraries/LibIPC/ClientConnection.h | |
parent | efac8625703e9b059af0f32422d0d274f99ae475 (diff) | |
download | serenity-3a71748e5d16a244c21aaf28ca3c4220c47f484e.zip |
Userland: Rename IPC ClientConnection => ConnectionFromClient
This was done with CLion's automatic rename feature and with:
find . -name ClientConnection.h
| rename 's/ClientConnection\.h/ConnectionFromClient.h/'
find . -name ClientConnection.cpp
| rename 's/ClientConnection\.cpp/ConnectionFromClient.cpp/'
Diffstat (limited to 'Userland/Libraries/LibIPC/ClientConnection.h')
-rw-r--r-- | Userland/Libraries/LibIPC/ClientConnection.h | 73 |
1 files changed, 0 insertions, 73 deletions
diff --git a/Userland/Libraries/LibIPC/ClientConnection.h b/Userland/Libraries/LibIPC/ClientConnection.h deleted file mode 100644 index 2fef3b83ef..0000000000 --- a/Userland/Libraries/LibIPC/ClientConnection.h +++ /dev/null @@ -1,73 +0,0 @@ -/* - * Copyright (c) 2018-2020, Andreas Kling <kling@serenityos.org> - * - * SPDX-License-Identifier: BSD-2-Clause - */ - -#pragma once - -#include <LibIPC/Connection.h> - -namespace IPC { - -template<typename T, class... Args> -NonnullRefPtr<T> new_client_connection(Args&&... args) -{ - return T::construct(forward<Args>(args)...) /* arghs */; -} - -template<typename ClientEndpoint, typename ServerEndpoint> -class ClientConnection : public Connection<ServerEndpoint, ClientEndpoint> - , public ServerEndpoint::Stub - , public ClientEndpoint::template Proxy<ServerEndpoint> { -public: - using ServerStub = typename ServerEndpoint::Stub; - using IPCProxy = typename ClientEndpoint::template Proxy<ServerEndpoint>; - - ClientConnection(ServerStub& stub, NonnullOwnPtr<Core::Stream::LocalSocket> socket, int client_id) - : IPC::Connection<ServerEndpoint, ClientEndpoint>(stub, move(socket)) - , ClientEndpoint::template Proxy<ServerEndpoint>(*this, {}) - , m_client_id(client_id) - { - VERIFY(this->socket().is_open()); - this->socket().on_ready_to_read = [this] { - // FIXME: Do something about errors. - (void)this->drain_messages_from_peer(); - }; - } - - virtual ~ClientConnection() override - { - } - - void did_misbehave() - { - dbgln("{} (id={}) misbehaved, disconnecting.", *this, m_client_id); - this->shutdown(); - } - - void did_misbehave(const char* message) - { - dbgln("{} (id={}) misbehaved ({}), disconnecting.", *this, m_client_id, message); - this->shutdown(); - } - - void shutdown_with_error(Error const& error) - { - dbgln("{} (id={}) had error ({}), disconnecting.", *this, m_client_id, error); - this->shutdown(); - } - - int client_id() const { return m_client_id; } - - virtual void die() override = 0; - -private: - int m_client_id { -1 }; -}; - -} - -template<typename ClientEndpoint, typename ServerEndpoint> -struct AK::Formatter<IPC::ClientConnection<ClientEndpoint, ServerEndpoint>> : Formatter<Core::Object> { -}; |