ynl/lib/ynl.py

101   def __init__(self, nl_msg):
102     self.nl_msg = nl_msg
103     self.error = -nl_msg.error
106     return f"Netlink error: {os.strerror(self.error)}\n{self.nl_msg}"
323             for nl_msg in nms:
324                 if nl_msg.error:
325                     print("Netlink error:", nl_msg.error)
327                 if nl_msg.done:
330                 gm = GenlMsg(nl_msg)
356     def __init__(self, nl_msg):
357         self.nl = nl_msg
358         self.genl_cmd, self.genl_version, _ = struct.unpack_from("BBH", nl_msg.raw, 0)
359         self.raw = nl_msg.raw[4:]
386     def _decode(self, nl_msg):
387         return nl_msg
389     def decode(self, ynl, nl_msg, op):
390         msg = self._decode(nl_msg)
420     def _decode(self, nl_msg):
421         return GenlMsg(nl_msg)
515         for nl_msg in nl_msgs:
516             print("  ", nl_msg, file=sys.stderr)
913             for nl_msg in nms:
914                 if nl_msg.error:
915                     print("Netlink error in ntf!?", os.strerror(-nl_msg.error))
916                     print(nl_msg)
918                 if nl_msg.done:
922                 op = self.rsp_by_value[nl_msg.cmd()]
923                 decoded = self.nlproto.decode(self, nl_msg, op)
975             for nl_msg in nms:
976                 if nl_msg.nl_seq in reqs_by_seq:
977                     (op, req_msg, req_flags) = reqs_by_seq[nl_msg.nl_seq]
978                     if nl_msg.extack:
979                         self._decode_extack(req_msg, op, nl_msg.extack)
981                     op = self.rsp_by_value[nl_msg.cmd()]
984                 if nl_msg.error:
985                     raise NlError(nl_msg)
986                 if nl_msg.done:
987                     if nl_msg.extack:
989                         print(nl_msg)
1001                     del reqs_by_seq[nl_msg.nl_seq]
1005                 decoded = self.nlproto.decode(self, nl_msg, op)
1008                 if nl_msg.nl_seq not in reqs_by_seq or decoded.cmd() != op.rsp_value: