Skip to content

Commit 5f7ce67

Browse files
authored
fix: fix pbss async node buffer force flush buffer (#2885)
1 parent afe4ba0 commit 5f7ce67

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

triedb/pathdb/database_test.go

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -450,6 +450,10 @@ func TestDatabaseRollback(t *testing.T) {
450450

451451
// Verify state histories
452452
tester := newTester(t, 0, false, 32)
453+
bottom := tester.db.tree.bottom()
454+
if err := bottom.buffer.flush(tester.db.diskdb, tester.db.freezer, bottom.nodes, bottom.id, true); err != nil {
455+
t.Fatalf("Failed to force flush: %v", err)
456+
}
453457
defer tester.release()
454458

455459
if err := tester.verifyHistory(); err != nil {
@@ -520,17 +524,18 @@ func TestDatabaseRecoverable(t *testing.T) {
520524
}
521525
}
522526

523-
// TODO(joey): fail when using asyncbuffer
524-
//
525-
//nolint:unused
526-
func testDisable(t *testing.T) {
527+
func TestDisable(t *testing.T) {
527528
// Redefine the diff layer depth allowance for faster testing.
528529
maxDiffLayers = 4
529530
defer func() {
530531
maxDiffLayers = 128
531532
}()
532533

533534
tester := newTester(t, 0, false, 32)
535+
bottom := tester.db.tree.bottom()
536+
if err := bottom.buffer.flush(tester.db.diskdb, tester.db.freezer, nil, bottom.id, true); err != nil {
537+
t.Fatalf("Failed to force flush: %v", err)
538+
}
534539
defer tester.release()
535540

536541
stored := crypto.Keccak256Hash(rawdb.ReadAccountTrieNode(tester.db.diskdb, nil))

0 commit comments

Comments
 (0)