Lines Matching refs:pdr
76 struct pdr_handle *pdr = container_of(qmi, struct pdr_handle, in pdr_locator_new_server() local
80 mutex_lock(&pdr->lock); in pdr_locator_new_server()
82 pdr->locator_addr.sq_family = AF_QIPCRTR; in pdr_locator_new_server()
83 pdr->locator_addr.sq_node = svc->node; in pdr_locator_new_server()
84 pdr->locator_addr.sq_port = svc->port; in pdr_locator_new_server()
86 pdr->locator_init_complete = true; in pdr_locator_new_server()
87 mutex_unlock(&pdr->lock); in pdr_locator_new_server()
90 mutex_lock(&pdr->list_lock); in pdr_locator_new_server()
91 list_for_each_entry(pds, &pdr->lookups, node) { in pdr_locator_new_server()
93 schedule_work(&pdr->locator_work); in pdr_locator_new_server()
95 mutex_unlock(&pdr->list_lock); in pdr_locator_new_server()
103 struct pdr_handle *pdr = container_of(qmi, struct pdr_handle, in pdr_locator_del_server() local
106 mutex_lock(&pdr->lock); in pdr_locator_del_server()
107 pdr->locator_init_complete = false; in pdr_locator_del_server()
109 pdr->locator_addr.sq_node = 0; in pdr_locator_del_server()
110 pdr->locator_addr.sq_port = 0; in pdr_locator_del_server()
111 mutex_unlock(&pdr->lock); in pdr_locator_del_server()
119 static int pdr_register_listener(struct pdr_handle *pdr, in pdr_register_listener() argument
128 ret = qmi_txn_init(&pdr->notifier_hdl, &txn, in pdr_register_listener()
137 ret = qmi_send_request(&pdr->notifier_hdl, &pds->addr, in pdr_register_listener()
167 struct pdr_handle *pdr = container_of(work, struct pdr_handle, in pdr_notifier_work() local
172 mutex_lock(&pdr->list_lock); in pdr_notifier_work()
173 list_for_each_entry(pds, &pdr->lookups, node) { in pdr_notifier_work()
179 ret = pdr_register_listener(pdr, pds, true); in pdr_notifier_work()
190 mutex_lock(&pdr->status_lock); in pdr_notifier_work()
191 pdr->status(pds->state, pds->service_path, pdr->priv); in pdr_notifier_work()
192 mutex_unlock(&pdr->status_lock); in pdr_notifier_work()
194 mutex_unlock(&pdr->list_lock); in pdr_notifier_work()
200 struct pdr_handle *pdr = container_of(qmi, struct pdr_handle, in pdr_notifier_new_server() local
204 mutex_lock(&pdr->list_lock); in pdr_notifier_new_server()
205 list_for_each_entry(pds, &pdr->lookups, node) { in pdr_notifier_new_server()
213 queue_work(pdr->notifier_wq, &pdr->notifier_work); in pdr_notifier_new_server()
216 mutex_unlock(&pdr->list_lock); in pdr_notifier_new_server()
224 struct pdr_handle *pdr = container_of(qmi, struct pdr_handle, in pdr_notifier_del_server() local
228 mutex_lock(&pdr->list_lock); in pdr_notifier_del_server()
229 list_for_each_entry(pds, &pdr->lookups, node) { in pdr_notifier_del_server()
236 queue_work(pdr->notifier_wq, &pdr->notifier_work); in pdr_notifier_del_server()
239 mutex_unlock(&pdr->list_lock); in pdr_notifier_del_server()
247 static int pdr_send_indack_msg(struct pdr_handle *pdr, struct pdr_service *pds, in pdr_send_indack_msg() argument
255 ret = qmi_txn_init(&pdr->notifier_hdl, &txn, servreg_set_ack_resp_ei, in pdr_send_indack_msg()
263 ret = qmi_send_request(&pdr->notifier_hdl, &pds->addr, in pdr_send_indack_msg()
276 struct pdr_handle *pdr = container_of(work, struct pdr_handle, in pdr_indack_work() local
281 list_for_each_entry_safe(ind, tmp, &pdr->indack_list, node) { in pdr_indack_work()
284 mutex_lock(&pdr->status_lock); in pdr_indack_work()
286 pdr->status(pds->state, pds->service_path, pdr->priv); in pdr_indack_work()
287 mutex_unlock(&pdr->status_lock); in pdr_indack_work()
290 pdr_send_indack_msg(pdr, pds, ind->transaction_id); in pdr_indack_work()
292 mutex_lock(&pdr->list_lock); in pdr_indack_work()
294 mutex_unlock(&pdr->list_lock); in pdr_indack_work()
304 struct pdr_handle *pdr = container_of(qmi, struct pdr_handle, in pdr_indication_cb() local
314 mutex_lock(&pdr->list_lock); in pdr_indication_cb()
315 list_for_each_entry(iter, &pdr->lookups, node) { in pdr_indication_cb()
322 mutex_unlock(&pdr->list_lock); in pdr_indication_cb()
339 mutex_lock(&pdr->list_lock); in pdr_indication_cb()
340 list_add_tail(&ind->node, &pdr->indack_list); in pdr_indication_cb()
341 mutex_unlock(&pdr->list_lock); in pdr_indication_cb()
343 queue_work(pdr->indack_wq, &pdr->indack_work); in pdr_indication_cb()
359 struct pdr_handle *pdr) in pdr_get_domain_list() argument
364 ret = qmi_txn_init(&pdr->locator_hdl, &txn, in pdr_get_domain_list()
369 mutex_lock(&pdr->lock); in pdr_get_domain_list()
370 ret = qmi_send_request(&pdr->locator_hdl, in pdr_get_domain_list()
371 &pdr->locator_addr, in pdr_get_domain_list()
376 mutex_unlock(&pdr->lock); in pdr_get_domain_list()
398 static int pdr_locate_service(struct pdr_handle *pdr, struct pdr_service *pds) in pdr_locate_service() argument
417 ret = pdr_get_domain_list(&req, resp, pdr); in pdr_locate_service()
448 static void pdr_notify_lookup_failure(struct pdr_handle *pdr, in pdr_notify_lookup_failure() argument
460 mutex_lock(&pdr->status_lock); in pdr_notify_lookup_failure()
461 pdr->status(pds->state, pds->service_path, pdr->priv); in pdr_notify_lookup_failure()
462 mutex_unlock(&pdr->status_lock); in pdr_notify_lookup_failure()
468 struct pdr_handle *pdr = container_of(work, struct pdr_handle, in pdr_locator_work() local
474 mutex_lock(&pdr->lock); in pdr_locator_work()
475 if (!pdr->locator_init_complete) { in pdr_locator_work()
476 mutex_unlock(&pdr->lock); in pdr_locator_work()
480 mutex_unlock(&pdr->lock); in pdr_locator_work()
482 mutex_lock(&pdr->list_lock); in pdr_locator_work()
483 list_for_each_entry_safe(pds, tmp, &pdr->lookups, node) { in pdr_locator_work()
487 ret = pdr_locate_service(pdr, pds); in pdr_locator_work()
489 pdr_notify_lookup_failure(pdr, pds, ret); in pdr_locator_work()
493 ret = qmi_add_lookup(&pdr->notifier_hdl, pds->service, 1, in pdr_locator_work()
496 pdr_notify_lookup_failure(pdr, pds, ret); in pdr_locator_work()
502 mutex_unlock(&pdr->list_lock); in pdr_locator_work()
516 struct pdr_service *pdr_add_lookup(struct pdr_handle *pdr, in pdr_add_lookup() argument
522 if (IS_ERR_OR_NULL(pdr)) in pdr_add_lookup()
538 mutex_lock(&pdr->list_lock); in pdr_add_lookup()
539 list_for_each_entry(tmp, &pdr->lookups, node) { in pdr_add_lookup()
543 mutex_unlock(&pdr->list_lock); in pdr_add_lookup()
547 list_add(&pds->node, &pdr->lookups); in pdr_add_lookup()
548 mutex_unlock(&pdr->list_lock); in pdr_add_lookup()
550 schedule_work(&pdr->locator_work); in pdr_add_lookup()
565 int pdr_restart_pd(struct pdr_handle *pdr, struct pdr_service *pds) in pdr_restart_pd() argument
574 if (IS_ERR_OR_NULL(pdr) || IS_ERR_OR_NULL(pds)) in pdr_restart_pd()
577 mutex_lock(&pdr->list_lock); in pdr_restart_pd()
578 list_for_each_entry(tmp, &pdr->lookups, node) { in pdr_restart_pd()
590 mutex_unlock(&pdr->list_lock); in pdr_restart_pd()
595 ret = qmi_txn_init(&pdr->notifier_hdl, &txn, in pdr_restart_pd()
601 ret = qmi_send_request(&pdr->notifier_hdl, &addr, in pdr_restart_pd()
654 struct pdr_handle *pdr __free(kfree) = kzalloc(sizeof(*pdr), GFP_KERNEL); in pdr_handle_alloc()
655 if (!pdr) 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()
676 pdr->indack_wq = alloc_ordered_workqueue("pdr_indack_wq", WQ_HIGHPRI); in pdr_handle_alloc()
677 if (!pdr->indack_wq) { in pdr_handle_alloc()
682 ret = qmi_handle_init(&pdr->locator_hdl, in pdr_handle_alloc()
688 ret = qmi_add_lookup(&pdr->locator_hdl, SERVREG_LOCATOR_SERVICE, 1, 1); in pdr_handle_alloc()
692 ret = qmi_handle_init(&pdr->notifier_hdl, in pdr_handle_alloc()
699 return_ptr(pdr); in pdr_handle_alloc()
702 qmi_handle_release(&pdr->locator_hdl); in pdr_handle_alloc()
704 destroy_workqueue(pdr->indack_wq); in pdr_handle_alloc()
706 destroy_workqueue(pdr->notifier_wq); in pdr_handle_alloc()
718 void pdr_handle_release(struct pdr_handle *pdr) in pdr_handle_release() argument
722 if (IS_ERR_OR_NULL(pdr)) in pdr_handle_release()
725 mutex_lock(&pdr->list_lock); in pdr_handle_release()
726 list_for_each_entry_safe(pds, tmp, &pdr->lookups, node) { in pdr_handle_release()
730 mutex_unlock(&pdr->list_lock); in pdr_handle_release()
732 cancel_work_sync(&pdr->locator_work); in pdr_handle_release()
733 cancel_work_sync(&pdr->notifier_work); in pdr_handle_release()
734 cancel_work_sync(&pdr->indack_work); in pdr_handle_release()
736 destroy_workqueue(pdr->notifier_wq); in pdr_handle_release()
737 destroy_workqueue(pdr->indack_wq); in pdr_handle_release()
739 qmi_handle_release(&pdr->locator_hdl); in pdr_handle_release()
740 qmi_handle_release(&pdr->notifier_hdl); in pdr_handle_release()
742 kfree(pdr); in pdr_handle_release()