Fix node timeout handling in sync.Map traversal

NTHU-LSALAB · Apr 9, 2024 · b93cb64 · b93cb64
1 parent ca318ab
commit b93cb64
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/cmd/opt.go b/cmd/opt.go
@@ -165,9 +165,8 @@ func (nodeList *NodeList) Get() []common.Node {
 	nodeList.nodes.Range(func(k, v interface{}) bool {
 		//If this node has not been updated for a while, delete it
 		if v.(int64)+nodeList.Timeout < time.Now().Unix() {
-			// nodeList.nodes.Delete(k)
-			// nodeList.println("[[Timeout]:", k, "has been deleted]")
-			nodes = append(nodes, k.(common.Node))
+			nodeList.nodes.Delete(k)
+			nodeList.println("[[Timeout]:", k, "has been deleted]")
 		} else {
 			nodes = append(nodes, k.(common.Node))
 		}