libcaf  0.15.5
Public Types | Public Member Functions | Static Public Member Functions | Public Attributes | Static Public Attributes | List of all members
caf::inbound_path Class Reference

State for a path to an upstream actor (source). More...

#include <inbound_path.hpp>

Public Types

using regular_shutdown = stream_msg::drop
 Message type for propagating graceful shutdowns.
 
using irregular_shutdown = stream_msg::forced_drop
 Message type for propagating errors.
 

Public Member Functions

 inbound_path (local_actor *selfptr, const stream_id &id, strong_actor_ptr ptr)
 Constructs a path for given handle and stream ID.
 
void handle_batch (long batch_size, int64_t batch_id)
 Updates last_batch_id and assigned_credit.
 
void emit_ack_open (actor_addr rebind_from, long initial_demand, bool is_redeployable)
 Emits a stream_msg::ack_batch on this path and sets assigned_credit to initial_demand. More...
 
void emit_ack_batch (long new_demand)
 

Static Public Member Functions

static void emit_irregular_shutdown (local_actor *self, const stream_id &sid, const strong_actor_ptr &hdl, error reason)
 

Public Attributes

local_actor * self
 Pointer to the parent actor.
 
stream_id sid
 Stream ID used on this source.
 
strong_actor_ptr hdl
 Handle to the source.
 
stream_priority prio
 Priority of incoming batches from this source.
 
int64_t last_acked_batch_id
 ID of the last acknowledged batch ID.
 
int64_t last_batch_id
 ID of the last received batch.
 
long assigned_credit
 Amount of credit we have signaled upstream.
 
bool redeployable
 Stores whether the source actor is failsafe, i.e., allows the runtime to redeploy it on failure. More...
 
error shutdown_reason
 Stores whether an error occurred during stream processing. More...
 

Static Public Attributes

static constexpr const auto aborter_type = stream_aborter::source_aborter
 Stream aborter flag to monitor a path.
 

Detailed Description

State for a path to an upstream actor (source).

Member Function Documentation

void caf::inbound_path::emit_ack_open ( actor_addr  rebind_from,
long  initial_demand,
bool  is_redeployable 
)

Emits a stream_msg::ack_batch on this path and sets assigned_credit to initial_demand.

Member Data Documentation

bool caf::inbound_path::redeployable

Stores whether the source actor is failsafe, i.e., allows the runtime to redeploy it on failure.

error caf::inbound_path::shutdown_reason

Stores whether an error occurred during stream processing.

Configures whether the destructor sends close or forced_close messages.


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