![]() |
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 376 of file proxy-io.h.
|
inline |
Definition at line 379 of file proxy-io.h.
|
inline |
Definition at line 383 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 83 of file proxy.cpp.
| CleanupIt mp::Connection::addSyncCleanup | ( | std::function< void()> | fn | ) |
|
inline |
Add disconnect handler.
Definition at line 405 of file proxy-io.h.
| void mp::Connection::removeSyncCleanup | ( | CleanupIt | it | ) |
| LoggingErrorHandler mp::Connection::m_error_handler {*m_loop} |
Definition at line 418 of file proxy-io.h.
| EventLoopRef mp::Connection::m_loop |
Definition at line 416 of file proxy-io.h.
| ::capnp::TwoPartyVatNetwork mp::Connection::m_network |
Definition at line 420 of file proxy-io.h.
| kj::TaskSet mp::Connection::m_on_disconnect {m_error_handler} |
Definition at line 419 of file proxy-io.h.
| std::optional<::capnp::RpcSystem<::capnp::rpc::twoparty::VatId> > mp::Connection::m_rpc_system |
Definition at line 421 of file proxy-io.h.
| kj::Own<kj::AsyncIoStream> mp::Connection::m_stream |
Definition at line 417 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 434 of file proxy-io.h.
| ThreadMap::Client mp::Connection::m_thread_map {nullptr} |
Definition at line 425 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 429 of file proxy-io.h.