Merge pull request #150 from sylwiaszunejko/mark_node_down

Mark node as down if unable to dial control conn
scylladb · Oct 31, 2023 · 0545682 · 0545682
2 parents 7e10c93 + 01c3b3b
commit 0545682
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/control.go b/control.go
@@ -401,6 +401,9 @@ func (c *controlConn) attemptReconnectToAnyOfHosts(hosts []*HostInfo) (*Conn, er
 	for _, host := range hosts {
 		conn, err = c.session.connect(c.session.ctx, host, c)
 		if err != nil {
+			if c.session.cfg.ConvictionPolicy.AddFailure(err, host) {
+				c.session.handleNodeDown(host.ConnectAddress(), host.Port())
+			}
 			c.session.logger.Printf("gocql: unable to dial control conn %v:%v: %v\n", host.ConnectAddress(), host.Port(), err)
 			continue
 		}