Skip to content

Instantly share code, notes, and snippets.

@slfritchie
Created November 8, 2019 03:31
Show Gist options
  • Save slfritchie/652d3765e0fb4cd6ad59b55899014f81 to your computer and use it in GitHub Desktop.
Save slfritchie/652d3765e0fb4cd6ad59b55899014f81 to your computer and use it in GitHub Desktop.
diff --git a/lib/wallaroo/core/boundary/boundary.pony b/lib/wallaroo/core/boundary/boundary.pony
index 6c947cbd3..46778acfd 100644
--- a/lib/wallaroo/core/boundary/boundary.pony
+++ b/lib/wallaroo/core/boundary/boundary.pony
@@ -352,6 +352,9 @@ actor OutgoingBoundary is (Consumer & TCPActor)
fun ref receive_ack(acked_seq_id: SeqId) =>
ifdef debug then
+ if not (acked_seq_id > _lowest_queue_id) then
+ @printf[I32]("BUMMER: receive_ack: acked_seq_id %s _lowest_queue_id %s\n".cstring(), acked_seq_id.string().cstring(), _lowest_queue_id.string().cstring()) /////// SLF TODO NEW BUG, make new GH ticket?
+ end
Invariant(acked_seq_id > _lowest_queue_id)
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment