Changeset 242 in code for trunk/downstream.go

Timestamp:

Apr 7, 2020, 12:45:08 PM (5 years ago)

Author:

contact

Message:

Make Ring.NewConsumer seq argument mandatory

There's no point in supporting a nil argument anymore.

File:

• trunk/downstream.go (modified) (1 diff)

trunk/downstream.go

@@ -662 +662 @@
 
         dc.forEachNetwork(func(net *network) {
-                var seqPtr *uint64
-                if sendHistory {
-                        seq, ok := net.history[dc.clientName]
-                        if ok {
-                                seqPtr = &seq
-                        }
-                }
-
-                consumer := net.ring.NewConsumer(seqPtr)
+                seq, ok := net.history[dc.clientName]
+                if !sendHistory || !ok {
+                        return
+                }
+
+                consumer := net.ring.NewConsumer(seq)
 
                 // TODO: this means all history is lost when trying to send it while the