瀏覽代碼

Debugging for the simple pool

Ben Hood 11 年之前
父節點
當前提交
58a42819da
共有 1 個文件被更改,包括 11 次插入0 次删除
  1. 11 0
      cassandra_test.go

+ 11 - 0
cassandra_test.go

@@ -124,6 +124,17 @@ func TestRingDiscovery(t *testing.T) {
 		time.Sleep(*flagAutoWait)
 	}
 
+	pool, ok := session.Pool.(*SimplePool)
+	if ok {
+		pooledPeers := make([]string, len(pool.hosts))
+		i := 0
+		for peer, _ := range pool.hosts {
+			pooledPeers[i] = peer
+			i++
+		}
+		fmt.Printf("(Simple) Pooled peers: %+v\n", pooledPeers)
+	}
+
 	if *clusterSize != session.Pool.Size() {
 		t.Fatalf("Expected a cluster size of %d, but actual size was %d", *clusterSize, session.Pool.Size())
 	}