searcher.go
@@ -54,7 +54,7 @@ func (d *delegate) NotifyMsg(b []byte) { // logMsg(b) n := NodeInfo{} if err:= json.Unmarshal(b, &n);err !=nil { if err:= json.Unmarshal(b, &n);err ==nil { members[n.NodeID] = n } else { fmt.Println("NotifyMsg msg unmarshal err") @@ -102,11 +102,14 @@ time.Sleep(delay) m.Shutdown() fmt.Println("CreateSearchNodeWhitClose after ",delay,",shutdown success") } return members } func CloseSearchNode(m *memberlist.Memberlist) error { fmt.Println("CloseSearchNode") defer fmt.Println("ShutDown done") return m.Shutdown() }