Send a binary-packed message to VPP.
(self, buf)
| 181 | return max(self.message_table.values() or [0]) |
| 182 | |
| 183 | def write(self, buf): |
| 184 | """Send a binary-packed message to VPP.""" |
| 185 | if not self.connected: |
| 186 | raise VppTransportSocketIOError(1, "Not connected") |
| 187 | |
| 188 | # Send header |
| 189 | header = self.header.pack(0, len(buf), 0) |
| 190 | try: |
| 191 | self.socket.sendall(header) |
| 192 | self.socket.sendall(buf) |
| 193 | except socket.error as err: |
| 194 | raise VppTransportSocketIOError(1, "Sendall error: {err!r}".format(err=err)) |
| 195 | |
| 196 | def _read_fixed(self, size): |
| 197 | """Repeat receive until fixed size is read. Return empty on error.""" |