aboutsummaryrefslogtreecommitdiff
path: root/weed/command/msg_broker.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-03-15 22:28:18 -0700
committerchrislu <chris.lu@gmail.com>2022-03-15 22:28:18 -0700
commit3639cad69cf58f7161aff2a639829c195d08ec30 (patch)
tree9f45239b5ef240a36f22b428cbb88438c551ab2b /weed/command/msg_broker.go
parentfbc9f0eb64346fdfcdb70e43bedec068f1447c64 (diff)
downloadseaweedfs-3639cad69cf58f7161aff2a639829c195d08ec30.tar.xz
seaweedfs-3639cad69cf58f7161aff2a639829c195d08ec30.zip
master, filer, s3: also listen to "localhost" in addition to specific ip address
related to https://github.com/chrislusf/seaweedfs/issues/1937
Diffstat (limited to 'weed/command/msg_broker.go')
-rw-r--r--weed/command/msg_broker.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/command/msg_broker.go b/weed/command/msg_broker.go
index 35d59ea20..3274f599b 100644
--- a/weed/command/msg_broker.go
+++ b/weed/command/msg_broker.go
@@ -95,7 +95,7 @@ func (msgBrokerOpt *MessageBrokerOptions) startQueueServer() bool {
}, grpcDialOption)
// start grpc listener
- grpcL, err := util.NewListener(util.JoinHostPort("", *msgBrokerOpt.port), 0)
+ grpcL, _, err := util.NewIpAndLocalListeners("", *msgBrokerOpt.port, 0)
if err != nil {
glog.Fatalf("failed to listen on grpc port %d: %v", *msgBrokerOpt.port, err)
}