Changeset 167 in code for trunk/user.go

Timestamp:

Mar 27, 2020, 4:55:03 PM (5 years ago)

Author:

contact

Message:

Add eventDownstreamDisconnected

This should remove the need for protecting user.downstreamConns with a
mutex.

File:

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

trunk/user.go

@@ -21 +21 @@
 
 type eventDownstreamConnected struct {
+        dc *downstreamConn
+}
+
+type eventDownstreamDisconnected struct {
         dc *downstreamConn
 }
@@ -170 +174 @@
                         u.downstreamConns = append(u.downstreamConns, dc)
                         u.lock.Unlock()
+                case eventDownstreamDisconnected:
+                        dc := e.dc
+                        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()
                 case eventDownstreamMessage:
                         msg, dc := e.msg, e.dc
@@ -190 +204 @@
 }
 
-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) {
         if net.ID != 0 {