storage/concurrency: test and bugfix for clearing the locks when the

size limit of the lockTable is exceeded

Release note: None

pkg/storage/concurrency/lock_table.go

@@ -1493,17 +1493,19 @@ func (t *lockTableImpl) AcquireLock(
 func (t *lockTableImpl) clearMostLocks() {
 	for i := 0; i < int(spanset.NumSpanScope); i++ {
 		tree := &t.locks[i]
-		var cleared int64
 		tree.mu.Lock()
+		var locksToClear []*lockState
 		tree.Ascend(func(it btree.Item) bool {
 			l := it.(*lockState)
 			if l.tryClearLock() {
-				tree.Delete(l)
-				cleared++
+				locksToClear = append(locksToClear, l)
 			}
 			return true
 		})
-		atomic.AddInt64(&tree.numLocks, -cleared)
+		atomic.AddInt64(&tree.numLocks, int64(-len(locksToClear)))
+		for _, l := range locksToClear {
+			tree.Delete(l)
+		}
 		tree.mu.Unlock()
 	}
 }

pkg/storage/concurrency/lock_table_test.go

@@ -42,6 +42,11 @@ import (
 Test needs to handle caller constraints wrt latches being held. The datadriven
 test uses the following format:
 
+locktable maxlocks=<int>
+----
+
+  Creates a lockTable.
+
 txn txn=<name> ts=<int>[,<int>] epoch=<int>
 ----
 
@@ -180,13 +185,19 @@ func TestLockTableBasic(t *testing.T) {
 	defer leaktest.AfterTest(t)()
 
 	datadriven.Walk(t, "testdata/lock_table", func(t *testing.T, path string) {
-		lt := newLockTable(1000)
+		var lt lockTable
 		txnsByName := make(map[string]*enginepb.TxnMeta)
 		txnCounter := uint128.FromInts(0, 0)
 		requestsByName := make(map[string]Request)
 		guardsByReqName := make(map[string]lockTableGuard)
 		datadriven.RunTest(t, path, func(t *testing.T, d *datadriven.TestData) string {
 			switch d.Cmd {
+			case "locktable":
+				var maxLocks int
+				d.ScanArgs(t, "maxlocks", &maxLocks)
+				lt = newLockTable(int64(maxLocks))
+				return ""
+
 			case "txn":
 				// UUIDs for transactions are numbered from 1 by this test code and
 				// lockTableImpl.String() knows about UUIDs and not transaction names.
@@ -1155,7 +1166,6 @@ func BenchmarkLockTable(b *testing.B) {
 
 // TODO(sbhola):
 // - More datadriven and randomized test cases:
-//   - add test when maxLocks is exceeded
 //   - both local and global keys
 //   - repeated lock acquisition at same seqnums, different seqnums, epoch changes
 //   - updates with ignored seqs

pkg/storage/concurrency/testdata/lock_table/basic

@@ -1,3 +1,6 @@
+locktable maxlocks=10000
+----
+
 txn txn=txn1 ts=10,1 epoch=0
 ----
 

pkg/storage/concurrency/testdata/lock_table/non_txn_write

@@ -1,3 +1,6 @@
+locktable maxlocks=10000
+----
+
 txn txn=txn1 ts=10 epoch=0
 ----
 

pkg/storage/concurrency/testdata/lock_table/size_limit_exceeded

@@ -0,0 +1,225 @@
+# Tests various cases when the locks are cleared:
+# - lock with reservation and waiters (lock "a"): cleared and waiters transition to doneWaiting
+# - lock held unreplicated with waiters (lock "b"): cleared and waiters transition to doneWaiting
+# - lock held replicated with active waiter (lock "c"): cleared and waiters transition to
+#   waitElsewhere
+# - lock held replicated with no active waiter (lock "d"): not cleared and inactive waiter remains
+#   in queue. The next ScanAndEnqueue call makes it an active waiter.
+
+locktable maxlocks=4
+----
+
+txn txn=txn1 ts=10 epoch=0
+----
+
+txn txn=txn2 ts=10 epoch=0
+----
+
+request r=req1 txn=txn1 ts=10 spans=w@a,e
+----
+
+scan r=req1
+----
+start-waiting: false
+
+acquire r=req1 k=a durability=u
+----
+global: num=1
+ lock: "a"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+local: num=0
+
+acquire r=req1 k=b durability=u
+----
+global: num=2
+ lock: "a"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+ lock: "b"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+local: num=0
+
+acquire r=req1 k=c durability=u
+----
+global: num=3
+ lock: "a"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+ lock: "b"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+ lock: "c"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+local: num=0
+
+acquire r=req1 k=c durability=r
+----
+global: num=3
+ lock: "a"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+ lock: "b"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+ lock: "c"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+local: num=0
+
+done r=req1
+----
+global: num=3
+ lock: "a"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+ lock: "b"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+ lock: "c"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+local: num=0
+
+request r=req2 txn=txn2 ts=10 spans=w@a,c
+----
+
+scan r=req2
+----
+start-waiting: true
+
+request r=req3 txn=txn2 ts=10 spans=w@a,c
+----
+
+scan r=req3
+----
+start-waiting: true
+
+release txn=txn1 span=a
+----
+global: num=3
+ lock: "a"
+  res: req: 2, txn: 00000000-0000-0000-0000-000000000002, ts: 0.000000010,0
+   queued writers:
+    active: true req: 3, txn: 00000000-0000-0000-0000-000000000002
+ lock: "b"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+ lock: "c"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+local: num=0
+
+guard-state r=req2
+----
+new: state=waitForDistinguished txn=txn1 ts=10 key="b" held=true guard-access=write
+
+guard-state r=req3
+----
+new: state=waitSelf
+
+print
+----
+global: num=3
+ lock: "a"
+  res: req: 2, txn: 00000000-0000-0000-0000-000000000002, ts: 0.000000010,0
+   queued writers:
+    active: true req: 3, txn: 00000000-0000-0000-0000-000000000002
+ lock: "b"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+   queued writers:
+    active: true req: 2, txn: 00000000-0000-0000-0000-000000000002
+   distinguished req: 2
+ lock: "c"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+local: num=0
+
+request r=req4 txn=txn2 ts=10 spans=r@b
+----
+
+scan r=req4
+----
+start-waiting: true
+
+request r=req5 txn=txn2 ts=10 spans=w@b
+----
+
+scan r=req5
+----
+start-waiting: true
+
+request r=req6 txn=txn2 ts=10 spans=w@c
+----
+
+scan r=req6
+----
+start-waiting: true
+
+request r=req7 txn=txn2 ts=10 spans=w@d
+----
+
+scan r=req7
+----
+start-waiting: false
+
+guard-state r=req7
+----
+new: state=doneWaiting
+
+add-discovered r=req7 k=d txn=txn1
+----
+global: num=4
+ lock: "a"
+  res: req: 2, txn: 00000000-0000-0000-0000-000000000002, ts: 0.000000010,0
+   queued writers:
+    active: true req: 3, txn: 00000000-0000-0000-0000-000000000002
+ lock: "b"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+   waiting readers:
+    req: 4, txn: 00000000-0000-0000-0000-000000000002
+   queued writers:
+    active: true req: 2, txn: 00000000-0000-0000-0000-000000000002
+    active: true req: 5, txn: 00000000-0000-0000-0000-000000000002
+   distinguished req: 2
+ lock: "c"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+   queued writers:
+    active: true req: 6, txn: 00000000-0000-0000-0000-000000000002
+   distinguished req: 6
+ lock: "d"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+   queued writers:
+    active: false req: 7, txn: 00000000-0000-0000-0000-000000000002
+local: num=0
+
+request r=req8 txn=txn2 ts=10 spans=w@e
+----
+
+scan r=req8
+----
+start-waiting: false
+
+acquire r=req8 k=e durability=u
+----
+global: num=1
+ lock: "d"
+  holder: txn: 00000000-0000-0000-0000-000000000001, ts: 0.000000010,0
+   queued writers:
+    active: false req: 7, txn: 00000000-0000-0000-0000-000000000002
+local: num=0
+
+guard-state r=req2
+----
+new: state=doneWaiting
+
+guard-state r=req3
+----
+new: state=doneWaiting
+
+guard-state r=req4
+----
+new: state=doneWaiting
+
+guard-state r=req5
+----
+new: state=doneWaiting
+
+guard-state r=req6
+----
+new: state=waitElsewhere txn=txn1 ts=10 key="c" held=true guard-access=write
+
+scan r=req7
+----
+start-waiting: true
+
+guard-state r=req7
+----
+new: state=waitForDistinguished txn=txn1 ts=10 key="d" held=true guard-access=write