Drop expired packets in the processing chain.

This commit is contained in:
Kristian S. Stangeland 2012-11-02 01:18:38 +01:00
parent cda235af7e
commit 5ac15f11dc

View File

@ -441,12 +441,14 @@ public class AsyncListenerHandler {
}
// Now, get the next non-cancelled listener
for (; marker.getListenerTraversal().hasNext(); ) {
AsyncListenerHandler handler = marker.getListenerTraversal().next().getListener();
if (!handler.isCancelled()) {
handler.enqueuePacket(packet);
continue mainLoop;
if (!marker.hasExpired()) {
for (; marker.getListenerTraversal().hasNext(); ) {
AsyncListenerHandler handler = marker.getListenerTraversal().next().getListener();
if (!handler.isCancelled()) {
handler.enqueuePacket(packet);
continue mainLoop;
}
}
}