Changeset 228 in code for trunk/downstream.go

Timestamp:

Apr 6, 2020, 4:13:46 PM (5 years ago)

Author:

contact

Message:

Remove channel from ring buffer consumers

This is unused.

File:

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

trunk/downstream.go

@@ -695 +695 @@
                 }
 
-                consumer, _ := net.ring.NewConsumer(seqPtr)
-
-                if _, ok := dc.ringConsumers[net]; ok {
-                        panic("network has been added twice")
-                }
+                consumer := net.ring.NewConsumer(seqPtr)
                 dc.ringConsumers[net] = consumer