Changeset 39 in code for trunk/server.go

Timestamp:

Feb 7, 2020, 10:46:44 AM (5 years ago)

Author:

contact

Message:

Add user.forEachUpstream

File:

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

trunk/server.go

@@ -38 +38 @@
         lock          sync.Mutex
         upstreamConns []*upstreamConn
+}
+
+func (u *user) forEachUpstream(f func(uc *upstreamConn)) {
+        u.lock.Lock()
+        for _, uc := range u.upstreamConns {
+                if !uc.registered {
+                        continue
+                }
+                f(uc)
+        }
+        u.lock.Unlock()
 }