CovenantSQL
diff --git a/‎sqlchain/chain_test.go‎
Lines changed: 1 addition & 1 deletion b/‎sqlchain/chain_test.go‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎sqlchain/xxx_test.go‎
Lines changed: 10 additions & 3 deletions b/‎sqlchain/xxx_test.go‎
Lines changed: 10 additions & 3 deletions
@@ -360,7 +360,7 @@ func TestMultiChain(t *testing.T) {
 						// 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)
 						}
 
@@ -416,8 +416,11 @@ func (p *nodeProfile) buildQuery(
 	}
 	return
 }
-
 func (p *nodeProfile) sendQuery(req *types.Request) (err error) {
+	return p.sendQueryEx(req, true)
+}
+
+func (p *nodeProfile) sendQueryEx(req *types.Request, genAck bool) (err error) {
 	tracker, resp, err := p.Chain.Query(req, p.IsLeader)
 	if err != nil {
 		return
@@ -430,6 +433,10 @@ func (p *nodeProfile) sendQuery(req *types.Request) (err error) {
 	}
 	tracker.UpdateResp(resp)
 
+	if !genAck {
+		return
+	}
+
 	ack, err := createRandomQueryAckWithResponse(&resp.Header, p)
 	if err != nil {
 		return
@@ -441,11 +448,11 @@ func (p *nodeProfile) sendQuery(req *types.Request) (err error) {
 }
 
 func (p *nodeProfile) query(
-	qt types.QueryType, qs []types.Query) (err error,
+	qt types.QueryType, qs []types.Query, genAck bool) (err error,
 ) {
 	req, err := p.buildQuery(qt, qs)
 	if err != nil {
 		return
 	}
-	return p.sendQuery(req)
+	return p.sendQueryEx(req, genAck)
 }
Original file line number	Diff line number	Diff line change
`@@ -360,7 +360,7 @@ func TestMultiChain(t *testing.T) {`
`360`	`360`	`// Send a random query`
`361`	`361`	`err = cli.query(types.ReadQuery, []types.Query{`
`362`	`362`	buildQuery(`SELECT v FROM t1 WHERE k=?`, rand.Intn(5)),
`363`		`- })`
	`363`	`+ }, rand.Int()%10 != 0)`
`364`	`364`	`if err != nil {`
`365`	`365`	`t.Errorf("error occurred: %v", err)`
`366`	`366`	`}`
Original file line number	Diff line number	Diff line change
`@@ -416,8 +416,11 @@ func (p *nodeProfile) buildQuery(`
`416`	`416`	`}`
`417`	`417`	`return`
`418`	`418`	`}`
`419`		`-`
`420`	`419`	`func (p nodeProfile) sendQuery(req types.Request) (err error) {`
	`420`	`+ return p.sendQueryEx(req, true)`
	`421`	`+}`
	`422`	`+`
	`423`	`+func (p nodeProfile) sendQueryEx(req types.Request, genAck bool) (err error) {`
`421`	`424`	`tracker, resp, err := p.Chain.Query(req, p.IsLeader)`
`422`	`425`	`if err != nil {`
`423`	`426`	`return`
`@@ -430,6 +433,10 @@ func (p nodeProfile) sendQuery(req types.Request) (err error) {`
`430`	`433`	`}`
`431`	`434`	`tracker.UpdateResp(resp)`
`432`	`435`
	`436`	`+ if !genAck {`
	`437`	`+ return`
	`438`	`+ }`
	`439`	`+`
`433`	`440`	`ack, err := createRandomQueryAckWithResponse(&resp.Header, p)`
`434`	`441`	`if err != nil {`
`435`	`442`	`return`
`@@ -441,11 +448,11 @@ func (p nodeProfile) sendQuery(req types.Request) (err error) {`
`441`	`448`	`}`
`442`	`449`
`443`	`450`	`func (p *nodeProfile) query(`
`444`		`- qt types.QueryType, qs []types.Query) (err error,`
	`451`	`+ qt types.QueryType, qs []types.Query, genAck bool) (err error,`
`445`	`452`	`) {`
`446`	`453`	`req, err := p.buildQuery(qt, qs)`
`447`	`454`	`if err != nil {`
`448`	`455`	`return`
`449`	`456`	`}`
`450`		`- return p.sendQuery(req)`
	`457`	`+ return p.sendQueryEx(req, genAck)`
`451`	`458`	`}`