Changeset 138 in code for trunk

Timestamp:

Mar 24, 2020, 8:22:40 AM (5 years ago)

Author:

contact

Message:

Add more details to ring buffer panics

File:

• trunk/ring.go (modified) (3 diffs)

trunk/ring.go

@@ -2 +2 @@
 
 import (
+        "fmt"
         "sync"
 
@@ -87 +88 @@
 func (rc *RingConsumer) diff() uint64 {
         if rc.cur > rc.ring.cur {
-                panic("soju: consumer cursor greater than producer cursor")
+                panic(fmt.Sprintf("soju: consumer cursor (%v) greater than producer cursor (%v)", rc.cur, rc.ring.cur))
         }
         return rc.ring.cur - rc.cur
@@ -113 +114 @@
         msg := rc.ring.buffer[i]
         if msg == nil {
-                panic("soju: unexpected nil ring buffer entry")
+                panic(fmt.Sprintf("soju: unexpected nil ring buffer entry at index %v", i))
         }
         return msg