Merge Refresh ring when node UP event received for missing host (#1669)

This adds a check for case that was removed in an earlier commit.
apache · Mar 27, 2023 · 1d26125 · 1d26125
2 parents b8a948f + d80175d
commit 1d26125
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/AUTHORS b/AUTHORS
@@ -133,3 +133,4 @@ Adam Burk <[email protected]>
 Valerii Ponomarov <[email protected]>
 Neal Turett <[email protected]>
 Doug Schaapveld <[email protected]>
+Steven Seidman <[email protected]>
diff --git a/events.go b/events.go
@@ -286,6 +286,9 @@ func (s *Session) handleNodeUp(eventIp net.IP, eventPort int) {
 
 	host, ok := s.ring.getHostByIP(eventIp.String())
 	if !ok {
+		if err := s.hostSource.refreshRing(); err != nil && gocqlDebug {
+			s.logger.Printf("gocql: Session.handleNodeUp: failed to refresh ring: %w\n", err.Error())
+		}
 		return
 	}