(self, msg, no_type_conversion=False)
| 522 | return False |
| 523 | |
| 524 | def decode_incoming_msg(self, msg, no_type_conversion=False): |
| 525 | if not msg: |
| 526 | logger.warning("vpp_api.read failed") |
| 527 | return |
| 528 | |
| 529 | (i, ci), size = self.header.unpack(msg, 0) |
| 530 | if self.id_names[i] == "rx_thread_exit": |
| 531 | return |
| 532 | |
| 533 | # |
| 534 | # Decode message and returns a tuple. |
| 535 | # |
| 536 | msgobj = self.id_msgdef[i] |
| 537 | if not msgobj: |
| 538 | raise VPPIOError(2, "Reply message undefined") |
| 539 | |
| 540 | r, size = msgobj.unpack(msg, ntc=no_type_conversion) |
| 541 | return r |
| 542 | |
| 543 | def _control_ping(self, context): |
| 544 | """Send a ping command.""" |
no test coverage detected