|
|
@@ -4,7 +4,6 @@ package gocql
|
|
|
|
|
|
import (
|
|
|
"github.com/gocql/gocql/ccm_test"
|
|
|
- "log"
|
|
|
"testing"
|
|
|
"time"
|
|
|
)
|
|
|
@@ -40,6 +39,7 @@ func TestEventDiscovery(t *testing.T) {
|
|
|
|
|
|
func TestEventNodeDownControl(t *testing.T) {
|
|
|
const targetNode = "node1"
|
|
|
+ t.Log("marking " + targetNode + " as down")
|
|
|
if err := ccm.AllUp(); err != nil {
|
|
|
t.Fatal(err)
|
|
|
}
|
|
|
@@ -50,13 +50,13 @@ func TestEventNodeDownControl(t *testing.T) {
|
|
|
if err := ccm.NodeDown(targetNode); err != nil {
|
|
|
t.Fatal(err)
|
|
|
}
|
|
|
- log.Println("down")
|
|
|
|
|
|
status, err := ccm.Status()
|
|
|
if err != nil {
|
|
|
t.Fatal(err)
|
|
|
}
|
|
|
t.Logf("status=%+v\n", status)
|
|
|
+ t.Logf("marking node %q down: %v\n", targetNode, status[targetNode])
|
|
|
|
|
|
time.Sleep(5 * time.Second)
|
|
|
|
|
|
@@ -85,13 +85,13 @@ func TestEventNodeDown(t *testing.T) {
|
|
|
if err := ccm.NodeDown(targetNode); err != nil {
|
|
|
t.Fatal(err)
|
|
|
}
|
|
|
- log.Println("down")
|
|
|
|
|
|
status, err := ccm.Status()
|
|
|
if err != nil {
|
|
|
t.Fatal(err)
|
|
|
}
|
|
|
t.Logf("status=%+v\n", status)
|
|
|
+ t.Logf("marking node %q down: %v\n", targetNode, status[targetNode])
|
|
|
|
|
|
time.Sleep(5 * time.Second)
|
|
|
|