Skip to content

Commit

Permalink
Merge branch 'tools-ynl-handful-of-forward-looking-updates'
Browse files Browse the repository at this point in the history
Jakub Kicinski says:

====================
tools: ynl: handful of forward looking updates

Small YNL improvements, mostly for work-in-progress families.
====================

Link: https://lore.kernel.org/r/20230824003056.1436637-1-kuba@kernel.org
Signed-off-by: Jakub Kicinski <kuba@kernel.org>
  • Loading branch information
Jakub Kicinski committed Aug 25, 2023
2 parents 10ea77e + e83d4e9 commit 1355fe1
Show file tree
Hide file tree
Showing 5 changed files with 38 additions and 13 deletions.
18 changes: 9 additions & 9 deletions Documentation/netlink/specs/fou.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -107,16 +107,16 @@ operations:
flags: [ admin-perm ]

do:
request: &select_attrs
request: &select_attrs
attributes:
- af
- ifindex
- port
- peer_port
- local_v4
- peer_v4
- local_v6
- peer_v6
- af
- ifindex
- port
- peer_port
- local_v4
- peer_v4
- local_v6
- peer_v6

-
name: get
Expand Down
4 changes: 4 additions & 0 deletions tools/net/ynl/generated/ethtool-user.h
Original file line number Diff line number Diff line change
Expand Up @@ -1422,6 +1422,7 @@ ethtool_wol_set_req_set_sopass(struct ethtool_wol_set_req *req,
const void *sopass, size_t len)
{
free(req->sopass);
req->_present.sopass_len = len;
req->sopass = malloc(req->_present.sopass_len);
memcpy(req->sopass, sopass, req->_present.sopass_len);
}
Expand Down Expand Up @@ -4071,6 +4072,7 @@ ethtool_fec_set_req_set_stats_corrected(struct ethtool_fec_set_req *req,
const void *corrected, size_t len)
{
free(req->stats.corrected);
req->stats._present.corrected_len = len;
req->stats.corrected = malloc(req->stats._present.corrected_len);
memcpy(req->stats.corrected, corrected, req->stats._present.corrected_len);
}
Expand All @@ -4079,6 +4081,7 @@ ethtool_fec_set_req_set_stats_uncorr(struct ethtool_fec_set_req *req,
const void *uncorr, size_t len)
{
free(req->stats.uncorr);
req->stats._present.uncorr_len = len;
req->stats.uncorr = malloc(req->stats._present.uncorr_len);
memcpy(req->stats.uncorr, uncorr, req->stats._present.uncorr_len);
}
Expand All @@ -4087,6 +4090,7 @@ ethtool_fec_set_req_set_stats_corr_bits(struct ethtool_fec_set_req *req,
const void *corr_bits, size_t len)
{
free(req->stats.corr_bits);
req->stats._present.corr_bits_len = len;
req->stats.corr_bits = malloc(req->stats._present.corr_bits_len);
memcpy(req->stats.corr_bits, corr_bits, req->stats._present.corr_bits_len);
}
Expand Down
6 changes: 6 additions & 0 deletions tools/net/ynl/generated/fou-user.h
Original file line number Diff line number Diff line change
Expand Up @@ -91,6 +91,7 @@ fou_add_req_set_local_v6(struct fou_add_req *req, const void *local_v6,
size_t len)
{
free(req->local_v6);
req->_present.local_v6_len = len;
req->local_v6 = malloc(req->_present.local_v6_len);
memcpy(req->local_v6, local_v6, req->_present.local_v6_len);
}
Expand All @@ -99,6 +100,7 @@ fou_add_req_set_peer_v6(struct fou_add_req *req, const void *peer_v6,
size_t len)
{
free(req->peer_v6);
req->_present.peer_v6_len = len;
req->peer_v6 = malloc(req->_present.peer_v6_len);
memcpy(req->peer_v6, peer_v6, req->_present.peer_v6_len);
}
Expand Down Expand Up @@ -192,6 +194,7 @@ fou_del_req_set_local_v6(struct fou_del_req *req, const void *local_v6,
size_t len)
{
free(req->local_v6);
req->_present.local_v6_len = len;
req->local_v6 = malloc(req->_present.local_v6_len);
memcpy(req->local_v6, local_v6, req->_present.local_v6_len);
}
Expand All @@ -200,6 +203,7 @@ fou_del_req_set_peer_v6(struct fou_del_req *req, const void *peer_v6,
size_t len)
{
free(req->peer_v6);
req->_present.peer_v6_len = len;
req->peer_v6 = malloc(req->_present.peer_v6_len);
memcpy(req->peer_v6, peer_v6, req->_present.peer_v6_len);
}
Expand Down Expand Up @@ -280,6 +284,7 @@ fou_get_req_set_local_v6(struct fou_get_req *req, const void *local_v6,
size_t len)
{
free(req->local_v6);
req->_present.local_v6_len = len;
req->local_v6 = malloc(req->_present.local_v6_len);
memcpy(req->local_v6, local_v6, req->_present.local_v6_len);
}
Expand All @@ -288,6 +293,7 @@ fou_get_req_set_peer_v6(struct fou_get_req *req, const void *peer_v6,
size_t len)
{
free(req->peer_v6);
req->_present.peer_v6_len = len;
req->peer_v6 = malloc(req->_present.peer_v6_len);
memcpy(req->peer_v6, peer_v6, req->_present.peer_v6_len);
}
Expand Down
7 changes: 6 additions & 1 deletion tools/net/ynl/lib/ynl.py
Original file line number Diff line number Diff line change
Expand Up @@ -410,7 +410,12 @@ def _add_attr(self, space, name, value):
elif attr["type"] == 'string':
attr_payload = str(value).encode('ascii') + b'\x00'
elif attr["type"] == 'binary':
attr_payload = bytes.fromhex(value)
if isinstance(value, bytes):
attr_payload = value
elif isinstance(value, str):
attr_payload = bytes.fromhex(value)
else:
raise Exception(f'Unknown type for binary attribute, value: {value}')
elif attr['type'] in NlAttr.type_formats:
format = NlAttr.get_format(attr['type'], attr.byte_order)
attr_payload = format.pack(int(value))
Expand Down
16 changes: 13 additions & 3 deletions tools/net/ynl/ynl-gen-c.py
Original file line number Diff line number Diff line change
Expand Up @@ -428,6 +428,7 @@ def _attr_get(self, ri, var):

def _setter_lines(self, ri, member, presence):
return [f"free({member});",
f"{presence}_len = len;",
f"{member} = malloc({presence}_len);",
f'memcpy({member}, {self.c_name}, {presence}_len);']

Expand Down Expand Up @@ -614,7 +615,7 @@ def __init__(self, family, space_name, type_list=None, inherited=None):

self.attr_list = []
self.attrs = dict()
if type_list:
if type_list is not None:
for t in type_list:
self.attr_list.append((t, self.attr_set[t]),)
else:
Expand Down Expand Up @@ -977,7 +978,9 @@ def _load_global_policy(self):

for op_mode in ['do', 'dump']:
if op_mode in op:
global_set.update(op[op_mode].get('request', []))
req = op[op_mode].get('request')
if req:
global_set.update(req.get('attributes', []))

self.global_policy = []
self.global_policy_set = attr_set_name
Expand Down Expand Up @@ -1540,7 +1543,14 @@ def parse_rsp_msg(ri, deref=False):

ri.cw.write_func_prot('int', f'{op_prefix(ri, "reply", deref=deref)}_parse', func_args)

_multi_parse(ri, ri.struct["reply"], init_lines, local_vars)
if ri.struct["reply"].member_list():
_multi_parse(ri, ri.struct["reply"], init_lines, local_vars)
else:
# Empty reply
ri.cw.block_start()
ri.cw.p('return MNL_CB_OK;')
ri.cw.block_end()
ri.cw.nl()


def print_req(ri):
Expand Down

0 comments on commit 1355fe1

Please sign in to comment.