From a0c23fcec45d18efe14ba03128a976e1fc1b0f21 Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期六, 12 十月 2019 10:15:37 +0800
Subject: [PATCH] Merge branch 'master' of ssh://192.168.1.14:29418/syncdb
---
config.go | 12 ++++++++----
1 files changed, 8 insertions(+), 4 deletions(-)
diff --git a/config.go b/config.go
index bcb6446..79b07a5 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"
@@ -44,9 +43,9 @@
BroadcastInterval = 5
MaxQueryRespSize = 50 * 1024 * 1024
MaxQuerySize = 50 * 1024 * 1024
- MaxUserEventSize = 500 * 1024
+ MaxUserEventSize = 9 * 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