Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Dump cluster stats on test failure

pull/2385/head
Philip O'Toole 2015-04-21 22:27:54 -07:00
parent 20ee9e32eb
commit 8141da34c4
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
cmd/influxd/server_integration_test.go
View File

@ -180,7 +180,7 @@ func deleteDatabase(t *testing.T, testName string, nodes Cluster, database strin
query(t, nodes[:1], "", "DROP DATABASE "+database, `{"results":[{}]}`, "")
}
// dumpClusterDiags dumps the diagnositcs of each node.
// dumpClusterDiags dumps the diagnostics of each node.
func dumpClusterDiags(t *testing.T, testName string, nodes Cluster) {
t.Logf("Test: %s: dumping node diagnostics", testName)
for _, n := range nodes {
@ -189,6 +189,15 @@ func dumpClusterDiags(t *testing.T, testName string, nodes Cluster) {
}
}
// dumpClusterStats dumps the statistics of each node.
func dumpClusterStats(t *testing.T, testName string, nodes Cluster) {
t.Logf("Test: %s: dumping node stats", testName)
for _, n := range nodes {
r, _, _ := query(t, Cluster{n}, "", "SHOW STATS", "", "")
t.Log(r)
}
}
// writes writes the provided data to the cluster. It verfies that a 200 OK is returned by the server.
func write(t *testing.T, node *TestNode, data string) {
u := urlFor(node.url, "write", url.Values{})
@ -332,6 +341,8 @@ func runTest_rawDataReturnsInOrder(t *testing.T, testName string, nodes Cluster,
got, ok, nOK := queryAndWait(t, nodes, database, `SELECT count(value) FROM cpu`, expected, "", 120*time.Second)
if !ok {
t.Errorf("test %s:rawDataReturnsInOrder failed, SELECT count() query returned unexpected data\nexp: %s\n, got: %s\n%d nodes responded correctly", testName, expected, got, nOK)
dumpClusterDiags(t, testName, nodes)
dumpClusterStats(t, testName, nodes)
}
// Create expected JSON string dynamically.
@ -343,6 +354,8 @@ func runTest_rawDataReturnsInOrder(t *testing.T, testName string, nodes Cluster,
got, ok, nOK = query(t, nodes, database, `SELECT value FROM cpu`, expected, "")
if !ok {
t.Errorf("test %s failed, SELECT query returned unexpected data\nexp: %s\ngot: %s\n%d nodes responded correctly", testName, expected, got, nOK)
dumpClusterDiags(t, testName, nodes)
dumpClusterStats(t, testName, nodes)
}
}
@ -1407,6 +1420,7 @@ func runTestsData(t *testing.T, testName string, nodes Cluster, database, retent
t.Errorf("Test #%d: \"%s:%s\" failed\n query: %s\n exp: %s\n got: %s\n%d nodes responded correctly", i, testName, name, qry, rewriteDbRp(tt.expectPattern, database, retention), got, nOK)
}
dumpClusterDiags(t, name, nodes)
dumpClusterStats(t, name, nodes)
}
}
}