CAF  0.17.3
caf::io::basp_broker Member List

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

abstract_broker(abstract_broker &&)=delete (defined in caf::io::abstract_broker)caf::io::abstract_broker
abstract_broker(const abstract_broker &&)=delete (defined in caf::io::abstract_broker)caf::io::abstract_broker
abstract_broker(actor_config &cfg) (defined in caf::io::abstract_broker)caf::io::abstract_brokerexplicitprotected
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 namecaf::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_connectionscaf::io::basp_broker
awaited_responses_caf::scheduled_actorprotected
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_brokerexplicit
bhvr_stack_caf::scheduled_actorprotected
broker(actor_config &cfg) (defined in caf::io::broker)caf::io::brokerexplicit
broker(broker &&)=delete (defined in caf::io::broker)caf::io::broker
broker(const broker &)=delete (defined in caf::io::broker)caf::io::broker
by_id(Handle hdl) -> optional< decltype(*ptr_of(hdl))>caf::io::abstract_brokerprotected
callee(actor_system &sys, proxy_registry::backend &backend) (defined in caf::io::basp::instance::callee)caf::io::basp::instance::calleeexplicit
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() constcaf::io::abstract_broker
credit_round_ticks_caf::scheduled_actorprotected
ctxcaf::io::basp_broker
ctx_map typedef (defined in caf::io::basp_broker)caf::io::basp_broker
current_execution_unit() overridecaf::io::basp_brokervirtual
datagram_hdl_by_port(uint16_t port)caf::io::abstract_broker
datagram_servant_map typedef (defined in caf::io::abstract_broker)caf::io::abstract_brokerprotected
default_down_handler(pointer ptr, down_msg &x) (defined in caf::scheduled_actor)caf::scheduled_actorstatic
default_error_handler(pointer ptr, error &x) (defined in caf::scheduled_actor)caf::scheduled_actorstatic
default_exception_handler(pointer ptr, std::exception_ptr &x) (defined in caf::scheduled_actor)caf::scheduled_actorstatic
default_exit_handler(pointer ptr, exit_msg &x) (defined in caf::scheduled_actor)caf::scheduled_actorstatic
default_handler typedefcaf::scheduled_actor
default_handler_caf::scheduled_actorprotected
done enum value (defined in caf::resumable)caf::resumable
doorman_map typedef (defined in caf::io::abstract_broker)caf::io::abstract_brokerprotected
down_handler typedefcaf::scheduled_actor
down_handler_caf::scheduled_actorprotected
downstream_queue typedefcaf::scheduled_actor
downstream_queue_index (defined in caf::scheduled_actor)caf::scheduled_actorstatic
drop(scheduled_actor *, message_view &)caf::scheduled_actorrelated
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(strong_actor_ptr sender, message_id mid, message msg, execution_unit *host) override (defined in caf::scheduled_actor)caf::scheduled_actor
enqueue_datagram(datagram_handle, byte_buffer)caf::io::abstract_broker
error_handler typedefcaf::scheduled_actor
error_handler_caf::scheduled_actorprotected
exception_handler typedefcaf::scheduled_actor
exception_handler_caf::scheduled_actorprotected
exit_handler typedefcaf::scheduled_actor
exit_handler_caf::scheduled_actorprotected
finalize_handshake(const node_id &nid, actor_id aid, std::set< std::string > &sigs) overridecaf::io::basp_brokervirtual
flush(connection_handle hdl) overridecaf::io::basp_brokervirtual
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 valuecaf::resumable
get_buffer(connection_handle hdl) overridecaf::io::basp_brokervirtual
halt(Handle hdl)caf::io::abstract_broker
handle_down_msg(down_msg &) (defined in caf::io::basp_broker)caf::io::basp_broker
handle_heartbeat() overridecaf::io::basp_brokervirtual
hdl_by_port(uint16_t port)caf::io::abstract_broker
init_broker() (defined in caf::io::abstract_broker)caf::io::abstract_brokerprotected
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() overridecaf::scheduled_actorvirtual
intrusive_ptr_release_impl() overridecaf::scheduled_actorvirtual
io_actor enum valuecaf::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) overridecaf::io::basp_brokervirtual
learned_new_node_indirectly(const node_id &nid) overridecaf::io::basp_brokervirtual
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() noexceptcaf::scheduled_actor
mailbox_caf::scheduled_actorprotected
mailbox_type typedefcaf::scheduled_actor
make_behavior() override (defined in caf::io::basp_broker)caf::io::basp_brokervirtual
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) overridecaf::io::basp_brokervirtual
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
max_batch_delay_ticks_caf::scheduled_actorprotected
message_category enum namecaf::scheduled_actor
monitored_actor_map typedef (defined in caf::io::basp_broker)caf::io::basp_broker
monitored_actorscaf::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
multiplexed_responses_caf::scheduled_actorprotected
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::calleeprotected
normal_queue typedefcaf::scheduled_actor
normal_queue_index (defined in caf::scheduled_actor)caf::scheduled_actorstatic
num_connections() constcaf::io::abstract_broker
on_exit() override (defined in caf::io::basp_broker)caf::io::basp_broker
operator=(broker &&)=delete (defined in caf::io::broker)caf::io::broker
operator=(const broker &)=delete (defined in caf::io::broker)caf::io::broker
operator=(abstract_broker &&)=delete (defined in caf::io::abstract_broker)caf::io::abstract_broker
operator=(const abstract_broker &&)=delete (defined in caf::io::abstract_broker)caf::io::abstract_broker
operator=(scheduled_actor &&)=delete (defined in caf::scheduled_actor)caf::scheduled_actor
operator=(const scheduled_actor &)=delete (defined in caf::scheduled_actor)caf::scheduled_actor
parent()caf::io::abstract_broker
peek_at_next_mailbox_element() override (defined in caf::scheduled_actor)caf::scheduled_actor
pending_response typedefcaf::scheduled_actor
pending_stream_managers() noexceptcaf::scheduled_actor
pending_stream_managers_caf::scheduled_actorprotected
pointer typedefcaf::scheduled_actor
print_and_drop(scheduled_actor *, message_view &)caf::scheduled_actorrelated
private_thread_caf::scheduled_actorprotected
proxies()caf::io::basp::instance::callee
proxy_announced(const node_id &nid, actor_id aid) overridecaf::io::basp_brokervirtual
proxy_registry_ptr() overridecaf::io::basp_brokervirtual
purge_state(const node_id &nid) overridecaf::io::basp_brokervirtual
quit(error x=error{})caf::scheduled_actor
reflect(scheduled_actor *, message_view &)caf::scheduled_actorrelated
reflect_and_quit(scheduled_actor *, message_view &)caf::scheduled_actorrelated
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) overridecaf::io::basp_brokervirtual
resume_later enum value (defined in caf::resumable)caf::resumable
resume_result enum namecaf::resumable
scheduled_actor(actor_config &cfg) (defined in caf::scheduled_actor)caf::scheduled_actorexplicit
scheduled_actor(scheduled_actor &&)=delete (defined in caf::scheduled_actor)caf::scheduled_actor
scheduled_actor(const scheduled_actor &)=delete (defined in caf::scheduled_actor)caf::scheduled_actor
caf::resumable::scheduled_actor enum valuecaf::resumable
scribe_map typedef (defined in caf::io::abstract_broker)caf::io::abstract_brokerprotected
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) overridecaf::io::basp_brokervirtual
shutdown_execution_unit enum value (defined in caf::resumable)caf::resumable
signatures typedef (defined in caf::io::broker)caf::io::broker
spawn_serverscaf::io::basp_broker
stream_manager_map typedefcaf::scheduled_actor
stream_managers() noexceptcaf::scheduled_actor
stream_managers_caf::scheduled_actorprotected
stream_ticks_caf::scheduled_actorprotected
subtype() const overridecaf::io::abstract_brokervirtual
subtype_t enum namecaf::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() overridecaf::io::basp_brokervirtual
this_contextcaf::io::basp_broker
this_node() constcaf::io::basp_broker
timeout_id_caf::scheduled_actorprotected
trigger(Handle hdl)caf::io::abstract_broker
trigger(Handle hdl, size_t num_events)caf::io::abstract_broker
unspecified enum valuecaf::resumable
upstream_queue typedefcaf::scheduled_actor
upstream_queue_index (defined in caf::scheduled_actor)caf::scheduled_actorstatic
urgent_queue typedefcaf::scheduled_actor
urgent_queue_index (defined in caf::scheduled_actor)caf::scheduled_actorstatic
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::backendvirtual
~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::calleevirtual
~resumable() (defined in caf::resumable)caf::resumablevirtual
~scheduled_actor() override (defined in caf::scheduled_actor)caf::scheduled_actor