From 1fbf611500260cb78b36abd5cf95feeb211be6bc Mon Sep 17 00:00:00 2001
From: Florian Fischer <florian.fischer@muhq.space>
Date: Fri, 28 Jul 2023 12:12:09 +0200
Subject: add debug output for event ordering

---
 wrms.go | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'wrms.go')

diff --git a/wrms.go b/wrms.go
index c6d6086..04ee732 100644
--- a/wrms.go
+++ b/wrms.go
@@ -138,6 +138,7 @@ func (conn *Connection) serve() {
 			delete(toSend, conn.nextEvent)
 			// We have not received the next event yet -> receive a new event
 		} else {
+			llog.DDebug("%v: Awaiting event %d", conn.Id, conn.nextEvent)
 			select {
 			case ev = <-conn.Events:
 			case <-conn.ctx.Done():
@@ -145,6 +146,7 @@ func (conn *Connection) serve() {
 			}
 			// We received a future object -> store it and continue
 			if ev.Id > conn.nextEvent {
+				llog.DDebug("%v: Received future event %d", conn.Id, ev.Id)
 				toSend[ev.Id] = &ev
 				continue
 			}
-- 
cgit v1.2.3