Record that `replica` has applied all ops up to and including `hlc`. Monotonic: if the existing watermark for `replica` is already higher, the call is a silent no-op.
(&mut self, replica: ReplicaId, hlc: Hlc)
| 37 | /// Monotonic: if the existing watermark for `replica` is already higher, |
| 38 | /// the call is a silent no-op. |
| 39 | pub fn record(&mut self, replica: ReplicaId, hlc: Hlc) { |
| 40 | let entry = self.acks.entry(replica).or_insert(Hlc::ZERO); |
| 41 | if hlc > *entry { |
| 42 | *entry = hlc; |
| 43 | } |
| 44 | } |
| 45 | |
| 46 | /// Return the ack watermark for a specific replica, if known. |
| 47 | pub fn ack_for(&self, replica: ReplicaId) -> Option<Hlc> { |