Add an RemoveFromBuffer method for test (tikv#387)

* export DeleteKey Signed-off-by: ekexium <ekexium@gmail.com> * rename DeleteKey to UnsafeRemoveRecord Signed-off-by: ekexium <ekexium@gmail.com> * rename the old DeleteKey Signed-off-by: ekexium <ekexium@gmail.com> Signed-off-by: MyonKeminta <MyonKeminta@users.noreply.github.com>
MyonKeminta · Dec 13, 2021 · f070483 · f070483
1 parent 5421a0b
commit f070483
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 11 deletions.
diff --git a/internal/unionstore/memdb.go b/internal/unionstore/memdb.go
@@ -833,3 +833,13 @@ func (n *memdbNode) getKeyFlags() kv.KeyFlags {
 func (n *memdbNode) setKeyFlags(f kv.KeyFlags) {
 	n.flags = (^nodeFlagsMask & n.flags) | uint16(f)
 }
+
+// RemoveFromBuffer removes a record from the mem buffer. It should be only used for test.
+func (db *MemDB) RemoveFromBuffer(key []byte) {
+	x := db.traverse(key, false)
+	if x.isNull() {
+		return
+	}
+	db.size -= len(db.vlog.getValue(x.vptr))
+	db.deleteNode(x)
+}
diff --git a/internal/unionstore/memdb_norace_test.go b/internal/unionstore/memdb_norace_test.go
@@ -72,7 +72,7 @@ func TestRandom(t *testing.T) {
 	for _, k := range keys {
 		op := rand.Float64()
 		if op < 0.35 {
-			p1.DeleteKey(k)
+			p1.RemoveFromBuffer(k)
 			p2.Delete(k)
 		} else {
 			newValue := make([]byte, rand.Intn(19)+1)

diff --git a/internal/unionstore/memdb_test.go b/internal/unionstore/memdb_test.go
@@ -53,16 +53,6 @@ func init() {
 	testMode = true
 }
 
-// DeleteKey is used in test to verify the `deleteNode` used in `vlog.revertToCheckpoint`.
-func (db *MemDB) DeleteKey(key []byte) {
-	x := db.traverse(key, false)
-	if x.isNull() {
-		return
-	}
-	db.size -= len(db.vlog.getValue(x.vptr))
-	db.deleteNode(x)
-}
-
 func TestGetSet(t *testing.T) {
 	require := require.New(t)