(self, oid, methodname, args, kwargs)
| 234 | return seq |
| 235 | |
| 236 | def asyncqueue(self, oid, methodname, args, kwargs): |
| 237 | request = ("QUEUE", (oid, methodname, args, kwargs)) |
| 238 | seq = self.newseq() |
| 239 | if threading.current_thread() != self.sockthread: |
| 240 | cvar = threading.Condition() |
| 241 | self.cvars[seq] = cvar |
| 242 | self.debug(("asyncqueue:%d:" % seq), oid, methodname, args, kwargs) |
| 243 | self.putmessage((seq, request)) |
| 244 | return seq |
| 245 | |
| 246 | def asyncreturn(self, seq): |
| 247 | self.debug("asyncreturn:%d:call getresponse(): " % seq) |
no test coverage detected