acquire_credit(inbound_path *path, int32_t desired) | caf::stream_manager | virtual |
add_unchecked_inbound_path_impl(type_id_t input_type, inbound_path_ptr path) | caf::stream_manager | protected |
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 inbound_path &path) 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 | protectedvirtual |
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 | protectedvirtual |
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_path_ptr typedef (defined in caf::stream_manager) | caf::stream_manager | |
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 | protectedvirtual |
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 |
make_copy_on_write(Ts &&... xs) | caf::ref_counted | related |
make_counted(Ts &&... xs) | caf::ref_counted | related |
max_batch_delay_ | caf::stream_manager | protected |
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 | protectedvirtual |
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 | mutableprotected |
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() noexcept | 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 > | |
tick(time_point now) (defined in caf::stream_manager) | caf::stream_manager | |
time_point typedef | caf::stream_manager | |
unique() const noexcept | caf::ref_counted | |
~ref_counted() (defined in caf::ref_counted) | caf::ref_counted | virtual |
~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 | |