aboutsummaryrefslogtreecommitdiff
path: root/weed/command
diff options
context:
space:
mode:
authorRyan Russell <ryanrussell@users.noreply.github.com>2022-09-14 13:59:55 -0500
committerGitHub <noreply@github.com>2022-09-14 11:59:55 -0700
commit8efe1db01aab21268bf35d685ce643cb7ae5dde5 (patch)
tree9a99547c4c897d8586a8568b65b10ad23d234e61 /weed/command
parenta8d7615eecea9ef88e33fd63ecc7bb93edfdc9dc (diff)
downloadseaweedfs-8efe1db01aab21268bf35d685ce643cb7ae5dde5.tar.xz
seaweedfs-8efe1db01aab21268bf35d685ce643cb7ae5dde5.zip
refactor(various): `Listner` -> `Listener` readability improvements (#3672)
* refactor(net_timeout): `listner` -> `listener` Signed-off-by: Ryan Russell <git@ryanrussell.org> * refactor(s3): `s3ApiLocalListner` -> `s3ApiLocalListener` Signed-off-by: Ryan Russell <git@ryanrussell.org> * refactor(filer): `localPublicListner` -> `localPublicListener` Signed-off-by: Ryan Russell <git@ryanrussell.org> * refactor(command): `masterLocalListner` -> `masterLocalListener` Signed-off-by: Ryan Russell <git@ryanrussell.org> * refactor(net_timeout): `ipListner` -> `ipListener` Signed-off-by: Ryan Russell <git@ryanrussell.org> Signed-off-by: Ryan Russell <git@ryanrussell.org>
Diffstat (limited to 'weed/command')
-rw-r--r--weed/command/filer.go6
-rw-r--r--weed/command/master.go6
-rw-r--r--weed/command/master_follower.go6
-rw-r--r--weed/command/s3.go10
4 files changed, 14 insertions, 14 deletions
diff --git a/weed/command/filer.go b/weed/command/filer.go
index 3a7bc0049..4aa537f46 100644
--- a/weed/command/filer.go
+++ b/weed/command/filer.go
@@ -250,7 +250,7 @@ func (fo *FilerOptions) startFiler() {
if *fo.publicPort != 0 {
publicListeningAddress := util.JoinHostPort(*fo.bindIp, *fo.publicPort)
glog.V(0).Infoln("Start Seaweed filer server", util.Version(), "public at", publicListeningAddress)
- publicListener, localPublicListner, e := util.NewIpAndLocalListeners(*fo.bindIp, *fo.publicPort, 0)
+ publicListener, localPublicListener, e := util.NewIpAndLocalListeners(*fo.bindIp, *fo.publicPort, 0)
if e != nil {
glog.Fatalf("Filer server public listener error on port %d:%v", *fo.publicPort, e)
}
@@ -259,9 +259,9 @@ func (fo *FilerOptions) startFiler() {
glog.Fatalf("Volume server fail to serve public: %v", e)
}
}()
- if localPublicListner != nil {
+ if localPublicListener != nil {
go func() {
- if e := http.Serve(localPublicListner, publicVolumeMux); e != nil {
+ if e := http.Serve(localPublicListener, publicVolumeMux); e != nil {
glog.Errorf("Volume server fail to serve public: %v", e)
}
}()
diff --git a/weed/command/master.go b/weed/command/master.go
index 908299c8a..f20b2dc62 100644
--- a/weed/command/master.go
+++ b/weed/command/master.go
@@ -146,7 +146,7 @@ func startMaster(masterOption MasterOptions, masterWhiteList []string) {
ms := weed_server.NewMasterServer(r, masterOption.toMasterOption(masterWhiteList), masterPeers)
listeningAddress := util.JoinHostPort(*masterOption.ipBind, *masterOption.port)
glog.V(0).Infof("Start Seaweed Master %s at %s", util.Version(), listeningAddress)
- masterListener, masterLocalListner, e := util.NewIpAndLocalListeners(*masterOption.ipBind, *masterOption.port, 0)
+ masterListener, masterLocalListener, e := util.NewIpAndLocalListeners(*masterOption.ipBind, *masterOption.port, 0)
if e != nil {
glog.Fatalf("Master startup error: %v", e)
}
@@ -239,8 +239,8 @@ func startMaster(masterOption MasterOptions, masterWhiteList []string) {
}
httpS := &http.Server{Handler: r}
- if masterLocalListner != nil {
- go httpS.Serve(masterLocalListner)
+ if masterLocalListener != nil {
+ go httpS.Serve(masterLocalListener)
}
if useMTLS {
diff --git a/weed/command/master_follower.go b/weed/command/master_follower.go
index 5e5244c05..c4f0cfc3c 100644
--- a/weed/command/master_follower.go
+++ b/weed/command/master_follower.go
@@ -120,7 +120,7 @@ func startMasterFollower(masterOptions MasterOptions) {
ms := weed_server.NewMasterServer(r, option, masters)
listeningAddress := util.JoinHostPort(*masterOptions.ipBind, *masterOptions.port)
glog.V(0).Infof("Start Seaweed Master %s at %s", util.Version(), listeningAddress)
- masterListener, masterLocalListner, e := util.NewIpAndLocalListeners(*masterOptions.ipBind, *masterOptions.port, 0)
+ masterListener, masterLocalListener, e := util.NewIpAndLocalListeners(*masterOptions.ipBind, *masterOptions.port, 0)
if e != nil {
glog.Fatalf("Master startup error: %v", e)
}
@@ -144,8 +144,8 @@ func startMasterFollower(masterOptions MasterOptions) {
// start http server
httpS := &http.Server{Handler: r}
- if masterLocalListner != nil {
- go httpS.Serve(masterLocalListner)
+ if masterLocalListener != nil {
+ go httpS.Serve(masterLocalListener)
}
go httpS.Serve(masterListener)
diff --git a/weed/command/s3.go b/weed/command/s3.go
index 3c35e489c..aa435b822 100644
--- a/weed/command/s3.go
+++ b/weed/command/s3.go
@@ -215,7 +215,7 @@ func (s3opt *S3Options) startS3Server() bool {
}
listenAddress := fmt.Sprintf("%s:%d", *s3opt.bindIp, *s3opt.port)
- s3ApiListener, s3ApiLocalListner, err := util.NewIpAndLocalListeners(*s3opt.bindIp, *s3opt.port, time.Duration(10)*time.Second)
+ s3ApiListener, s3ApiLocalListener, err := util.NewIpAndLocalListeners(*s3opt.bindIp, *s3opt.port, time.Duration(10)*time.Second)
if err != nil {
glog.Fatalf("S3 API Server listener on %s error: %v", listenAddress, err)
}
@@ -243,9 +243,9 @@ func (s3opt *S3Options) startS3Server() bool {
if *s3opt.tlsPrivateKey != "" {
glog.V(0).Infof("Start Seaweed S3 API Server %s at https port %d", util.Version(), *s3opt.port)
- if s3ApiLocalListner != nil {
+ if s3ApiLocalListener != nil {
go func() {
- if err = httpS.ServeTLS(s3ApiLocalListner, *s3opt.tlsCertificate, *s3opt.tlsPrivateKey); err != nil {
+ if err = httpS.ServeTLS(s3ApiLocalListener, *s3opt.tlsCertificate, *s3opt.tlsPrivateKey); err != nil {
glog.Fatalf("S3 API Server Fail to serve: %v", err)
}
}()
@@ -255,9 +255,9 @@ func (s3opt *S3Options) startS3Server() bool {
}
} else {
glog.V(0).Infof("Start Seaweed S3 API Server %s at http port %d", util.Version(), *s3opt.port)
- if s3ApiLocalListner != nil {
+ if s3ApiLocalListener != nil {
go func() {
- if err = httpS.Serve(s3ApiLocalListner); err != nil {
+ if err = httpS.Serve(s3ApiLocalListener); err != nil {
glog.Fatalf("S3 API Server Fail to serve: %v", err)
}
}()