Skip to content

Commit

Permalink
Don't error when trying to put the same report to the inflight
Browse files Browse the repository at this point in the history
  • Loading branch information
mateusz-sekara committed Apr 2, 2024
1 parent e20cfca commit 1664d67
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions core/services/ocr2/plugins/ccip/ccipexec/inflight.go
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,6 @@ func (container *inflightExecReportsContainer) expire(lggr logger.Logger) {
"Inflight report expired",
"minSeqNr", report.messages[0].SequenceNumber,
"maxSeqNr", report.messages[len(report.messages)-1].SequenceNumber,
"messages", report.messages,
)
} else {
stillInFlight = append(stillInFlight, report)
Expand All @@ -70,7 +69,7 @@ func (container *inflightExecReportsContainer) add(lggr logger.Logger, messages
container.locker.Lock()
defer container.locker.Unlock()

tmpReports := container.reports[:0]
tmpReports := make([]InflightInternalExecutionReport, 0, len(container.reports))
for _, report := range container.reports {
if (len(report.messages) > 0) && (report.messages[0].SequenceNumber == messages[0].SequenceNumber) {
// This should be very rare case, happening only when transmitters are not reliable enough
Expand Down

0 comments on commit 1664d67

Please sign in to comment.