Loading...
Searching...
No Matches
caf::io::basp_broker Member List

This is the complete list of members for caf::io::basp_broker, including all inherited members.

abstract_broker(actor_config &cfg) (defined in caf::io::abstract_broker) | caf::io::abstract_broker | explicit protected
ack_writes(connection_handle hdl, bool enable) | caf::io::abstract_broker |
ack_writes(datagram_handle hdl, bool enable) | caf::io::abstract_broker |
activation_result enum name | caf::scheduled_actor |
add_datagram_servant(datagram_servant_ptr ptr) | caf::io::abstract_broker |
add_datagram_servant(network::native_socket fd) | caf::io::abstract_broker |
add_datagram_servant_for_endpoint(network::native_socket fd, const network::ip_endpoint &ep) | caf::io::abstract_broker |
add_doorman(doorman_ptr ptr) | caf::io::abstract_broker |
add_doorman(network::native_socket fd) | caf::io::abstract_broker |
add_hdl_for_datagram_servant(datagram_servant_ptr ptr, datagram_handle hdl) | caf::io::abstract_broker |
add_scribe(scribe_ptr ptr) | caf::io::abstract_broker |
add_scribe(network::native_socket fd) | caf::io::abstract_broker |
add_tcp_doorman(uint16_t port=0, const char *in=nullptr, bool reuse_addr=false) | caf::io::abstract_broker |
add_tcp_scribe(const std::string &host, uint16_t port) | caf::io::abstract_broker |
add_udp_datagram_servant(const std::string &host, uint16_t port) | caf::io::abstract_broker |
add_udp_datagram_servant(uint16_t port=0, const char *in=nullptr, bool reuse_addr=false) | caf::io::abstract_broker |
automatic_connections | caf::io::basp_broker |
awaiting_message enum value (defined in caf::resumable) | caf::resumable |
backend() | caf::io::abstract_broker |
basp_broker(actor_config &cfg) (defined in caf::io::basp_broker) | caf::io::basp_broker | explicit
broker(actor_config &cfg) (defined in caf::io::broker) | caf::io::broker | explicit
buffer_type typedef (defined in caf::io::basp::instance::callee) | caf::io::basp::instance::callee |
by_id(Handle hdl) -> optional< decltype(*ptr_of(hdl))> | caf::io::abstract_broker | protected
callee(actor_system &sys, proxy_registry::backend &backend) (defined in caf::io::basp::instance::callee) | caf::io::basp::instance::callee | explicit
cleanup(error &&reason, execution_unit *host) override (defined in caf::io::abstract_broker) | caf::io::abstract_broker |
close(Handle hdl) | caf::io::abstract_broker |
close_all() | caf::io::abstract_broker |
config() (defined in caf::io::basp_broker) | caf::io::basp_broker |
configure_read(connection_handle hdl, receive_policy::config cfg) | caf::io::abstract_broker |
connection_cleanup(connection_handle hdl, sec code) | caf::io::basp_broker |
connections() const | caf::io::abstract_broker |
ctx | caf::io::basp_broker |
ctx_map typedef (defined in caf::io::basp_broker) | caf::io::basp_broker |
current_execution_unit() override | caf::io::basp_broker | virtual
datagram_hdl_by_port(uint16_t port) | caf::io::abstract_broker |
datagram_servant_map typedef (defined in caf::io::abstract_broker) | caf::io::abstract_broker | protected
default_down_handler(pointer ptr, down_msg &x) (defined in caf::scheduled_actor) | caf::scheduled_actor | static
default_error_handler(pointer ptr, error &x) (defined in caf::scheduled_actor) | caf::scheduled_actor | static
default_exception_handler(pointer ptr, std::exception_ptr &x) (defined in caf::scheduled_actor) | caf::scheduled_actor | static
default_exit_handler(pointer ptr, exit_msg &x) (defined in caf::scheduled_actor) | caf::scheduled_actor | static
default_handler typedef | caf::scheduled_actor |
done enum value (defined in caf::resumable) | caf::resumable |
doorman_map typedef (defined in caf::io::abstract_broker) | caf::io::abstract_broker | protected
down_handler typedef | caf::scheduled_actor |
downstream_queue typedef | caf::scheduled_actor |
downstream_queue_index (defined in caf::scheduled_actor) | caf::scheduled_actor | static
drop(scheduled_actor *, message_view &) | caf::scheduled_actor | related
enqueue(mailbox_element_ptr, execution_unit *) override (defined in caf::io::abstract_broker) | caf::io::abstract_broker |
enqueue(strong_actor_ptr, message_id, message, execution_unit *) override (defined in caf::io::abstract_broker) | caf::io::abstract_broker |
enqueue_datagram(datagram_handle, std::vector< char >) | caf::io::abstract_broker |
error_handler typedef | caf::scheduled_actor |
exception_handler typedef | caf::scheduled_actor |
exit_handler typedef | caf::scheduled_actor |
finalize_handshake(const node_id &nid, actor_id aid, std::set< std::string > &sigs) override | caf::io::basp_broker | virtual
flush(connection_handle hdl) override | caf::io::basp_broker | virtual
caf::io::broker::flush(datagram_handle hdl) | caf::io::abstract_broker |
fork(F fun, connection_handle hdl, Ts &&... xs) (defined in caf::io::broker) | caf::io::broker |
function_object enum value | caf::resumable |
get_buffer(connection_handle hdl) override | caf::io::basp_broker | virtual
halt(Handle hdl) | caf::io::abstract_broker |
handle_down_msg(down_msg &) (defined in caf::io::basp_broker) | caf::io::basp_broker |
handle_heartbeat() override | caf::io::basp_broker | virtual
hdl_by_port(uint16_t port) | caf::io::abstract_broker |
init_broker() (defined in caf::io::abstract_broker) | caf::io::abstract_broker | protected
initialize() override (defined in caf::io::broker) | caf::io::broker |
instance (defined in caf::io::basp_broker) | caf::io::basp_broker |
intrusive_ptr_add_ref_impl() override | caf::scheduled_actor | virtual
intrusive_ptr_release_impl() override | caf::scheduled_actor | virtual
io_actor enum value | caf::resumable |
launch(execution_unit *eu, bool lazy, bool hide) override (defined in caf::io::abstract_broker) | caf::io::abstract_broker |
learned_new_node(const node_id &nid) | caf::io::basp_broker |
learned_new_node_directly(const node_id &nid, bool was_indirectly_before) override | caf::io::basp_broker | virtual
learned_new_node_indirectly(const node_id &nid) override | caf::io::basp_broker | virtual
local_addr(accept_handle hdl) | caf::io::abstract_broker |
local_port(accept_handle hdl) | caf::io::abstract_broker |
local_port(datagram_handle hdl) | caf::io::abstract_broker |
mailbox() noexcept | caf::scheduled_actor |
mailbox_type typedef | caf::scheduled_actor |
make_behavior() override (defined in caf::io::basp_broker) | caf::io::basp_broker | virtual
make_continuous_source(Init init, Pull pull, Done done, Finalize fin={}) | caf::scheduled_actor |
make_continuous_source(Init init, Pull pull, Done done, Finalize fin={}, policy::arg< DownstreamManager >={}) | caf::scheduled_actor |
make_continuous_stage(Ts &&... xs) | caf::scheduled_actor |
make_continuous_stage(Init init, Fun fun, Cleanup cleanup, policy::arg< DownstreamManager > token={}) | caf::scheduled_actor |
make_proxy(node_id nid, actor_id aid) override | caf::io::basp_broker | virtual
make_sink(const stream< typename Driver::input_type > &src, Ts &&... xs) | caf::scheduled_actor |
make_sink(const stream< In > &in, Init init, Fun fun, Finalize fin={}) | caf::scheduled_actor |
make_source(std::tuple< Ts... > xs, Init init, Pull pull, Done done, Finalize fin={}) | caf::scheduled_actor |
make_source(std::tuple< Ts... > xs, Init init, Pull pull, Done done, Finalize fin={}, policy::arg< DownstreamManager >={}) | caf::scheduled_actor |
make_source(Init init, Pull pull, Done done, Finalize finalize={}, policy::arg< DownstreamManager > token={}) | caf::scheduled_actor |
make_source(const ActorHandle &dest, std::tuple< Ts... > xs, Init init, Pull pull, Done done, Finalize fin={}, policy::arg< DownstreamManager >={}) | caf::scheduled_actor |
make_source(const ActorHandle &dest, Init init, Pull pull, Done done, Finalize fin={}, policy::arg< DownstreamManager > token={}) | caf::scheduled_actor |
make_stage(const stream< In > &src, std::tuple< Ts... > xs, Us &&... ys) | caf::scheduled_actor |
make_stage(const stream< In > &in, std::tuple< Ts... > xs, Init init, Fun fun, Finalize fin={}, policy::arg< DownstreamManager > token={}) | caf::scheduled_actor |
make_stage(const stream< In > &in, Init init, Fun fun, Finalize fin={}, policy::arg< DownstreamManager > token={}) | caf::scheduled_actor |
message_category enum name | caf::scheduled_actor |
monitored_actor_map typedef (defined in caf::io::basp_broker) | caf::io::basp_broker |
monitored_actors | caf::io::basp_broker |
move_datagram_servant(datagram_servant_ptr ptr) | caf::io::abstract_broker |
move_doorman(doorman_ptr ptr) | caf::io::abstract_broker |
move_scribe(scribe_ptr ptr) | caf::io::abstract_broker |
name() const override (defined in caf::io::basp_broker) | caf::io::basp_broker |
namespace_ (defined in caf::io::basp::instance::callee) | caf::io::basp::instance::callee | protected
normal_queue typedef | caf::scheduled_actor |
normal_queue_index (defined in caf::scheduled_actor) | caf::scheduled_actor | static
num_connections() const | caf::io::abstract_broker |
on_exit() override (defined in caf::io::basp_broker) | caf::io::basp_broker |
parent() | caf::io::abstract_broker |
peek_at_next_mailbox_element() override (defined in caf::scheduled_actor) | caf::scheduled_actor |
pending_response typedef | caf::scheduled_actor |
pending_stream_managers() noexcept | caf::scheduled_actor |
pointer typedef | caf::scheduled_actor |
print_and_drop(scheduled_actor *, message_view &) | caf::scheduled_actor | related
proxies() | caf::io::basp::instance::callee |
proxy_announced(const node_id &nid, actor_id aid) override | caf::io::basp_broker | virtual
proxy_registry_ptr() override | caf::io::basp_broker | virtual
purge_state(const node_id &nid) override | caf::io::basp_broker | virtual
quit(error x=error{}) | caf::scheduled_actor |
reflect(scheduled_actor *, message_view &) | caf::scheduled_actor | related
reflect_and_quit(scheduled_actor *, message_view &) | caf::scheduled_actor | related
remote_addr(connection_handle hdl) | caf::io::abstract_broker |
remote_addr(datagram_handle hdl) | caf::io::abstract_broker |
remote_port(connection_handle hdl) | caf::io::abstract_broker |
remote_port(datagram_handle hdl) | caf::io::abstract_broker |
remove_endpoint(datagram_handle hdl) | caf::io::abstract_broker |
resumable()=default (defined in caf::resumable) | caf::resumable |
resume(execution_unit *, size_t) override | caf::io::basp_broker | virtual
resume_later enum value (defined in caf::resumable) | caf::resumable |
resume_result enum name | caf::resumable |
scheduled_actor(actor_config &cfg) (defined in caf::scheduled_actor) | caf::scheduled_actor | explicit
caf::resumable::scheduled_actor enum value | caf::resumable |
scribe_map typedef (defined in caf::io::abstract_broker) | caf::io::abstract_broker | protected
send_basp_down_message(const node_id &nid, actor_id aid, error err) | caf::io::basp_broker |
set_context(connection_handle hdl) | caf::io::basp_broker |
set_default_handler(default_handler fun) | caf::scheduled_actor |
set_default_handler(F fun) | caf::scheduled_actor |
set_down_handler(down_handler fun) | caf::scheduled_actor |
set_down_handler(T fun) -> decltype(fun(std::declval< down_msg & >())) | caf::scheduled_actor |
set_error_handler(error_handler fun) | caf::scheduled_actor |
set_error_handler(T fun) -> decltype(fun(std::declval< error & >())) | caf::scheduled_actor |
set_exception_handler(exception_handler fun) | caf::scheduled_actor |
set_exception_handler(F f) | caf::scheduled_actor |
set_exit_handler(exit_handler fun) | caf::scheduled_actor |
set_exit_handler(T fun) -> decltype(fun(std::declval< exit_msg & >())) | caf::scheduled_actor |
set_last_hop(node_id *ptr) override | caf::io::basp_broker | virtual
shutdown_execution_unit enum value (defined in caf::resumable) | caf::resumable |
signatures typedef (defined in caf::io::broker) | caf::io::broker |
spawn_servers | caf::io::basp_broker |
stream_manager_map typedef | caf::scheduled_actor |
stream_managers() noexcept | caf::scheduled_actor |
subtype() const override | caf::io::abstract_broker | virtual
subtype_t enum name | caf::resumable |
super typedef (defined in caf::io::basp_broker) | caf::io::basp_broker |
system() (defined in caf::io::basp_broker) | caf::io::basp_broker |
this_actor() override | caf::io::basp_broker | virtual
this_context | caf::io::basp_broker |
this_node() const | caf::io::basp_broker |
trigger(Handle hdl) | caf::io::abstract_broker |
trigger(Handle hdl, size_t num_events) | caf::io::abstract_broker |
unspecified enum value | caf::resumable |
upstream_queue typedef | caf::scheduled_actor |
upstream_queue_index (defined in caf::scheduled_actor) | caf::scheduled_actor | static
urgent_queue typedef | caf::scheduled_actor |
urgent_queue_index (defined in caf::scheduled_actor) | caf::scheduled_actor | static
valid(Handle hdl) | caf::io::abstract_broker |
wr_buf(connection_handle hdl) | caf::io::abstract_broker |
wr_buf(datagram_handle hdl) | caf::io::abstract_broker |
write(connection_handle hdl, size_t bs, const void *buf) | caf::io::abstract_broker |
write(datagram_handle hdl, size_t data_size, const void *data) | caf::io::abstract_broker |
~abstract_broker() override (defined in caf::io::abstract_broker) | caf::io::abstract_broker |
~backend() (defined in caf::proxy_registry::backend) | caf::proxy_registry::backend | virtual
~basp_broker() override (defined in caf::io::basp_broker) | caf::io::basp_broker |
~callee() (defined in caf::io::basp::instance::callee) | caf::io::basp::instance::callee | virtual
~resumable() (defined in caf::resumable) | caf::resumable | virtual
~scheduled_actor() override (defined in caf::scheduled_actor) | caf::scheduled_actor |