diff --git a/weed/command/master_follower.go b/weed/command/master_follower.go index 949743b3e..b628f7abf 100644 --- a/weed/command/master_follower.go +++ b/weed/command/master_follower.go @@ -109,11 +109,9 @@ func startMasterFollower(masterOptions MasterOptions) { return } - option := masterOptions.toMasterOption(nil) option.IsFollower = true - r := mux.NewRouter() ms := weed_server.NewMasterServer(r, option, masters) listeningAddress := *masterOptions.ipBind + ":" + strconv.Itoa(*masterOptions.port) diff --git a/weed/replication/source/filer_source.go b/weed/replication/source/filer_source.go index 085c0a700..60c33463f 100644 --- a/weed/replication/source/filer_source.go +++ b/weed/replication/source/filer_source.go @@ -96,7 +96,7 @@ func (fs *FilerSource) LookupFileId(part string) (fileUrls []string, err error) func (fs *FilerSource) ReadPart(fileId string) (filename string, header http.Header, resp *http.Response, err error) { if fs.proxyByFiler { - return util.DownloadFile("http://" + fs.address + "/?proxyChunkId=" + fileId, "") + return util.DownloadFile("http://"+fs.address+"/?proxyChunkId="+fileId, "") } fileUrls, err := fs.LookupFileId(fileId) diff --git a/weed/shell/command_volume_move.go b/weed/shell/command_volume_move.go index db212fe3f..3dcf41354 100644 --- a/weed/shell/command_volume_move.go +++ b/weed/shell/command_volume_move.go @@ -195,7 +195,7 @@ func markVolumeWritable(grpcDialOption grpc.DialOption, volumeId needle.VolumeId func markVolumeReplicasWritable(grpcDialOption grpc.DialOption, volumeId needle.VolumeId, locations []wdclient.Location, writable bool) error { for _, location := range locations { fmt.Printf("markVolumeReadonly %d on %s ...\n", volumeId, location.Url) - if err:= markVolumeWritable(grpcDialOption, volumeId, location.Url, writable); err != nil { + if err := markVolumeWritable(grpcDialOption, volumeId, location.Url, writable); err != nil { return err } }