Changeset 227 in code for trunk/user.go

Timestamp:

Apr 6, 2020, 4:05:36 PM (5 years ago)

Author:

contact

Message:

Remove per-network ring buffer goroutines

Just dispatch from the user goroutine. This allows removes a lot of complexity.

File:

• trunk/user.go (modified) (2 diffs)

trunk/user.go

@@ -352 +352 @@
         u.forEachDownstream(func(dc *downstreamConn) {
                 if dc.network == nil {
-                        dc.runNetwork(network, false)
+                        consumer, _ := network.ring.NewConsumer(nil)
+                        dc.ringConsumers[network] = consumer
                 }
         })
@@ -376 +377 @@
                                 dc.Close()
                         }
+                        delete(dc.ringConsumers, net)
                 })