1

dkropachev · May 30, 2024 · 673a5db · 673a5db
1 parent e589302
commit 673a5db
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/policies.go b/policies.go
@@ -325,17 +325,17 @@ func (r *roundRobinHostPolicy) Init(*Session)                       {}
 
 func (r *roundRobinHostPolicy) Pick(qry ExecutableQuery) NextHost {
 	nextStartOffset := atomic.AddUint64(&r.lastUsedHostIdx, 1)
-	println("roundRobinHostPolicy Pick", nextStartOffset, " ", r.hosts.get())
+	println("roundRobinHostPolicy Pick", nextStartOffset, " ", len(r.hosts.get()), " ", r.hosts.get())
 	return roundRobbin(int(nextStartOffset), r.hosts.get())
 }
 
 func (r *roundRobinHostPolicy) AddHost(host *HostInfo) {
-	println("roundRobinHostPolicy AddHost", host.ConnectAddress(), " ", host.State(), " ", r.hosts.get())
+	println("roundRobinHostPolicy AddHost", host.ConnectAddress().String(), " ", host.State(), " ", r.hosts.get())
 	r.hosts.add(host)
 }
 
 func (r *roundRobinHostPolicy) RemoveHost(host *HostInfo) {
-	println("roundRobinHostPolicy RemoveHost", host.ConnectAddress(), " ", host.State(), " ", r.hosts.get())
+	println("roundRobinHostPolicy RemoveHost", host.ConnectAddress().String(), " ", host.State(), " ", r.hosts.get())
 	r.hosts.remove(host.ConnectAddress())
 }