Loading...
Searching...
No Matches
caf::detail::stream_distribution_tree< Policy > Member List

This is the complete list of members for caf::detail::stream_distribution_tree< Policy >, including all inherited members.

acquire_credit(inbound_path *path, int32_t desired) | caf::stream_manager | virtual
add_unchecked_inbound_path_impl(rtti_pair rtti) | caf::stream_manager |
advance() | caf::stream_manager |
assign_next_pending_slot() (defined in caf::stream_manager) | caf::stream_manager | protected
assign_next_slot() (defined in caf::stream_manager) | caf::stream_manager | protected
congested() const noexcept | caf::stream_manager | virtual
continuous() const noexcept | caf::stream_manager |
continuous(bool x) noexcept | caf::stream_manager |
cycle_timeout(size_t cycle_nr) | caf::stream_manager | virtual
deliver_handshake(response_promise &rp, stream_slot slot, message handshake) | caf::stream_manager | virtual
deref() const noexcept | caf::ref_counted |
deregister_input_path(inbound_path *x) noexcept | caf::stream_manager | virtual
done() const override | caf::detail::stream_distribution_tree< Policy > | virtual
downstream_demand(outbound_path *ptr, long demand) | caf::stream_manager | protected virtual
downstream_manager_type typedef (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > |
finalize(const error &reason) (defined in caf::stream_manager) | caf::stream_manager | protected virtual
flags_ | caf::stream_manager | protected
generate_messages() | caf::stream_manager | virtual
get_inbound_path(stream_slot x) const noexcept | caf::stream_manager |
get_reference_count() const noexcept (defined in caf::ref_counted) | caf::ref_counted |
handle(inbound_path *path, downstream_msg::batch &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual
handle(inbound_path *path, downstream_msg::close &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual
handle(inbound_path *path, downstream_msg::forced_close &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual
handle(stream_slots slots, upstream_msg::ack_open &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual
handle(stream_slots slots, upstream_msg::drop &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual
handle(stream_slots slots, upstream_msg::forced_drop &x) override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > | virtual
handle(stream_slots slots, upstream_msg::ack_batch &x) (defined in caf::stream_manager) | caf::stream_manager | virtual
idle() const noexcept override | caf::detail::stream_distribution_tree< Policy > | virtual
inbound_paths() const noexcept | caf::stream_manager |
inbound_paths_ | caf::stream_manager | protected
inbound_paths_idle() const noexcept | caf::stream_manager |
inbound_paths_list typedef (defined in caf::stream_manager) | caf::stream_manager |
input_closed(error reason) | caf::stream_manager | protected virtual
intrusive_ptr_add_ref(const ref_counted *p) (defined in caf::ref_counted) | caf::ref_counted | related
intrusive_ptr_release(const ref_counted *p) (defined in caf::ref_counted) | caf::ref_counted | related
is_continuous_flag | caf::stream_manager | static
is_shutting_down_flag | caf::stream_manager | static
is_stopped_flag | caf::stream_manager | static
operator=(const ref_counted &) (defined in caf::ref_counted) | caf::ref_counted |
out() override | caf::detail::stream_distribution_tree< Policy > | virtual
caf::stream_manager::out() const | caf::stream_manager |
output_closed(error reason) | caf::stream_manager | protected virtual
pending_handshakes_ | caf::stream_manager | protected
policy() (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > |
policy() const (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > |
priority_ | caf::stream_manager | protected
push() | caf::stream_manager | virtual
rc_ (defined in caf::ref_counted) | caf::ref_counted | mutable protected
ref() const noexcept | caf::ref_counted |
ref_counted() (defined in caf::ref_counted) | caf::ref_counted |
ref_counted(const ref_counted &) (defined in caf::ref_counted) | caf::ref_counted |
register_input_path(inbound_path *x) | caf::stream_manager | virtual
remove_input_path(stream_slot slot, error reason, bool silent) | caf::stream_manager | virtual
running() const noexcept | caf::stream_manager |
self() | caf::stream_manager |
self_ | caf::stream_manager | protected
shutdown() | caf::stream_manager | virtual
stop(error reason=none) | caf::stream_manager | virtual
stream_distribution_tree(scheduled_actor *selfptr, Ts &&... xs) (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > |
stream_manager(scheduled_actor *selfptr, stream_priority prio=stream_priority::normal) (defined in caf::stream_manager) | caf::stream_manager |
stream_manager_ptr typedef | caf::stream_manager | related
super typedef (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > |
unique() const noexcept | caf::ref_counted |
~ref_counted() override (defined in caf::ref_counted) | caf::ref_counted |
~stream_distribution_tree() override (defined in caf::detail::stream_distribution_tree< Policy >) | caf::detail::stream_distribution_tree< Policy > |
~stream_manager() override (defined in caf::stream_manager) | caf::stream_manager |