Changeset 40 in code for trunk/server.go

Timestamp:

Feb 7, 2020, 10:56:36 AM (5 years ago)

Author:

contact

Message:

Add user.forEachDownstream

File:

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

trunk/server.go

@@ -36 +36 @@
         srv      *Server
 
-        lock          sync.Mutex
-        upstreamConns []*upstreamConn
+        lock            sync.Mutex
+        upstreamConns   []*upstreamConn
+        downstreamConns []*downstreamConn
 }
 
@@ -47 +48 @@
                 }
                 f(uc)
+        }
+        u.lock.Unlock()
+}
+
+func (u *user) forEachDownstream(f func(dc *downstreamConn)) {
+        u.lock.Lock()
+        for _, dc := range u.downstreamConns {
+                f(dc)
         }
         u.lock.Unlock()