consul: Adding a sanity check

11 years ago · bd1a140476
parent 89bffaf467
commit bd1a140476
1 changed files with 5 additions and 0 deletions
--- a/consul/rpc.go
+++ b/consul/rpc.go
@ -162,6 +162,11 @@ func (s *Server) blockingRPC(b *structs.BlockingQuery, tables MDBTables, run fun
 		goto RUN_QUERY
 	}

+	// Sanity check that we have tables to block on
+	if len(tables) == 0 {
+		panic("no tables to block on")
+	}
+
 	// Restrict the max query time
 	if b.MaxQueryTime > maxQueryTime {
 		b.MaxQueryTime = maxQueryTime