|
|
| inbound_path (stream_manager_ptr mgr_ptr, stream_slots id, strong_actor_ptr ptr, rtti_pair input_type) |
| | Constructs a path for given handle and stream ID.
|
| |
|
void | handle (downstream_msg::batch &x) |
| | Updates last_batch_id and assigned_credit before dispatching to the manager.
|
| |
|
template<class T > |
| void | handle (T &x) |
| | Dispatches any downstream_msg other than batch directly to the manager.
|
| |
|
void | emit_ack_open (local_actor *self, actor_addr rebind_from) |
| | Emits an upstream_msg::ack_batch.
|
| |
| void | emit_ack_batch (local_actor *self, int32_t queued_items, actor_clock::time_point now, timespan cycle, timespan desired_batch_complexity) |
| | Sends an upstream_msg::ack_batch for granting new credit.
|
| |
|
bool | up_to_date () |
| | Returns whether the path received no input since last emitting ack_batch, i.e., last_acked_batch_id == last_batch_id.
|
| |
|
void | emit_regular_shutdown (local_actor *self) |
| | Sends an upstream_msg::drop on this path.
|
| |
|
void | emit_irregular_shutdown (local_actor *self, error reason) |
| | Sends an upstream_msg::forced_drop on this path.
|
| |
|
|
stream_manager_ptr | mgr |
| | Points to the manager responsible for incoming traffic.
|
| |
|
strong_actor_ptr | hdl |
| | Handle to the source.
|
| |
|
stream_slots | slots |
| | Stores slot IDs for sender (hdl) and receiver (self).
|
| |
|
int32_t | desired_batch_size |
| | Stores the last computed desired batch size.
|
| |
|
int32_t | assigned_credit |
| | Amount of credit we have signaled upstream.
|
| |
|
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.
|
| |
|
stats_t | stats |
| | Summarizes how many elements we processed during the last cycle and how much time we spent processing those elements.
|
| |
|
actor_clock::time_point | last_credit_decision |
| | Stores the time point of the last credit decision for this source.
|
| |
|
actor_clock::time_point | next_credit_decision |
| | Stores the time point of the last credit decision for this source.
|
| |
State for a path to an upstream actor (source).
