修改snapShot的bug

chenshijun

2020-01-15 4d6bafff86a6863450622c96f00661b9eb686b90

 agent.go

@@ -520,8 +520,8 @@
}

//Init serf Init
func Init(clusterID string, password string, nodeID string, addrs []string) (*Agent, error) {
   agent, err := InitNode(clusterID, password, nodeID)
func Init(clusterID string, password string, nodeID string, addrs []string, snapshotPath string) (*Agent, error) {
   agent, err := InitNode(clusterID, password, nodeID, snapshotPath)
   if err != nil {
      //fmt.Printf("InitNode failed, error: %s", err)
      return agent, err
@@ -537,7 +537,7 @@
}

//InitNode web后台收到创建集群的请求，
func InitNode(clusterID string, password string, nodeID string) (*Agent, error) {
func InitNode(clusterID string, password string, nodeID string, snapshotPath string) (*Agent, error) {
   conf := DefaultConfig()
   //fmt.Println("clusterID:", clusterID, "password:", password, "nodeID:", nodeID)
   conf.ClusterID = clusterID
@@ -553,7 +553,7 @@
      }
      conf.EncryptKey = password
   }
   agent, err := Create(conf)
   agent, err := Create(conf, snapshotPath)
   if err != nil {
      //fmt.Printf("create agent failed, error: %s", err)
      return agent, err