From 37de86645f8a415e96cbbe9b406b68111820eaa7 Mon Sep 17 00:00:00 2001 From: erickson Date: Thu, 20 Dec 2007 15:53:54 +0000 Subject: [PATCH] added a multisession class for agregating requets into a single recv manager git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@1181 9efc2488-bf62-4759-914b-345cdb29e865 --- src/python/osrf/ses.py | 53 ++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 53 insertions(+) diff --git a/src/python/osrf/ses.py b/src/python/osrf/ses.py index f8b2c21..fa4fe07 100644 --- a/src/python/osrf/ses.py +++ b/src/python/osrf/ses.py @@ -317,3 +317,56 @@ def AtomicRequest(service, method, *args): +class MultiSession(object): + ''' Manages multiple requests. With the current implementation, a 1 second + lag time before the first response is practically guaranteed. Use + only for long running requests. + + Another approach would be a threaded version, but that would require + build-up and breakdown of thread-specific xmpp connections somewhere. + conection pooling? + ''' + class Container(object): + def __init__(self, req): + self.req = req + self.id = None + + def __init__(self): + self.complete = False + self.reqs = [] + + def request(self, service, method, *args): + ses = ClientSession(service) + cont = MultiSession.Container(ses.request(method, *args)) + cont.id = len(self.reqs) + self.reqs.append(cont) + + def recv(self, timeout=10): + ''' Returns a tuple of req_id, response ''' + duration = 0 + block_time = 1 + while True: + for i in range(0, len(self.reqs)): + cont = self.reqs[i] + req = cont.req + + res = req.recv(0) + if i == 0 and not res: + res = req.recv(block_time) + + if res: break + + if res: break + + duration += block_time + if duration >= timeout: + return None + + if req.complete: + self.reqs.pop(self.reqs.index(cont)) + + if len(self.reqs) == 0: + self.complete = True + + return cont.id, res.content() + -- 2.43.2