mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-03 17:44:29 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

mdbx: runtime options are changeable in Ascedee mode (#771)

Browse Source
This commit is contained in:
Alex Sharov 2022-12-07 17:10:32 +07:00 committed by GitHub
parent 263a9e3583
commit 3cf9b451e1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
kv/mdbx/kv_mdbx.go
View File

@ -30,7 +30,6 @@ import (
"github.com/c2h5oh/datasize" "github.com/c2h5oh/datasize"
stack2 "github.com/go-stack/stack" stack2 "github.com/go-stack/stack"
"github.com/ledgerwatch/erigon-lib/common/cmp"
"github.com/ledgerwatch/erigon-lib/common/dbg" "github.com/ledgerwatch/erigon-lib/common/dbg"
"github.com/ledgerwatch/erigon-lib/kv" "github.com/ledgerwatch/erigon-lib/kv"
"github.com/ledgerwatch/log/v3" "github.com/ledgerwatch/log/v3"
@ -257,9 +256,12 @@ func (opts MdbxOpts) Open() (kv.RwDB, error) {
} }
opts.pageSize = uint64(in.PageSize) opts.pageSize = uint64(in.PageSize)
//nolint
if opts.flags&mdbx.Accede == 0 && opts.flags&mdbx.Readonly == 0 {
}
// erigon using big transactions // erigon using big transactions
// increase "page measured" options. need do it after env.Open() because default are depend on pageSize known only after env.Open() // increase "page measured" options. need do it after env.Open() because default are depend on pageSize known only after env.Open()
if opts.flags&mdbx.Accede == 0 && opts.flags&mdbx.Readonly == 0 { if opts.flags&mdbx.Readonly == 0 {
// 1/8 is good for transactions with a lot of modifications - to reduce invalidation size. // 1/8 is good for transactions with a lot of modifications - to reduce invalidation size.
// But Erigon app now using Batch and etl.Collectors to avoid writing to DB frequently changing data. // But Erigon app now using Batch and etl.Collectors to avoid writing to DB frequently changing data.
// It means most of our writes are: APPEND or "single UPSERT per key during transaction" // It means most of our writes are: APPEND or "single UPSERT per key during transaction"
@ -307,7 +309,7 @@ func (opts MdbxOpts) Open() (kv.RwDB, error) {
} }
if opts.roTxsLimiter == nil { if opts.roTxsLimiter == nil {
targetSemCount := int64(cmp.Max(32, runtime.GOMAXPROCS(-1)*8)) targetSemCount := int64(runtime.GOMAXPROCS(-1) * 8)
opts.roTxsLimiter = semaphore.NewWeighted(targetSemCount) // 1 less than max to allow unlocking to happen opts.roTxsLimiter = semaphore.NewWeighted(targetSemCount) // 1 less than max to allow unlocking to happen
} }
db := &MdbxKV{ db := &MdbxKV{