Lines Matching refs:response
248 response = self.getresponse(seq, wait=0.05)
249 self.debug(("asyncreturn:%d:response: " % seq), response)
250 return self.decoderesponse(response)
252 def decoderesponse(self, response):
253 how, what = response
291 response = self._getresponse(myseq, wait)
292 if response is not None:
293 how, what = response
295 response = how, self._proxify(what)
296 return response
311 response = self.pollresponse(myseq, wait)
312 if response is not None:
313 return response
320 response = self.responses[myseq]
321 self.debug("_getresponse:%s: thread woke up: response: %s" %
322 (myseq, response))
326 return response
411 request/response) tuples and code using this module removing messages
415 pollresponse() will loop until a response message with the myseq
421 # send queued response if there is one available
427 seq, response = qmsg
428 message = (seq, ('OK', response))
446 response = self.localcall(seq, resq)
447 self.debug("pollresponse:%d:localcall:response:%s"
448 % (seq, response))
450 self.putmessage((seq, response))
458 # must be a response for a different thread:
461 # response involving unknown sequence number is discarded,