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

mdbx mergeThreshold option #665

Browse Source
This commit is contained in:
Alex Sharov 2022-10-03 16:53:23 +07:00 committed by GitHub
parent ca2ebac0f9
commit 9860f845fe
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
kv/mdbx/kv_mdbx.go
View File

@ -59,6 +59,11 @@ type MdbxOpts struct {
syncPeriod time.Duration syncPeriod time.Duration
augumentLimit uint64 augumentLimit uint64
pageSize uint64 pageSize uint64
// must be in the range from 12.5% (almost empty) to 50% (half empty)
// which corresponds to the range from 8192 and to 32768 in units respectively
mergeThreshold uint64
roTxsLimiter *semaphore.Weighted roTxsLimiter *semaphore.Weighted
} }
@ -77,6 +82,7 @@ func NewMDBX(log log.Logger) MdbxOpts {
log: log, log: log,
pageSize: kv.DefaultPageSize(), pageSize: kv.DefaultPageSize(),
growthStep: 2 * datasize.GB, growthStep: 2 * datasize.GB,
mergeThreshold: 32768,
} }
} }
@ -160,6 +166,11 @@ func (opts MdbxOpts) WriteMap() MdbxOpts {
return opts return opts
} }
func (opts MdbxOpts) WriteMergeThreshold(v uint64) MdbxOpts {
opts.mergeThreshold = v
return opts
}
func (opts MdbxOpts) WithTableCfg(f TableCfgFunc) MdbxOpts { func (opts MdbxOpts) WithTableCfg(f TableCfgFunc) MdbxOpts {
opts.bucketsCfg = f opts.bucketsCfg = f
return opts return opts
@ -263,7 +274,7 @@ func (opts MdbxOpts) Open() (kv.RwDB, error) {
} }
// must be in the range from 12.5% (almost empty) to 50% (half empty) // must be in the range from 12.5% (almost empty) to 50% (half empty)
// which corresponds to the range from 8192 and to 32768 in units respectively // which corresponds to the range from 8192 and to 32768 in units respectively
if err = env.SetOption(mdbx.OptMergeThreshold16dot16Percent, 32768); err != nil { if err = env.SetOption(mdbx.OptMergeThreshold16dot16Percent, opts.mergeThreshold); err != nil {
return nil, err return nil, err
} }
} }