Groups a (distributed) set of actors and allows actors in the same namespace to exchange messages.
More...
#include <proxy_registry.hpp>
|
using | proxy_map = std::map<actor_id, strong_actor_ptr> |
| A map that stores all proxies for known remote actors.
|
|
|
| proxy_registry (actor_system &sys, backend &be) |
|
| proxy_registry (const proxy_registry &)=delete |
|
proxy_registry & | operator= (const proxy_registry &)=delete |
|
void | serialize (serializer &sink, const actor_addr &addr) const |
|
void | serialize (deserializer &source, actor_addr &addr) |
|
void | write (serializer *sink, const actor_addr &ptr) const |
| Writes an actor address to sink and adds the actor to the list of known actors for a later deserialization.
|
|
actor_addr | read (deserializer *source) |
| Reads an actor address from source, creating addresses for remote actors on the fly if needed.
|
|
size_t | count_proxies (const node_id &node) const |
| Returns the number of proxies for node .
|
|
strong_actor_ptr | get (const node_id &node, actor_id aid) const |
| Returns the proxy instance identified by node and aid .
|
|
strong_actor_ptr | get_or_put (const node_id &nid, actor_id aid) |
| Returns the proxy instance identified by node and aid or creates a new (default) proxy instance.
|
|
std::vector< strong_actor_ptr > | get_all (const node_id &node) const |
| Returns all known proxies.
|
|
void | erase (const node_id &nid) |
| Deletes all proxies for node .
|
|
void | erase (const node_id &nid, actor_id aid, error rsn=exit_reason::remote_link_unreachable) |
| Deletes the proxy with id aid for nid .
|
|
bool | empty () const |
| Queries whether there are any proxies left.
|
|
void | clear () |
| Deletes all proxies.
|
|
actor_system & | system () |
| Returns the hosting actor system.
|
|
const actor_system & | system () const |
| Returns the hosting actor system.
|
|
void | set_last_hop (node_id *ptr) |
| Sets the thread-local last hop variable on the backend.
|
|
|
static proxy_registry * | current () noexcept |
| Returns the current proxy registry for the calling thread.
|
|
static void | current (proxy_registry *) noexcept |
| Sets the current proxy registry for the calling thread.
|
|
Groups a (distributed) set of actors and allows actors in the same namespace to exchange messages.
The documentation for this class was generated from the following files:
- libcaf_core/caf/proxy_registry.hpp
- libcaf_core/caf/proxy_registry.cpp