Changeset 137 in code for trunk/user.go

Timestamp:

Mar 23, 2020, 3:05:00 PM (5 years ago)

Author:

contact

Message:

Add user.{add,remove}Downstream

File:

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

trunk/user.go

@@ -177 +177 @@
 }
 
+func (u *user) addDownstream(dc *downstreamConn) (first bool) {
+        u.lock.Lock()
+        first = len(dc.user.downstreamConns) == 0
+        u.downstreamConns = append(u.downstreamConns, dc)
+        u.lock.Unlock()
+        return first
+}
+
+func (u *user) removeDownstream(dc *downstreamConn) {
+        u.lock.Lock()
+        for i := range u.downstreamConns {
+                if u.downstreamConns[i] == dc {
+                        u.downstreamConns = append(u.downstreamConns[:i], u.downstreamConns[i+1:]...)
+                        break
+                }
+        }
+        u.lock.Unlock()
+}
+
 func (u *user) createNetwork(net *Network) (*network, error) {
         network := newNetwork(u, net)