added session.sync(); session.auto_sync; made transfers not auto-complete; fixed bug in RangedSet

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@634744 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 18 insertions, 0 deletions

diff --git a/python/qpid/delegates.py b/python/qpid/delegates.py
index 83413b91ea..a29d5c5265 100644
--- a/python/qpid/delegates.py
+++ b/python/qpid/delegates.py
@@ -20,6 +20,7 @@
 import connection010
 import session
 from util import notify
+from datatypes import RangedSet
 
 class Delegate:
 
@@ -79,6 +80,23 @@ class Delegate:
     ssn.receiver.next_id = cp.command_id
     ssn.receiver.next_offset = cp.command_offset
 
+  def session_completed(self, ch, cmp):
+    ch.session.sender.completed(cmp.commands)
+    notify(ch.session.condition)
+
+  def session_flush(self, ch, f):
+    rcv = ch.session.receiver
+    if f.expected:
+      if rcv.next_id == None:
+        exp = None
+      else:
+        exp = RangedSet(rcv.next_id)
+      ch.session_expected(exp)
+    if f.confirmed:
+      ch.session_confirmed(rcv._completed)
+    if f.completed:
+      ch.session_completed(rcv._completed)
+
 class Server(Delegate):
 
   def start(self):