(self)
| 300 | self.sock.close() |
| 301 | |
| 302 | def do_call(self): |
| 303 | call = self.packer.get_buf() |
| 304 | sendrecord(self.sock, call) |
| 305 | reply = recvrecord(self.sock) |
| 306 | u = self.unpacker |
| 307 | u.reset(reply) |
| 308 | xid, verf = u.unpack_replyheader() |
| 309 | if xid != self.lastxid: |
| 310 | # Can't really happen since this is TCP... |
| 311 | raise RPCError('wrong xid in reply %r instead of %r' % (xid, self.lastxid)) |
| 312 | |
| 313 | |
| 314 | # Client using UDP to a specific port |
nothing calls this directly
no test coverage detected