(skywalking-banyandb) 01/01: Stop check loop once the node is healthy

[hanahmily]

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

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

commit fe6650a63319fca13bd042a8852252871a3b0a8c
Author: Gao Hongtao <hanahm...@gmail.com>
AuthorDate: Fri Jun 21 08:36:05 2024 +0000

    Stop check loop once the node is healthy
    
    Signed-off-by: Gao Hongtao <hanahm...@gmail.com>
---
 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 1ebeb463..4966f04f 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()