Lines Matching defs:nl_msg

103   def __init__(self, nl_msg):
104     self.nl_msg = nl_msg
105     self.error = -nl_msg.error
108     return f"Netlink error: {os.strerror(self.error)}\n{self.nl_msg}"
330             for nl_msg in nms:
331                 if nl_msg.error:
332                     print("Netlink error:", nl_msg.error)
334                 if nl_msg.done:
337                 gm = GenlMsg(nl_msg)
363     def __init__(self, nl_msg):
364         self.nl = nl_msg
365         self.genl_cmd, self.genl_version, _ = struct.unpack_from("BBH", nl_msg.raw, 0)
366         self.raw = nl_msg.raw[4:]
393     def _decode(self, nl_msg):
394         return nl_msg
396     def decode(self, ynl, nl_msg, op):
397         msg = self._decode(nl_msg)
429     def _decode(self, nl_msg):
430         return GenlMsg(nl_msg)
524         for nl_msg in nl_msgs:
525             print("  ", nl_msg, file=sys.stderr)
1006             for nl_msg in nms:
1007                 if nl_msg.error:
1008                     print("Netlink error in ntf!?", os.strerror(-nl_msg.error))
1009                     print(nl_msg)
1011                 if nl_msg.done:
1015                 decoded = self.nlproto.decode(self, nl_msg, None)
1086             for nl_msg in nms:
1087                 if nl_msg.nl_seq in reqs_by_seq:
1088                     (op, vals, req_msg, req_flags) = reqs_by_seq[nl_msg.nl_seq]
1089                     if nl_msg.extack:
1090                         nl_msg.annotate_extack(op.attr_set)
1091                         self._decode_extack(req_msg, op, nl_msg.extack, vals)
1096                 if nl_msg.error:
1097                     raise NlError(nl_msg)
1098                 if nl_msg.done:
1099                     if nl_msg.extack:
1101                         print(nl_msg)
1113                     del reqs_by_seq[nl_msg.nl_seq]
1117                 decoded = self.nlproto.decode(self, nl_msg, op)
1120                 if nl_msg.nl_seq not in reqs_by_seq or decoded.cmd() != op.rsp_value: