1 # SPDX-License-Identifier: GPL-2.0 OR BSD-3-Clause
35     # Netlink message
99                                   'binary', 'string', 'nul-string',
100                                   'nested', 'nested-array',
106     self.error = -nl_msg.error
141             return format.big if byte_order == "big-endian" \
151             raise Exception(f"Auto-scalar len payload be 4 or 8 bytes, got {len(self.raw)}")
157         return self.raw.decode('ascii')[:-1]
221                     self.extack['miss-type'] = extack.as_scalar('u32')
223                     self.extack['miss-nest'] = extack.as_scalar('u32')
225                     self.extack['bad-attr-offs'] = extack.as_scalar('u32')
235                 if 'miss-type' in self.extack and 'miss-nest' not in self.extack:
236                     miss_type = self.extack['miss-type']
239                         self.extack['miss-type'] = spec['name']
241                             self.extack['miss-type-doc'] = spec['doc']
250                 policy['min-value'] = attr.as_scalar('s64')
252                 policy['max-value'] = attr.as_scalar('s64')
254                 policy['min-value'] = attr.as_scalar('u64')
256                 policy['max-value'] = attr.as_scalar('u64')
258                 policy['min-length'] = attr.as_scalar('u32')
260                 policy['max-length'] = attr.as_scalar('u32')
262                 policy['bitfield32-mask'] = attr.as_scalar('u32')
386     def message(self, flags, command, version, seq=None):  member in NetlinkProtocol
420     def message(self, flags, command, version, seq=None):  member in GenlProtocol
453         raise Exception(f"Attribute '{name}' not defined in any attribute-set")
470             if self.proto == "netlink-raw":
479         # Note that netlink will use conservative (min) message size for
483         # Netlink will always allocate at least PAGE_SIZE - sizeof(skb_shinfo)
484         # for a message, so smaller receive sizes will lead to truncation.
525         if enum.type == 'flags' or attr_spec.get('enum-as-flags', False):
559             sub_space = attr['nested-attributes']
591         elif attr['type'] == 'sub-message':
604                     raise Exception(f"Unknown attribute-set '{msg_format.attr_set}'")
608         pad = b'\x00' * ((4 - len(attr_payload) % 4) % 4)
613         if enum.type == 'flags' or attr_spec.get('enum-as-flags', False):
643             if attr_spec["sub-type"] == 'nest':
644                 subattrs = self._decode(NlAttrs(item.raw), attr_spec['nested-attributes'])
646             elif attr_spec["sub-type"] == 'binary':
651             elif attr_spec["sub-type"] in NlAttr.type_formats:
652                 subattrs = item.as_scalar(attr_spec['sub-type'], attr_spec.byte_order)
657                 raise Exception(f'Unknown {attr_spec["sub-type"]} with name {attr_spec["name"]}')
663         for name in attr_spec['type-value']:
666         subattrs = self._decode(NlAttrs(value.raw), attr_spec['nested-attributes'])
694             raise Exception(f"No sub-message spec named {sub_msg} for {attr_spec.name}")
700             raise Exception(f"No message format for '{value}' in sub-message spec '{sub_msg}'")
717 …          raise Exception(f"Unknown attribute-set '{attr_space}' when decoding '{attr_spec.name}'")
738 …            subdict = self._decode(NlAttrs(attr.raw), attr_spec['nested-attributes'], search_attrs)
754                 elif attr_spec["type"] == 'indexed-array':
762                 elif attr_spec["type"] == 'sub-message':
764                 elif attr_spec["type"] == 'nest-type-value':
796                                                self.attr_sets[attr_spec['nested-attributes']],
805         if 'bad-attr-offs' not in extack:
811                                         extack['bad-attr-offs'])
813             del extack['bad-attr-offs']
814             extack['bad-attr'] = path
926                     print("Netlink error in ntf!?", os.strerror(-nl_msg.error))
950                     timeout = start_time + duration - time.time()
975         msg = self.nlproto.message(nl_flags, op.req_value, 1, req_seq)
1042                         print('Unexpected message: ' + repr(decoded))