Changeset 204 in code for trunk/user.go

Timestamp:

Apr 1, 2020, 2:02:31 PM (5 years ago)

Author:

contact

Message:

Simplify ring consumer goroutine

Since network.history is now only accessed from the user goroutine, a
lock becomes unnecessary.

File:

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

trunk/user.go

@@ -42 +42 @@
         stopped chan struct{}
 
-        lock    sync.Mutex
-        conn    *upstreamConn
         history map[string]uint64
+
+        lock sync.Mutex
+        conn *upstreamConn
 }
 
@@ -236 +237 @@
                 case eventDownstreamDisconnected:
                         dc := e.dc
+
+                        for net, rc := range dc.ringConsumers {
+                                seq := rc.Close()
+                                net.history[dc.clientName] = seq
+                        }
+
                         for i := range u.downstreamConns {
                                 if u.downstreamConns[i] == dc {