diff --git a/core/http/views/p2p.html b/core/http/views/p2p.html index 34257e897848..dc8c0177d730 100644 --- a/core/http/views/p2p.html +++ b/core/http/views/p2p.html @@ -10,7 +10,9 @@
Total Workers Detected: {{ len .Nodes}}
diff --git a/core/p2p/p2p.go b/core/p2p/p2p.go index e86b5fba6cd1..96db593189fa 100644 --- a/core/p2p/p2p.go +++ b/core/p2p/p2p.go @@ -166,7 +166,7 @@ func LLamaCPPRPCServerDiscoverer(ctx context.Context, token string) error { AddNode(tunnel) var tunnelAddresses []string - for _, v := range nodes { + for _, v := range GetAvailableNodes() { if v.IsOnline() { tunnelAddresses = append(tunnelAddresses, v.TunnelAddress) } else { @@ -237,7 +237,9 @@ func discoveryTunnels(ctx context.Context, token string) (chan NodeData, error) } ensureService(ctx, n, nd, k) muservice.Lock() - tunnels <- service[nd.Name].NodeData + if _, ok := service[nd.Name]; ok { + tunnels <- service[nd.Name].NodeData + } muservice.Unlock() } }