mirror of
https://github.com/gravitl/netmaker.git
synced 2026-04-22 16:07:11 +08:00
skip if mutex is not set
This commit is contained in:
+1
-5
@@ -140,11 +140,7 @@ func snapshotNodeTagIDs(n *models.Node) []models.TagID {
|
||||
n.Mutex.Unlock()
|
||||
return out
|
||||
}
|
||||
out := make([]models.TagID, 0, len(n.Tags))
|
||||
for tid := range n.Tags {
|
||||
out = append(out, tid)
|
||||
}
|
||||
return out
|
||||
return nil
|
||||
}
|
||||
|
||||
func AddEgressInfoToPeerByAccess(node, targetNode *models.Node, eli []schema.Egress, acls []models.Acl, isDefaultPolicyActive bool) {
|
||||
|
||||
+1
-1
@@ -78,6 +78,7 @@ func getNodesFromCache() (nodes []models.Node) {
|
||||
nodeCacheMutex.RUnlock()
|
||||
|
||||
nodeCacheMutex.Lock()
|
||||
defer nodeCacheMutex.Unlock()
|
||||
for id, node := range nodesCacheMap {
|
||||
if node.Mutex == nil {
|
||||
node.Mutex = &sync.Mutex{}
|
||||
@@ -88,7 +89,6 @@ func getNodesFromCache() (nodes []models.Node) {
|
||||
for _, node := range nodesCacheMap {
|
||||
nodes = append(nodes, node)
|
||||
}
|
||||
nodeCacheMutex.Unlock()
|
||||
return
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user