Skip to content

Commit

Permalink
fix: avoid packet message get removed before open channel
Browse files Browse the repository at this point in the history
  • Loading branch information
mmsqe committed May 1, 2024
1 parent 84f610d commit 5ab054b
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 2 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@
* [\#1326](https://github.com/cosmos/relayer/pull/1326) Avoid sending channel close confirm message after channel get closed successfully.
* [\#1364](https://github.com/cosmos/relayer/pull/1364) Include feegrant message when calculate gas.
* [\#1390](https://github.com/cosmos/relayer/pull/1390) Avoid no concrete type registered for type URL error of EthAccount.
* [\#](https://github.com/cosmos/relayer/pull/) Allow retry for pathEnd to avoid packet message get removed before open channel.

## v0.9.3

Expand Down
9 changes: 7 additions & 2 deletions relayer/processor/path_end_runtime.go
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@ type pathEndRuntime struct {
metrics *PrometheusMetrics

finishedProcessing chan messageToTrack
retryCount uint64
}

func newPathEndRuntime(log *zap.Logger, pathEnd PathEnd, metrics *PrometheusMetrics) *pathEndRuntime {
Expand Down Expand Up @@ -560,8 +561,12 @@ func (pathEnd *pathEndRuntime) shouldSendPacketMessage(message packetIBCMessage,
zap.Uint64("sequence", sequence),
zap.Inline(k),
)
pathEnd.removePacketRetention(counterparty, eventType, k, sequence)
return false
pathEnd.retryCount++
if pathEnd.retryCount >= maxMessageSendRetries {
pathEnd.removePacketRetention(counterparty, eventType, k, sequence)
pathEnd.retryCount = 0
return false
}
}
msgProcessCache, ok := pathEnd.packetProcessing[k]
if !ok {
Expand Down

0 comments on commit 5ab054b

Please sign in to comment.