165     def __init__(self, msg):  argument
169         while offset < len(msg):
170             attr = NlAttr(msg, offset)
178         msg = ''
180             if msg:
181                 msg += '\n'
182             msg += repr(a)
183         return msg
187     def __init__(self, msg, offset, attr_space=None):  argument
188         self.hdr = msg[offset:offset + 16]
193         self.raw = msg[offset + 16:offset + self.nl_len]
241 …msg = f"nl_len = {self.nl_len} ({len(self.raw)}) nl_flags = 0x{self.nl_flags:x} nl_type = {self.nl…
243             msg += '\terror: ' + str(self.error)
245             msg += '\textack: ' + repr(self.extack)
246         return msg
255             msg = NlMsg(data, offset, attr_space=attr_space)
256             offset += msg.nl_len
257             self.msgs.append(msg)
275 def _genl_msg_finalize(msg):  argument
276     return struct.pack("I", len(msg) + 4) + msg
283         msg = _genl_msg(Netlink.GENL_ID_CTRL,
286         msg = _genl_msg_finalize(msg)
288         sock.send(msg, 0)
338         msg = repr(self.nl)
339         msg += f"\tgenl_cmd = {self.genl_cmd} genl_ver = {self.genl_version}\n"
341             msg += '\t\t' + repr(a) + '\n'
342         return msg
363         msg = self._decode(nl_msg)
366             op = ynl.rsp_by_value[msg.cmd()]
368         msg.raw_attrs = NlAttrs(msg.raw[fixed_header_size:])
369         return msg
430         for msg in self.msgs.values():
431             if msg.is_async:
432                 self.async_msg_ids.add(msg.rsp_value)
582         msg = self.nlproto.decode(self, NlMsg(request, 0, op.attr_set))
584         path = self._decode_extack_path(msg.raw_attrs, op.attr_set, offset,
601     def _decode_fixed_header(self, msg, name):  argument
607             [ value ] = format.unpack_from(msg.raw, offset)
615         msg = dict()
617             msg['raw'] = decoded
623         msg['name'] = op['name']
624         msg['msg'] = attrs
625         self.async_msg_queue.append(msg)
672         msg = self.nlproto.message(nl_flags, op.req_value, 1, req_seq)
679                 msg += format.pack(value)
681             msg += self._add_attr(op.attr_set.name, name, value)
682         msg = _genl_msg_finalize(msg)
684         self.sock.send(msg, 0)
693                     self._decode_extack(msg, op, nl_msg.extack)