erigon-pulse/cmd/integration/commands/root.go

122 lines
3.1 KiB
Go
Raw Normal View History

2020-07-14 01:56:29 +00:00
package commands
import (
2023-03-26 03:36:23 +00:00
"context"
"fmt"
"os"
"path/filepath"
"strings"
2021-07-29 10:23:23 +00:00
"github.com/ledgerwatch/log/v3"
2020-07-14 01:56:29 +00:00
"github.com/spf13/cobra"
"golang.org/x/sync/semaphore"
2023-06-09 06:46:58 +00:00
"github.com/ledgerwatch/erigon-lib/kv"
"github.com/ledgerwatch/erigon-lib/kv/kvcfg"
kv2 "github.com/ledgerwatch/erigon-lib/kv/mdbx"
"github.com/ledgerwatch/erigon/cmd/utils"
2023-06-02 03:35:26 +00:00
"github.com/ledgerwatch/erigon/core/state/temporal"
"github.com/ledgerwatch/erigon/core/systemcontracts"
"github.com/ledgerwatch/erigon/migrations"
"github.com/ledgerwatch/erigon/turbo/debug"
"github.com/ledgerwatch/erigon/turbo/logging"
2020-07-14 01:56:29 +00:00
)
func expandHomeDir(dirpath string) string {
home, err := os.UserHomeDir()
if err != nil {
return dirpath
}
prefix := fmt.Sprintf("~%c", os.PathSeparator)
if strings.HasPrefix(dirpath, prefix) {
return filepath.Join(home, dirpath[len(prefix):])
} else if dirpath == "~" {
return home
}
return dirpath
}
2020-07-14 01:56:29 +00:00
var rootCmd = &cobra.Command{
Use: "integration",
Short: "long and heavy integration tests for Erigon",
2020-07-14 01:56:29 +00:00
PersistentPreRun: func(cmd *cobra.Command, args []string) {
datadirCli = expandHomeDir(datadirCli)
if chaindata == "" {
2022-06-07 04:00:37 +00:00
chaindata = filepath.Join(datadirCli, "chaindata")
} else {
chaindata = expandHomeDir(chaindata)
}
2020-07-14 01:56:29 +00:00
},
2020-08-20 03:52:27 +00:00
PersistentPostRun: func(cmd *cobra.Command, args []string) {
defer debug.Exit()
2020-08-20 03:52:27 +00:00
},
2020-07-14 01:56:29 +00:00
}
func RootCommand() *cobra.Command {
utils.CobraFlags(rootCmd, debug.Flags, utils.MetricFlags, logging.Flags)
return rootCmd
2020-07-14 01:56:29 +00:00
}
2022-08-12 14:45:09 +00:00
func dbCfg(label kv.Label, path string) kv2.MdbxOpts {
2022-12-20 15:59:23 +00:00
const ThreadsLimit = 9_000
limiterB := semaphore.NewWeighted(ThreadsLimit)
opts := kv2.NewMDBX(log.New()).Path(path).Label(label).RoTxsLimiter(limiterB).Accede()
//if label == kv.ChainDB {
// opts = opts.MapSize(8 * datasize.TB)
//}
if databaseVerbosity != -1 {
opts = opts.DBVerbosity(kv.DBVerbosityLvl(databaseVerbosity))
}
return opts
}
func openDB(opts kv2.MdbxOpts, applyMigrations bool, logger log.Logger) (kv.RwDB, error) {
// integration tool don't intent to create db, then easiest way to open db - it's pass mdbx.Accede flag, which allow
// to read all options from DB, instead of overriding them
opts = opts.Accede()
2022-12-02 14:01:43 +00:00
db := opts.MustOpen()
if applyMigrations {
migrator := migrations.NewMigrator(opts.GetLabel())
has, err := migrator.HasPendingMigrations(db)
if err != nil {
return nil, err
}
if has {
logger.Info("Re-Opening DB in exclusive mode to apply DB migrations")
db.Close()
db = opts.Exclusive().MustOpen()
if err := migrator.Apply(db, datadirCli, logger); err != nil {
return nil, err
}
db.Close()
db = opts.MustOpen()
}
}
2023-03-26 03:36:23 +00:00
if opts.GetLabel() == kv.ChainDB {
var h3 bool
var err error
if err := db.View(context.Background(), func(tx kv.Tx) error {
h3, err = kvcfg.HistoryV3.Enabled(tx)
if err != nil {
return err
}
return nil
}); err != nil {
return nil, err
2023-03-26 03:36:23 +00:00
}
if h3 {
_, _, agg := allSnapshots(context.Background(), db, logger)
2023-06-02 03:35:26 +00:00
tdb, err := temporal.New(db, agg, systemcontracts.SystemContractCodeLookup[chain])
2023-03-26 03:36:23 +00:00
if err != nil {
return nil, err
2023-03-26 03:36:23 +00:00
}
db = tdb
}
}
return db, nil
}