diff --git a/router/java/src/net/i2p/router/util/CoDelBlockingQueue.java b/router/java/src/net/i2p/router/util/CoDelBlockingQueue.java index 6c742e7eba..77a995d213 100644 --- a/router/java/src/net/i2p/router/util/CoDelBlockingQueue.java +++ b/router/java/src/net/i2p/router/util/CoDelBlockingQueue.java @@ -248,7 +248,7 @@ public class CoDelBlockingQueue extends LinkedBlockingQueue< if (!ok_to_drop) { // sojurn time below target - leave dropping state _dropping = false; - } else if (_now >= _drop_next) { + } else { // It's time for the next drop. Drop the current packet and dequeue the next. // The dequeue might take us out of dropping state. If not, schedule the next drop. // A large backlog might result in drop rates so high that the next drop should happen now; diff --git a/router/java/src/net/i2p/router/util/CoDelPriorityBlockingQueue.java b/router/java/src/net/i2p/router/util/CoDelPriorityBlockingQueue.java index e84ec651ee..f15dad4872 100644 --- a/router/java/src/net/i2p/router/util/CoDelPriorityBlockingQueue.java +++ b/router/java/src/net/i2p/router/util/CoDelPriorityBlockingQueue.java @@ -230,7 +230,7 @@ public class CoDelPriorityBlockingQueue extends PriBlocking if (!ok_to_drop) { // sojurn time below target - leave dropping state _dropping = false; - } else if (_now >= _drop_next) { + } else { // It's time for the next drop. Drop the current packet and dequeue the next. // The dequeue might take us out of dropping state. If not, schedule the next drop. // A large backlog might result in drop rates so high that the next drop should happen now;