Lines Matching +full:pd +full:- +full:node
1 // SPDX-License-Identifier: GPL-2.0
31 struct list_head node; member
46 /* serialize pd status invocation */
69 struct list_head node; member
78 mutex_lock(&pdr->lock); in pdr_locator_new_server()
80 pdr->locator_addr.sq_family = AF_QIPCRTR; in pdr_locator_new_server()
81 pdr->locator_addr.sq_node = svc->node; in pdr_locator_new_server()
82 pdr->locator_addr.sq_port = svc->port; in pdr_locator_new_server()
84 pdr->locator_init_complete = true; in pdr_locator_new_server()
85 mutex_unlock(&pdr->lock); in pdr_locator_new_server()
88 schedule_work(&pdr->locator_work); in pdr_locator_new_server()
99 mutex_lock(&pdr->lock); in pdr_locator_del_server()
100 pdr->locator_init_complete = false; in pdr_locator_del_server()
102 pdr->locator_addr.sq_node = 0; in pdr_locator_del_server()
103 pdr->locator_addr.sq_port = 0; in pdr_locator_del_server()
104 mutex_unlock(&pdr->lock); in pdr_locator_del_server()
121 ret = qmi_txn_init(&pdr->notifier_hdl, &txn, in pdr_register_listener()
128 strscpy(req.service_path, pds->service_path, sizeof(req.service_path)); in pdr_register_listener()
130 ret = qmi_send_request(&pdr->notifier_hdl, &pds->addr, in pdr_register_listener()
143 pds->service_path, ret); in pdr_register_listener()
149 pds->service_path, resp.resp.error); in pdr_register_listener()
150 return -EREMOTEIO; in pdr_register_listener()
153 pds->state = resp.curr_state; in pdr_register_listener()
165 mutex_lock(&pdr->list_lock); in pdr_notifier_work()
166 list_for_each_entry(pds, &pdr->lookups, node) { in pdr_notifier_work()
167 if (pds->service_connected) { in pdr_notifier_work()
168 if (!pds->need_notifier_register) in pdr_notifier_work()
171 pds->need_notifier_register = false; in pdr_notifier_work()
174 pds->state = SERVREG_SERVICE_STATE_DOWN; in pdr_notifier_work()
176 if (!pds->need_notifier_remove) in pdr_notifier_work()
179 pds->need_notifier_remove = false; in pdr_notifier_work()
180 pds->state = SERVREG_SERVICE_STATE_DOWN; in pdr_notifier_work()
183 mutex_lock(&pdr->status_lock); in pdr_notifier_work()
184 pdr->status(pds->state, pds->service_path, pdr->priv); in pdr_notifier_work()
185 mutex_unlock(&pdr->status_lock); in pdr_notifier_work()
187 mutex_unlock(&pdr->list_lock); in pdr_notifier_work()
197 mutex_lock(&pdr->list_lock); in pdr_notifier_new_server()
198 list_for_each_entry(pds, &pdr->lookups, node) { in pdr_notifier_new_server()
199 if (pds->service == svc->service && in pdr_notifier_new_server()
200 pds->instance == svc->instance) { in pdr_notifier_new_server()
201 pds->service_connected = true; in pdr_notifier_new_server()
202 pds->need_notifier_register = true; in pdr_notifier_new_server()
203 pds->addr.sq_family = AF_QIPCRTR; in pdr_notifier_new_server()
204 pds->addr.sq_node = svc->node; in pdr_notifier_new_server()
205 pds->addr.sq_port = svc->port; in pdr_notifier_new_server()
206 queue_work(pdr->notifier_wq, &pdr->notifier_work); in pdr_notifier_new_server()
209 mutex_unlock(&pdr->list_lock); in pdr_notifier_new_server()
221 mutex_lock(&pdr->list_lock); in pdr_notifier_del_server()
222 list_for_each_entry(pds, &pdr->lookups, node) { in pdr_notifier_del_server()
223 if (pds->service == svc->service && in pdr_notifier_del_server()
224 pds->instance == svc->instance) { in pdr_notifier_del_server()
225 pds->service_connected = false; in pdr_notifier_del_server()
226 pds->need_notifier_remove = true; in pdr_notifier_del_server()
227 pds->addr.sq_node = 0; in pdr_notifier_del_server()
228 pds->addr.sq_port = 0; in pdr_notifier_del_server()
229 queue_work(pdr->notifier_wq, &pdr->notifier_work); in pdr_notifier_del_server()
232 mutex_unlock(&pdr->list_lock); in pdr_notifier_del_server()
248 ret = qmi_txn_init(&pdr->notifier_hdl, &txn, servreg_set_ack_resp_ei, in pdr_send_indack_msg()
254 strscpy(req.service_path, pds->service_path, sizeof(req.service_path)); in pdr_send_indack_msg()
256 ret = qmi_send_request(&pdr->notifier_hdl, &pds->addr, in pdr_send_indack_msg()
274 list_for_each_entry_safe(ind, tmp, &pdr->indack_list, node) { in pdr_indack_work()
275 pds = ind->pds; in pdr_indack_work()
277 mutex_lock(&pdr->status_lock); in pdr_indack_work()
278 pds->state = ind->curr_state; in pdr_indack_work()
279 pdr->status(pds->state, pds->service_path, pdr->priv); in pdr_indack_work()
280 mutex_unlock(&pdr->status_lock); in pdr_indack_work()
282 /* Ack the indication after clients release the PD resources */ in pdr_indack_work()
283 pdr_send_indack_msg(pdr, pds, ind->transaction_id); in pdr_indack_work()
285 mutex_lock(&pdr->list_lock); in pdr_indack_work()
286 list_del(&ind->node); in pdr_indack_work()
287 mutex_unlock(&pdr->list_lock); in pdr_indack_work()
303 if (!ind_msg || !ind_msg->service_path[0] || in pdr_indication_cb()
304 strlen(ind_msg->service_path) > SERVREG_NAME_LENGTH) in pdr_indication_cb()
307 mutex_lock(&pdr->list_lock); in pdr_indication_cb()
308 list_for_each_entry(iter, &pdr->lookups, node) { in pdr_indication_cb()
309 if (strcmp(iter->service_path, ind_msg->service_path)) in pdr_indication_cb()
315 mutex_unlock(&pdr->list_lock); in pdr_indication_cb()
320 pr_info("PDR: Indication received from %s, state: 0x%x, trans-id: %d\n", in pdr_indication_cb()
321 ind_msg->service_path, ind_msg->curr_state, in pdr_indication_cb()
322 ind_msg->transaction_id); in pdr_indication_cb()
328 ind->transaction_id = ind_msg->transaction_id; in pdr_indication_cb()
329 ind->curr_state = ind_msg->curr_state; in pdr_indication_cb()
330 ind->pds = pds; in pdr_indication_cb()
332 mutex_lock(&pdr->list_lock); in pdr_indication_cb()
333 list_add_tail(&ind->node, &pdr->indack_list); in pdr_indication_cb()
334 mutex_unlock(&pdr->list_lock); in pdr_indication_cb()
336 queue_work(pdr->indack_wq, &pdr->indack_work); in pdr_indication_cb()
357 ret = qmi_txn_init(&pdr->locator_hdl, &txn, in pdr_get_domain_list()
362 mutex_lock(&pdr->lock); in pdr_get_domain_list()
363 ret = qmi_send_request(&pdr->locator_hdl, in pdr_get_domain_list()
364 &pdr->locator_addr, in pdr_get_domain_list()
369 mutex_unlock(&pdr->lock); in pdr_get_domain_list()
378 req->service_name, ret); in pdr_get_domain_list()
382 if (resp->resp.result != QMI_RESULT_SUCCESS_V01) { in pdr_get_domain_list()
384 req->service_name, resp->resp.error); in pdr_get_domain_list()
385 return -EREMOTEIO; in pdr_get_domain_list()
401 return -ENOMEM; in pdr_locate_service()
404 strscpy(req.service_name, pds->service_name, sizeof(req.service_name)); in pdr_locate_service()
414 for (i = 0; i < resp->domain_list_len; i++) { in pdr_locate_service()
415 entry = &resp->domain_list[i]; in pdr_locate_service()
417 if (strnlen(entry->name, sizeof(entry->name)) == sizeof(entry->name)) in pdr_locate_service()
420 if (!strcmp(entry->name, pds->service_path)) { in pdr_locate_service()
421 pds->service_data_valid = entry->service_data_valid; in pdr_locate_service()
422 pds->service_data = entry->service_data; in pdr_locate_service()
423 pds->instance = entry->instance; in pdr_locate_service()
429 ret = -ENXIO; in pdr_locate_service()
432 if (resp->domain_list_len > resp->total_domains) in pdr_locate_service()
433 resp->domain_list_len = resp->total_domains; in pdr_locate_service()
435 domains_read += resp->domain_list_len; in pdr_locate_service()
436 } while (domains_read < resp->total_domains); in pdr_locate_service()
447 pds->service_name, err); in pdr_notify_lookup_failure()
449 if (err == -ENXIO) in pdr_notify_lookup_failure()
452 list_del(&pds->node); in pdr_notify_lookup_failure()
453 pds->state = SERVREG_LOCATOR_ERR; in pdr_notify_lookup_failure()
454 mutex_lock(&pdr->status_lock); in pdr_notify_lookup_failure()
455 pdr->status(pds->state, pds->service_path, pdr->priv); in pdr_notify_lookup_failure()
456 mutex_unlock(&pdr->status_lock); in pdr_notify_lookup_failure()
468 mutex_lock(&pdr->lock); in pdr_locator_work()
469 if (!pdr->locator_init_complete) { in pdr_locator_work()
470 mutex_unlock(&pdr->lock); in pdr_locator_work()
474 mutex_unlock(&pdr->lock); in pdr_locator_work()
476 mutex_lock(&pdr->list_lock); in pdr_locator_work()
477 list_for_each_entry_safe(pds, tmp, &pdr->lookups, node) { in pdr_locator_work()
478 if (!pds->need_locator_lookup) in pdr_locator_work()
487 ret = qmi_add_lookup(&pdr->notifier_hdl, pds->service, 1, in pdr_locator_work()
488 pds->instance); in pdr_locator_work()
494 pds->need_locator_lookup = false; in pdr_locator_work()
496 mutex_unlock(&pdr->list_lock); in pdr_locator_work()
500 * pdr_add_lookup() - register a tracking request for a PD
505 * Registering a pdr lookup allows for tracking the life cycle of the PD.
507 * Return: pdr_service object on success, ERR_PTR on failure. -EALREADY is
518 return ERR_PTR(-EINVAL); in pdr_add_lookup()
522 return ERR_PTR(-EINVAL); in pdr_add_lookup()
526 return ERR_PTR(-ENOMEM); in pdr_add_lookup()
528 pds->service = SERVREG_NOTIFIER_SERVICE; in pdr_add_lookup()
529 strscpy(pds->service_name, service_name, sizeof(pds->service_name)); in pdr_add_lookup()
530 strscpy(pds->service_path, service_path, sizeof(pds->service_path)); in pdr_add_lookup()
531 pds->need_locator_lookup = true; in pdr_add_lookup()
533 mutex_lock(&pdr->list_lock); in pdr_add_lookup()
534 list_for_each_entry(tmp, &pdr->lookups, node) { in pdr_add_lookup()
535 if (strcmp(tmp->service_path, service_path)) in pdr_add_lookup()
538 mutex_unlock(&pdr->list_lock); in pdr_add_lookup()
539 ret = -EALREADY; in pdr_add_lookup()
543 list_add(&pds->node, &pdr->lookups); in pdr_add_lookup()
544 mutex_unlock(&pdr->list_lock); in pdr_add_lookup()
546 schedule_work(&pdr->locator_work); in pdr_add_lookup()
556 * pdr_restart_pd() - restart PD
558 * @pds: PD service handle
560 * Restarts the PD tracked by the PDR client handle for a given service path.
574 return -EINVAL; in pdr_restart_pd()
576 mutex_lock(&pdr->list_lock); in pdr_restart_pd()
577 list_for_each_entry(tmp, &pdr->lookups, node) { in pdr_restart_pd()
581 if (!pds->service_connected) in pdr_restart_pd()
585 strscpy(req.service_path, pds->service_path, sizeof(req.service_path)); in pdr_restart_pd()
586 addr = pds->addr; in pdr_restart_pd()
589 mutex_unlock(&pdr->list_lock); in pdr_restart_pd()
592 return -EINVAL; in pdr_restart_pd()
594 ret = qmi_txn_init(&pdr->notifier_hdl, &txn, in pdr_restart_pd()
600 ret = qmi_send_request(&pdr->notifier_hdl, &addr, in pdr_restart_pd()
611 pr_err("PDR: %s PD restart txn wait failed: %d\n", in pdr_restart_pd()
619 pr_err("PDR: %s PD restart is disabled: 0x%x\n", in pdr_restart_pd()
621 return -EOPNOTSUPP; in pdr_restart_pd()
626 pr_err("PDR: %s request for PD restart failed: 0x%x\n", in pdr_restart_pd()
628 return -EREMOTEIO; in pdr_restart_pd()
636 * pdr_handle_alloc() - initialize the PDR client handle
637 * @status: function to be called on PD state change
652 return ERR_PTR(-EINVAL); in pdr_handle_alloc()
656 return ERR_PTR(-ENOMEM); in pdr_handle_alloc()
658 pdr->status = status; in pdr_handle_alloc()
659 pdr->priv = priv; in pdr_handle_alloc()
661 mutex_init(&pdr->status_lock); in pdr_handle_alloc()
662 mutex_init(&pdr->list_lock); in pdr_handle_alloc()
663 mutex_init(&pdr->lock); in pdr_handle_alloc()
665 INIT_LIST_HEAD(&pdr->lookups); in pdr_handle_alloc()
666 INIT_LIST_HEAD(&pdr->indack_list); in pdr_handle_alloc()
668 INIT_WORK(&pdr->locator_work, pdr_locator_work); in pdr_handle_alloc()
669 INIT_WORK(&pdr->notifier_work, pdr_notifier_work); in pdr_handle_alloc()
670 INIT_WORK(&pdr->indack_work, pdr_indack_work); in pdr_handle_alloc()
672 pdr->notifier_wq = create_singlethread_workqueue("pdr_notifier_wq"); in pdr_handle_alloc()
673 if (!pdr->notifier_wq) { in pdr_handle_alloc()
674 ret = -ENOMEM; in pdr_handle_alloc()
678 pdr->indack_wq = alloc_ordered_workqueue("pdr_indack_wq", WQ_HIGHPRI); in pdr_handle_alloc()
679 if (!pdr->indack_wq) { in pdr_handle_alloc()
680 ret = -ENOMEM; in pdr_handle_alloc()
684 ret = qmi_handle_init(&pdr->locator_hdl, in pdr_handle_alloc()
690 ret = qmi_add_lookup(&pdr->locator_hdl, SERVREG_LOCATOR_SERVICE, 1, 1); in pdr_handle_alloc()
694 ret = qmi_handle_init(&pdr->notifier_hdl, in pdr_handle_alloc()
704 qmi_handle_release(&pdr->locator_hdl); in pdr_handle_alloc()
706 destroy_workqueue(pdr->indack_wq); in pdr_handle_alloc()
708 destroy_workqueue(pdr->notifier_wq); in pdr_handle_alloc()
717 * pdr_handle_release() - release the PDR client handle
729 mutex_lock(&pdr->list_lock); in pdr_handle_release()
730 list_for_each_entry_safe(pds, tmp, &pdr->lookups, node) { in pdr_handle_release()
731 list_del(&pds->node); in pdr_handle_release()
734 mutex_unlock(&pdr->list_lock); in pdr_handle_release()
736 cancel_work_sync(&pdr->locator_work); in pdr_handle_release()
737 cancel_work_sync(&pdr->notifier_work); in pdr_handle_release()
738 cancel_work_sync(&pdr->indack_work); in pdr_handle_release()
740 destroy_workqueue(pdr->notifier_wq); in pdr_handle_release()
741 destroy_workqueue(pdr->indack_wq); in pdr_handle_release()
743 qmi_handle_release(&pdr->locator_hdl); in pdr_handle_release()
744 qmi_handle_release(&pdr->notifier_hdl); in pdr_handle_release()