Browse Source

add debug logs to removing host from network

abhishek9686 1 year ago
parent
commit
0dae81438f
2 changed files with 12 additions and 7 deletions
  1. 6 6
      logic/hosts.go
  2. 6 1
      logic/nodes.go

+ 6 - 6
logic/hosts.go

@@ -411,16 +411,16 @@ func DissasociateNodeFromHost(n *models.Node, h *models.Host) error {
 	logger.Log(0, "Hereeeee-----> 4.7.3")
 	logger.Log(0, "Hereeeee-----> 4.7.3")
 	go func() {
 	go func() {
 		if servercfg.IsPro {
 		if servercfg.IsPro {
-			logger.Log(0, "Hereeeee-----> 4.7.3.1")
+			//logger.Log(0, "Hereeeee-----> 4.7.3.1")
 			if clients, err := GetNetworkExtClients(n.Network); err != nil {
 			if clients, err := GetNetworkExtClients(n.Network); err != nil {
-				logger.Log(0, "Hereeeee-----> 4.7.3.2")
+				//logger.Log(0, "Hereeeee-----> 4.7.3.2")
 				for i := range clients {
 				for i := range clients {
 					AllowClientNodeAccess(&clients[i], n.ID.String())
 					AllowClientNodeAccess(&clients[i], n.ID.String())
-					logger.Log(0, "Hereeeee-----> 4.7.3.3")
+					//logger.Log(0, "Hereeeee-----> 4.7.3.3")
 				}
 				}
-				logger.Log(0, "Hereeeee-----> 4.7.3.4")
+				//logger.Log(0, "Hereeeee-----> 4.7.3.4")
 			}
 			}
-			logger.Log(0, "Hereeeee-----> 4.7.3.5")
+			//logger.Log(0, "Hereeeee-----> 4.7.3.5")
 
 
 		}
 		}
 	}()
 	}()
@@ -428,7 +428,7 @@ func DissasociateNodeFromHost(n *models.Node, h *models.Host) error {
 	if err := DeleteNodeByID(n); err != nil {
 	if err := DeleteNodeByID(n); err != nil {
 		return err
 		return err
 	}
 	}
-
+	logger.Log(0, "Hereeeee-----> 4.7.5")
 	return UpsertHost(h)
 	return UpsertHost(h)
 }
 }
 
 

+ 6 - 1
logic/nodes.go

@@ -287,27 +287,32 @@ func GetNodeByHostRef(hostid, network string) (node models.Node, err error) {
 func DeleteNodeByID(node *models.Node) error {
 func DeleteNodeByID(node *models.Node) error {
 	var err error
 	var err error
 	var key = node.ID.String()
 	var key = node.ID.String()
-
+	logger.Log(0, "Hereeeee-----> 4.7.4.1")
 	if err = database.DeleteRecord(database.NODES_TABLE_NAME, key); err != nil {
 	if err = database.DeleteRecord(database.NODES_TABLE_NAME, key); err != nil {
 		if !database.IsEmptyRecord(err) {
 		if !database.IsEmptyRecord(err) {
 			return err
 			return err
 		}
 		}
 	}
 	}
+	logger.Log(0, "Hereeeee-----> 4.7.4.2")
 	if servercfg.CacheEnabled() {
 	if servercfg.CacheEnabled() {
 		deleteNodeFromCache(node.ID.String())
 		deleteNodeFromCache(node.ID.String())
 	}
 	}
+	logger.Log(0, "Hereeeee-----> 4.7.4.3")
 	if servercfg.IsDNSMode() {
 	if servercfg.IsDNSMode() {
 		SetDNS()
 		SetDNS()
 	}
 	}
+	logger.Log(0, "Hereeeee-----> 4.7.4.4")
 	_, err = nodeacls.RemoveNodeACL(nodeacls.NetworkID(node.Network), nodeacls.NodeID(node.ID.String()))
 	_, err = nodeacls.RemoveNodeACL(nodeacls.NetworkID(node.Network), nodeacls.NodeID(node.ID.String()))
 	if err != nil {
 	if err != nil {
 		// ignoring for now, could hit a nil pointer if delete called twice
 		// ignoring for now, could hit a nil pointer if delete called twice
 		logger.Log(2, "attempted to remove node ACL for node", node.ID.String())
 		logger.Log(2, "attempted to remove node ACL for node", node.ID.String())
 	}
 	}
+	logger.Log(0, "Hereeeee-----> 4.7.4.5")
 	// removeZombie <- node.ID
 	// removeZombie <- node.ID
 	if err = DeleteMetrics(node.ID.String()); err != nil {
 	if err = DeleteMetrics(node.ID.String()); err != nil {
 		logger.Log(1, "unable to remove metrics from DB for node", node.ID.String(), err.Error())
 		logger.Log(1, "unable to remove metrics from DB for node", node.ID.String(), err.Error())
 	}
 	}
+	logger.Log(0, "Hereeeee-----> 4.7.4.6")
 	return nil
 	return nil
 }
 }