From 205ae0e54ba0c5fdeb5d2e884997c80cb52f1799 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Fri, 7 Mar 2008 16:57:43 +0000 Subject: 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 --- python/qpid/delegates.py | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) (limited to 'python/qpid/delegates.py') 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): -- cgit v1.2.1