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.

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: