add default tag

zhangzengfei

2023-05-15 12f52d5835388f22fdecb2a890d58e5425688c8e

 searcher.go

@@ -2,7 +2,7 @@

import (
   "encoding/json"
   "fmt"
   "basic.com/valib/logger.git"
   "time"

   "github.com/hashicorp/memberlist"
@@ -57,7 +57,7 @@
   if err:= json.Unmarshal(b, &n);err ==nil {
      members[n.NodeID] = n
   } else {
      fmt.Println("NotifyMsg msg unmarshal err")
      logger.Error("NotifyMsg msg unmarshal err")
   }
}

@@ -70,14 +70,15 @@
   node := nodeInfo{}
   if err := json.Unmarshal(b, &node); err != nil {

      fmt.Println("Umarshal failed:", err)
      logger.Error("Umarshal failed:", err)
      return
   }

   fmt.Println(node)
   logger.Info(node)
}

func CreateSearchNode(key string) (*memberlist.Memberlist, error) {
   members = make(map[string]NodeInfo,0)
   conf := memberlist.DefaultLocalConfig()
   conf.Events = &eventDelegate{}
   conf.Delegate = &delegate{}
@@ -87,7 +88,7 @@

   keyring, err := memberlist.NewKeyring(nil, []byte(key))
   if err != nil {
      fmt.Printf("Failed to restore keyring: %s", err)
      logger.Error("Failed to restore keyring: %s", err)
      return nil, err
   }
   conf.Keyring = keyring
@@ -98,7 +99,7 @@
func CreateSearchNodeWhitClose(key string, delay time.Duration) map[string]NodeInfo {
   m, err := CreateSearchNode(key)
   if err == nil {
      // fmt.Printf("Local member %s:%d\n", m.LocalNode().Addr, m.LocalNode().Port)
      //logger.Info("Local member %s:%d\n", m.LocalNode().Addr, m.LocalNode().Port)
      time.Sleep(delay)

      m.Shutdown()