| 102 | raise Exception('error: {}'.format(message)) |
| 103 | |
| 104 | def _send(self, action, payload=None): |
| 105 | if not payload: |
| 106 | payload = b'' |
| 107 | trans_id, header = self._request_header(action) |
| 108 | self.transactions[trans_id] = trans = { |
| 109 | 'action': action, |
| 110 | 'time': time.time(), |
| 111 | 'payload': payload, |
| 112 | 'completed': False, |
| 113 | } |
| 114 | self.sock.connect((self.host, self.port)) |
| 115 | self.sock.send(header + payload) |
| 116 | return trans |
| 117 | |
| 118 | def _request_header(self, action): |
| 119 | trans_id = random.randint(0, (1 << 32) - 1) |