aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFlorian Fischer <florian.fischer@muhq.space>2023-07-28 12:12:09 +0200
committerFlorian Fischer <florian.fischer@muhq.space>2023-07-28 12:12:09 +0200
commit1fbf611500260cb78b36abd5cf95feeb211be6bc (patch)
treefefdcda7017336da59092bdaa8ff6e2c01f06cc5
parent7d097ff3d18159907698e6af9be5f8ed8bc79cd9 (diff)
downloadWRMS-1fbf611500260cb78b36abd5cf95feeb211be6bc.tar.gz
WRMS-1fbf611500260cb78b36abd5cf95feeb211be6bc.zip
add debug output for event ordering
-rw-r--r--wrms.go2
1 files changed, 2 insertions, 0 deletions
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
}