From 67594b07efe656a3bdc5a7c233a07f9d1f175a36 Mon Sep 17 00:00:00 2001 From: wei_lilitw Date: Thu, 23 May 2024 17:21:21 +0800 Subject: [PATCH 1/2] fix(broker):fix unix sock file not be removed --- broker/broker.go | 1 + 1 file changed, 1 insertion(+) diff --git a/broker/broker.go b/broker/broker.go index 5d6f7c8..e838423 100644 --- a/broker/broker.go +++ b/broker/broker.go @@ -285,6 +285,7 @@ func (b *Broker) StartUnixSocketClientListening(socketPath string, unixSocket bo if unixSocket { if FileExist(socketPath) { if err != nil { + err = os.Remove(socketPath) log.Error("Remove Unix socketPath ", zap.Error(err)) } } From 646f13199da4ad7969b74b410760309dd1db8334 Mon Sep 17 00:00:00 2001 From: wei_lilitw Date: Thu, 23 May 2024 17:22:29 +0800 Subject: [PATCH 2/2] fix(broker):fix unix sock file not be removed --- broker/broker.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/broker.go b/broker/broker.go index e838423..55b53fb 100644 --- a/broker/broker.go +++ b/broker/broker.go @@ -284,8 +284,8 @@ func (b *Broker) StartUnixSocketClientListening(socketPath string, unixSocket bo for { if unixSocket { if FileExist(socketPath) { + err = os.Remove(socketPath) if err != nil { - err = os.Remove(socketPath) log.Error("Remove Unix socketPath ", zap.Error(err)) } }