xref: /linux/drivers/dpll/dpll_netlink.c (revision f5c31bcf604db54470868f3118a60dc4a9ba8813)
1 // SPDX-License-Identifier: GPL-2.0
2 /*
3  * Generic netlink for DPLL management framework
4  *
5  *  Copyright (c) 2023 Meta Platforms, Inc. and affiliates
6  *  Copyright (c) 2023 Intel and affiliates
7  *
8  */
9 #include <linux/module.h>
10 #include <linux/kernel.h>
11 #include <linux/netdevice.h>
12 #include <net/genetlink.h>
13 #include "dpll_core.h"
14 #include "dpll_netlink.h"
15 #include "dpll_nl.h"
16 #include <uapi/linux/dpll.h>
17 
18 #define ASSERT_NOT_NULL(ptr)	(WARN_ON(!ptr))
19 
20 #define xa_for_each_marked_start(xa, index, entry, filter, start) \
21 	for (index = start, entry = xa_find(xa, &index, ULONG_MAX, filter); \
22 	     entry; entry = xa_find_after(xa, &index, ULONG_MAX, filter))
23 
24 struct dpll_dump_ctx {
25 	unsigned long idx;
26 };
27 
28 static struct dpll_dump_ctx *dpll_dump_context(struct netlink_callback *cb)
29 {
30 	return (struct dpll_dump_ctx *)cb->ctx;
31 }
32 
33 static int
34 dpll_msg_add_dev_handle(struct sk_buff *msg, struct dpll_device *dpll)
35 {
36 	if (nla_put_u32(msg, DPLL_A_ID, dpll->id))
37 		return -EMSGSIZE;
38 
39 	return 0;
40 }
41 
42 static int
43 dpll_msg_add_dev_parent_handle(struct sk_buff *msg, u32 id)
44 {
45 	if (nla_put_u32(msg, DPLL_A_PIN_PARENT_ID, id))
46 		return -EMSGSIZE;
47 
48 	return 0;
49 }
50 
51 /**
52  * dpll_msg_add_pin_handle - attach pin handle attribute to a given message
53  * @msg: pointer to sk_buff message to attach a pin handle
54  * @pin: pin pointer
55  *
56  * Return:
57  * * 0 - success
58  * * -EMSGSIZE - no space in message to attach pin handle
59  */
60 static int dpll_msg_add_pin_handle(struct sk_buff *msg, struct dpll_pin *pin)
61 {
62 	if (!pin)
63 		return 0;
64 	if (nla_put_u32(msg, DPLL_A_PIN_ID, pin->id))
65 		return -EMSGSIZE;
66 	return 0;
67 }
68 
69 static struct dpll_pin *dpll_netdev_pin(const struct net_device *dev)
70 {
71 	return rcu_dereference_rtnl(dev->dpll_pin);
72 }
73 
74 /**
75  * dpll_netdev_pin_handle_size - get size of pin handle attribute of a netdev
76  * @dev: netdev from which to get the pin
77  *
78  * Return: byte size of pin handle attribute, or 0 if @dev has no pin.
79  */
80 size_t dpll_netdev_pin_handle_size(const struct net_device *dev)
81 {
82 	return dpll_netdev_pin(dev) ? nla_total_size(4) : 0; /* DPLL_A_PIN_ID */
83 }
84 
85 int dpll_netdev_add_pin_handle(struct sk_buff *msg,
86 			       const struct net_device *dev)
87 {
88 	return dpll_msg_add_pin_handle(msg, dpll_netdev_pin(dev));
89 }
90 
91 static int
92 dpll_msg_add_mode(struct sk_buff *msg, struct dpll_device *dpll,
93 		  struct netlink_ext_ack *extack)
94 {
95 	const struct dpll_device_ops *ops = dpll_device_ops(dpll);
96 	enum dpll_mode mode;
97 	int ret;
98 
99 	ret = ops->mode_get(dpll, dpll_priv(dpll), &mode, extack);
100 	if (ret)
101 		return ret;
102 	if (nla_put_u32(msg, DPLL_A_MODE, mode))
103 		return -EMSGSIZE;
104 
105 	return 0;
106 }
107 
108 static int
109 dpll_msg_add_mode_supported(struct sk_buff *msg, struct dpll_device *dpll,
110 			    struct netlink_ext_ack *extack)
111 {
112 	const struct dpll_device_ops *ops = dpll_device_ops(dpll);
113 	enum dpll_mode mode;
114 	int ret;
115 
116 	/* No mode change is supported now, so the only supported mode is the
117 	 * one obtained by mode_get().
118 	 */
119 
120 	ret = ops->mode_get(dpll, dpll_priv(dpll), &mode, extack);
121 	if (ret)
122 		return ret;
123 	if (nla_put_u32(msg, DPLL_A_MODE_SUPPORTED, mode))
124 		return -EMSGSIZE;
125 
126 	return 0;
127 }
128 
129 static int
130 dpll_msg_add_lock_status(struct sk_buff *msg, struct dpll_device *dpll,
131 			 struct netlink_ext_ack *extack)
132 {
133 	const struct dpll_device_ops *ops = dpll_device_ops(dpll);
134 	enum dpll_lock_status_error status_error = 0;
135 	enum dpll_lock_status status;
136 	int ret;
137 
138 	ret = ops->lock_status_get(dpll, dpll_priv(dpll), &status,
139 				   &status_error, extack);
140 	if (ret)
141 		return ret;
142 	if (nla_put_u32(msg, DPLL_A_LOCK_STATUS, status))
143 		return -EMSGSIZE;
144 	if (status_error &&
145 	    (status == DPLL_LOCK_STATUS_UNLOCKED ||
146 	     status == DPLL_LOCK_STATUS_HOLDOVER) &&
147 	    nla_put_u32(msg, DPLL_A_LOCK_STATUS_ERROR, status_error))
148 		return -EMSGSIZE;
149 
150 	return 0;
151 }
152 
153 static int
154 dpll_msg_add_temp(struct sk_buff *msg, struct dpll_device *dpll,
155 		  struct netlink_ext_ack *extack)
156 {
157 	const struct dpll_device_ops *ops = dpll_device_ops(dpll);
158 	s32 temp;
159 	int ret;
160 
161 	if (!ops->temp_get)
162 		return 0;
163 	ret = ops->temp_get(dpll, dpll_priv(dpll), &temp, extack);
164 	if (ret)
165 		return ret;
166 	if (nla_put_s32(msg, DPLL_A_TEMP, temp))
167 		return -EMSGSIZE;
168 
169 	return 0;
170 }
171 
172 static int
173 dpll_msg_add_pin_prio(struct sk_buff *msg, struct dpll_pin *pin,
174 		      struct dpll_pin_ref *ref,
175 		      struct netlink_ext_ack *extack)
176 {
177 	const struct dpll_pin_ops *ops = dpll_pin_ops(ref);
178 	struct dpll_device *dpll = ref->dpll;
179 	u32 prio;
180 	int ret;
181 
182 	if (!ops->prio_get)
183 		return 0;
184 	ret = ops->prio_get(pin, dpll_pin_on_dpll_priv(dpll, pin), dpll,
185 			    dpll_priv(dpll), &prio, extack);
186 	if (ret)
187 		return ret;
188 	if (nla_put_u32(msg, DPLL_A_PIN_PRIO, prio))
189 		return -EMSGSIZE;
190 
191 	return 0;
192 }
193 
194 static int
195 dpll_msg_add_pin_on_dpll_state(struct sk_buff *msg, struct dpll_pin *pin,
196 			       struct dpll_pin_ref *ref,
197 			       struct netlink_ext_ack *extack)
198 {
199 	const struct dpll_pin_ops *ops = dpll_pin_ops(ref);
200 	struct dpll_device *dpll = ref->dpll;
201 	enum dpll_pin_state state;
202 	int ret;
203 
204 	if (!ops->state_on_dpll_get)
205 		return 0;
206 	ret = ops->state_on_dpll_get(pin, dpll_pin_on_dpll_priv(dpll, pin),
207 				     dpll, dpll_priv(dpll), &state, extack);
208 	if (ret)
209 		return ret;
210 	if (nla_put_u32(msg, DPLL_A_PIN_STATE, state))
211 		return -EMSGSIZE;
212 
213 	return 0;
214 }
215 
216 static int
217 dpll_msg_add_pin_direction(struct sk_buff *msg, struct dpll_pin *pin,
218 			   struct dpll_pin_ref *ref,
219 			   struct netlink_ext_ack *extack)
220 {
221 	const struct dpll_pin_ops *ops = dpll_pin_ops(ref);
222 	struct dpll_device *dpll = ref->dpll;
223 	enum dpll_pin_direction direction;
224 	int ret;
225 
226 	ret = ops->direction_get(pin, dpll_pin_on_dpll_priv(dpll, pin), dpll,
227 				 dpll_priv(dpll), &direction, extack);
228 	if (ret)
229 		return ret;
230 	if (nla_put_u32(msg, DPLL_A_PIN_DIRECTION, direction))
231 		return -EMSGSIZE;
232 
233 	return 0;
234 }
235 
236 static int
237 dpll_msg_add_pin_phase_adjust(struct sk_buff *msg, struct dpll_pin *pin,
238 			      struct dpll_pin_ref *ref,
239 			      struct netlink_ext_ack *extack)
240 {
241 	const struct dpll_pin_ops *ops = dpll_pin_ops(ref);
242 	struct dpll_device *dpll = ref->dpll;
243 	s32 phase_adjust;
244 	int ret;
245 
246 	if (!ops->phase_adjust_get)
247 		return 0;
248 	ret = ops->phase_adjust_get(pin, dpll_pin_on_dpll_priv(dpll, pin),
249 				    dpll, dpll_priv(dpll),
250 				    &phase_adjust, extack);
251 	if (ret)
252 		return ret;
253 	if (nla_put_s32(msg, DPLL_A_PIN_PHASE_ADJUST, phase_adjust))
254 		return -EMSGSIZE;
255 
256 	return 0;
257 }
258 
259 static int
260 dpll_msg_add_phase_offset(struct sk_buff *msg, struct dpll_pin *pin,
261 			  struct dpll_pin_ref *ref,
262 			  struct netlink_ext_ack *extack)
263 {
264 	const struct dpll_pin_ops *ops = dpll_pin_ops(ref);
265 	struct dpll_device *dpll = ref->dpll;
266 	s64 phase_offset;
267 	int ret;
268 
269 	if (!ops->phase_offset_get)
270 		return 0;
271 	ret = ops->phase_offset_get(pin, dpll_pin_on_dpll_priv(dpll, pin),
272 				    dpll, dpll_priv(dpll), &phase_offset,
273 				    extack);
274 	if (ret)
275 		return ret;
276 	if (nla_put_64bit(msg, DPLL_A_PIN_PHASE_OFFSET, sizeof(phase_offset),
277 			  &phase_offset, DPLL_A_PIN_PAD))
278 		return -EMSGSIZE;
279 
280 	return 0;
281 }
282 
283 static int dpll_msg_add_ffo(struct sk_buff *msg, struct dpll_pin *pin,
284 			    struct dpll_pin_ref *ref,
285 			    struct netlink_ext_ack *extack)
286 {
287 	const struct dpll_pin_ops *ops = dpll_pin_ops(ref);
288 	struct dpll_device *dpll = ref->dpll;
289 	s64 ffo;
290 	int ret;
291 
292 	if (!ops->ffo_get)
293 		return 0;
294 	ret = ops->ffo_get(pin, dpll_pin_on_dpll_priv(dpll, pin),
295 			   dpll, dpll_priv(dpll), &ffo, extack);
296 	if (ret) {
297 		if (ret == -ENODATA)
298 			return 0;
299 		return ret;
300 	}
301 	return nla_put_sint(msg, DPLL_A_PIN_FRACTIONAL_FREQUENCY_OFFSET, ffo);
302 }
303 
304 static int
305 dpll_msg_add_pin_freq(struct sk_buff *msg, struct dpll_pin *pin,
306 		      struct dpll_pin_ref *ref, struct netlink_ext_ack *extack)
307 {
308 	const struct dpll_pin_ops *ops = dpll_pin_ops(ref);
309 	struct dpll_device *dpll = ref->dpll;
310 	struct nlattr *nest;
311 	int fs, ret;
312 	u64 freq;
313 
314 	if (!ops->frequency_get)
315 		return 0;
316 	ret = ops->frequency_get(pin, dpll_pin_on_dpll_priv(dpll, pin), dpll,
317 				 dpll_priv(dpll), &freq, extack);
318 	if (ret)
319 		return ret;
320 	if (nla_put_64bit(msg, DPLL_A_PIN_FREQUENCY, sizeof(freq), &freq,
321 			  DPLL_A_PIN_PAD))
322 		return -EMSGSIZE;
323 	for (fs = 0; fs < pin->prop.freq_supported_num; fs++) {
324 		nest = nla_nest_start(msg, DPLL_A_PIN_FREQUENCY_SUPPORTED);
325 		if (!nest)
326 			return -EMSGSIZE;
327 		freq = pin->prop.freq_supported[fs].min;
328 		if (nla_put_64bit(msg, DPLL_A_PIN_FREQUENCY_MIN, sizeof(freq),
329 				  &freq, DPLL_A_PIN_PAD)) {
330 			nla_nest_cancel(msg, nest);
331 			return -EMSGSIZE;
332 		}
333 		freq = pin->prop.freq_supported[fs].max;
334 		if (nla_put_64bit(msg, DPLL_A_PIN_FREQUENCY_MAX, sizeof(freq),
335 				  &freq, DPLL_A_PIN_PAD)) {
336 			nla_nest_cancel(msg, nest);
337 			return -EMSGSIZE;
338 		}
339 		nla_nest_end(msg, nest);
340 	}
341 
342 	return 0;
343 }
344 
345 static bool dpll_pin_is_freq_supported(struct dpll_pin *pin, u32 freq)
346 {
347 	int fs;
348 
349 	for (fs = 0; fs < pin->prop.freq_supported_num; fs++)
350 		if (freq >= pin->prop.freq_supported[fs].min &&
351 		    freq <= pin->prop.freq_supported[fs].max)
352 			return true;
353 	return false;
354 }
355 
356 static int
357 dpll_msg_add_pin_parents(struct sk_buff *msg, struct dpll_pin *pin,
358 			 struct dpll_pin_ref *dpll_ref,
359 			 struct netlink_ext_ack *extack)
360 {
361 	enum dpll_pin_state state;
362 	struct dpll_pin_ref *ref;
363 	struct dpll_pin *ppin;
364 	struct nlattr *nest;
365 	unsigned long index;
366 	int ret;
367 
368 	xa_for_each(&pin->parent_refs, index, ref) {
369 		const struct dpll_pin_ops *ops = dpll_pin_ops(ref);
370 		void *parent_priv;
371 
372 		ppin = ref->pin;
373 		parent_priv = dpll_pin_on_dpll_priv(dpll_ref->dpll, ppin);
374 		ret = ops->state_on_pin_get(pin,
375 					    dpll_pin_on_pin_priv(ppin, pin),
376 					    ppin, parent_priv, &state, extack);
377 		if (ret)
378 			return ret;
379 		nest = nla_nest_start(msg, DPLL_A_PIN_PARENT_PIN);
380 		if (!nest)
381 			return -EMSGSIZE;
382 		ret = dpll_msg_add_dev_parent_handle(msg, ppin->id);
383 		if (ret)
384 			goto nest_cancel;
385 		if (nla_put_u32(msg, DPLL_A_PIN_STATE, state)) {
386 			ret = -EMSGSIZE;
387 			goto nest_cancel;
388 		}
389 		nla_nest_end(msg, nest);
390 	}
391 
392 	return 0;
393 
394 nest_cancel:
395 	nla_nest_cancel(msg, nest);
396 	return ret;
397 }
398 
399 static int
400 dpll_msg_add_pin_dplls(struct sk_buff *msg, struct dpll_pin *pin,
401 		       struct netlink_ext_ack *extack)
402 {
403 	struct dpll_pin_ref *ref;
404 	struct nlattr *attr;
405 	unsigned long index;
406 	int ret;
407 
408 	xa_for_each(&pin->dpll_refs, index, ref) {
409 		attr = nla_nest_start(msg, DPLL_A_PIN_PARENT_DEVICE);
410 		if (!attr)
411 			return -EMSGSIZE;
412 		ret = dpll_msg_add_dev_parent_handle(msg, ref->dpll->id);
413 		if (ret)
414 			goto nest_cancel;
415 		ret = dpll_msg_add_pin_on_dpll_state(msg, pin, ref, extack);
416 		if (ret)
417 			goto nest_cancel;
418 		ret = dpll_msg_add_pin_prio(msg, pin, ref, extack);
419 		if (ret)
420 			goto nest_cancel;
421 		ret = dpll_msg_add_pin_direction(msg, pin, ref, extack);
422 		if (ret)
423 			goto nest_cancel;
424 		ret = dpll_msg_add_phase_offset(msg, pin, ref, extack);
425 		if (ret)
426 			goto nest_cancel;
427 		nla_nest_end(msg, attr);
428 	}
429 
430 	return 0;
431 
432 nest_cancel:
433 	nla_nest_end(msg, attr);
434 	return ret;
435 }
436 
437 static int
438 dpll_cmd_pin_get_one(struct sk_buff *msg, struct dpll_pin *pin,
439 		     struct netlink_ext_ack *extack)
440 {
441 	const struct dpll_pin_properties *prop = &pin->prop;
442 	struct dpll_pin_ref *ref;
443 	int ret;
444 
445 	ref = dpll_xa_ref_dpll_first(&pin->dpll_refs);
446 	ASSERT_NOT_NULL(ref);
447 
448 	ret = dpll_msg_add_pin_handle(msg, pin);
449 	if (ret)
450 		return ret;
451 	if (nla_put_string(msg, DPLL_A_PIN_MODULE_NAME,
452 			   module_name(pin->module)))
453 		return -EMSGSIZE;
454 	if (nla_put_64bit(msg, DPLL_A_PIN_CLOCK_ID, sizeof(pin->clock_id),
455 			  &pin->clock_id, DPLL_A_PIN_PAD))
456 		return -EMSGSIZE;
457 	if (prop->board_label &&
458 	    nla_put_string(msg, DPLL_A_PIN_BOARD_LABEL, prop->board_label))
459 		return -EMSGSIZE;
460 	if (prop->panel_label &&
461 	    nla_put_string(msg, DPLL_A_PIN_PANEL_LABEL, prop->panel_label))
462 		return -EMSGSIZE;
463 	if (prop->package_label &&
464 	    nla_put_string(msg, DPLL_A_PIN_PACKAGE_LABEL,
465 			   prop->package_label))
466 		return -EMSGSIZE;
467 	if (nla_put_u32(msg, DPLL_A_PIN_TYPE, prop->type))
468 		return -EMSGSIZE;
469 	if (nla_put_u32(msg, DPLL_A_PIN_CAPABILITIES, prop->capabilities))
470 		return -EMSGSIZE;
471 	ret = dpll_msg_add_pin_freq(msg, pin, ref, extack);
472 	if (ret)
473 		return ret;
474 	if (nla_put_s32(msg, DPLL_A_PIN_PHASE_ADJUST_MIN,
475 			prop->phase_range.min))
476 		return -EMSGSIZE;
477 	if (nla_put_s32(msg, DPLL_A_PIN_PHASE_ADJUST_MAX,
478 			prop->phase_range.max))
479 		return -EMSGSIZE;
480 	ret = dpll_msg_add_pin_phase_adjust(msg, pin, ref, extack);
481 	if (ret)
482 		return ret;
483 	ret = dpll_msg_add_ffo(msg, pin, ref, extack);
484 	if (ret)
485 		return ret;
486 	if (xa_empty(&pin->parent_refs))
487 		ret = dpll_msg_add_pin_dplls(msg, pin, extack);
488 	else
489 		ret = dpll_msg_add_pin_parents(msg, pin, ref, extack);
490 
491 	return ret;
492 }
493 
494 static int
495 dpll_device_get_one(struct dpll_device *dpll, struct sk_buff *msg,
496 		    struct netlink_ext_ack *extack)
497 {
498 	int ret;
499 
500 	ret = dpll_msg_add_dev_handle(msg, dpll);
501 	if (ret)
502 		return ret;
503 	if (nla_put_string(msg, DPLL_A_MODULE_NAME, module_name(dpll->module)))
504 		return -EMSGSIZE;
505 	if (nla_put_64bit(msg, DPLL_A_CLOCK_ID, sizeof(dpll->clock_id),
506 			  &dpll->clock_id, DPLL_A_PAD))
507 		return -EMSGSIZE;
508 	ret = dpll_msg_add_temp(msg, dpll, extack);
509 	if (ret)
510 		return ret;
511 	ret = dpll_msg_add_lock_status(msg, dpll, extack);
512 	if (ret)
513 		return ret;
514 	ret = dpll_msg_add_mode(msg, dpll, extack);
515 	if (ret)
516 		return ret;
517 	ret = dpll_msg_add_mode_supported(msg, dpll, extack);
518 	if (ret)
519 		return ret;
520 	if (nla_put_u32(msg, DPLL_A_TYPE, dpll->type))
521 		return -EMSGSIZE;
522 
523 	return 0;
524 }
525 
526 static int
527 dpll_device_event_send(enum dpll_cmd event, struct dpll_device *dpll)
528 {
529 	struct sk_buff *msg;
530 	int ret = -ENOMEM;
531 	void *hdr;
532 
533 	if (WARN_ON(!xa_get_mark(&dpll_device_xa, dpll->id, DPLL_REGISTERED)))
534 		return -ENODEV;
535 	msg = genlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
536 	if (!msg)
537 		return -ENOMEM;
538 	hdr = genlmsg_put(msg, 0, 0, &dpll_nl_family, 0, event);
539 	if (!hdr)
540 		goto err_free_msg;
541 	ret = dpll_device_get_one(dpll, msg, NULL);
542 	if (ret)
543 		goto err_cancel_msg;
544 	genlmsg_end(msg, hdr);
545 	genlmsg_multicast(&dpll_nl_family, msg, 0, 0, GFP_KERNEL);
546 
547 	return 0;
548 
549 err_cancel_msg:
550 	genlmsg_cancel(msg, hdr);
551 err_free_msg:
552 	nlmsg_free(msg);
553 
554 	return ret;
555 }
556 
557 int dpll_device_create_ntf(struct dpll_device *dpll)
558 {
559 	return dpll_device_event_send(DPLL_CMD_DEVICE_CREATE_NTF, dpll);
560 }
561 
562 int dpll_device_delete_ntf(struct dpll_device *dpll)
563 {
564 	return dpll_device_event_send(DPLL_CMD_DEVICE_DELETE_NTF, dpll);
565 }
566 
567 static int
568 __dpll_device_change_ntf(struct dpll_device *dpll)
569 {
570 	return dpll_device_event_send(DPLL_CMD_DEVICE_CHANGE_NTF, dpll);
571 }
572 
573 static bool dpll_pin_available(struct dpll_pin *pin)
574 {
575 	struct dpll_pin_ref *par_ref;
576 	unsigned long i;
577 
578 	if (!xa_get_mark(&dpll_pin_xa, pin->id, DPLL_REGISTERED))
579 		return false;
580 	xa_for_each(&pin->parent_refs, i, par_ref)
581 		if (xa_get_mark(&dpll_pin_xa, par_ref->pin->id,
582 				DPLL_REGISTERED))
583 			return true;
584 	xa_for_each(&pin->dpll_refs, i, par_ref)
585 		if (xa_get_mark(&dpll_device_xa, par_ref->dpll->id,
586 				DPLL_REGISTERED))
587 			return true;
588 	return false;
589 }
590 
591 /**
592  * dpll_device_change_ntf - notify that the dpll device has been changed
593  * @dpll: registered dpll pointer
594  *
595  * Context: acquires and holds a dpll_lock.
596  * Return: 0 if succeeds, error code otherwise.
597  */
598 int dpll_device_change_ntf(struct dpll_device *dpll)
599 {
600 	int ret;
601 
602 	mutex_lock(&dpll_lock);
603 	ret = __dpll_device_change_ntf(dpll);
604 	mutex_unlock(&dpll_lock);
605 
606 	return ret;
607 }
608 EXPORT_SYMBOL_GPL(dpll_device_change_ntf);
609 
610 static int
611 dpll_pin_event_send(enum dpll_cmd event, struct dpll_pin *pin)
612 {
613 	struct sk_buff *msg;
614 	int ret = -ENOMEM;
615 	void *hdr;
616 
617 	if (!dpll_pin_available(pin))
618 		return -ENODEV;
619 
620 	msg = genlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
621 	if (!msg)
622 		return -ENOMEM;
623 
624 	hdr = genlmsg_put(msg, 0, 0, &dpll_nl_family, 0, event);
625 	if (!hdr)
626 		goto err_free_msg;
627 	ret = dpll_cmd_pin_get_one(msg, pin, NULL);
628 	if (ret)
629 		goto err_cancel_msg;
630 	genlmsg_end(msg, hdr);
631 	genlmsg_multicast(&dpll_nl_family, msg, 0, 0, GFP_KERNEL);
632 
633 	return 0;
634 
635 err_cancel_msg:
636 	genlmsg_cancel(msg, hdr);
637 err_free_msg:
638 	nlmsg_free(msg);
639 
640 	return ret;
641 }
642 
643 int dpll_pin_create_ntf(struct dpll_pin *pin)
644 {
645 	return dpll_pin_event_send(DPLL_CMD_PIN_CREATE_NTF, pin);
646 }
647 
648 int dpll_pin_delete_ntf(struct dpll_pin *pin)
649 {
650 	return dpll_pin_event_send(DPLL_CMD_PIN_DELETE_NTF, pin);
651 }
652 
653 static int __dpll_pin_change_ntf(struct dpll_pin *pin)
654 {
655 	return dpll_pin_event_send(DPLL_CMD_PIN_CHANGE_NTF, pin);
656 }
657 
658 /**
659  * dpll_pin_change_ntf - notify that the pin has been changed
660  * @pin: registered pin pointer
661  *
662  * Context: acquires and holds a dpll_lock.
663  * Return: 0 if succeeds, error code otherwise.
664  */
665 int dpll_pin_change_ntf(struct dpll_pin *pin)
666 {
667 	int ret;
668 
669 	mutex_lock(&dpll_lock);
670 	ret = __dpll_pin_change_ntf(pin);
671 	mutex_unlock(&dpll_lock);
672 
673 	return ret;
674 }
675 EXPORT_SYMBOL_GPL(dpll_pin_change_ntf);
676 
677 static int
678 dpll_pin_freq_set(struct dpll_pin *pin, struct nlattr *a,
679 		  struct netlink_ext_ack *extack)
680 {
681 	u64 freq = nla_get_u64(a), old_freq;
682 	struct dpll_pin_ref *ref, *failed;
683 	const struct dpll_pin_ops *ops;
684 	struct dpll_device *dpll;
685 	unsigned long i;
686 	int ret;
687 
688 	if (!dpll_pin_is_freq_supported(pin, freq)) {
689 		NL_SET_ERR_MSG_ATTR(extack, a, "frequency is not supported by the device");
690 		return -EINVAL;
691 	}
692 
693 	xa_for_each(&pin->dpll_refs, i, ref) {
694 		ops = dpll_pin_ops(ref);
695 		if (!ops->frequency_set || !ops->frequency_get) {
696 			NL_SET_ERR_MSG(extack, "frequency set not supported by the device");
697 			return -EOPNOTSUPP;
698 		}
699 	}
700 	ref = dpll_xa_ref_dpll_first(&pin->dpll_refs);
701 	ops = dpll_pin_ops(ref);
702 	dpll = ref->dpll;
703 	ret = ops->frequency_get(pin, dpll_pin_on_dpll_priv(dpll, pin), dpll,
704 				 dpll_priv(dpll), &old_freq, extack);
705 	if (ret) {
706 		NL_SET_ERR_MSG(extack, "unable to get old frequency value");
707 		return ret;
708 	}
709 	if (freq == old_freq)
710 		return 0;
711 
712 	xa_for_each(&pin->dpll_refs, i, ref) {
713 		ops = dpll_pin_ops(ref);
714 		dpll = ref->dpll;
715 		ret = ops->frequency_set(pin, dpll_pin_on_dpll_priv(dpll, pin),
716 					 dpll, dpll_priv(dpll), freq, extack);
717 		if (ret) {
718 			failed = ref;
719 			NL_SET_ERR_MSG_FMT(extack, "frequency set failed for dpll_id:%u",
720 					   dpll->id);
721 			goto rollback;
722 		}
723 	}
724 	__dpll_pin_change_ntf(pin);
725 
726 	return 0;
727 
728 rollback:
729 	xa_for_each(&pin->dpll_refs, i, ref) {
730 		if (ref == failed)
731 			break;
732 		ops = dpll_pin_ops(ref);
733 		dpll = ref->dpll;
734 		if (ops->frequency_set(pin, dpll_pin_on_dpll_priv(dpll, pin),
735 				       dpll, dpll_priv(dpll), old_freq, extack))
736 			NL_SET_ERR_MSG(extack, "set frequency rollback failed");
737 	}
738 	return ret;
739 }
740 
741 static int
742 dpll_pin_on_pin_state_set(struct dpll_pin *pin, u32 parent_idx,
743 			  enum dpll_pin_state state,
744 			  struct netlink_ext_ack *extack)
745 {
746 	struct dpll_pin_ref *parent_ref;
747 	const struct dpll_pin_ops *ops;
748 	struct dpll_pin_ref *dpll_ref;
749 	void *pin_priv, *parent_priv;
750 	struct dpll_pin *parent;
751 	unsigned long i;
752 	int ret;
753 
754 	if (!(DPLL_PIN_CAPABILITIES_STATE_CAN_CHANGE &
755 	      pin->prop.capabilities)) {
756 		NL_SET_ERR_MSG(extack, "state changing is not allowed");
757 		return -EOPNOTSUPP;
758 	}
759 	parent = xa_load(&dpll_pin_xa, parent_idx);
760 	if (!parent)
761 		return -EINVAL;
762 	parent_ref = xa_load(&pin->parent_refs, parent->pin_idx);
763 	if (!parent_ref)
764 		return -EINVAL;
765 	xa_for_each(&parent->dpll_refs, i, dpll_ref) {
766 		ops = dpll_pin_ops(parent_ref);
767 		if (!ops->state_on_pin_set)
768 			return -EOPNOTSUPP;
769 		pin_priv = dpll_pin_on_pin_priv(parent, pin);
770 		parent_priv = dpll_pin_on_dpll_priv(dpll_ref->dpll, parent);
771 		ret = ops->state_on_pin_set(pin, pin_priv, parent, parent_priv,
772 					    state, extack);
773 		if (ret)
774 			return ret;
775 	}
776 	__dpll_pin_change_ntf(pin);
777 
778 	return 0;
779 }
780 
781 static int
782 dpll_pin_state_set(struct dpll_device *dpll, struct dpll_pin *pin,
783 		   enum dpll_pin_state state,
784 		   struct netlink_ext_ack *extack)
785 {
786 	const struct dpll_pin_ops *ops;
787 	struct dpll_pin_ref *ref;
788 	int ret;
789 
790 	if (!(DPLL_PIN_CAPABILITIES_STATE_CAN_CHANGE &
791 	      pin->prop.capabilities)) {
792 		NL_SET_ERR_MSG(extack, "state changing is not allowed");
793 		return -EOPNOTSUPP;
794 	}
795 	ref = xa_load(&pin->dpll_refs, dpll->id);
796 	ASSERT_NOT_NULL(ref);
797 	ops = dpll_pin_ops(ref);
798 	if (!ops->state_on_dpll_set)
799 		return -EOPNOTSUPP;
800 	ret = ops->state_on_dpll_set(pin, dpll_pin_on_dpll_priv(dpll, pin),
801 				     dpll, dpll_priv(dpll), state, extack);
802 	if (ret)
803 		return ret;
804 	__dpll_pin_change_ntf(pin);
805 
806 	return 0;
807 }
808 
809 static int
810 dpll_pin_prio_set(struct dpll_device *dpll, struct dpll_pin *pin,
811 		  u32 prio, struct netlink_ext_ack *extack)
812 {
813 	const struct dpll_pin_ops *ops;
814 	struct dpll_pin_ref *ref;
815 	int ret;
816 
817 	if (!(DPLL_PIN_CAPABILITIES_PRIORITY_CAN_CHANGE &
818 	      pin->prop.capabilities)) {
819 		NL_SET_ERR_MSG(extack, "prio changing is not allowed");
820 		return -EOPNOTSUPP;
821 	}
822 	ref = xa_load(&pin->dpll_refs, dpll->id);
823 	ASSERT_NOT_NULL(ref);
824 	ops = dpll_pin_ops(ref);
825 	if (!ops->prio_set)
826 		return -EOPNOTSUPP;
827 	ret = ops->prio_set(pin, dpll_pin_on_dpll_priv(dpll, pin), dpll,
828 			    dpll_priv(dpll), prio, extack);
829 	if (ret)
830 		return ret;
831 	__dpll_pin_change_ntf(pin);
832 
833 	return 0;
834 }
835 
836 static int
837 dpll_pin_direction_set(struct dpll_pin *pin, struct dpll_device *dpll,
838 		       enum dpll_pin_direction direction,
839 		       struct netlink_ext_ack *extack)
840 {
841 	const struct dpll_pin_ops *ops;
842 	struct dpll_pin_ref *ref;
843 	int ret;
844 
845 	if (!(DPLL_PIN_CAPABILITIES_DIRECTION_CAN_CHANGE &
846 	      pin->prop.capabilities)) {
847 		NL_SET_ERR_MSG(extack, "direction changing is not allowed");
848 		return -EOPNOTSUPP;
849 	}
850 	ref = xa_load(&pin->dpll_refs, dpll->id);
851 	ASSERT_NOT_NULL(ref);
852 	ops = dpll_pin_ops(ref);
853 	if (!ops->direction_set)
854 		return -EOPNOTSUPP;
855 	ret = ops->direction_set(pin, dpll_pin_on_dpll_priv(dpll, pin),
856 				 dpll, dpll_priv(dpll), direction, extack);
857 	if (ret)
858 		return ret;
859 	__dpll_pin_change_ntf(pin);
860 
861 	return 0;
862 }
863 
864 static int
865 dpll_pin_phase_adj_set(struct dpll_pin *pin, struct nlattr *phase_adj_attr,
866 		       struct netlink_ext_ack *extack)
867 {
868 	struct dpll_pin_ref *ref, *failed;
869 	const struct dpll_pin_ops *ops;
870 	s32 phase_adj, old_phase_adj;
871 	struct dpll_device *dpll;
872 	unsigned long i;
873 	int ret;
874 
875 	phase_adj = nla_get_s32(phase_adj_attr);
876 	if (phase_adj > pin->prop.phase_range.max ||
877 	    phase_adj < pin->prop.phase_range.min) {
878 		NL_SET_ERR_MSG_ATTR(extack, phase_adj_attr,
879 				    "phase adjust value not supported");
880 		return -EINVAL;
881 	}
882 
883 	xa_for_each(&pin->dpll_refs, i, ref) {
884 		ops = dpll_pin_ops(ref);
885 		if (!ops->phase_adjust_set || !ops->phase_adjust_get) {
886 			NL_SET_ERR_MSG(extack, "phase adjust not supported");
887 			return -EOPNOTSUPP;
888 		}
889 	}
890 	ref = dpll_xa_ref_dpll_first(&pin->dpll_refs);
891 	ops = dpll_pin_ops(ref);
892 	dpll = ref->dpll;
893 	ret = ops->phase_adjust_get(pin, dpll_pin_on_dpll_priv(dpll, pin),
894 				    dpll, dpll_priv(dpll), &old_phase_adj,
895 				    extack);
896 	if (ret) {
897 		NL_SET_ERR_MSG(extack, "unable to get old phase adjust value");
898 		return ret;
899 	}
900 	if (phase_adj == old_phase_adj)
901 		return 0;
902 
903 	xa_for_each(&pin->dpll_refs, i, ref) {
904 		ops = dpll_pin_ops(ref);
905 		dpll = ref->dpll;
906 		ret = ops->phase_adjust_set(pin,
907 					    dpll_pin_on_dpll_priv(dpll, pin),
908 					    dpll, dpll_priv(dpll), phase_adj,
909 					    extack);
910 		if (ret) {
911 			failed = ref;
912 			NL_SET_ERR_MSG_FMT(extack,
913 					   "phase adjust set failed for dpll_id:%u",
914 					   dpll->id);
915 			goto rollback;
916 		}
917 	}
918 	__dpll_pin_change_ntf(pin);
919 
920 	return 0;
921 
922 rollback:
923 	xa_for_each(&pin->dpll_refs, i, ref) {
924 		if (ref == failed)
925 			break;
926 		ops = dpll_pin_ops(ref);
927 		dpll = ref->dpll;
928 		if (ops->phase_adjust_set(pin, dpll_pin_on_dpll_priv(dpll, pin),
929 					  dpll, dpll_priv(dpll), old_phase_adj,
930 					  extack))
931 			NL_SET_ERR_MSG(extack, "set phase adjust rollback failed");
932 	}
933 	return ret;
934 }
935 
936 static int
937 dpll_pin_parent_device_set(struct dpll_pin *pin, struct nlattr *parent_nest,
938 			   struct netlink_ext_ack *extack)
939 {
940 	struct nlattr *tb[DPLL_A_PIN_MAX + 1];
941 	enum dpll_pin_direction direction;
942 	enum dpll_pin_state state;
943 	struct dpll_pin_ref *ref;
944 	struct dpll_device *dpll;
945 	u32 pdpll_idx, prio;
946 	int ret;
947 
948 	nla_parse_nested(tb, DPLL_A_PIN_MAX, parent_nest,
949 			 dpll_pin_parent_device_nl_policy, extack);
950 	if (!tb[DPLL_A_PIN_PARENT_ID]) {
951 		NL_SET_ERR_MSG(extack, "device parent id expected");
952 		return -EINVAL;
953 	}
954 	pdpll_idx = nla_get_u32(tb[DPLL_A_PIN_PARENT_ID]);
955 	dpll = xa_load(&dpll_device_xa, pdpll_idx);
956 	if (!dpll) {
957 		NL_SET_ERR_MSG(extack, "parent device not found");
958 		return -EINVAL;
959 	}
960 	ref = xa_load(&pin->dpll_refs, dpll->id);
961 	if (!ref) {
962 		NL_SET_ERR_MSG(extack, "pin not connected to given parent device");
963 		return -EINVAL;
964 	}
965 	if (tb[DPLL_A_PIN_STATE]) {
966 		state = nla_get_u32(tb[DPLL_A_PIN_STATE]);
967 		ret = dpll_pin_state_set(dpll, pin, state, extack);
968 		if (ret)
969 			return ret;
970 	}
971 	if (tb[DPLL_A_PIN_PRIO]) {
972 		prio = nla_get_u32(tb[DPLL_A_PIN_PRIO]);
973 		ret = dpll_pin_prio_set(dpll, pin, prio, extack);
974 		if (ret)
975 			return ret;
976 	}
977 	if (tb[DPLL_A_PIN_DIRECTION]) {
978 		direction = nla_get_u32(tb[DPLL_A_PIN_DIRECTION]);
979 		ret = dpll_pin_direction_set(pin, dpll, direction, extack);
980 		if (ret)
981 			return ret;
982 	}
983 	return 0;
984 }
985 
986 static int
987 dpll_pin_parent_pin_set(struct dpll_pin *pin, struct nlattr *parent_nest,
988 			struct netlink_ext_ack *extack)
989 {
990 	struct nlattr *tb[DPLL_A_PIN_MAX + 1];
991 	u32 ppin_idx;
992 	int ret;
993 
994 	nla_parse_nested(tb, DPLL_A_PIN_MAX, parent_nest,
995 			 dpll_pin_parent_pin_nl_policy, extack);
996 	if (!tb[DPLL_A_PIN_PARENT_ID]) {
997 		NL_SET_ERR_MSG(extack, "device parent id expected");
998 		return -EINVAL;
999 	}
1000 	ppin_idx = nla_get_u32(tb[DPLL_A_PIN_PARENT_ID]);
1001 
1002 	if (tb[DPLL_A_PIN_STATE]) {
1003 		enum dpll_pin_state state = nla_get_u32(tb[DPLL_A_PIN_STATE]);
1004 
1005 		ret = dpll_pin_on_pin_state_set(pin, ppin_idx, state, extack);
1006 		if (ret)
1007 			return ret;
1008 	}
1009 
1010 	return 0;
1011 }
1012 
1013 static int
1014 dpll_pin_set_from_nlattr(struct dpll_pin *pin, struct genl_info *info)
1015 {
1016 	struct nlattr *a;
1017 	int rem, ret;
1018 
1019 	nla_for_each_attr(a, genlmsg_data(info->genlhdr),
1020 			  genlmsg_len(info->genlhdr), rem) {
1021 		switch (nla_type(a)) {
1022 		case DPLL_A_PIN_FREQUENCY:
1023 			ret = dpll_pin_freq_set(pin, a, info->extack);
1024 			if (ret)
1025 				return ret;
1026 			break;
1027 		case DPLL_A_PIN_PHASE_ADJUST:
1028 			ret = dpll_pin_phase_adj_set(pin, a, info->extack);
1029 			if (ret)
1030 				return ret;
1031 			break;
1032 		case DPLL_A_PIN_PARENT_DEVICE:
1033 			ret = dpll_pin_parent_device_set(pin, a, info->extack);
1034 			if (ret)
1035 				return ret;
1036 			break;
1037 		case DPLL_A_PIN_PARENT_PIN:
1038 			ret = dpll_pin_parent_pin_set(pin, a, info->extack);
1039 			if (ret)
1040 				return ret;
1041 			break;
1042 		}
1043 	}
1044 
1045 	return 0;
1046 }
1047 
1048 static struct dpll_pin *
1049 dpll_pin_find(u64 clock_id, struct nlattr *mod_name_attr,
1050 	      enum dpll_pin_type type, struct nlattr *board_label,
1051 	      struct nlattr *panel_label, struct nlattr *package_label,
1052 	      struct netlink_ext_ack *extack)
1053 {
1054 	bool board_match, panel_match, package_match;
1055 	struct dpll_pin *pin_match = NULL, *pin;
1056 	const struct dpll_pin_properties *prop;
1057 	bool cid_match, mod_match, type_match;
1058 	unsigned long i;
1059 
1060 	xa_for_each_marked(&dpll_pin_xa, i, pin, DPLL_REGISTERED) {
1061 		prop = &pin->prop;
1062 		cid_match = clock_id ? pin->clock_id == clock_id : true;
1063 		mod_match = mod_name_attr && module_name(pin->module) ?
1064 			!nla_strcmp(mod_name_attr,
1065 				    module_name(pin->module)) : true;
1066 		type_match = type ? prop->type == type : true;
1067 		board_match = board_label ? (prop->board_label ?
1068 			!nla_strcmp(board_label, prop->board_label) : false) :
1069 			true;
1070 		panel_match = panel_label ? (prop->panel_label ?
1071 			!nla_strcmp(panel_label, prop->panel_label) : false) :
1072 			true;
1073 		package_match = package_label ? (prop->package_label ?
1074 			!nla_strcmp(package_label, prop->package_label) :
1075 			false) : true;
1076 		if (cid_match && mod_match && type_match && board_match &&
1077 		    panel_match && package_match) {
1078 			if (pin_match) {
1079 				NL_SET_ERR_MSG(extack, "multiple matches");
1080 				return ERR_PTR(-EINVAL);
1081 			}
1082 			pin_match = pin;
1083 		}
1084 	}
1085 	if (!pin_match) {
1086 		NL_SET_ERR_MSG(extack, "not found");
1087 		return ERR_PTR(-ENODEV);
1088 	}
1089 	return pin_match;
1090 }
1091 
1092 static struct dpll_pin *dpll_pin_find_from_nlattr(struct genl_info *info)
1093 {
1094 	struct nlattr *attr, *mod_name_attr = NULL, *board_label_attr = NULL,
1095 		*panel_label_attr = NULL, *package_label_attr = NULL;
1096 	enum dpll_pin_type type = 0;
1097 	u64 clock_id = 0;
1098 	int rem = 0;
1099 
1100 	nla_for_each_attr(attr, genlmsg_data(info->genlhdr),
1101 			  genlmsg_len(info->genlhdr), rem) {
1102 		switch (nla_type(attr)) {
1103 		case DPLL_A_PIN_CLOCK_ID:
1104 			if (clock_id)
1105 				goto duplicated_attr;
1106 			clock_id = nla_get_u64(attr);
1107 			break;
1108 		case DPLL_A_PIN_MODULE_NAME:
1109 			if (mod_name_attr)
1110 				goto duplicated_attr;
1111 			mod_name_attr = attr;
1112 			break;
1113 		case DPLL_A_PIN_TYPE:
1114 			if (type)
1115 				goto duplicated_attr;
1116 			type = nla_get_u32(attr);
1117 		break;
1118 		case DPLL_A_PIN_BOARD_LABEL:
1119 			if (board_label_attr)
1120 				goto duplicated_attr;
1121 			board_label_attr = attr;
1122 		break;
1123 		case DPLL_A_PIN_PANEL_LABEL:
1124 			if (panel_label_attr)
1125 				goto duplicated_attr;
1126 			panel_label_attr = attr;
1127 		break;
1128 		case DPLL_A_PIN_PACKAGE_LABEL:
1129 			if (package_label_attr)
1130 				goto duplicated_attr;
1131 			package_label_attr = attr;
1132 		break;
1133 		default:
1134 			break;
1135 		}
1136 	}
1137 	if (!(clock_id  || mod_name_attr || board_label_attr ||
1138 	      panel_label_attr || package_label_attr)) {
1139 		NL_SET_ERR_MSG(info->extack, "missing attributes");
1140 		return ERR_PTR(-EINVAL);
1141 	}
1142 	return dpll_pin_find(clock_id, mod_name_attr, type, board_label_attr,
1143 			     panel_label_attr, package_label_attr,
1144 			     info->extack);
1145 duplicated_attr:
1146 	NL_SET_ERR_MSG(info->extack, "duplicated attribute");
1147 	return ERR_PTR(-EINVAL);
1148 }
1149 
1150 int dpll_nl_pin_id_get_doit(struct sk_buff *skb, struct genl_info *info)
1151 {
1152 	struct dpll_pin *pin;
1153 	struct sk_buff *msg;
1154 	struct nlattr *hdr;
1155 	int ret;
1156 
1157 	msg = genlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
1158 	if (!msg)
1159 		return -ENOMEM;
1160 	hdr = genlmsg_put_reply(msg, info, &dpll_nl_family, 0,
1161 				DPLL_CMD_PIN_ID_GET);
1162 	if (!hdr) {
1163 		nlmsg_free(msg);
1164 		return -EMSGSIZE;
1165 	}
1166 	pin = dpll_pin_find_from_nlattr(info);
1167 	if (!IS_ERR(pin)) {
1168 		if (!dpll_pin_available(pin)) {
1169 			nlmsg_free(msg);
1170 			return -ENODEV;
1171 		}
1172 		ret = dpll_msg_add_pin_handle(msg, pin);
1173 		if (ret) {
1174 			nlmsg_free(msg);
1175 			return ret;
1176 		}
1177 	}
1178 	genlmsg_end(msg, hdr);
1179 
1180 	return genlmsg_reply(msg, info);
1181 }
1182 
1183 int dpll_nl_pin_get_doit(struct sk_buff *skb, struct genl_info *info)
1184 {
1185 	struct dpll_pin *pin = info->user_ptr[0];
1186 	struct sk_buff *msg;
1187 	struct nlattr *hdr;
1188 	int ret;
1189 
1190 	if (!pin)
1191 		return -ENODEV;
1192 	msg = genlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
1193 	if (!msg)
1194 		return -ENOMEM;
1195 	hdr = genlmsg_put_reply(msg, info, &dpll_nl_family, 0,
1196 				DPLL_CMD_PIN_GET);
1197 	if (!hdr) {
1198 		nlmsg_free(msg);
1199 		return -EMSGSIZE;
1200 	}
1201 	ret = dpll_cmd_pin_get_one(msg, pin, info->extack);
1202 	if (ret) {
1203 		nlmsg_free(msg);
1204 		return ret;
1205 	}
1206 	genlmsg_end(msg, hdr);
1207 
1208 	return genlmsg_reply(msg, info);
1209 }
1210 
1211 int dpll_nl_pin_get_dumpit(struct sk_buff *skb, struct netlink_callback *cb)
1212 {
1213 	struct dpll_dump_ctx *ctx = dpll_dump_context(cb);
1214 	struct dpll_pin *pin;
1215 	struct nlattr *hdr;
1216 	unsigned long i;
1217 	int ret = 0;
1218 
1219 	mutex_lock(&dpll_lock);
1220 	xa_for_each_marked_start(&dpll_pin_xa, i, pin, DPLL_REGISTERED,
1221 				 ctx->idx) {
1222 		if (!dpll_pin_available(pin))
1223 			continue;
1224 		hdr = genlmsg_put(skb, NETLINK_CB(cb->skb).portid,
1225 				  cb->nlh->nlmsg_seq,
1226 				  &dpll_nl_family, NLM_F_MULTI,
1227 				  DPLL_CMD_PIN_GET);
1228 		if (!hdr) {
1229 			ret = -EMSGSIZE;
1230 			break;
1231 		}
1232 		ret = dpll_cmd_pin_get_one(skb, pin, cb->extack);
1233 		if (ret) {
1234 			genlmsg_cancel(skb, hdr);
1235 			break;
1236 		}
1237 		genlmsg_end(skb, hdr);
1238 	}
1239 	mutex_unlock(&dpll_lock);
1240 
1241 	if (ret == -EMSGSIZE) {
1242 		ctx->idx = i;
1243 		return skb->len;
1244 	}
1245 	return ret;
1246 }
1247 
1248 int dpll_nl_pin_set_doit(struct sk_buff *skb, struct genl_info *info)
1249 {
1250 	struct dpll_pin *pin = info->user_ptr[0];
1251 
1252 	return dpll_pin_set_from_nlattr(pin, info);
1253 }
1254 
1255 static struct dpll_device *
1256 dpll_device_find(u64 clock_id, struct nlattr *mod_name_attr,
1257 		 enum dpll_type type, struct netlink_ext_ack *extack)
1258 {
1259 	struct dpll_device *dpll_match = NULL, *dpll;
1260 	bool cid_match, mod_match, type_match;
1261 	unsigned long i;
1262 
1263 	xa_for_each_marked(&dpll_device_xa, i, dpll, DPLL_REGISTERED) {
1264 		cid_match = clock_id ? dpll->clock_id == clock_id : true;
1265 		mod_match = mod_name_attr ? (module_name(dpll->module) ?
1266 			!nla_strcmp(mod_name_attr,
1267 				    module_name(dpll->module)) : false) : true;
1268 		type_match = type ? dpll->type == type : true;
1269 		if (cid_match && mod_match && type_match) {
1270 			if (dpll_match) {
1271 				NL_SET_ERR_MSG(extack, "multiple matches");
1272 				return ERR_PTR(-EINVAL);
1273 			}
1274 			dpll_match = dpll;
1275 		}
1276 	}
1277 	if (!dpll_match) {
1278 		NL_SET_ERR_MSG(extack, "not found");
1279 		return ERR_PTR(-ENODEV);
1280 	}
1281 
1282 	return dpll_match;
1283 }
1284 
1285 static struct dpll_device *
1286 dpll_device_find_from_nlattr(struct genl_info *info)
1287 {
1288 	struct nlattr *attr, *mod_name_attr = NULL;
1289 	enum dpll_type type = 0;
1290 	u64 clock_id = 0;
1291 	int rem = 0;
1292 
1293 	nla_for_each_attr(attr, genlmsg_data(info->genlhdr),
1294 			  genlmsg_len(info->genlhdr), rem) {
1295 		switch (nla_type(attr)) {
1296 		case DPLL_A_CLOCK_ID:
1297 			if (clock_id)
1298 				goto duplicated_attr;
1299 			clock_id = nla_get_u64(attr);
1300 			break;
1301 		case DPLL_A_MODULE_NAME:
1302 			if (mod_name_attr)
1303 				goto duplicated_attr;
1304 			mod_name_attr = attr;
1305 			break;
1306 		case DPLL_A_TYPE:
1307 			if (type)
1308 				goto duplicated_attr;
1309 			type = nla_get_u32(attr);
1310 			break;
1311 		default:
1312 			break;
1313 		}
1314 	}
1315 	if (!clock_id && !mod_name_attr && !type) {
1316 		NL_SET_ERR_MSG(info->extack, "missing attributes");
1317 		return ERR_PTR(-EINVAL);
1318 	}
1319 	return dpll_device_find(clock_id, mod_name_attr, type, info->extack);
1320 duplicated_attr:
1321 	NL_SET_ERR_MSG(info->extack, "duplicated attribute");
1322 	return ERR_PTR(-EINVAL);
1323 }
1324 
1325 int dpll_nl_device_id_get_doit(struct sk_buff *skb, struct genl_info *info)
1326 {
1327 	struct dpll_device *dpll;
1328 	struct sk_buff *msg;
1329 	struct nlattr *hdr;
1330 	int ret;
1331 
1332 	msg = genlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
1333 	if (!msg)
1334 		return -ENOMEM;
1335 	hdr = genlmsg_put_reply(msg, info, &dpll_nl_family, 0,
1336 				DPLL_CMD_DEVICE_ID_GET);
1337 	if (!hdr) {
1338 		nlmsg_free(msg);
1339 		return -EMSGSIZE;
1340 	}
1341 
1342 	dpll = dpll_device_find_from_nlattr(info);
1343 	if (!IS_ERR(dpll)) {
1344 		ret = dpll_msg_add_dev_handle(msg, dpll);
1345 		if (ret) {
1346 			nlmsg_free(msg);
1347 			return ret;
1348 		}
1349 	}
1350 	genlmsg_end(msg, hdr);
1351 
1352 	return genlmsg_reply(msg, info);
1353 }
1354 
1355 int dpll_nl_device_get_doit(struct sk_buff *skb, struct genl_info *info)
1356 {
1357 	struct dpll_device *dpll = info->user_ptr[0];
1358 	struct sk_buff *msg;
1359 	struct nlattr *hdr;
1360 	int ret;
1361 
1362 	msg = genlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
1363 	if (!msg)
1364 		return -ENOMEM;
1365 	hdr = genlmsg_put_reply(msg, info, &dpll_nl_family, 0,
1366 				DPLL_CMD_DEVICE_GET);
1367 	if (!hdr) {
1368 		nlmsg_free(msg);
1369 		return -EMSGSIZE;
1370 	}
1371 
1372 	ret = dpll_device_get_one(dpll, msg, info->extack);
1373 	if (ret) {
1374 		nlmsg_free(msg);
1375 		return ret;
1376 	}
1377 	genlmsg_end(msg, hdr);
1378 
1379 	return genlmsg_reply(msg, info);
1380 }
1381 
1382 int dpll_nl_device_set_doit(struct sk_buff *skb, struct genl_info *info)
1383 {
1384 	/* placeholder for set command */
1385 	return 0;
1386 }
1387 
1388 int dpll_nl_device_get_dumpit(struct sk_buff *skb, struct netlink_callback *cb)
1389 {
1390 	struct dpll_dump_ctx *ctx = dpll_dump_context(cb);
1391 	struct dpll_device *dpll;
1392 	struct nlattr *hdr;
1393 	unsigned long i;
1394 	int ret = 0;
1395 
1396 	mutex_lock(&dpll_lock);
1397 	xa_for_each_marked_start(&dpll_device_xa, i, dpll, DPLL_REGISTERED,
1398 				 ctx->idx) {
1399 		hdr = genlmsg_put(skb, NETLINK_CB(cb->skb).portid,
1400 				  cb->nlh->nlmsg_seq, &dpll_nl_family,
1401 				  NLM_F_MULTI, DPLL_CMD_DEVICE_GET);
1402 		if (!hdr) {
1403 			ret = -EMSGSIZE;
1404 			break;
1405 		}
1406 		ret = dpll_device_get_one(dpll, skb, cb->extack);
1407 		if (ret) {
1408 			genlmsg_cancel(skb, hdr);
1409 			break;
1410 		}
1411 		genlmsg_end(skb, hdr);
1412 	}
1413 	mutex_unlock(&dpll_lock);
1414 
1415 	if (ret == -EMSGSIZE) {
1416 		ctx->idx = i;
1417 		return skb->len;
1418 	}
1419 	return ret;
1420 }
1421 
1422 int dpll_pre_doit(const struct genl_split_ops *ops, struct sk_buff *skb,
1423 		  struct genl_info *info)
1424 {
1425 	u32 id;
1426 
1427 	if (GENL_REQ_ATTR_CHECK(info, DPLL_A_ID))
1428 		return -EINVAL;
1429 
1430 	mutex_lock(&dpll_lock);
1431 	id = nla_get_u32(info->attrs[DPLL_A_ID]);
1432 	info->user_ptr[0] = dpll_device_get_by_id(id);
1433 	if (!info->user_ptr[0]) {
1434 		NL_SET_ERR_MSG(info->extack, "device not found");
1435 		goto unlock;
1436 	}
1437 	return 0;
1438 unlock:
1439 	mutex_unlock(&dpll_lock);
1440 	return -ENODEV;
1441 }
1442 
1443 void dpll_post_doit(const struct genl_split_ops *ops, struct sk_buff *skb,
1444 		    struct genl_info *info)
1445 {
1446 	mutex_unlock(&dpll_lock);
1447 }
1448 
1449 int
1450 dpll_lock_doit(const struct genl_split_ops *ops, struct sk_buff *skb,
1451 	       struct genl_info *info)
1452 {
1453 	mutex_lock(&dpll_lock);
1454 
1455 	return 0;
1456 }
1457 
1458 void
1459 dpll_unlock_doit(const struct genl_split_ops *ops, struct sk_buff *skb,
1460 		 struct genl_info *info)
1461 {
1462 	mutex_unlock(&dpll_lock);
1463 }
1464 
1465 int dpll_pin_pre_doit(const struct genl_split_ops *ops, struct sk_buff *skb,
1466 		      struct genl_info *info)
1467 {
1468 	int ret;
1469 
1470 	mutex_lock(&dpll_lock);
1471 	if (GENL_REQ_ATTR_CHECK(info, DPLL_A_PIN_ID)) {
1472 		ret = -EINVAL;
1473 		goto unlock_dev;
1474 	}
1475 	info->user_ptr[0] = xa_load(&dpll_pin_xa,
1476 				    nla_get_u32(info->attrs[DPLL_A_PIN_ID]));
1477 	if (!info->user_ptr[0] ||
1478 	    !dpll_pin_available(info->user_ptr[0])) {
1479 		NL_SET_ERR_MSG(info->extack, "pin not found");
1480 		ret = -ENODEV;
1481 		goto unlock_dev;
1482 	}
1483 
1484 	return 0;
1485 
1486 unlock_dev:
1487 	mutex_unlock(&dpll_lock);
1488 	return ret;
1489 }
1490 
1491 void dpll_pin_post_doit(const struct genl_split_ops *ops, struct sk_buff *skb,
1492 			struct genl_info *info)
1493 {
1494 	mutex_unlock(&dpll_lock);
1495 }
1496