aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-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
}