diff options
-rw-r--r-- | java/common/src/main/java/org/apache/qpidity/transport/Session.java | 6 | ||||
-rw-r--r-- | java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java | 17 |
2 files changed, 18 insertions, 5 deletions
diff --git a/java/common/src/main/java/org/apache/qpidity/transport/Session.java b/java/common/src/main/java/org/apache/qpidity/transport/Session.java index e0bdcf789e..331e1517d1 100644 --- a/java/common/src/main/java/org/apache/qpidity/transport/Session.java +++ b/java/common/src/main/java/org/apache/qpidity/transport/Session.java @@ -226,11 +226,12 @@ public class Session extends Invoker } } - void complete(int lower, int upper) + boolean complete(int lower, int upper) { log.debug("%s complete(%d, %d)", this, lower, upper); synchronized (commands) { + int old = maxComplete; for (int id = max(maxComplete, lower); le(id, upper); id++) { commands.remove(id); @@ -239,8 +240,9 @@ public class Session extends Invoker { maxComplete = max(maxComplete, upper); } - commands.notifyAll(); log.debug("%s commands remaining: %s", this, commands); + commands.notifyAll(); + return gt(maxComplete, old); } } diff --git a/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java b/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java index bd56149b34..0e289c54e9 100644 --- a/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java +++ b/java/common/src/main/java/org/apache/qpidity/transport/SessionDelegate.java @@ -67,16 +67,27 @@ public abstract class SessionDelegate @Override public void sessionCompleted(Session ssn, SessionCompleted cmp) { RangeSet ranges = cmp.getCommands(); + RangeSet known = null; + if (cmp.getTimelyReply()) + { + known = new RangeSet(); + } + if (ranges != null) { for (Range range : ranges) { - ssn.complete(range.getLower(), range.getUpper()); + boolean advanced = ssn.complete(range.getLower(), range.getUpper()); + if (advanced && known != null) + { + known.add(range); + } } } - if (cmp.getTimelyReply()) + + if (known != null) { - ssn.sessionKnownCompleted(ranges); + ssn.sessionKnownCompleted(known); } } |