no business

liuxiaolong

2021-05-31 d70649cfb61e64fabce40199ad1d53d6a4973f0e

 config.go

@@ -19,11 +19,14 @@
import (
   "fmt"
   "net"
   "os"
   "strconv"
   "strings"

   //"github.com/apache/servicecomb-service-center/syncer/pkg/utils"
   "github.com/hashicorp/memberlist"
   "github.com/hashicorp/serf/cmd/serf/command/agent"
   "github.com/hashicorp/serf/serf"
   "basic.com/valib/serf.git/cmd/serf/command/agent"
   "basic.com/valib/serf.git/serf"
)

const (
@@ -47,8 +50,6 @@
   ReplayOnJoinDefault = false
   SnapshotPathDefault = "./serfSnapShot"
   MaxEventBufferCount = 2048

   TcpTransportPort = 30194 //tcp传输大数据量接口
)

// DefaultConfig default config
@@ -70,14 +71,14 @@
type Config struct {
   // config from serf agent
   *agent.Config
   Mode string `json:"mode"`
   Mode       string       `json:"mode"`

   // name to group members into cluster
   ClusterID string `json:"cluster_name"`
   ClusterID    string       `json:"cluster_name"`

   // port to communicate between cluster members
   ClusterPort int `yaml:"cluster_port"`
   RPCPort     int `yaml:"-"`
   ClusterPort int       `yaml:"cluster_port"`
   RPCPort     int       `yaml:"-"`
}

// readConfigFile reads configuration from config file
@@ -86,6 +87,28 @@
      // todo:
   }
   return nil
}

func isFileRightful(filePath string) bool {
   if filePath != "" {
      _, err := os.Stat(filePath)
      if err != nil && os.IsNotExist(err) {
         pos := strings.LastIndex(filePath, "/")
         if pos != -1 {
            filePath = filePath[0:pos]
         }

         _, err = os.Stat(filePath)
         if err == nil || !os.IsNotExist(err) {
            return true
         } else {
            return false
         }
      } else {
         return false
      }
   }
   return false
}

// convertToSerf convert Config to serf.Config
@@ -124,7 +147,7 @@
   }

   c.SnapshotPath = SnapshotPathDefault
   if snapshotPath != "" {
   if isFileRightful(snapshotPath) {
      c.SnapshotPath = snapshotPath
   }