基于serf的数据库同步模块库
chenshijun
2019-09-04 0495bb9aa85ffd7dfe4ee268c768c423982f8afb
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()
}