Merge pull request #97 from divebomb/master

Fix: close client before close sessions
apache · Jun 17, 2019 · 23f39b2 · 23f39b2
2 parents c8554c3 + 36ff235
commit 23f39b2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/protocol/dubbo/pool.go b/protocol/dubbo/pool.go
@@ -225,13 +225,13 @@ func (c *gettyRPCClient) close() error {
 	c.once.Do(func() {
 		// delete @c from client pool
 		c.pool.remove(c)
+		c.gettyClient.Close()
+		c.gettyClient = nil
 		for _, s := range c.sessions {
 			logger.Infof("close client session{%s, last active:%s, request number:%d}",
 				s.session.Stat(), s.session.GetActive().String(), s.reqNum)
 			s.session.Close()
 		}
-		c.gettyClient.Close()
-		c.gettyClient = nil
 		c.sessions = c.sessions[:0]
 
 		c.created = 0