(skywalking-banyandb) branch main updated: Stop check loop once the node is healthy (#474)

[wusheng]

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git


The following commit(s) were added to refs/heads/main by this push:
     new 7a12fd03 Stop check loop once the node is healthy (#474)
7a12fd03 is described below

commit 7a12fd03339fcab8e4d65286d2f65319e5576ba2
Author: Gao Hongtao <hanahm...@gmail.com>
AuthorDate: Fri Jun 21 16:50:58 2024 +0800

    Stop check loop once the node is healthy (#474)
---
 banyand/queue/pub/client.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/banyand/queue/pub/client.go b/banyand/queue/pub/client.go
index 7adc5978..14e25276 100644
--- a/banyand/queue/pub/client.go
+++ b/banyand/queue/pub/client.go
@@ -263,8 +263,9 @@ func (p *pub) checkClientHealthAndReconnect(conn 
*grpc.ClientConn, md schema.Met
                                                        
p.handler.OnAddOrUpdate(md)
                                                }
                                                delete(p.evictable, name)
-                                               p.log.Info().Stringer("node", 
en.n).Msg("node is healthy, move it back to active queue")
+                                               p.log.Info().Str("status", 
p.dump()).Stringer("node", en.n).Msg("node is healthy, move it back to active 
queue")
                                        }()
+                                       return
                                }
                                if errEvict != nil {
                                        _ = connEvict.Close()