From e624f23a48c8378e5a68d0e6556e4bdc53d072b5 Mon Sep 17 00:00:00 2001 From: wenbingshen Date: Fri, 3 Dec 2021 13:55:26 +0800 Subject: [PATCH 1/2] before cnx.close, the stat need change to connectionClosing --- pulsar/internal/connection.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go index ecda4faf22..39147b6837 100644 --- a/pulsar/internal/connection.go +++ b/pulsar/internal/connection.go @@ -858,13 +858,14 @@ func (c *connection) Close() { c.Lock() cnx := c.cnx c.Unlock() - c.changeState(connectionClosed) + c.changeState(connectionClosing) if cnx != nil { _ = cnx.Close() } close(c.closeCh) + c.changeState(connectionClosed) listeners := make(map[uint64]ConnectionListener) c.listenersLock.Lock() From fad646c4ae496599923fe8add9985bc21b4e9530 Mon Sep 17 00:00:00 2001 From: wenbingshen Date: Mon, 6 Dec 2021 11:13:53 +0800 Subject: [PATCH 2/2] go fmt connection.go --- pulsar/internal/connection.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go index 39147b6837..e9b2443b43 100644 --- a/pulsar/internal/connection.go +++ b/pulsar/internal/connection.go @@ -865,7 +865,7 @@ func (c *connection) Close() { } close(c.closeCh) - c.changeState(connectionClosed) + c.changeState(connectionClosed) listeners := make(map[uint64]ConnectionListener) c.listenersLock.Lock()