1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /*
3 * Copyright (c) 2016 Mellanox Technologies. All rights reserved.
4 * Copyright (c) 2016 Jiri Pirko <jiri@mellanox.com>
5 */
6
7 #include "devl_internal.h"
8
9 /**
10 * struct devlink_resource - devlink resource
11 * @name: name of the resource
12 * @id: id, per devlink instance
13 * @size: size of the resource
14 * @size_new: updated size of the resource, reload is needed
15 * @size_valid: valid in case the total size of the resource is valid
16 * including its children
17 * @parent: parent resource
18 * @size_params: size parameters
19 * @list: parent list
20 * @resource_list: list of child resources
21 * @occ_get: occupancy getter callback
22 * @occ_get_priv: occupancy getter callback priv
23 */
24 struct devlink_resource {
25 const char *name;
26 u64 id;
27 u64 size;
28 u64 size_new;
29 bool size_valid;
30 struct devlink_resource *parent;
31 struct devlink_resource_size_params size_params;
32 struct list_head list;
33 struct list_head resource_list;
34 devlink_resource_occ_get_t *occ_get;
35 void *occ_get_priv;
36 };
37
38 static struct devlink_resource *
devlink_resource_find(struct devlink * devlink,struct devlink_resource * resource,u64 resource_id)39 devlink_resource_find(struct devlink *devlink,
40 struct devlink_resource *resource, u64 resource_id)
41 {
42 struct list_head *resource_list;
43
44 if (resource)
45 resource_list = &resource->resource_list;
46 else
47 resource_list = &devlink->resource_list;
48
49 list_for_each_entry(resource, resource_list, list) {
50 struct devlink_resource *child_resource;
51
52 if (resource->id == resource_id)
53 return resource;
54
55 child_resource = devlink_resource_find(devlink, resource,
56 resource_id);
57 if (child_resource)
58 return child_resource;
59 }
60 return NULL;
61 }
62
63 static void
devlink_resource_validate_children(struct devlink_resource * resource)64 devlink_resource_validate_children(struct devlink_resource *resource)
65 {
66 struct devlink_resource *child_resource;
67 bool size_valid = true;
68 u64 parts_size = 0;
69
70 if (list_empty(&resource->resource_list))
71 goto out;
72
73 list_for_each_entry(child_resource, &resource->resource_list, list)
74 parts_size += child_resource->size_new;
75
76 if (parts_size > resource->size_new)
77 size_valid = false;
78 out:
79 resource->size_valid = size_valid;
80 }
81
82 static int
devlink_resource_validate_size(struct devlink_resource * resource,u64 size,struct netlink_ext_ack * extack)83 devlink_resource_validate_size(struct devlink_resource *resource, u64 size,
84 struct netlink_ext_ack *extack)
85 {
86 u64 reminder;
87 int err = 0;
88
89 if (size > resource->size_params.size_max) {
90 NL_SET_ERR_MSG(extack, "Size larger than maximum");
91 err = -EINVAL;
92 }
93
94 if (size < resource->size_params.size_min) {
95 NL_SET_ERR_MSG(extack, "Size smaller than minimum");
96 err = -EINVAL;
97 }
98
99 div64_u64_rem(size, resource->size_params.size_granularity, &reminder);
100 if (reminder) {
101 NL_SET_ERR_MSG(extack, "Wrong granularity");
102 err = -EINVAL;
103 }
104
105 return err;
106 }
107
devlink_nl_resource_set_doit(struct sk_buff * skb,struct genl_info * info)108 int devlink_nl_resource_set_doit(struct sk_buff *skb, struct genl_info *info)
109 {
110 struct devlink *devlink = info->user_ptr[0];
111 struct devlink_resource *resource;
112 u64 resource_id;
113 u64 size;
114 int err;
115
116 if (GENL_REQ_ATTR_CHECK(info, DEVLINK_ATTR_RESOURCE_ID) ||
117 GENL_REQ_ATTR_CHECK(info, DEVLINK_ATTR_RESOURCE_SIZE))
118 return -EINVAL;
119 resource_id = nla_get_u64(info->attrs[DEVLINK_ATTR_RESOURCE_ID]);
120
121 resource = devlink_resource_find(devlink, NULL, resource_id);
122 if (!resource)
123 return -EINVAL;
124
125 size = nla_get_u64(info->attrs[DEVLINK_ATTR_RESOURCE_SIZE]);
126 err = devlink_resource_validate_size(resource, size, info->extack);
127 if (err)
128 return err;
129
130 resource->size_new = size;
131 devlink_resource_validate_children(resource);
132 if (resource->parent)
133 devlink_resource_validate_children(resource->parent);
134 return 0;
135 }
136
137 static int
devlink_resource_size_params_put(struct devlink_resource * resource,struct sk_buff * skb)138 devlink_resource_size_params_put(struct devlink_resource *resource,
139 struct sk_buff *skb)
140 {
141 struct devlink_resource_size_params *size_params;
142
143 size_params = &resource->size_params;
144 if (nla_put_u64_64bit(skb, DEVLINK_ATTR_RESOURCE_SIZE_GRAN,
145 size_params->size_granularity, DEVLINK_ATTR_PAD) ||
146 nla_put_u64_64bit(skb, DEVLINK_ATTR_RESOURCE_SIZE_MAX,
147 size_params->size_max, DEVLINK_ATTR_PAD) ||
148 nla_put_u64_64bit(skb, DEVLINK_ATTR_RESOURCE_SIZE_MIN,
149 size_params->size_min, DEVLINK_ATTR_PAD) ||
150 nla_put_u8(skb, DEVLINK_ATTR_RESOURCE_UNIT, size_params->unit))
151 return -EMSGSIZE;
152 return 0;
153 }
154
devlink_resource_occ_put(struct devlink_resource * resource,struct sk_buff * skb)155 static int devlink_resource_occ_put(struct devlink_resource *resource,
156 struct sk_buff *skb)
157 {
158 if (!resource->occ_get)
159 return 0;
160 return nla_put_u64_64bit(skb, DEVLINK_ATTR_RESOURCE_OCC,
161 resource->occ_get(resource->occ_get_priv),
162 DEVLINK_ATTR_PAD);
163 }
164
devlink_resource_put(struct devlink * devlink,struct sk_buff * skb,struct devlink_resource * resource)165 static int devlink_resource_put(struct devlink *devlink, struct sk_buff *skb,
166 struct devlink_resource *resource)
167 {
168 struct devlink_resource *child_resource;
169 struct nlattr *child_resource_attr;
170 struct nlattr *resource_attr;
171
172 resource_attr = nla_nest_start_noflag(skb, DEVLINK_ATTR_RESOURCE);
173 if (!resource_attr)
174 return -EMSGSIZE;
175
176 if (nla_put_string(skb, DEVLINK_ATTR_RESOURCE_NAME, resource->name) ||
177 nla_put_u64_64bit(skb, DEVLINK_ATTR_RESOURCE_SIZE, resource->size,
178 DEVLINK_ATTR_PAD) ||
179 nla_put_u64_64bit(skb, DEVLINK_ATTR_RESOURCE_ID, resource->id,
180 DEVLINK_ATTR_PAD))
181 goto nla_put_failure;
182 if (resource->size != resource->size_new &&
183 nla_put_u64_64bit(skb, DEVLINK_ATTR_RESOURCE_SIZE_NEW,
184 resource->size_new, DEVLINK_ATTR_PAD))
185 goto nla_put_failure;
186 if (devlink_resource_occ_put(resource, skb))
187 goto nla_put_failure;
188 if (devlink_resource_size_params_put(resource, skb))
189 goto nla_put_failure;
190 if (list_empty(&resource->resource_list))
191 goto out;
192
193 if (nla_put_u8(skb, DEVLINK_ATTR_RESOURCE_SIZE_VALID,
194 resource->size_valid))
195 goto nla_put_failure;
196
197 child_resource_attr = nla_nest_start_noflag(skb,
198 DEVLINK_ATTR_RESOURCE_LIST);
199 if (!child_resource_attr)
200 goto nla_put_failure;
201
202 list_for_each_entry(child_resource, &resource->resource_list, list) {
203 if (devlink_resource_put(devlink, skb, child_resource))
204 goto resource_put_failure;
205 }
206
207 nla_nest_end(skb, child_resource_attr);
208 out:
209 nla_nest_end(skb, resource_attr);
210 return 0;
211
212 resource_put_failure:
213 nla_nest_cancel(skb, child_resource_attr);
214 nla_put_failure:
215 nla_nest_cancel(skb, resource_attr);
216 return -EMSGSIZE;
217 }
218
devlink_resource_fill(struct genl_info * info,enum devlink_command cmd,int flags)219 static int devlink_resource_fill(struct genl_info *info,
220 enum devlink_command cmd, int flags)
221 {
222 struct devlink *devlink = info->user_ptr[0];
223 struct devlink_resource *resource;
224 struct nlattr *resources_attr;
225 struct sk_buff *skb = NULL;
226 struct nlmsghdr *nlh;
227 bool incomplete;
228 void *hdr;
229 int i;
230 int err;
231
232 resource = list_first_entry(&devlink->resource_list,
233 struct devlink_resource, list);
234 start_again:
235 err = devlink_nl_msg_reply_and_new(&skb, info);
236 if (err)
237 return err;
238
239 hdr = genlmsg_put(skb, info->snd_portid, info->snd_seq,
240 &devlink_nl_family, NLM_F_MULTI, cmd);
241 if (!hdr) {
242 nlmsg_free(skb);
243 return -EMSGSIZE;
244 }
245
246 if (devlink_nl_put_handle(skb, devlink))
247 goto nla_put_failure;
248
249 resources_attr = nla_nest_start_noflag(skb,
250 DEVLINK_ATTR_RESOURCE_LIST);
251 if (!resources_attr)
252 goto nla_put_failure;
253
254 incomplete = false;
255 i = 0;
256 list_for_each_entry_from(resource, &devlink->resource_list, list) {
257 err = devlink_resource_put(devlink, skb, resource);
258 if (err) {
259 if (!i)
260 goto err_resource_put;
261 incomplete = true;
262 break;
263 }
264 i++;
265 }
266 nla_nest_end(skb, resources_attr);
267 genlmsg_end(skb, hdr);
268 if (incomplete)
269 goto start_again;
270 send_done:
271 nlh = nlmsg_put(skb, info->snd_portid, info->snd_seq,
272 NLMSG_DONE, 0, flags | NLM_F_MULTI);
273 if (!nlh) {
274 err = devlink_nl_msg_reply_and_new(&skb, info);
275 if (err)
276 return err;
277 goto send_done;
278 }
279 return genlmsg_reply(skb, info);
280
281 nla_put_failure:
282 err = -EMSGSIZE;
283 err_resource_put:
284 nlmsg_free(skb);
285 return err;
286 }
287
devlink_nl_resource_dump_doit(struct sk_buff * skb,struct genl_info * info)288 int devlink_nl_resource_dump_doit(struct sk_buff *skb, struct genl_info *info)
289 {
290 struct devlink *devlink = info->user_ptr[0];
291
292 if (list_empty(&devlink->resource_list))
293 return -EOPNOTSUPP;
294
295 return devlink_resource_fill(info, DEVLINK_CMD_RESOURCE_DUMP, 0);
296 }
297
devlink_resources_validate(struct devlink * devlink,struct devlink_resource * resource,struct genl_info * info)298 int devlink_resources_validate(struct devlink *devlink,
299 struct devlink_resource *resource,
300 struct genl_info *info)
301 {
302 struct list_head *resource_list;
303 int err = 0;
304
305 if (resource)
306 resource_list = &resource->resource_list;
307 else
308 resource_list = &devlink->resource_list;
309
310 list_for_each_entry(resource, resource_list, list) {
311 if (!resource->size_valid)
312 return -EINVAL;
313 err = devlink_resources_validate(devlink, resource, info);
314 if (err)
315 return err;
316 }
317 return err;
318 }
319
320 /**
321 * devl_resource_register - devlink resource register
322 *
323 * @devlink: devlink
324 * @resource_name: resource's name
325 * @resource_size: resource's size
326 * @resource_id: resource's id
327 * @parent_resource_id: resource's parent id
328 * @size_params: size parameters
329 *
330 * Generic resources should reuse the same names across drivers.
331 * Please see the generic resources list at:
332 * Documentation/networking/devlink/devlink-resource.rst
333 */
devl_resource_register(struct devlink * devlink,const char * resource_name,u64 resource_size,u64 resource_id,u64 parent_resource_id,const struct devlink_resource_size_params * size_params)334 int devl_resource_register(struct devlink *devlink,
335 const char *resource_name,
336 u64 resource_size,
337 u64 resource_id,
338 u64 parent_resource_id,
339 const struct devlink_resource_size_params *size_params)
340 {
341 struct devlink_resource *resource;
342 struct list_head *resource_list;
343 bool top_hierarchy;
344
345 lockdep_assert_held(&devlink->lock);
346
347 top_hierarchy = parent_resource_id == DEVLINK_RESOURCE_ID_PARENT_TOP;
348
349 resource = devlink_resource_find(devlink, NULL, resource_id);
350 if (resource)
351 return -EINVAL;
352
353 resource = kzalloc(sizeof(*resource), GFP_KERNEL);
354 if (!resource)
355 return -ENOMEM;
356
357 if (top_hierarchy) {
358 resource_list = &devlink->resource_list;
359 } else {
360 struct devlink_resource *parent_resource;
361
362 parent_resource = devlink_resource_find(devlink, NULL,
363 parent_resource_id);
364 if (parent_resource) {
365 resource_list = &parent_resource->resource_list;
366 resource->parent = parent_resource;
367 } else {
368 kfree(resource);
369 return -EINVAL;
370 }
371 }
372
373 resource->name = resource_name;
374 resource->size = resource_size;
375 resource->size_new = resource_size;
376 resource->id = resource_id;
377 resource->size_valid = true;
378 memcpy(&resource->size_params, size_params,
379 sizeof(resource->size_params));
380 INIT_LIST_HEAD(&resource->resource_list);
381 list_add_tail(&resource->list, resource_list);
382
383 return 0;
384 }
385 EXPORT_SYMBOL_GPL(devl_resource_register);
386
387 /**
388 * devlink_resource_register - devlink resource register
389 *
390 * @devlink: devlink
391 * @resource_name: resource's name
392 * @resource_size: resource's size
393 * @resource_id: resource's id
394 * @parent_resource_id: resource's parent id
395 * @size_params: size parameters
396 *
397 * Generic resources should reuse the same names across drivers.
398 * Please see the generic resources list at:
399 * Documentation/networking/devlink/devlink-resource.rst
400 *
401 * Context: Takes and release devlink->lock <mutex>.
402 */
devlink_resource_register(struct devlink * devlink,const char * resource_name,u64 resource_size,u64 resource_id,u64 parent_resource_id,const struct devlink_resource_size_params * size_params)403 int devlink_resource_register(struct devlink *devlink,
404 const char *resource_name,
405 u64 resource_size,
406 u64 resource_id,
407 u64 parent_resource_id,
408 const struct devlink_resource_size_params *size_params)
409 {
410 int err;
411
412 devl_lock(devlink);
413 err = devl_resource_register(devlink, resource_name, resource_size,
414 resource_id, parent_resource_id, size_params);
415 devl_unlock(devlink);
416 return err;
417 }
418 EXPORT_SYMBOL_GPL(devlink_resource_register);
419
devlink_resource_unregister(struct devlink * devlink,struct devlink_resource * resource)420 static void devlink_resource_unregister(struct devlink *devlink,
421 struct devlink_resource *resource)
422 {
423 struct devlink_resource *tmp, *child_resource;
424
425 list_for_each_entry_safe(child_resource, tmp, &resource->resource_list,
426 list) {
427 devlink_resource_unregister(devlink, child_resource);
428 list_del(&child_resource->list);
429 kfree(child_resource);
430 }
431 }
432
433 /**
434 * devl_resources_unregister - free all resources
435 *
436 * @devlink: devlink
437 */
devl_resources_unregister(struct devlink * devlink)438 void devl_resources_unregister(struct devlink *devlink)
439 {
440 struct devlink_resource *tmp, *child_resource;
441
442 lockdep_assert_held(&devlink->lock);
443
444 list_for_each_entry_safe(child_resource, tmp, &devlink->resource_list,
445 list) {
446 devlink_resource_unregister(devlink, child_resource);
447 list_del(&child_resource->list);
448 kfree(child_resource);
449 }
450 }
451 EXPORT_SYMBOL_GPL(devl_resources_unregister);
452
453 /**
454 * devlink_resources_unregister - free all resources
455 *
456 * @devlink: devlink
457 *
458 * Context: Takes and release devlink->lock <mutex>.
459 */
devlink_resources_unregister(struct devlink * devlink)460 void devlink_resources_unregister(struct devlink *devlink)
461 {
462 devl_lock(devlink);
463 devl_resources_unregister(devlink);
464 devl_unlock(devlink);
465 }
466 EXPORT_SYMBOL_GPL(devlink_resources_unregister);
467
468 /**
469 * devl_resource_size_get - get and update size
470 *
471 * @devlink: devlink
472 * @resource_id: the requested resource id
473 * @p_resource_size: ptr to update
474 */
devl_resource_size_get(struct devlink * devlink,u64 resource_id,u64 * p_resource_size)475 int devl_resource_size_get(struct devlink *devlink,
476 u64 resource_id,
477 u64 *p_resource_size)
478 {
479 struct devlink_resource *resource;
480
481 lockdep_assert_held(&devlink->lock);
482
483 resource = devlink_resource_find(devlink, NULL, resource_id);
484 if (!resource)
485 return -EINVAL;
486 *p_resource_size = resource->size_new;
487 resource->size = resource->size_new;
488 return 0;
489 }
490 EXPORT_SYMBOL_GPL(devl_resource_size_get);
491
492 /**
493 * devl_resource_occ_get_register - register occupancy getter
494 *
495 * @devlink: devlink
496 * @resource_id: resource id
497 * @occ_get: occupancy getter callback
498 * @occ_get_priv: occupancy getter callback priv
499 */
devl_resource_occ_get_register(struct devlink * devlink,u64 resource_id,devlink_resource_occ_get_t * occ_get,void * occ_get_priv)500 void devl_resource_occ_get_register(struct devlink *devlink,
501 u64 resource_id,
502 devlink_resource_occ_get_t *occ_get,
503 void *occ_get_priv)
504 {
505 struct devlink_resource *resource;
506
507 lockdep_assert_held(&devlink->lock);
508
509 resource = devlink_resource_find(devlink, NULL, resource_id);
510 if (WARN_ON(!resource))
511 return;
512 WARN_ON(resource->occ_get);
513
514 resource->occ_get = occ_get;
515 resource->occ_get_priv = occ_get_priv;
516 }
517 EXPORT_SYMBOL_GPL(devl_resource_occ_get_register);
518
519 /**
520 * devlink_resource_occ_get_register - register occupancy getter
521 *
522 * @devlink: devlink
523 * @resource_id: resource id
524 * @occ_get: occupancy getter callback
525 * @occ_get_priv: occupancy getter callback priv
526 *
527 * Context: Takes and release devlink->lock <mutex>.
528 */
devlink_resource_occ_get_register(struct devlink * devlink,u64 resource_id,devlink_resource_occ_get_t * occ_get,void * occ_get_priv)529 void devlink_resource_occ_get_register(struct devlink *devlink,
530 u64 resource_id,
531 devlink_resource_occ_get_t *occ_get,
532 void *occ_get_priv)
533 {
534 devl_lock(devlink);
535 devl_resource_occ_get_register(devlink, resource_id,
536 occ_get, occ_get_priv);
537 devl_unlock(devlink);
538 }
539 EXPORT_SYMBOL_GPL(devlink_resource_occ_get_register);
540
541 /**
542 * devl_resource_occ_get_unregister - unregister occupancy getter
543 *
544 * @devlink: devlink
545 * @resource_id: resource id
546 */
devl_resource_occ_get_unregister(struct devlink * devlink,u64 resource_id)547 void devl_resource_occ_get_unregister(struct devlink *devlink,
548 u64 resource_id)
549 {
550 struct devlink_resource *resource;
551
552 lockdep_assert_held(&devlink->lock);
553
554 resource = devlink_resource_find(devlink, NULL, resource_id);
555 if (WARN_ON(!resource))
556 return;
557 WARN_ON(!resource->occ_get);
558
559 resource->occ_get = NULL;
560 resource->occ_get_priv = NULL;
561 }
562 EXPORT_SYMBOL_GPL(devl_resource_occ_get_unregister);
563
564 /**
565 * devlink_resource_occ_get_unregister - unregister occupancy getter
566 *
567 * @devlink: devlink
568 * @resource_id: resource id
569 *
570 * Context: Takes and release devlink->lock <mutex>.
571 */
devlink_resource_occ_get_unregister(struct devlink * devlink,u64 resource_id)572 void devlink_resource_occ_get_unregister(struct devlink *devlink,
573 u64 resource_id)
574 {
575 devl_lock(devlink);
576 devl_resource_occ_get_unregister(devlink, resource_id);
577 devl_unlock(devlink);
578 }
579 EXPORT_SYMBOL_GPL(devlink_resource_occ_get_unregister);
580