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):
561             sub_space = attr['nested-attributes']
596         elif attr['type'] == 'sub-message':
609                     raise Exception(f"Unknown attribute-set '{msg_format.attr_set}'")
613         pad = b'\x00' * ((4 - len(attr_payload) % 4) % 4)
618         if enum.type == 'flags' or attr_spec.get('enum-as-flags', False):
653             if attr_spec["sub-type"] == 'nest':
654                 subattrs = self._decode(NlAttrs(item.raw), attr_spec['nested-attributes'])
656             elif attr_spec["sub-type"] == 'binary':
661             elif attr_spec["sub-type"] in NlAttr.type_formats:
662                 subattr = item.as_scalar(attr_spec['sub-type'], attr_spec.byte_order)
669                 raise Exception(f'Unknown {attr_spec["sub-type"]} with name {attr_spec["name"]}')
675         for name in attr_spec['type-value']:
678         subattrs = self._decode(NlAttrs(value.raw), attr_spec['nested-attributes'])
706             raise Exception(f"No sub-message spec named {sub_msg} for {attr_spec.name}")
712             raise Exception(f"No message format for '{value}' in sub-message spec '{sub_msg}'")
729 …          raise Exception(f"Unknown attribute-set '{attr_space}' when decoding '{attr_spec.name}'")
750 …            subdict = self._decode(NlAttrs(attr.raw), attr_spec['nested-attributes'], search_attrs)
766                 elif attr_spec["type"] == 'indexed-array':
774                 elif attr_spec["type"] == 'sub-message':
776                 elif attr_spec["type"] == 'nest-type-value':
808                                                self.attr_sets[attr_spec['nested-attributes']],
817         if 'bad-attr-offs' not in extack:
823                                         extack['bad-attr-offs'])
825             del extack['bad-attr-offs']
826             extack['bad-attr'] = path
950                     print("Netlink error in ntf!?", os.strerror(-nl_msg.error))
974                     timeout = start_time + duration - time.time()
999         msg = self.nlproto.message(nl_flags, op.req_value, 1, req_seq)
1066                         print('Unexpected message: ' + repr(decoded))