Changeset 30 in code for trunk/downstream.go

Timestamp:

Feb 6, 2020, 9:29:24 PM (5 years ago)

Author:

contact

Message:

Send channel info to downstream on registration

File:

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

trunk/downstream.go

@@ -198 +198 @@
         })
 
+        c.srv.lock.Lock()
+        for _, uc := range c.srv.upstreamConns {
+                // TODO: fix races accessing upstream connection data
+                if !uc.registered {
+                        continue
+                }
+                for _, ch := range uc.channels {
+                        if ch.complete {
+                                forwardChannel(c, ch)
+                        }
+                }
+        }
+        c.srv.lock.Unlock()
+
         return nil
 }