CAF  0.17.2
Classes | Public Types | Public Member Functions | Protected Member Functions | Protected Attributes | List of all members
caf::downstream_manager Class Reference

Manages downstream communication for a stream_manager. More...

#include <downstream_manager.hpp>

Inheritance diagram for caf::downstream_manager:
caf::downstream_manager_base caf::fused_downstream_manager< T, Ts > caf::buffered_downstream_manager< T >

Classes

struct  path_predicate
 Predicate object for paths. More...
 
struct  path_visitor
 Function object for iterating over all paths. More...
 

Public Types

enum  path_algorithm {
  all_of,
  any_of,
  none_of
}
 Selects a check algorithms.
 
using path_type = outbound_path
 Outbound path.
 
using path_ptr = path_type *
 Pointer to an outbound path.
 
using const_path_ptr = const path_type *
 Pointer to an immutable outbound path.
 
using unique_path_ptr = std::unique_ptr< path_type >
 Unique pointer to an outbound path.
 

Public Member Functions

 downstream_manager (stream_manager *parent)
 
scheduled_actorself () const noexcept
 
stream_managerparent () const noexcept
 
virtual bool terminal () const noexcept
 Returns true if this manager belongs to a sink, i.e., terminates the stream and never has outbound paths.
 
template<class F >
void for_each_path (F f)
 Applies f to each path.
 
std::vector< stream_slotpath_slots ()
 Returns all used slots.
 
std::vector< stream_slotopen_path_slots ()
 Returns all open slots, i.e., slots assigned to outbound paths with closing == false.
 
template<class Predicate >
bool all_paths (Predicate predicate) const noexcept
 Checks whether predicate holds true for all paths.
 
template<class Predicate >
bool any_path (Predicate predicate) const noexcept
 Checks whether predicate holds true for any path.
 
template<class Predicate >
bool no_path (Predicate predicate) const noexcept
 Checks whether predicate holds true for no path.
 
virtual size_t num_paths () const noexcept
 Returns the current number of paths.
 
path_ptr add_path (stream_slot slot, strong_actor_ptr target)
 Adds a pending path to target to the manager. More...
 
virtual bool remove_path (stream_slot slot, error reason, bool silent) noexcept
 Removes a path from the manager.
 
virtual path_ptr path (stream_slot slot) noexcept
 Returns the path associated to slot or nullptr.
 
const_path_ptr path (stream_slot slot) const noexcept
 Returns the path associated to slot or nullptr.
 
bool clean () const noexcept
 Returns true if there is no data pending and all batches are acknowledged batch on all paths.
 
bool clean (stream_slot slot) const noexcept
 Returns true if slot is unknown or if there is no data pending and all batches are acknowledged on slot. More...
 
virtual void close ()
 Removes all paths gracefully.
 
virtual void close (stream_slot slot)
 Removes path slot gracefully by sending pending batches before removing it. More...
 
virtual void abort (error reason)
 Removes all paths with an error message.
 
bool empty () const noexcept
 Returns num_paths() == 0.
 
size_t min_credit () const
 Returns the minimum amount of credit on all output paths.
 
size_t max_credit () const
 Returns the maximum amount of credit on all output paths.
 
size_t total_credit () const
 Returns the total amount of credit on all output paths, i.e., the sum of all individual credits.
 
virtual void emit_batches ()
 Sends batches to sinks.
 
virtual void force_emit_batches ()
 Sends batches to sinks regardless of whether or not the batches reach the desired batch size.
 
virtual size_t capacity () const noexcept
 Queries the currently available capacity for the output buffer.
 
virtual size_t buffered () const noexcept
 Queries the size of the output buffer.
 
virtual size_t buffered (stream_slot slot) const noexcept
 Queries an estimate of the size of the output buffer for slot.
 
virtual int32_t max_capacity () const noexcept
 Computes the maximum available downstream capacity.
 
bool stalled () const noexcept
 Queries whether the manager cannot make any progress, because its buffer is full and no more credit is available.
 
virtual void clear_paths ()
 Silently removes all paths.
 

Protected Member Functions

virtual bool insert_path (unique_path_ptr ptr)
 Inserts ptr to the implementation-specific container.
 
virtual void for_each_path_impl (path_visitor &f)
 Applies f to each path.
 
virtual bool check_paths_impl (path_algorithm algo, path_predicate &pred) const noexcept
 Dispatches the predicate to std::all_of, std::any_of, or std::none_of.
 
virtual void about_to_erase (path_ptr ptr, bool silent, error *reason)
 Emits a regular (reason == nullptr) or irregular (reason != nullptr) shutdown if silent == false. More...
 
template<class Predicate >
bool check_paths (path_algorithm algorithm, Predicate predicate) const noexcept
 Delegates to check_paths_impl.
 

Protected Attributes

stream_managerparent_
 

Detailed Description

Manages downstream communication for a stream_manager.

The downstream manager owns the outbound_path objects, has a buffer for storing pending output and is responsible for the dispatching policy (broadcasting, for example). The default implementation terminates the stream and never accepts any pahts.

Member Function Documentation

◆ about_to_erase()

virtual void caf::downstream_manager::about_to_erase ( path_ptr  ptr,
bool  silent,
error reason 
)
protectedvirtual

Emits a regular (reason == nullptr) or irregular (reason != nullptr) shutdown if silent == false.

Warning
moves *reason if reason == nullptr

◆ add_path()

path_ptr caf::downstream_manager::add_path ( stream_slot  slot,
strong_actor_ptr  target 
)

Adds a pending path to target to the manager.

Returns
The added path on success, nullptr otherwise.

◆ clean()

bool caf::downstream_manager::clean ( stream_slot  slot) const
noexcept

Returns true if slot is unknown or if there is no data pending and all batches are acknowledged on slot.

The default implementation returns false for all paths, even if clean() return true.

◆ close()

virtual void caf::downstream_manager::close ( stream_slot  slot)
virtual

Removes path slot gracefully by sending pending batches before removing it.

Effectively calls path(slot)->closing = true.


The documentation for this class was generated from the following file: