mirror of
https://gitlab.com/pulsechaincom/erigon-pulse.git
synced 2025-01-03 09:37:38 +00:00
Add STOP_AFTER_STAGE environ (#5207)
Adds ability to stop after a stage instead of just before a stage. This will allow users to use something like: `STOP_AFTER_STAGE=Finish erigon` And erigon will stop after a full cycle of syncing.
This commit is contained in:
parent
12331e018a
commit
002aba4686
@ -57,7 +57,7 @@ Additional info:
|
|||||||
|
|
||||||
```shell
|
```shell
|
||||||
# Snapshots creation does not require fully-synced Erigon - few first stages enough. For example:
|
# Snapshots creation does not require fully-synced Erigon - few first stages enough. For example:
|
||||||
STOP_BEFORE_STAGE=Execution ./build/bin/erigon --snapshots=false --datadir=<your_datadir>
|
STOP_AFTER_STAGE=Senders ./build/bin/erigon --snapshots=false --datadir=<your_datadir>
|
||||||
# But for security - better have fully-synced Erigon
|
# But for security - better have fully-synced Erigon
|
||||||
|
|
||||||
|
|
||||||
|
@ -70,6 +70,8 @@ func SlowCommit() time.Duration {
|
|||||||
var (
|
var (
|
||||||
stopBeforeStage string
|
stopBeforeStage string
|
||||||
stopBeforeStageFlag sync.Once
|
stopBeforeStageFlag sync.Once
|
||||||
|
stopAfterStage string
|
||||||
|
stopAfterStageFlag sync.Once
|
||||||
)
|
)
|
||||||
|
|
||||||
func StopBeforeStage() string {
|
func StopBeforeStage() string {
|
||||||
@ -82,3 +84,17 @@ func StopBeforeStage() string {
|
|||||||
stopBeforeStageFlag.Do(f)
|
stopBeforeStageFlag.Do(f)
|
||||||
return stopBeforeStage
|
return stopBeforeStage
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TODO(allada) We should possibly consider removing `STOP_BEFORE_STAGE`, as `STOP_AFTER_STAGE` can
|
||||||
|
// perform all same the functionality, but due to reverse compatibility reasons we are going to
|
||||||
|
// leave it.
|
||||||
|
func StopAfterStage() string {
|
||||||
|
f := func() {
|
||||||
|
v, _ := os.LookupEnv("STOP_AFTER_STAGE") // see names in eth/stagedsync/stages/stages.go
|
||||||
|
if v != "" {
|
||||||
|
stopAfterStage = v
|
||||||
|
}
|
||||||
|
}
|
||||||
|
stopAfterStageFlag.Do(f)
|
||||||
|
return stopAfterStage
|
||||||
|
}
|
||||||
|
@ -256,6 +256,11 @@ func (s *Sync) Run(db kv.RwDB, tx kv.RwTx, firstCycle bool) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if string(stage.ID) == debug.StopAfterStage() { // stop process for debugging reasons
|
||||||
|
log.Warn("STOP_AFTER_STAGE env flag forced to stop app")
|
||||||
|
return libcommon.ErrStopped
|
||||||
|
}
|
||||||
|
|
||||||
s.NextStage()
|
s.NextStage()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user