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

"erigon snapshots ram" command (#5449)

Browse Source 
* save

* save

* save
This commit is contained in:
Alex Sharov 2022-09-21 09:18:37 +07:00 committed by GitHub
parent 46f8d891d5
commit 50811f9cd6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
turbo/app/snapshots.go
View File

@ -86,6 +86,12 @@ var snapshotCommand = cli.Command{
Before: func(ctx *cli.Context) error { return debug.Setup(ctx) }, Before: func(ctx *cli.Context) error { return debug.Setup(ctx) },
Flags: append([]cli.Flag{utils.DataDirFlag}, debug.Flags...), Flags: append([]cli.Flag{utils.DataDirFlag}, debug.Flags...),
}, },
{
Name: "ram",
Action: doRam,
Before: func(ctx *cli.Context) error { return debug.Setup(ctx) },
Flags: append([]cli.Flag{utils.DataDirFlag}, debug.Flags...),
},
}, },
} }
@ -116,6 +122,26 @@ var (
} }
) )
func doRam(cliCtx *cli.Context) error {
args := cliCtx.Args()
if len(args) != 1 {
return fmt.Errorf("expecting .seg file path")
}
f := args[0]
var m runtime.MemStats
runtime.ReadMemStats(&m)
runtime.ReadMemStats(&m)
before := m.Alloc
log.Info("RAM before open", "alloc", common.ByteCount(m.Alloc), "sys", common.ByteCount(m.Sys))
decompressor, err := compress.NewDecompressor(f)
if err != nil {
return err
}
defer decompressor.Close()
runtime.ReadMemStats(&m)
log.Info("RAM after open", "alloc", common.ByteCount(m.Alloc), "sys", common.ByteCount(m.Sys), "diff", common.ByteCount(m.Alloc-before))
return nil
}
func doIndicesCommand(cliCtx *cli.Context) error { func doIndicesCommand(cliCtx *cli.Context) error {
ctx, cancel := common.RootContext() ctx, cancel := common.RootContext()
defer cancel() defer cancel()