disable caches

Author: omerfirmak

cmd/migration-checker/main.go

@@ -21,6 +21,7 @@ import (
 	"github.com/scroll-tech/go-ethereum/ethdb/leveldb"
 	"github.com/scroll-tech/go-ethereum/rlp"
 	"github.com/scroll-tech/go-ethereum/trie"
+	"github.com/syndtr/goleveldb/leveldb/opt"
 )
 
 var accountsDone atomic.Uint64
@@ -46,9 +47,23 @@ func main() {
 		log.Println(http.ListenAndServe("0.0.0.0:6060", nil))
 	}()
 
-	zkDb, err := leveldb.New(*zkDbPath, 1024, 128, "", true)
+	zkDb, err := leveldb.NewCustom(*zkDbPath, "zkDb", func(options *opt.Options) {
+		// Set default options
+		options.ReadOnly = true
+		options.BlockCacher = opt.NoCacher
+		options.BlockCacheCapacity = 0
+		options.OpenFilesCacher = opt.NoCacher
+		options.OpenFilesCacheCapacity = 0
+	})
 	panicOnError(err, "", "failed to open zk db")
-	mptDb, err := leveldb.New(*mptDbPath, 1024, 128, "", true)
+	mptDb, err := leveldb.NewCustom(*mptDbPath, "mptDb", func(options *opt.Options) {
+		// Set default options
+		options.ReadOnly = true
+		options.BlockCacher = opt.NoCacher
+		options.BlockCacheCapacity = 0
+		options.OpenFilesCacher = opt.NoCacher
+		options.OpenFilesCacheCapacity = 0
+	})
 	panicOnError(err, "", "failed to open mpt db")
 
 	zkRootHash := common.HexToHash(*zkRoot)
@@ -209,7 +224,7 @@ func checkStorageEquality(label string, _ *dbs, zkStorageBytes, mptStorageBytes
 
 func loadMPT(mptTrie *trie.SecureTrie, parallel bool) chan map[string][]byte {
 	startKey := make([]byte, 32)
-	workers := 1 << 5
+	workers := 1 << 6
 	if !parallel {
 		workers = 1
 	}

trie/zk_trie.go

@@ -271,7 +271,7 @@ func (t *ZkTrie) countLeaves(root *zkt.Hash, cb func(key, value []byte), depth i
 		cb(append([]byte{}, rootNode.NodeKey.Bytes()...), append([]byte{}, rootNode.Data()...))
 		return 1
 	} else {
-		if parallel && depth < 5 {
+		if parallel && depth < 6 {
 			count := make(chan uint64)
 			leftT := t.Copy()
 			rightT := t.Copy()