increase threshold for lock timings

Switcheo · Jun 4, 2024 · 9a55922 · 9a55922
1 parent f178e00
commit 9a55922
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 6 deletions.
diff --git a/oracle/reactor.go b/oracle/reactor.go
@@ -162,7 +162,7 @@ func (oracleR *Reactor) Receive(e p2p.Envelope) {
 		oracleR.OracleInfo.GossipVoteBuffer.UpdateMtx.Unlock()
 		postLockTime := time.Now().UnixMilli()
 		diff := postLockTime - preLockTime
-		if diff > 10 {
+		if diff > 100 {
 			logrus.Warnf("WARNING!!! Receiving gossip lock took %v milliseconds", diff)
 		}
 	default:
@@ -231,7 +231,7 @@ func (oracleR *Reactor) broadcastVoteRoutine(peer p2p.Peer) {
 		oracleR.OracleInfo.GossipVoteBuffer.UpdateMtx.RUnlock()
 		postLockTime := time.Now().UnixMilli()
 		diff := postLockTime - preLockTime
-		if diff > 10 {
+		if diff > 100 {
 			logrus.Warnf("WARNING!!! Sending gossip lock took %v milliseconds", diff)
 		}
 

diff --git a/oracle/service/runner/runner.go b/oracle/service/runner/runner.go
@@ -85,7 +85,7 @@ func ProcessSignVoteQueue(oracleInfo *types.OracleInfo, consensusState *cs.State
 	oracleInfo.GossipVoteBuffer.UpdateMtx.Unlock()
 	postLockTime := time.Now().UnixMilli()
 	diff := postLockTime - preLockTime
-	if diff > 10 {
+	if diff > 100 {
 		log.Warnf("WARNING!!! Updating gossip lock took %v milliseconds", diff)
 	}
 }
@@ -164,7 +164,7 @@ func PruneVoteBuffers(oracleInfo *types.OracleInfo, consensusState *cs.State) {
 			oracleInfo.GossipVoteBuffer.UpdateMtx.Unlock()
 			postLockTime := time.Now().UnixMilli()
 			diff := postLockTime - preLockTime
-			if diff > 10 {
+			if diff > 100 {
 				log.Warnf("WARNING!!! Pruning gossip lock took %v milliseconds", diff)
 			}
 		}

diff --git a/state/execution.go b/state/execution.go
@@ -134,7 +134,6 @@ func (blockExec *BlockExecutor) CreateProposalBlock(
 	commit := lastExtCommit.ToCommit()
 	block := state.MakeBlock(height, txs, commit, evidence, proposerAddr)
 	txSlice := block.Txs.ToSliceOfBytes()
-	logrus.Infof("Proposer :%v, preparing block proposal for height: %v", block.ProposerAddress.String(), block.Height)
 	rpp, err := blockExec.proxyApp.PrepareProposal(
 		ctx,
 		&abci.RequestPrepareProposal{
@@ -179,7 +178,7 @@ func (blockExec *BlockExecutor) CreateProposalBlock(
 	blockExec.oracleInfo.GossipVoteBuffer.UpdateMtx.RUnlock()
 	postLockTime := time.Now().UnixMilli()
 	diff := postLockTime - preLockTime
-	if diff > 10 {
+	if diff > 100 {
 		logrus.Warnf("WARNING!!! Injecting oracle tx gossip lock took %v milliseconds", diff)
 	}