Changeset 144 in code for trunk/user.go

Timestamp:

Mar 25, 2020, 10:28:25 AM (5 years ago)

Author:

contact

Message:

Consume ring buffer for networks added on-the-fly

File:

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

trunk/user.go

@@ -199 +199 @@
 
 func (u *user) createNetwork(net *Network) (*network, error) {
+        if net.ID != 0 {
+                panic("tried creating an already-existing network")
+        }
+
         network := newNetwork(u, net)
         err := u.srv.db.StoreNetwork(u.Username, &network.Network)
@@ -204 +208 @@
                 return nil, err
         }
+
+        u.forEachDownstream(func(dc *downstreamConn) {
+                if dc.network == nil {
+                        dc.runNetwork(network, false)
+                }
+        })
+
         u.lock.Lock()
         u.networks = append(u.networks, network)
         u.lock.Unlock()
+
         go network.run()
         return network, nil