Skip to content

Commit d633b78

Browse files
dai1975Copilot
andauthored
Update core/naive-strategy.go
Co-authored-by: Copilot <[email protected]> Signed-off-by: Daisuke Kanda <[email protected]>
1 parent c1acdf7 commit d633b78

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
@@ -275,6 +275,9 @@ func (st *NaiveStrategy) ProcessTimeoutPackets(ctx context.Context, src, dst *Pr
275275
// For ordered channel, a timeout notification will cause the channel to be closed.
276276
// Packets proceeding the timeout packet is relayed first
277277
// so that they can be proceeded before the channel is closed.
278+
// In ordered channels, only the first timed-out packet is selected because
279+
// a timeout notification will close the channel. Subsequent packets cannot
280+
// be processed once the channel is closed.
278281
if i == 0 {
279282
srcTimeoutPacket = p
280283
}

0 commit comments

Comments
 (0)