From 31b20710d5d52a5747e9e940d5902c70b0cee576 Mon Sep 17 00:00:00 2001 From: Alex Gartner Date: Sat, 7 Sep 2024 10:15:16 -0700 Subject: [PATCH] manually cherry pick https://github.com/zeta-chain/node/pull/2843 --- zetaclient/orchestrator/orchestrator.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/zetaclient/orchestrator/orchestrator.go b/zetaclient/orchestrator/orchestrator.go index 93b3af3893..fc7c6b059c 100644 --- a/zetaclient/orchestrator/orchestrator.go +++ b/zetaclient/orchestrator/orchestrator.go @@ -450,6 +450,12 @@ func (oc *Orchestrator) ScheduleCctxEVM( // #nosec G115 positive outboundScheduleInterval := uint64(observer.GetChainParams().OutboundScheduleInterval) + // determining critical outbound; if it satisfies following criteria + // 1. it's the first pending outbound for this chain + // 2. the following 5 nonces have been in tracker + criticalInterval := uint64(10) // for critical pending outbound we reduce re-try interval + nonCriticalInterval := outboundScheduleInterval * 2 // for non-critical pending outbound we increase re-try interval + for idx, cctx := range cctxList { params := cctx.GetCurrentOutboundParam() nonce := params.TssNonce @@ -480,11 +486,6 @@ func (oc *Orchestrator) ScheduleCctxEVM( continue } - // determining critical outbound; if it satisfies following criteria - // 1. it's the first pending outbound for this chain - // 2. the following 5 nonces have been in tracker - criticalInterval := uint64(10) // for critical pending outbound we reduce re-try interval - nonCriticalInterval := outboundScheduleInterval * 2 // for non-critical pending outbound we increase re-try interval if nonce%criticalInterval == zetaHeight%criticalInterval { count := 0 for i := nonce + 1; i <= nonce+10; i++ {