use max msgs for ack flush

cosmos · Jul 21, 2023 · beea0e6 · beea0e6
1 parent 7ec30a3
commit beea0e6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/relayer/processor/path_processor.go b/relayer/processor/path_processor.go
@@ -30,7 +30,7 @@ const (
 	interchainQueryTimeout = 60 * time.Second
 
 	// Amount of time between flushes if the previous flush failed.
-	flushFailureRetry = 15 * time.Second
+	flushFailureRetry = 10 * time.Second
 
 	// If message assembly fails from either proof query failure on the source
 	// or assembling the message for the destination, how many blocks should pass

diff --git a/relayer/processor/path_processor_internal.go b/relayer/processor/path_processor_internal.go
@@ -19,9 +19,8 @@ import (
 // i.e. a MsgConnectionOpenInit or a MsgChannelOpenInit should be broadcasted to start
 // the handshake if this key exists in the relevant cache.
 const (
-	preInitKey         = "pre_init"
-	preCloseKey        = "pre_close"
-	maxPacketsPerFlush = 10
+	preInitKey  = "pre_init"
+	preCloseKey = "pre_close"
 )
 
 // getMessagesToSend returns only the lowest sequence message (if it should be sent) for ordered channels,
@@ -1289,7 +1288,7 @@ SeqLoop:
 		}
 		dstMu.Unlock()
 
-		if i >= maxPacketsPerFlush {
+		if i >= int(pp.maxMsgs) {
 			skipped = true
 			break
 		}