diff options
| author | Florian Fischer <florian.fischer@muhq.space> | 2023-07-28 12:12:09 +0200 |
|---|---|---|
| committer | Florian Fischer <florian.fischer@muhq.space> | 2023-07-28 12:12:09 +0200 |
| commit | 1fbf611500260cb78b36abd5cf95feeb211be6bc (patch) | |
| tree | fefdcda7017336da59092bdaa8ff6e2c01f06cc5 | |
| parent | 7d097ff3d18159907698e6af9be5f8ed8bc79cd9 (diff) | |
| download | WRMS-1fbf611500260cb78b36abd5cf95feeb211be6bc.tar.gz WRMS-1fbf611500260cb78b36abd5cf95feeb211be6bc.zip | |
add debug output for event ordering
| -rw-r--r-- | wrms.go | 2 |
1 files changed, 2 insertions, 0 deletions
@@ -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 } |
