diff options
| author | Chris Lu <chris.lu@gmail.com> | 2013-12-09 13:34:05 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2013-12-09 13:34:05 -0800 |
| commit | da9abc2a930be0107268fe1236200616642f56c2 (patch) | |
| tree | 93f3da7f1c7e21369eed29e7f5fea986cbdb1cb3 /go/weed/server.go | |
| parent | 11e91bd5497fe5f97392119d5680a7a1b934c2a7 (diff) | |
| download | seaweedfs-da9abc2a930be0107268fe1236200616642f56c2.tar.xz seaweedfs-da9abc2a930be0107268fe1236200616642f56c2.zip | |
a start for distributed master support, not working yet
Diffstat (limited to 'go/weed/server.go')
| -rw-r--r-- | go/weed/server.go | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/go/weed/server.go b/go/weed/server.go index f4752992b..ade040b15 100644 --- a/go/weed/server.go +++ b/go/weed/server.go @@ -41,7 +41,7 @@ var ( serverDataCenter = cmdServer.Flag.String("dataCenter", "", "current volume server's data center name") serverRack = cmdServer.Flag.String("rack", "", "current volume server's rack name") serverWhiteListOption = cmdServer.Flag.String("whiteList", "", "comma separated Ip addresses having write permission. No limit if empty.") - serverMembers = cmdServer.Flag.String("members", "", "comma separated ip:masterPort list") + serverPeers = cmdServer.Flag.String("peers", "", "comma separated ip:masterPort list") masterPort = cmdServer.Flag.Int("masterPort", 9333, "master server http listen port") masterMetaFolder = cmdServer.Flag.String("mdir", os.TempDir(), "data directory to store meta data") masterVolumeSizeLimitMB = cmdServer.Flag.Uint("volumeSizeLimitMB", 32*1024, "Default Volume Size in MegaBytes") @@ -107,11 +107,11 @@ func runServer(cmd *Command, args []string) bool { go func() { time.Sleep(100 * time.Millisecond) - var members []string - if *serverMembers != "" { - members = strings.Split(*serverMembers, ",") + var peers []string + if *serverPeers != "" { + peers = strings.Split(*serverPeers, ",") } - weed_server.NewRaftServer(r, VERSION, members, *serverIp+":"+strconv.Itoa(*masterPort), *masterMetaFolder) + weed_server.NewRaftServer(r, VERSION, peers, *serverIp+":"+strconv.Itoa(*masterPort), *masterMetaFolder) }() e := masterServer.ListenAndServe() |