76 	struct pdr_handle *pdr = container_of(qmi, struct pdr_handle,  in pdr_locator_new_server()  local
79 	mutex_lock(&pdr->lock);  in pdr_locator_new_server()
81 	pdr->locator_addr.sq_family = AF_QIPCRTR;  in pdr_locator_new_server()
82 	pdr->locator_addr.sq_node = svc->node;  in pdr_locator_new_server()
83 	pdr->locator_addr.sq_port = svc->port;  in pdr_locator_new_server()
85 	pdr->locator_init_complete = true;  in pdr_locator_new_server()
86 	mutex_unlock(&pdr->lock);  in pdr_locator_new_server()
89 	schedule_work(&pdr->locator_work);  in pdr_locator_new_server()
97 	struct pdr_handle *pdr = container_of(qmi, struct pdr_handle,  in pdr_locator_del_server()  local
100 	mutex_lock(&pdr->lock);  in pdr_locator_del_server()
101 	pdr->locator_init_complete = false;  in pdr_locator_del_server()
103 	pdr->locator_addr.sq_node = 0;  in pdr_locator_del_server()
104 	pdr->locator_addr.sq_port = 0;  in pdr_locator_del_server()
105 	mutex_unlock(&pdr->lock);  in pdr_locator_del_server()
113 static int pdr_register_listener(struct pdr_handle *pdr,  in pdr_register_listener()  argument
122 	ret = qmi_txn_init(&pdr->notifier_hdl, &txn,  in pdr_register_listener()
131 	ret = qmi_send_request(&pdr->notifier_hdl, &pds->addr,  in pdr_register_listener()
161 	struct pdr_handle *pdr = container_of(work, struct pdr_handle,  in pdr_notifier_work()  local
166 	mutex_lock(&pdr->list_lock);  in pdr_notifier_work()
167 	list_for_each_entry(pds, &pdr->lookups, node) {  in pdr_notifier_work()
173 			ret = pdr_register_listener(pdr, pds, true);  in pdr_notifier_work()
184 		mutex_lock(&pdr->status_lock);  in pdr_notifier_work()
185 		pdr->status(pds->state, pds->service_path, pdr->priv);  in pdr_notifier_work()
186 		mutex_unlock(&pdr->status_lock);  in pdr_notifier_work()
188 	mutex_unlock(&pdr->list_lock);  in pdr_notifier_work()
194 	struct pdr_handle *pdr = container_of(qmi, struct pdr_handle,  in pdr_notifier_new_server()  local
198 	mutex_lock(&pdr->list_lock);  in pdr_notifier_new_server()
199 	list_for_each_entry(pds, &pdr->lookups, node) {  in pdr_notifier_new_server()
207 			queue_work(pdr->notifier_wq, &pdr->notifier_work);  in pdr_notifier_new_server()
210 	mutex_unlock(&pdr->list_lock);  in pdr_notifier_new_server()
218 	struct pdr_handle *pdr = container_of(qmi, struct pdr_handle,  in pdr_notifier_del_server()  local
222 	mutex_lock(&pdr->list_lock);  in pdr_notifier_del_server()
223 	list_for_each_entry(pds, &pdr->lookups, node) {  in pdr_notifier_del_server()
230 			queue_work(pdr->notifier_wq, &pdr->notifier_work);  in pdr_notifier_del_server()
233 	mutex_unlock(&pdr->list_lock);  in pdr_notifier_del_server()
241 static int pdr_send_indack_msg(struct pdr_handle *pdr, struct pdr_service *pds,  in pdr_send_indack_msg()  argument
249 	ret = qmi_txn_init(&pdr->notifier_hdl, &txn, servreg_set_ack_resp_ei,  in pdr_send_indack_msg()
257 	ret = qmi_send_request(&pdr->notifier_hdl, &pds->addr,  in pdr_send_indack_msg()
270 	struct pdr_handle *pdr = container_of(work, struct pdr_handle,  in pdr_indack_work()  local
275 	list_for_each_entry_safe(ind, tmp, &pdr->indack_list, node) {  in pdr_indack_work()
278 		mutex_lock(&pdr->status_lock);  in pdr_indack_work()
280 		pdr->status(pds->state, pds->service_path, pdr->priv);  in pdr_indack_work()
281 		mutex_unlock(&pdr->status_lock);  in pdr_indack_work()
284 		pdr_send_indack_msg(pdr, pds, ind->transaction_id);  in pdr_indack_work()
286 		mutex_lock(&pdr->list_lock);  in pdr_indack_work()
288 		mutex_unlock(&pdr->list_lock);  in pdr_indack_work()
298 	struct pdr_handle *pdr = container_of(qmi, struct pdr_handle,  in pdr_indication_cb()  local
308 	mutex_lock(&pdr->list_lock);  in pdr_indication_cb()
309 	list_for_each_entry(iter, &pdr->lookups, node) {  in pdr_indication_cb()
316 	mutex_unlock(&pdr->list_lock);  in pdr_indication_cb()
333 	mutex_lock(&pdr->list_lock);  in pdr_indication_cb()
334 	list_add_tail(&ind->node, &pdr->indack_list);  in pdr_indication_cb()
335 	mutex_unlock(&pdr->list_lock);  in pdr_indication_cb()
337 	queue_work(pdr->indack_wq, &pdr->indack_work);  in pdr_indication_cb()
353 			       struct pdr_handle *pdr)  in pdr_get_domain_list()  argument
358 	ret = qmi_txn_init(&pdr->locator_hdl, &txn,  in pdr_get_domain_list()
363 	mutex_lock(&pdr->lock);  in pdr_get_domain_list()
364 	ret = qmi_send_request(&pdr->locator_hdl,  in pdr_get_domain_list()
365 			       &pdr->locator_addr,  in pdr_get_domain_list()
370 	mutex_unlock(&pdr->lock);  in pdr_get_domain_list()
392 static int pdr_locate_service(struct pdr_handle *pdr, struct pdr_service *pds)  in pdr_locate_service()  argument
410 		ret = pdr_get_domain_list(&req, resp, pdr);  in pdr_locate_service()
441 static void pdr_notify_lookup_failure(struct pdr_handle *pdr,  in pdr_notify_lookup_failure()  argument
453 	mutex_lock(&pdr->status_lock);  in pdr_notify_lookup_failure()
454 	pdr->status(pds->state, pds->service_path, pdr->priv);  in pdr_notify_lookup_failure()
455 	mutex_unlock(&pdr->status_lock);  in pdr_notify_lookup_failure()
461 	struct pdr_handle *pdr = container_of(work, struct pdr_handle,  in pdr_locator_work()  local
467 	mutex_lock(&pdr->lock);  in pdr_locator_work()
468 	if (!pdr->locator_init_complete) {  in pdr_locator_work()
469 		mutex_unlock(&pdr->lock);  in pdr_locator_work()
473 	mutex_unlock(&pdr->lock);  in pdr_locator_work()
475 	mutex_lock(&pdr->list_lock);  in pdr_locator_work()
476 	list_for_each_entry_safe(pds, tmp, &pdr->lookups, node) {  in pdr_locator_work()
480 		ret = pdr_locate_service(pdr, pds);  in pdr_locator_work()
482 			pdr_notify_lookup_failure(pdr, pds, ret);  in pdr_locator_work()
486 		ret = qmi_add_lookup(&pdr->notifier_hdl, pds->service, 1,  in pdr_locator_work()
489 			pdr_notify_lookup_failure(pdr, pds, ret);  in pdr_locator_work()
495 	mutex_unlock(&pdr->list_lock);  in pdr_locator_work()
509 struct pdr_service *pdr_add_lookup(struct pdr_handle *pdr,  in pdr_add_lookup()  argument
515 	if (IS_ERR_OR_NULL(pdr))  in pdr_add_lookup()
531 	mutex_lock(&pdr->list_lock);  in pdr_add_lookup()
532 	list_for_each_entry(tmp, &pdr->lookups, node) {  in pdr_add_lookup()
536 		mutex_unlock(&pdr->list_lock);  in pdr_add_lookup()
540 	list_add(&pds->node, &pdr->lookups);  in pdr_add_lookup()
541 	mutex_unlock(&pdr->list_lock);  in pdr_add_lookup()
543 	schedule_work(&pdr->locator_work);  in pdr_add_lookup()
558 int pdr_restart_pd(struct pdr_handle *pdr, struct pdr_service *pds)  in pdr_restart_pd()  argument
567 	if (IS_ERR_OR_NULL(pdr) || IS_ERR_OR_NULL(pds))  in pdr_restart_pd()
570 	mutex_lock(&pdr->list_lock);  in pdr_restart_pd()
571 	list_for_each_entry(tmp, &pdr->lookups, node) {  in pdr_restart_pd()
583 	mutex_unlock(&pdr->list_lock);  in pdr_restart_pd()
588 	ret = qmi_txn_init(&pdr->notifier_hdl, &txn,  in pdr_restart_pd()
594 	ret = qmi_send_request(&pdr->notifier_hdl, &addr,  in pdr_restart_pd()
647 	struct pdr_handle *pdr __free(kfree) = kzalloc_obj(*pdr);  in pdr_handle_alloc()
648 	if (!pdr)  in pdr_handle_alloc()
651 	pdr->status = status;  in pdr_handle_alloc()
652 	pdr->priv = priv;  in pdr_handle_alloc()
654 	mutex_init(&pdr->status_lock);  in pdr_handle_alloc()
655 	mutex_init(&pdr->list_lock);  in pdr_handle_alloc()
656 	mutex_init(&pdr->lock);  in pdr_handle_alloc()
658 	INIT_LIST_HEAD(&pdr->lookups);  in pdr_handle_alloc()
659 	INIT_LIST_HEAD(&pdr->indack_list);  in pdr_handle_alloc()
661 	INIT_WORK(&pdr->locator_work, pdr_locator_work);  in pdr_handle_alloc()
662 	INIT_WORK(&pdr->notifier_work, pdr_notifier_work);  in pdr_handle_alloc()
663 	INIT_WORK(&pdr->indack_work, pdr_indack_work);  in pdr_handle_alloc()
665 	pdr->notifier_wq = create_singlethread_workqueue("pdr_notifier_wq");  in pdr_handle_alloc()
666 	if (!pdr->notifier_wq)  in pdr_handle_alloc()
669 	pdr->indack_wq = alloc_ordered_workqueue("pdr_indack_wq", WQ_HIGHPRI);  in pdr_handle_alloc()
670 	if (!pdr->indack_wq) {  in pdr_handle_alloc()
675 	ret = qmi_handle_init(&pdr->locator_hdl,  in pdr_handle_alloc()
681 	ret = qmi_add_lookup(&pdr->locator_hdl, SERVREG_LOCATOR_SERVICE, 1, 1);  in pdr_handle_alloc()
685 	ret = qmi_handle_init(&pdr->notifier_hdl,  in pdr_handle_alloc()
692 	return_ptr(pdr);  in pdr_handle_alloc()
695 	qmi_handle_release(&pdr->locator_hdl);  in pdr_handle_alloc()
697 	destroy_workqueue(pdr->indack_wq);  in pdr_handle_alloc()
699 	destroy_workqueue(pdr->notifier_wq);  in pdr_handle_alloc()
711 void pdr_handle_release(struct pdr_handle *pdr)  in pdr_handle_release()  argument
715 	if (IS_ERR_OR_NULL(pdr))  in pdr_handle_release()
718 	mutex_lock(&pdr->list_lock);  in pdr_handle_release()
719 	list_for_each_entry_safe(pds, tmp, &pdr->lookups, node) {  in pdr_handle_release()
723 	mutex_unlock(&pdr->list_lock);  in pdr_handle_release()
725 	cancel_work_sync(&pdr->locator_work);  in pdr_handle_release()
726 	cancel_work_sync(&pdr->notifier_work);  in pdr_handle_release()
727 	cancel_work_sync(&pdr->indack_work);  in pdr_handle_release()
729 	destroy_workqueue(pdr->notifier_wq);  in pdr_handle_release()
730 	destroy_workqueue(pdr->indack_wq);  in pdr_handle_release()
732 	qmi_handle_release(&pdr->locator_hdl);  in pdr_handle_release()
733 	qmi_handle_release(&pdr->notifier_hdl);  in pdr_handle_release()
735 	kfree(pdr);  in pdr_handle_release()