aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-08-14 02:55:44 -0700
committerChris Lu <chris.lu@gmail.com>2021-08-14 02:55:44 -0700
commit0db251799457849ff9d9e4839cb3efb438c93e14 (patch)
tree58e9ea5955ede4f2437ae1358e560233a920323f
parent7937db52e1a6b8be0e04da0b2ed9d62284fa2698 (diff)
downloadseaweedfs-0db251799457849ff9d9e4839cb3efb438c93e14.tar.xz
seaweedfs-0db251799457849ff9d9e4839cb3efb438c93e14.zip
go fmt
-rw-r--r--weed/command/master_follower.go2
-rw-r--r--weed/replication/source/filer_source.go2
-rw-r--r--weed/shell/command_volume_move.go2
3 files changed, 2 insertions, 4 deletions
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
}
}