Add config param for missed-blocks-threshold

strangelove-ventures · Jul 21, 2022 · b31be3c · b31be3c
1 parent 0b8d482
commit b31be3c
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 4 deletions.
diff --git a/cmd/config.go b/cmd/config.go
@@ -172,6 +172,7 @@ type ValidatorMonitor struct {
 	ChainID                string    `yaml:"chain-id"`
 	DiscordStatusMessageID *string   `yaml:"discord-status-message-id"`
 	RPCRetries             *int      `yaml:"rpc-retries"`
+	MissedBlocksThreshold  *int64    `yaml:"missed-blocks-threshold"`
 	Sentries               *[]Sentry `yaml:"sentries"`
 }
 

diff --git a/cmd/validator.go b/cmd/validator.go
@@ -12,9 +12,10 @@ import (
 )
 
 const (
-	rpcErrorRetries          = 5
-	outOfSyncThreshold       = 5
-	haltThresholdNanoseconds = 3e11 // if nodes are stuck for > 5 minutes, will be considered halt
+	rpcErrorRetries              = 5
+	outOfSyncThreshold           = 5
+	haltThresholdNanoseconds     = 3e11 // if nodes are stuck for > 5 minutes, will be considered halt
+	defaultMissedBlocksThreshold = 0
 )
 
 func monitorValidator(
@@ -108,7 +109,14 @@ func monitorValidator(
 			}
 		}
 
-		if !vm.FullNode && stats.RecentMissedBlocks > 0 {
+		var missedBlocksThreshold int64
+		if vm.MissedBlocksThreshold == nil {
+			missedBlocksThreshold = defaultMissedBlocksThreshold
+		} else {
+			missedBlocksThreshold = *vm.MissedBlocksThreshold
+		}
+
+		if !vm.FullNode && stats.RecentMissedBlocks > missedBlocksThreshold {
 			errs = append(errs, newMissedRecentBlocksError(stats.RecentMissedBlocks))
 			// Go back to find last signed block
 			if stats.LastSignedBlockHeight == -1 {