Lines Matching refs:seq
166 def localcall(self, seq, request):
193 request_queue.put((seq, (method, args, kwargs)))
210 seq = self.asynccall(oid, methodname, args, kwargs)
211 return self.asyncreturn(seq)
215 seq = self.asyncqueue(oid, methodname, args, kwargs)
216 return self.asyncreturn(seq)
220 seq = self.newseq()
223 self.cvars[seq] = cvar
224 self.debug(("asynccall:%d:" % seq), oid, methodname, args, kwargs)
225 self.putmessage((seq, request))
226 return seq
230 seq = self.newseq()
233 self.cvars[seq] = cvar
234 self.debug(("asyncqueue:%d:" % seq), oid, methodname, args, kwargs)
235 self.putmessage((seq, request))
236 return seq
238 def asyncreturn(self, seq):
239 self.debug("asyncreturn:%d:call getresponse(): " % seq)
240 response = self.getresponse(seq, wait=0.05)
241 self.debug(("asyncreturn:%d:response: " % seq), response)
269 pollresponse() will loop looking for seq number None, which
318 self.nextseq = seq = self.nextseq + 2
319 return seq
419 seq, response = qmsg
420 message = (seq, ('OK', response))
432 seq, resq = message
434 self.debug("pollresponse:%d:myseq:%s" % (seq, myseq))
437 self.debug("pollresponse:%d:localcall:call:" % seq)
438 response = self.localcall(seq, resq)
440 % (seq, response))
442 self.putmessage((seq, response))
448 elif seq == myseq:
452 cv = self.cvars.get(seq, None)
457 self.responses[seq] = resq
