CovenantSQL
diff --git a/‎sqlchain/chain_test.go‎
Lines changed: 11 additions & 5 deletions b/‎sqlchain/chain_test.go‎
Lines changed: 11 additions & 5 deletions
diff --git a/‎xenomint/state.go‎
Lines changed: 2 additions & 0 deletions b/‎xenomint/state.go‎
Lines changed: 2 additions & 0 deletions
@@ -358,11 +358,17 @@ func TestMultiChain(t *testing.T) {
 					default:
 						var err error
 						// Send a random query
-						err = cli.query(types.ReadQuery, []types.Query{
-							buildQuery(`SELECT v FROM t1 WHERE k=?`, rand.Intn(5)),
-						}, rand.Int()%10 != 0)
-						if err != nil {
-							t.Errorf("error occurred: %v", err)
+						if rand.Intn(10) != 0 {
+							err = cli.query(types.ReadQuery, []types.Query{
+								buildQuery(`SELECT v FROM t1 WHERE k=?`, rand.Intn(5)),
+							}, rand.Intn(10) != 0)
+							if err != nil {
+								t.Errorf("error occurred: %v", err)
+							}
+						} else {
+							err = cli.query(types.ReadQuery, []types.Query{
+								buildQuery(`XXX`),
+							}, false)
 						}
 					}
 				}
 
@@ -287,7 +287,9 @@ func (s *State) readTx(
 		if cnames, ctypes, data, ierr = readSingle(ctx, querier, &v); ierr != nil {
 			err = errors.Wrapf(ierr, "query at #%d failed", i)
 			// Add to failed pool list
+			s.Lock()
 			s.pool.setFailed(req)
+			s.Unlock()
 			return
 		}
 	}
Original file line number	Diff line number	Diff line change
`@@ -287,7 +287,9 @@ func (s *State) readTx(`
`287`	`287`	`if cnames, ctypes, data, ierr = readSingle(ctx, querier, &v); ierr != nil {`
`288`	`288`	`err = errors.Wrapf(ierr, "query at #%d failed", i)`
`289`	`289`	`// Add to failed pool list`
	`290`	`+ s.Lock()`
`290`	`291`	`s.pool.setFailed(req)`
	`292`	`+ s.Unlock()`
`291`	`293`	`return`
`292`	`294`	`}`
`293`	`295`	`}`