修改snapShot的bug

chenshijun

2020-01-15 4d6bafff86a6863450622c96f00661b9eb686b90

修改snapShot的bug

 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

 agent_test.go

@@ -28,7 +28,7 @@
    conf := DefaultConfig()
    conf.ClusterID = "testCluster"
    conf.NodeName = "testnode"
    agent, err := Create(conf)
    agent, err := Create(conf, "")
    if err != nil {
        t.Errorf("create agent failed, error: %s", err)
    }