From 164c94a4d82ccad8277b1c2dcb32943102d846aa Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期六, 12 十月 2019 10:15:27 +0800
Subject: [PATCH] 修改SnapshotPath为配置文件可配

---
 config.go |   10 +++++++---
 1 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/config.go b/config.go
index 14f4453..68a158b 100644
--- a/config.go
+++ b/config.go
@@ -20,7 +20,6 @@
 	"fmt"
 	"net"
 	"strconv"
-
 	//"github.com/apache/servicecomb-service-center/syncer/pkg/utils"
 	"github.com/hashicorp/memberlist"
 	"github.com/hashicorp/serf/cmd/serf/command/agent"
@@ -46,7 +45,7 @@
 	MaxQuerySize       = 50 * 1024 * 1024
 	MaxUserEventSize   = 5 * 1024
 	ReplayOnJoinDefault = false
-	SnapshotPathDefault = "/opt/vasystem/serfSnapShot"
+	SnapshotPathDefault = "./serfSnapShot"
 	MaxEventBufferCount = 2048
 
 	TcpTransportPort = 30194 //tcp浼犺緭澶ф暟鎹噺鎺ュ彛
@@ -90,7 +89,7 @@
 }
 
 // convertToSerf convert Config to serf.Config
-func (c *Config) convertToSerf() (*serf.Config, error) {
+func (c *Config) convertToSerf(snapshotPath string) (*serf.Config, error) {
 	serfConf := serf.DefaultConfig()
 
 	bindIP, bindPort, err := SplitHostPort(c.BindAddr, DefaultBindPort)
@@ -123,7 +122,12 @@
 	if c.Mode == ModeCluster && c.RetryMaxAttempts <= 0 {
 		c.RetryMaxAttempts = retryMaxAttempts
 	}
+
 	c.SnapshotPath = SnapshotPathDefault
+	if snapshotPath != "" {
+		c.SnapshotPath = snapshotPath
+	}
+
 	c.ReplayOnJoin = ReplayOnJoinDefault
 
 	serfConf.QueryResponseSizeLimit = c.QueryResponseSizeLimit

--
Gitblit v1.8.0