Commit 97ba6743 authored by Dominik Charousset's avatar Dominik Charousset

Allow streams to keep track of last seen ACK IDs

parent d6e09d4b
......@@ -50,6 +50,10 @@ public:
/// `unacknowledged_batches` is unused.
bool redeployable;
/// Next expected batch ID to be acknowledged. Actors can receive a more
/// advanced batch ID in an ACK message, since CAF uses accumulative ACKs.
int64_t next_ack_id;
/// Caches batches until receiving an ACK.
std::deque<std::pair<int64_t, stream_msg::batch>> unacknowledged_batches;
......
......@@ -25,7 +25,8 @@ downstream_path::downstream_path(strong_actor_ptr p, bool redeploy)
: hdl(std::move(p)),
next_batch_id(0),
open_credit(0),
redeployable(redeploy) {
redeployable(redeploy),
next_ack_id(0) {
// nop
}
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment