cerc-io/ipld-eth-server
12
0
Fork 1
Code Issues 10 Pull Requests 2 Actions Packages Projects Releases 37 Wiki Activity

Validator for static replicas to keep cache warm

Browse Source
This commit is contained in:
Ashwin Phatak 2021-08-26 17:05:53 +05:30 committed by Arijit Das
parent 1cfcc6776b
commit 758be29969
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
cmd/serve.go
View File

@ -94,7 +94,7 @@ func serve() {
}
if serverConfig.StateValidationEnabled {
go startStateTrieValidator(server, serverConfig.StateValidationEveryNthBlock)
go startStateTrieValidator(serverConfig, server)
logWithCommand.Info("state validator enabled")
} else {
logWithCommand.Info("state validator disabled")
@ -244,7 +244,9 @@ func startGroupCacheService(settings *s.Config) error {
return nil
}
func startStateTrieValidator(server s.Server, validateEveryNthBlock uint64) {
func startStateTrieValidator(config *s.Config, server s.Server) {
validateEveryNthBlock := config.StateValidationEveryNthBlock
var lastBlockNumber uint64 = 0
backend := server.Backend()
@ -261,7 +263,9 @@ func startStateTrieValidator(server s.Server, validateEveryNthBlock uint64) {
blockNumber := block.NumberU64()
blockHash := block.Hash()
if (blockNumber > lastBlockNumber) && (blockNumber%validateEveryNthBlock == 0) {
if validateEveryNthBlock <= 0 || // Used for static replicas where block number doesn't progress.
(blockNumber > lastBlockNumber) && (blockNumber%validateEveryNthBlock == 0) {
// The validate trie call will take a long time on mainnet, e.g. a few hours.
if err = backend.ValidateTrie(stateRoot); err != nil {
log.Fatalf("Error validating trie for block number %d hash %s state root %s",
@ -277,6 +281,11 @@ func startStateTrieValidator(server s.Server, validateEveryNthBlock uint64) {
stateRoot,
)
if validateEveryNthBlock <= 0 {
// Static replica, sleep a long-ish time (1/2 of cache expiry time) since we only need to keep the cache warm.
time.Sleep((time.Minute * time.Duration(config.GroupCache.StateDB.CacheExpiryInMins)) / 2)
}
lastBlockNumber = blockNumber
}
}