Browse Source

add additional mutex lock on node acls func

abhishek9686 1 year ago
parent
commit
5325f0e7d7
1 changed files with 5 additions and 0 deletions
  1. 5 0
      logic/acls/nodeacls/retrieve.go

+ 5 - 0
logic/acls/nodeacls/retrieve.go

@@ -3,12 +3,17 @@ package nodeacls
 import (
 	"encoding/json"
 	"fmt"
+	"sync"
 
 	"github.com/gravitl/netmaker/logic/acls"
 )
 
+var NodesAllowedACLMutex = &sync.Mutex{}
+
 // AreNodesAllowed - checks if nodes are allowed to communicate in their network ACL
 func AreNodesAllowed(networkID NetworkID, node1, node2 NodeID) bool {
+	NodesAllowedACLMutex.Lock()
+	defer NodesAllowedACLMutex.Unlock()
 	var currentNetworkACL, err = FetchAllACLs(networkID)
 	if err != nil {
 		return false