caf::stream_manager Member List

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

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 =0	caf::stream_manager	pure virtual
downstream_demand(outbound_path *ptr, long demand)	caf::stream_manager	protectedvirtual
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 *from, downstream_msg::batch &x) (defined in caf::stream_manager)	caf::stream_manager	virtual
handle(inbound_path *from, downstream_msg::close &x) (defined in caf::stream_manager)	caf::stream_manager	virtual
handle(inbound_path *from, downstream_msg::forced_close &x) (defined in caf::stream_manager)	caf::stream_manager	virtual
handle(stream_slots, upstream_msg::ack_open &x) (defined in caf::stream_manager)	caf::stream_manager	virtual
handle(stream_slots slots, upstream_msg::ack_batch &x) (defined in caf::stream_manager)	caf::stream_manager	virtual
handle(stream_slots slots, upstream_msg::drop &x) (defined in caf::stream_manager)	caf::stream_manager	virtual
handle(stream_slots slots, upstream_msg::forced_drop &x) (defined in caf::stream_manager)	caf::stream_manager	virtual
idle() const noexcept=0	caf::stream_manager	pure 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()=0	caf::stream_manager	pure virtual
out() const	caf::stream_manager
output_closed(error reason)	caf::stream_manager	protectedvirtual
pending_handshakes_	caf::stream_manager	protected
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_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
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_manager() override (defined in caf::stream_manager)	caf::stream_manager