![]() |
Bitcoin Core 30.99.0
P2P Digital Currency
|
Object holding network & rpc state associated with either an incoming server connection, or an outgoing client connection. More...
#include <proxy-io.h>
Public Member Functions | |
Connection (EventLoop &loop, kj::Own< kj::AsyncIoStream > &&stream_) | |
Connection (EventLoop &loop, kj::Own< kj::AsyncIoStream > &&stream_, const std::function<::capnp::Capability::Client(Connection &)> &make_client) | |
~Connection () | |
Run cleanup functions. More... | |
CleanupIt | addSyncCleanup (std::function< void()> fn) |
Register synchronous cleanup function to run on event loop thread (with access to capnp thread local variables) when disconnect() is called. More... | |
void | removeSyncCleanup (CleanupIt it) |
template<typename F > | |
void | onDisconnect (F &&f) |
Add disconnect handler. More... | |
Public Attributes | |
EventLoopRef | m_loop |
kj::Own< kj::AsyncIoStream > | m_stream |
LoggingErrorHandler | m_error_handler {*m_loop} |
kj::TaskSet | m_on_disconnect {m_error_handler} |
::capnp::TwoPartyVatNetwork | m_network |
std::optional<::capnp::RpcSystem<::capnp::rpc::twoparty::VatId > > | m_rpc_system |
ThreadMap::Client | m_thread_map {nullptr} |
::capnp::CapabilityServerSet< Thread > | m_threads |
Collection of server-side IPC worker threads (ProxyServer<Thread> objects previously returned by ThreadMap.makeThread) used to service requests to clients. More... | |
CleanupList | m_sync_cleanup_fns |
Cleanup functions to run if connection is broken unexpectedly. More... | |
Object holding network & rpc state associated with either an incoming server connection, or an outgoing client connection.
It must be created and destroyed on the event loop thread. In addition to Cap'n Proto state, it also holds lists of callbacks to run when the connection is closed.
Definition at line 330 of file proxy-io.h.
|
inline |
Definition at line 333 of file proxy-io.h.
|
inline |
Definition at line 337 of file proxy-io.h.
mp::Connection::~Connection | ( | ) |
Run cleanup functions.
Must be called from the event loop thread. First calls synchronous cleanup functions while blocked (to free capnp Capability::Client handles owned by ProxyClient objects), then schedules asynchronous cleanup functions to run in a worker thread (to run destructors of m_impl instances owned by ProxyServer objects).
Definition at line 82 of file proxy.cpp.
CleanupIt mp::Connection::addSyncCleanup | ( | std::function< void()> | fn | ) |
|
inline |
Add disconnect handler.
Definition at line 359 of file proxy-io.h.
void mp::Connection::removeSyncCleanup | ( | CleanupIt | it | ) |
LoggingErrorHandler mp::Connection::m_error_handler {*m_loop} |
Definition at line 372 of file proxy-io.h.
EventLoopRef mp::Connection::m_loop |
Definition at line 370 of file proxy-io.h.
::capnp::TwoPartyVatNetwork mp::Connection::m_network |
Definition at line 374 of file proxy-io.h.
kj::TaskSet mp::Connection::m_on_disconnect {m_error_handler} |
Definition at line 373 of file proxy-io.h.
std::optional<::capnp::RpcSystem<::capnp::rpc::twoparty::VatId> > mp::Connection::m_rpc_system |
Definition at line 375 of file proxy-io.h.
kj::Own<kj::AsyncIoStream> mp::Connection::m_stream |
Definition at line 371 of file proxy-io.h.
CleanupList mp::Connection::m_sync_cleanup_fns |
Cleanup functions to run if connection is broken unexpectedly.
List will be empty if all ProxyClient are destroyed cleanly before the connection is destroyed.
Definition at line 388 of file proxy-io.h.
ThreadMap::Client mp::Connection::m_thread_map {nullptr} |
Definition at line 379 of file proxy-io.h.
::capnp::CapabilityServerSet<Thread> mp::Connection::m_threads |
Collection of server-side IPC worker threads (ProxyServer<Thread> objects previously returned by ThreadMap.makeThread) used to service requests to clients.
Definition at line 383 of file proxy-io.h.