Skip to content

Commit

Permalink
storage: simplify TestIsOnePhaseCommit
Browse files Browse the repository at this point in the history
This test was creating batches with different flags set. The combination
of the WriteTooOld flag being set and the write timestamp not being
bumped in relation to the read timestamp does not make sense. All such
tests are removed, and the test spec is improved.
A future commit introduces an assertion that such requests are indeed
not received by servers.

Release note: None
  • Loading branch information
andreimatei committed Jan 15, 2020
1 parent 412378f commit 9c0f475
Showing 1 changed file with 5 additions and 11 deletions.
16 changes: 5 additions & 11 deletions pkg/storage/replica_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -569,9 +569,10 @@ func TestIsOnePhaseCommit(t *testing.T) {
ru []roachpb.RequestUnion
isTxn bool
isRestarted bool
isWTO bool
isTSOff bool
exp1PC bool
// isWTO implies isTSOff.
isWTO bool
isTSOff bool
exp1PC bool
}{
{ru: noReqs, isTxn: false, exp1PC: false},
{ru: noReqs, isTxn: true, exp1PC: false},
Expand All @@ -580,41 +581,33 @@ func TestIsOnePhaseCommit(t *testing.T) {
{ru: etReq, isTxn: true, exp1PC: true},
{ru: etReq, isTxn: true, isTSOff: true, exp1PC: false},
{ru: etReq, isTxn: true, isWTO: true, exp1PC: false},
{ru: etReq, isTxn: true, isWTO: true, isTSOff: true, exp1PC: false},
{ru: etReq, isTxn: true, isRestarted: true, exp1PC: false},
{ru: etReq, isTxn: true, isRestarted: true, isTSOff: true, exp1PC: false},
{ru: etReq, isTxn: true, isRestarted: true, isWTO: true, exp1PC: false},
{ru: etReq, isTxn: true, isRestarted: true, isWTO: true, isTSOff: true, exp1PC: false},
{ru: txnReqs[:1], isTxn: true, exp1PC: false},
{ru: txnReqs[1:], isTxn: true, exp1PC: false},
{ru: txnReqs, isTxn: true, exp1PC: true},
{ru: txnReqs, isTxn: true, isTSOff: true, exp1PC: false},
{ru: txnReqs, isTxn: true, isWTO: true, exp1PC: false},
{ru: txnReqs, isTxn: true, isWTO: true, isTSOff: true, exp1PC: false},
{ru: txnReqs, isTxn: true, isRestarted: true, exp1PC: false},
{ru: txnReqs, isTxn: true, isRestarted: true, isTSOff: true, exp1PC: false},
{ru: txnReqs, isTxn: true, isRestarted: true, isWTO: true, exp1PC: false},
{ru: txnReqs, isTxn: true, isRestarted: true, isWTO: true, isTSOff: true, exp1PC: false},
{ru: txnReqsNoRefresh[:1], isTxn: true, exp1PC: false},
{ru: txnReqsNoRefresh[1:], isTxn: true, exp1PC: false},
{ru: txnReqsNoRefresh, isTxn: true, exp1PC: true},
{ru: txnReqsNoRefresh, isTxn: true, isTSOff: true, exp1PC: true},
{ru: txnReqsNoRefresh, isTxn: true, isWTO: true, exp1PC: true},
{ru: txnReqsNoRefresh, isTxn: true, isWTO: true, isTSOff: true, exp1PC: true},
{ru: txnReqsNoRefresh, isTxn: true, isRestarted: true, exp1PC: false},
{ru: txnReqsNoRefresh, isTxn: true, isRestarted: true, isTSOff: true, exp1PC: false},
{ru: txnReqsNoRefresh, isTxn: true, isRestarted: true, isWTO: true, exp1PC: false},
{ru: txnReqsNoRefresh, isTxn: true, isRestarted: true, isWTO: true, isTSOff: true, exp1PC: false},
{ru: txnReqsRequire1PC[:1], isTxn: true, exp1PC: false},
{ru: txnReqsRequire1PC[1:], isTxn: true, exp1PC: false},
{ru: txnReqsRequire1PC, isTxn: true, exp1PC: true},
{ru: txnReqsRequire1PC, isTxn: true, isTSOff: true, exp1PC: false},
{ru: txnReqsRequire1PC, isTxn: true, isWTO: true, exp1PC: false},
{ru: txnReqsRequire1PC, isTxn: true, isWTO: true, isTSOff: true, exp1PC: false},
{ru: txnReqsRequire1PC, isTxn: true, isRestarted: true, exp1PC: true},
{ru: txnReqsRequire1PC, isTxn: true, isRestarted: true, isTSOff: true, exp1PC: false},
{ru: txnReqsRequire1PC, isTxn: true, isRestarted: true, isWTO: true, exp1PC: false},
{ru: txnReqsRequire1PC, isTxn: true, isRestarted: true, isWTO: true, isTSOff: true, exp1PC: false},
}

clock := hlc.NewClock(hlc.UnixNano, time.Nanosecond)
Expand All @@ -627,6 +620,7 @@ func TestIsOnePhaseCommit(t *testing.T) {
}
if c.isWTO {
ba.Txn.WriteTooOld = true
c.isTSOff = true
}
if c.isTSOff {
ba.Txn.WriteTimestamp = ba.Txn.ReadTimestamp.Add(1, 0)
Expand Down

0 comments on commit 9c0f475

Please sign in to comment.