Race in Broker.Close()/Broker.RunContinousQueryProcessing()

[jwilder]

WARNING: DATA RACE
Read by goroutine 82:
github.com/influxdb/influxdb.(_Broker).requestContinuousQueryProcessing()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/broker.go:127 +0xbe
github.com/influxdb/influxdb.(_Broker).runContinuousQueries()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/broker.go:112 +0x473
github.com/influxdb/influxdb.(*Broker).continuousQueryLoop()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/broker.go:82 +0x76

Previous write by goroutine 470:
github.com/influxdb/influxdb.(_Broker).Close()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/broker.go:72 +0x112
github.com/influxdb/influxdb/cmd/influxd.(_Node).Close()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/cmd/influxd/run.go:72 +0x1ce
github.com/influxdb/influxdb/cmd/influxd_test.(*Cluster).Close()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/cmd/influxd/server_integration_test.go:67 +0xca
github.com/influxdb/influxdb/cmd/influxd_test.Test3NodeServerFailover()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/cmd/influxd/server_integration_test.go:1424 +0x579
github.com/influxdb/influxdb/cmd/influxd_test.createCombinedNodeCluster()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/cmd/influxd/server_integration_test.go:134 +0x19be
github.com/influxdb/influxdb/cmd/influxd_test.Test3NodeServerFailover()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/cmd/influxd/server_integration_test.go:1416 +0x38c
testing.tRunner()
/home/ubuntu/.gvm/gos/go1.4/src/testing/testing.go:447 +0x133

Goroutine 82 (running) created at:
github.com/influxdb/influxdb.(_Broker).RunContinuousQueryLoop()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/broker.go:58 +0xb6
github.com/influxdb/influxdb/cmd/influxd.(_RunCommand).Open()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/cmd/influxd/run.go:432 +0x3c0f
github.com/influxdb/influxdb/cmd/influxd_test.createCombinedNodeCluster()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/cmd/influxd/server_integration_test.go:110 +0xe70
github.com/influxdb/influxdb/cmd/influxd_test.Test3NodeServerFailover()
/home/ubuntu/influxdb-build/src/github.com/influxdb/influxdb/cmd/influxd/server_integration_test.go:1416 +0x38c
testing.tRunner()
/home/ubuntu/.gvm/gos/go1.4/src/testing/testing.go:447 +0x133

Goroutine 470 (finished) created at:
testing.RunTests()
/home/ubuntu/.gvm/gos/go1.4/src/testing/testing.go:555 +0xd4e
testing.(*M).Run()
/home/ubuntu/.gvm/gos/go1.4/src/testing/testing.go:485 +0xe0
main.main()
github.com/influxdb/influxdb/cmd/influxd/_test/_testmain.go:104 +0x28c