Chris Lu
3 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with
10 additions and
8 deletions
-
weed/command/filer.go
-
weed/command/master.go
-
weed/command/master_follower.go
|
|
@ -13,7 +13,7 @@ import ( |
|
|
|
"github.com/chrislusf/seaweedfs/weed/pb" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/security" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/server" |
|
|
|
weed_server "github.com/chrislusf/seaweedfs/weed/server" |
|
|
|
stats_collect "github.com/chrislusf/seaweedfs/weed/stats" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/util" |
|
|
|
) |
|
|
@ -103,6 +103,7 @@ func init() { |
|
|
|
|
|
|
|
// start iam on filer
|
|
|
|
filerStartIam = cmdFiler.Flag.Bool("iam", false, "whether to start IAM service") |
|
|
|
filerIamOptions.ip = f.ip |
|
|
|
filerIamOptions.port = cmdFiler.Flag.Int("iam.port", 8111, "iam server http listen port") |
|
|
|
} |
|
|
|
|
|
|
|
|
|
@ -127,7 +127,7 @@ func startMaster(masterOption MasterOptions, masterWhiteList []string) { |
|
|
|
*masterOption.portGrpc = 10000 + *masterOption.port |
|
|
|
} |
|
|
|
if *masterOption.ipBind == "" { |
|
|
|
*masterOption.ipBind = "localhost" |
|
|
|
*masterOption.ipBind = *masterOption.ip |
|
|
|
} |
|
|
|
|
|
|
|
myMasterAddress, peers := checkPeers(*masterOption.ip, *masterOption.port, *masterOption.portGrpc, *masterOption.peers) |
|
|
|
|
|
@ -3,17 +3,18 @@ package command |
|
|
|
import ( |
|
|
|
"context" |
|
|
|
"fmt" |
|
|
|
"net/http" |
|
|
|
"time" |
|
|
|
|
|
|
|
"github.com/aws/aws-sdk-go/aws" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/glog" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/pb" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/pb/master_pb" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/security" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/server" |
|
|
|
weed_server "github.com/chrislusf/seaweedfs/weed/server" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/util" |
|
|
|
"github.com/gorilla/mux" |
|
|
|
"google.golang.org/grpc/reflection" |
|
|
|
"net/http" |
|
|
|
"time" |
|
|
|
) |
|
|
|
|
|
|
|
var ( |
|
|
@ -112,7 +113,7 @@ func startMasterFollower(masterOptions MasterOptions) { |
|
|
|
option.IsFollower = true |
|
|
|
|
|
|
|
if *masterOptions.ipBind == "" { |
|
|
|
*masterOptions.ipBind = "localhost" |
|
|
|
*masterOptions.ipBind = *masterOptions.ip |
|
|
|
} |
|
|
|
|
|
|
|
r := mux.NewRouter() |
|
|
|