libcaf
0.17.1
|
Default implementation of the middleman_actor
interface.
More...
#include <middleman_actor_impl.hpp>
Public Types | |
using | put_res = result< uint16_t > |
using | mpi_set = std::set< std::string > |
using | get_res = result< node_id, strong_actor_ptr, mpi_set > |
using | get_delegated = delegated< node_id, strong_actor_ptr, mpi_set > |
using | del_res = result< void > |
using | endpoint_data = std::tuple< node_id, strong_actor_ptr, mpi_set > |
using | endpoint = std::pair< std::string, uint16_t > |
![]() | |
using | super = typename extend< scheduled_actor, typed_event_based_actor< Sigs...>>::template with< mixin::sender, mixin::requester, mixin::behavior_changer > |
using | signatures = detail::type_list< Sigs...> |
using | behavior_type = typed_behavior< Sigs...> |
using | actor_hdl = typed_actor< Sigs...> |
Public Member Functions | |
middleman_actor_impl (actor_config &cfg, actor default_broker) | |
void | on_exit () override |
const char * | name () const override |
behavior_type | make_behavior () override |
![]() | |
typed_event_based_actor (actor_config &cfg) | |
std::set< std::string > | message_types () const override |
void | initialize () override |
Protected Member Functions | |
virtual expected< scribe_ptr > | connect (const std::string &host, uint16_t port) |
Tries to connect to given host and port . More... | |
virtual expected < datagram_servant_ptr > | contact (const std::string &host, uint16_t port) |
Tries to connect to given host and port . More... | |
virtual expected< doorman_ptr > | open (uint16_t port, const char *addr, bool reuse) |
Tries to open a local port. More... | |
virtual expected < datagram_servant_ptr > | open_udp (uint16_t port, const char *addr, bool reuse) |
Tries to open a local port. More... | |
Default implementation of the middleman_actor
interface.
|
protectedvirtual |
Tries to connect to given host
and port
.
The default implementation calls system().middleman().backend().new_tcp_scribe(host, port)
.
|
protectedvirtual |
Tries to connect to given host
and port
.
The default implementation calls system().middleman().backend().new_udp
.
|
protectedvirtual |
Tries to open a local port.
The default implementation calls system().middleman().backend().new_tcp_doorman(port, addr, reuse)
.
|
protectedvirtual |
Tries to open a local port.
The default implementation calls system().middleman().backend().new_tcp_doorman(port, addr, reuse)
.