Skip to content

Commit a02d1fb

Browse files
dai1975Copilot
authored andcommitted
Update core/naive-strategy.go
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> Signed-off-by: Daisuke Kanda <dai1975@gmail.com>
1 parent b62e0b2 commit a02d1fb

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

core/naive-strategy.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -277,6 +277,9 @@ func (st *NaiveStrategy) ProcessTimeoutPackets(ctx context.Context, src, dst *Pr
277277
// For ordered channel, a timeout notification will cause the channel to be closed.
278278
// Packets proceeding the timeout packet is relayed first
279279
// so that they can be proceeded before the channel is closed.
280+
// In ordered channels, only the first timed-out packet is selected because
281+
// a timeout notification will close the channel. Subsequent packets cannot
282+
// be processed once the channel is closed.
280283
if i == 0 {
281284
srcTimeoutPacket = p
282285
}

0 commit comments

Comments
 (0)