You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

97 lines
3.5 KiB

12 years ago
12 years ago
12 years ago
12 years ago
12 years ago
  1. package main
  2. import (
  3. "net/http"
  4. "os"
  5. "runtime"
  6. "strconv"
  7. "strings"
  8. "time"
  9. "github.com/chrislusf/weed-fs/go/glog"
  10. "github.com/chrislusf/weed-fs/go/util"
  11. "github.com/chrislusf/weed-fs/go/weed/weed_server"
  12. "github.com/gorilla/mux"
  13. )
  14. func init() {
  15. cmdMaster.Run = runMaster // break init cycle
  16. }
  17. var cmdMaster = &Command{
  18. UsageLine: "master -port=9333",
  19. Short: "start a master server",
  20. Long: `start a master server to provide volume=>location mapping service
  21. and sequence number of file ids
  22. `,
  23. }
  24. var (
  25. mport = cmdMaster.Flag.Int("port", 9333, "http listen port")
  26. masterIp = cmdMaster.Flag.String("ip", "", "master listening ip address, default to listen on all network interfaces")
  27. masterBindIp = cmdMaster.Flag.String("ip.bind", "0.0.0.0", "ip address to bind to")
  28. mPublicIp = cmdMaster.Flag.String("publicIp", "", "peer accessible <ip>|<server_name>")
  29. metaFolder = cmdMaster.Flag.String("mdir", os.TempDir(), "data directory to store meta data")
  30. masterPeers = cmdMaster.Flag.String("peers", "", "other master nodes in comma separated ip:port list")
  31. volumeSizeLimitMB = cmdMaster.Flag.Uint("volumeSizeLimitMB", 30*1000, "Master stops directing writes to oversized volumes.")
  32. mpulse = cmdMaster.Flag.Int("pulseSeconds", 5, "number of seconds between heartbeats")
  33. confFile = cmdMaster.Flag.String("conf", "/etc/weedfs/weedfs.conf", "xml configuration file")
  34. defaultReplicaPlacement = cmdMaster.Flag.String("defaultReplication", "000", "Default replication type if not specified.")
  35. mTimeout = cmdMaster.Flag.Int("idleTimeout", 10, "connection idle seconds")
  36. mMaxCpu = cmdMaster.Flag.Int("maxCpu", 0, "maximum number of CPUs. 0 means all available CPUs")
  37. garbageThreshold = cmdMaster.Flag.String("garbageThreshold", "0.3", "threshold to vacuum and reclaim spaces")
  38. masterWhiteListOption = cmdMaster.Flag.String("whiteList", "", "comma separated Ip addresses having write permission. No limit if empty.")
  39. masterWhiteList []string
  40. )
  41. func runMaster(cmd *Command, args []string) bool {
  42. if *mMaxCpu < 1 {
  43. *mMaxCpu = runtime.NumCPU()
  44. }
  45. runtime.GOMAXPROCS(*mMaxCpu)
  46. if err := util.TestFolderWritable(*metaFolder); err != nil {
  47. glog.Fatalf("Check Meta Folder (-mdir) Writable %s : %s", *metaFolder, err)
  48. }
  49. if *masterWhiteListOption != "" {
  50. masterWhiteList = strings.Split(*masterWhiteListOption, ",")
  51. }
  52. r := mux.NewRouter()
  53. ms := weed_server.NewMasterServer(r, *mport, *metaFolder,
  54. *volumeSizeLimitMB, *mpulse, *confFile, *defaultReplicaPlacement, *garbageThreshold, masterWhiteList,
  55. )
  56. listeningAddress := *masterBindIp + ":" + strconv.Itoa(*mport)
  57. glog.V(0).Infoln("Start Seaweed Master", util.VERSION, "at", listeningAddress)
  58. listener, e := util.NewListener(listeningAddress, time.Duration(*mTimeout)*time.Second)
  59. if e != nil {
  60. glog.Fatalf(e.Error())
  61. }
  62. go func() {
  63. time.Sleep(100 * time.Millisecond)
  64. if *mPublicIp == "" {
  65. if *masterIp == "" {
  66. *mPublicIp = "localhost"
  67. } else {
  68. *mPublicIp = *masterIp
  69. }
  70. }
  71. myPublicMasterAddress := *mPublicIp + ":" + strconv.Itoa(*mport)
  72. var peers []string
  73. if *masterPeers != "" {
  74. peers = strings.Split(*masterPeers, ",")
  75. }
  76. raftServer := weed_server.NewRaftServer(r, peers, myPublicMasterAddress, *metaFolder, ms.Topo, *mpulse)
  77. ms.SetRaftServer(raftServer)
  78. }()
  79. if e := http.Serve(listener, r); e != nil {
  80. glog.Fatalf("Fail to serve:%s", e.Error())
  81. }
  82. return true
  83. }