seaweedfs/weed/command/master.go

212 lines
7.5 KiB
Go
Raw Normal View History

package command
import (
"github.com/chrislusf/raft/protobuf"
"github.com/gorilla/mux"
"google.golang.org/grpc/reflection"
"net/http"
"os"
"sort"
"strconv"
"strings"
"time"
"github.com/chrislusf/seaweedfs/weed/util/grace"
"github.com/chrislusf/seaweedfs/weed/glog"
2020-03-04 08:39:47 +00:00
"github.com/chrislusf/seaweedfs/weed/pb"
"github.com/chrislusf/seaweedfs/weed/pb/master_pb"
2019-02-18 20:11:52 +00:00
"github.com/chrislusf/seaweedfs/weed/security"
"github.com/chrislusf/seaweedfs/weed/server"
"github.com/chrislusf/seaweedfs/weed/storage/backend"
"github.com/chrislusf/seaweedfs/weed/util"
)
2019-06-23 10:08:27 +00:00
var (
m MasterOptions
)
type MasterOptions struct {
2020-07-14 14:34:16 +00:00
port *int
ip *string
ipBind *string
metaFolder *string
peers *string
volumeSizeLimitMB *uint
volumePreallocate *bool
// pulseSeconds *int
2019-06-23 10:08:27 +00:00
defaultReplication *string
garbageThreshold *float64
whiteList *string
disableHttp *bool
metricsAddress *string
metricsIntervalSec *int
2020-10-03 09:03:41 +00:00
raftResumeState *bool
2019-06-23 10:08:27 +00:00
}
func init() {
2012-09-04 02:18:02 +00:00
cmdMaster.Run = runMaster // break init cycle
2019-06-23 10:08:27 +00:00
m.port = cmdMaster.Flag.Int("port", 9333, "http listen port")
m.ip = cmdMaster.Flag.String("ip", util.DetectedHostAddress(), "master <ip>|<server> address, also used as identifier")
m.ipBind = cmdMaster.Flag.String("ip.bind", "", "ip address to bind to")
2019-06-23 10:08:27 +00:00
m.metaFolder = cmdMaster.Flag.String("mdir", os.TempDir(), "data directory to store meta data")
2020-04-13 19:58:45 +00:00
m.peers = cmdMaster.Flag.String("peers", "", "all master nodes in comma separated ip:port list, example: 127.0.0.1:9093,127.0.0.1:9094,127.0.0.1:9095")
2019-06-23 10:08:27 +00:00
m.volumeSizeLimitMB = cmdMaster.Flag.Uint("volumeSizeLimitMB", 30*1000, "Master stops directing writes to oversized volumes.")
m.volumePreallocate = cmdMaster.Flag.Bool("volumePreallocate", false, "Preallocate disk space for volumes.")
// m.pulseSeconds = cmdMaster.Flag.Int("pulseSeconds", 5, "number of seconds between heartbeats")
2019-06-23 10:08:27 +00:00
m.defaultReplication = cmdMaster.Flag.String("defaultReplication", "000", "Default replication type if not specified.")
m.garbageThreshold = cmdMaster.Flag.Float64("garbageThreshold", 0.3, "threshold to vacuum and reclaim spaces")
m.whiteList = cmdMaster.Flag.String("whiteList", "", "comma separated Ip addresses having write permission. No limit if empty.")
m.disableHttp = cmdMaster.Flag.Bool("disableHttp", false, "disable http requests, only gRPC operations are allowed.")
m.metricsAddress = cmdMaster.Flag.String("metrics.address", "", "Prometheus gateway address <host>:<port>")
2019-06-23 10:08:27 +00:00
m.metricsIntervalSec = cmdMaster.Flag.Int("metrics.intervalSeconds", 15, "Prometheus push interval in seconds")
2020-10-03 17:16:47 +00:00
m.raftResumeState = cmdMaster.Flag.Bool("resumeState", false, "resume previous state on start master server")
}
var cmdMaster = &Command{
2012-09-04 02:18:02 +00:00
UsageLine: "master -port=9333",
Short: "start a master server",
2019-02-10 05:07:12 +00:00
Long: `start a master server to provide volume=>location mapping service and sequence number of file ids
The configuration file "security.toml" is read from ".", "$HOME/.seaweedfs/", "/usr/local/etc/seaweedfs/", or "/etc/seaweedfs/", in that order.
2019-02-10 05:07:12 +00:00
The example security.toml configuration file can be generated by "weed scaffold -config=security"
`,
}
var (
2019-06-23 10:08:27 +00:00
masterCpuProfile = cmdMaster.Flag.String("cpuprofile", "", "cpu profile output file")
masterMemProfile = cmdMaster.Flag.String("memprofile", "", "memory profile output file")
)
func runMaster(cmd *Command, args []string) bool {
2019-02-18 20:11:52 +00:00
util.LoadConfiguration("security", false)
util.LoadConfiguration("master", false)
2019-02-18 20:11:52 +00:00
grace.SetupProfiling(*masterCpuProfile, *masterMemProfile)
2017-06-22 08:33:58 +00:00
parent, _ := util.FullPath(*m.metaFolder).DirAndName()
2020-10-25 03:12:04 +00:00
if util.FileExists(string(parent)) && !util.FileExists(*m.metaFolder) {
os.MkdirAll(*m.metaFolder, 0755)
}
if err := util.TestFolderWritable(util.ResolvePath(*m.metaFolder)); err != nil {
2019-06-23 10:08:27 +00:00
glog.Fatalf("Check Meta Folder (-mdir) Writable %s : %s", *m.metaFolder, err)
}
2019-07-28 08:55:05 +00:00
var masterWhiteList []string
2019-06-23 10:08:27 +00:00
if *m.whiteList != "" {
masterWhiteList = strings.Split(*m.whiteList, ",")
}
2019-06-23 10:08:27 +00:00
if *m.volumeSizeLimitMB > util.VolumeSizeLimitGB*1000 {
glog.Fatalf("volumeSizeLimitMB should be smaller than 30000")
}
2019-07-28 08:55:05 +00:00
startMaster(m, masterWhiteList)
2019-07-28 08:55:05 +00:00
return true
}
2019-07-28 08:55:05 +00:00
func startMaster(masterOption MasterOptions, masterWhiteList []string) {
backend.LoadConfiguration(util.GetViper())
myMasterAddress, peers := checkPeers(*masterOption.ip, *masterOption.port, *masterOption.peers)
2019-07-28 08:55:05 +00:00
r := mux.NewRouter()
ms := weed_server.NewMasterServer(r, masterOption.toMasterOption(masterWhiteList), peers)
2019-07-28 08:55:05 +00:00
listeningAddress := *masterOption.ipBind + ":" + strconv.Itoa(*masterOption.port)
2020-06-02 07:10:35 +00:00
glog.V(0).Infof("Start Seaweed Master %s at %s", util.Version(), listeningAddress)
masterListener, e := util.NewListener(listeningAddress, 0)
if e != nil {
2015-01-14 01:04:41 +00:00
glog.Fatalf("Master startup error: %v", e)
2012-09-28 17:21:06 +00:00
}
2019-07-28 08:55:05 +00:00
// start raftServer
2020-10-02 18:01:20 +00:00
raftServer, err := weed_server.NewRaftServer(security.LoadClientTLS(util.GetViper(), "grpc.master"),
2020-10-24 06:06:44 +00:00
peers, myMasterAddress, util.ResolvePath(*masterOption.metaFolder), ms.Topo, *masterOption.raftResumeState)
2019-07-28 08:55:05 +00:00
if raftServer == nil {
2020-10-02 18:01:20 +00:00
glog.Fatalf("please verify %s is writable, see https://github.com/chrislusf/seaweedfs/issues/717: %s", *masterOption.metaFolder, err)
2019-07-28 08:55:05 +00:00
}
ms.SetRaftServer(raftServer)
r.HandleFunc("/cluster/status", raftServer.StatusHandler).Methods("GET")
// starting grpc server
grpcPort := *masterOption.port + 10000
grpcL, err := util.NewListener(*masterOption.ipBind+":"+strconv.Itoa(grpcPort), 0)
if err != nil {
glog.Fatalf("master failed to listen on grpc port %d: %v", grpcPort, err)
}
2020-03-04 08:39:47 +00:00
grpcS := pb.NewGrpcServer(security.LoadServerTLS(util.GetViper(), "grpc.master"))
2019-07-28 08:55:05 +00:00
master_pb.RegisterSeaweedServer(grpcS, ms)
protobuf.RegisterRaftServer(grpcS, raftServer)
reflection.Register(grpcS)
2020-06-02 07:10:35 +00:00
glog.V(0).Infof("Start Seaweed Master %s grpc server at %s:%d", util.Version(), *masterOption.ipBind, grpcPort)
2019-07-28 08:55:05 +00:00
go grpcS.Serve(grpcL)
2017-01-10 09:01:12 +00:00
go func() {
time.Sleep(1500 * time.Millisecond)
if ms.Topo.RaftServer.Leader() == "" && ms.Topo.RaftServer.IsLogEmpty() && isTheFirstOne(myMasterAddress, peers) {
2020-10-16 18:02:44 +00:00
if ms.MasterClient.FindLeaderFromOtherPeers(myMasterAddress) == "" {
raftServer.DoJoinCommand()
}
}
}()
go ms.MasterClient.KeepConnectedToMaster()
// start http server
2017-01-10 09:01:12 +00:00
httpS := &http.Server{Handler: r}
2019-07-28 08:55:05 +00:00
go httpS.Serve(masterListener)
2017-01-10 09:01:12 +00:00
2019-07-28 08:55:05 +00:00
select {}
}
2018-08-12 21:25:31 +00:00
func checkPeers(masterIp string, masterPort int, peers string) (masterAddress string, cleanedPeers []string) {
2020-04-13 19:58:45 +00:00
glog.V(0).Infof("current: %s:%d peers:%s", masterIp, masterPort, peers)
2018-08-12 21:25:31 +00:00
masterAddress = masterIp + ":" + strconv.Itoa(masterPort)
if peers != "" {
cleanedPeers = strings.Split(peers, ",")
}
hasSelf := false
for _, peer := range cleanedPeers {
if peer == masterAddress {
hasSelf = true
break
}
}
if !hasSelf {
cleanedPeers = append(cleanedPeers, masterAddress)
2018-08-12 21:25:31 +00:00
}
if len(cleanedPeers)%2 == 0 {
2018-08-12 21:25:31 +00:00
glog.Fatalf("Only odd number of masters are supported!")
}
return
}
2019-06-23 10:08:27 +00:00
func isTheFirstOne(self string, peers []string) bool {
sort.Strings(peers)
if len(peers) <= 0 {
return true
}
return self == peers[0]
}
2019-06-23 10:08:27 +00:00
func (m *MasterOptions) toMasterOption(whiteList []string) *weed_server.MasterOption {
return &weed_server.MasterOption{
2020-07-14 14:34:16 +00:00
Host: *m.ip,
Port: *m.port,
MetaFolder: *m.metaFolder,
VolumeSizeLimitMB: *m.volumeSizeLimitMB,
VolumePreallocate: *m.volumePreallocate,
// PulseSeconds: *m.pulseSeconds,
2019-06-23 10:08:27 +00:00
DefaultReplicaPlacement: *m.defaultReplication,
GarbageThreshold: *m.garbageThreshold,
WhiteList: whiteList,
DisableHttp: *m.disableHttp,
MetricsAddress: *m.metricsAddress,
MetricsIntervalSec: *m.metricsIntervalSec,
}
2019-06-23 22:30:16 +00:00
}