mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2024-12-25 13:07:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

rpcdaemon, stagedsync: make sure we update the current block number after a sync cycle (#1015)

Browse Source 
* rpcdaemon, stagedsync: make sure we update the current block number after a sync cycle

fixes #1014

* linters
This commit is contained in:
Igor Mandrigin 2020-08-30 18:51:06 +02:00 committed by GitHub
parent 5365b8e402
commit a1a7f6607a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 26 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/rpcdaemon/commands/eth_api.go
View File

@ -52,7 +52,7 @@ func NewAPI(db ethdb.KV, dbReader ethdb.Getter, eth ethdb.Backend, gascap uint64
}
func (api *APIImpl) BlockNumber(ctx context.Context) (hexutil.Uint64, error) {
execution, _, err := stages.GetStageProgress(api.dbReader, stages.Execution)
execution, _, err := stages.GetStageProgress(api.dbReader, stages.Finish)
if err != nil {
return 0, err
}

5
eth/stagedsync/README.md
View File

@ -158,3 +158,8 @@ During this stage we start the transaction pool or update its state. For instanc
On unwinds, we add the transactions from the blocks we unwind, back to the pool.
This stage doesn't use a network connection.
### Stage 12: Finish
This stage sets the current block number that is then used by [RPC calls](../../cmd/rpcdaemon/Readme.md), such as [`eth_blockNumber`](../../README.md).

20
eth/stagedsync/stagedsync.go
View File

@ -170,6 +170,26 @@ func (*StagedSync) Prepare(
return unwindTxPool(u, s, tx, txPool, quitCh)
},
},
{
ID: stages.Finish,
Description: "Final: update current block for the RPC API",
ExecFunc: func(s *StageState, _ Unwinder) error {
var executionAt uint64
var err error
if executionAt, err = s.ExecutionAt(tx); err != nil {
return err
}
return s.DoneAndUpdate(tx, executionAt)
},
UnwindFunc: func(u *UnwindState, s *StageState) error {
var executionAt uint64
var err error
if executionAt, err = s.ExecutionAt(tx); err != nil {
return err
}
return s.DoneAndUpdate(tx, executionAt)
},
},
}
state := NewState(stages)