From 22f3b246cd07923726b19df588dc5797f207f127 Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Sat, 21 Feb 2015 12:21:34 -0800 Subject: [PATCH] Multi-batch write testing on a single-node --- cmd/influxd/server_integration_test.go | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/cmd/influxd/server_integration_test.go b/cmd/influxd/server_integration_test.go index a6b612ffc5..644b6e300f 100644 --- a/cmd/influxd/server_integration_test.go +++ b/cmd/influxd/server_integration_test.go @@ -543,3 +543,21 @@ func Test_Server5NodeLargeBatchIntegration(t *testing.T) { write(t, testName, nodes, createBatch(batchSize, "foo", "bar", "cpu", map[string]string{"host": "server01"})) simpleCountQuery(t, "single node large batch", nodes, `select count(value) from "foo"."bar".cpu`, "value", batchSize) } + +func Test_ServerMultiLargeBatchIntegration(t *testing.T) { + if testing.Short() { + t.Skip() + } + nNodes := 1 + nBatches := 5 + basePort := 8690 + testName := "single node multi batch" + nodes := createCombinedNodeCluster(t, testName, nNodes, basePort) + + createDatabase(t, testName, nodes, "foo") + createRetentionPolicy(t, testName, nodes, "foo", "bar") + for i := 0; i < nBatches; i++ { + write(t, testName, nodes, createBatch(batchSize, "foo", "bar", "cpu", map[string]string{"host": "server01"})) + } + simpleCountQuery(t, "single node large batch", nodes, `select count(value) from "foo"."bar".cpu`, "value", batchSize*int64(nBatches)) +}