75 	struct pdr_handle *pdr = container_of(qmi, struct pdr_handle,  in pdr_locator_new_server()  local
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 	mutex_lock(&pdr->lock);  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 	mutex_lock(&pdr->list_lock);  in pdr_locator_new_server()
90 	list_for_each_entry(pds, &pdr->lookups, node) {  in pdr_locator_new_server()
92 			schedule_work(&pdr->locator_work);  in pdr_locator_new_server()
94 	mutex_unlock(&pdr->list_lock);  in pdr_locator_new_server()
102 	struct pdr_handle *pdr = container_of(qmi, struct pdr_handle,  in pdr_locator_del_server()  local
105 	mutex_lock(&pdr->lock);  in pdr_locator_del_server()
106 	pdr->locator_init_complete = false;  in pdr_locator_del_server()
107 	mutex_unlock(&pdr->lock);  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()
118 static int pdr_register_listener(struct pdr_handle *pdr,  in pdr_register_listener()  argument
127 	ret = qmi_txn_init(&pdr->notifier_hdl, &txn,  in pdr_register_listener()
136 	ret = qmi_send_request(&pdr->notifier_hdl, &pds->addr,  in pdr_register_listener()
166 	struct pdr_handle *pdr = container_of(work, struct pdr_handle,  in pdr_notifier_work()  local
171 	mutex_lock(&pdr->list_lock);  in pdr_notifier_work()
172 	list_for_each_entry(pds, &pdr->lookups, node) {  in pdr_notifier_work()
178 			ret = pdr_register_listener(pdr, pds, true);  in pdr_notifier_work()
189 		mutex_lock(&pdr->status_lock);  in pdr_notifier_work()
190 		pdr->status(pds->state, pds->service_path, pdr->priv);  in pdr_notifier_work()
191 		mutex_unlock(&pdr->status_lock);  in pdr_notifier_work()
193 	mutex_unlock(&pdr->list_lock);  in pdr_notifier_work()
199 	struct pdr_handle *pdr = container_of(qmi, struct pdr_handle,  in pdr_notifier_new_server()  local
203 	mutex_lock(&pdr->list_lock);  in pdr_notifier_new_server()
204 	list_for_each_entry(pds, &pdr->lookups, node) {  in pdr_notifier_new_server()
212 			queue_work(pdr->notifier_wq, &pdr->notifier_work);  in pdr_notifier_new_server()
215 	mutex_unlock(&pdr->list_lock);  in pdr_notifier_new_server()
223 	struct pdr_handle *pdr = container_of(qmi, struct pdr_handle,  in pdr_notifier_del_server()  local
227 	mutex_lock(&pdr->list_lock);  in pdr_notifier_del_server()
228 	list_for_each_entry(pds, &pdr->lookups, node) {  in pdr_notifier_del_server()
235 			queue_work(pdr->notifier_wq, &pdr->notifier_work);  in pdr_notifier_del_server()
238 	mutex_unlock(&pdr->list_lock);  in pdr_notifier_del_server()
246 static int pdr_send_indack_msg(struct pdr_handle *pdr, struct pdr_service *pds,  in pdr_send_indack_msg()  argument
254 	ret = qmi_txn_init(&pdr->notifier_hdl, &txn, servreg_set_ack_resp_ei,  in pdr_send_indack_msg()
262 	ret = qmi_send_request(&pdr->notifier_hdl, &pds->addr,  in pdr_send_indack_msg()
275 	struct pdr_handle *pdr = container_of(work, struct pdr_handle,  in pdr_indack_work()  local
280 	list_for_each_entry_safe(ind, tmp, &pdr->indack_list, node) {  in pdr_indack_work()
283 		mutex_lock(&pdr->status_lock);  in pdr_indack_work()
285 		pdr->status(pds->state, pds->service_path, pdr->priv);  in pdr_indack_work()
286 		mutex_unlock(&pdr->status_lock);  in pdr_indack_work()
289 		pdr_send_indack_msg(pdr, pds, ind->transaction_id);  in pdr_indack_work()
291 		mutex_lock(&pdr->list_lock);  in pdr_indack_work()
293 		mutex_unlock(&pdr->list_lock);  in pdr_indack_work()
303 	struct pdr_handle *pdr = container_of(qmi, struct pdr_handle,  in pdr_indication_cb()  local
313 	mutex_lock(&pdr->list_lock);  in pdr_indication_cb()
314 	list_for_each_entry(iter, &pdr->lookups, node) {  in pdr_indication_cb()
321 	mutex_unlock(&pdr->list_lock);  in pdr_indication_cb()
338 	mutex_lock(&pdr->list_lock);  in pdr_indication_cb()
339 	list_add_tail(&ind->node, &pdr->indack_list);  in pdr_indication_cb()
340 	mutex_unlock(&pdr->list_lock);  in pdr_indication_cb()
342 	queue_work(pdr->indack_wq, &pdr->indack_work);  in pdr_indication_cb()
358 			       struct pdr_handle *pdr)  in pdr_get_domain_list()  argument
363 	ret = qmi_txn_init(&pdr->locator_hdl, &txn,  in pdr_get_domain_list()
368 	ret = qmi_send_request(&pdr->locator_hdl,  in pdr_get_domain_list()
369 			       &pdr->locator_addr,  in pdr_get_domain_list()
395 static int pdr_locate_service(struct pdr_handle *pdr, struct pdr_service *pds)  in pdr_locate_service()  argument
414 		ret = pdr_get_domain_list(&req, resp, pdr);  in pdr_locate_service()
446 static void pdr_notify_lookup_failure(struct pdr_handle *pdr,  in pdr_notify_lookup_failure()  argument
458 	mutex_lock(&pdr->status_lock);  in pdr_notify_lookup_failure()
459 	pdr->status(pds->state, pds->service_path, pdr->priv);  in pdr_notify_lookup_failure()
460 	mutex_unlock(&pdr->status_lock);  in pdr_notify_lookup_failure()
466 	struct pdr_handle *pdr = container_of(work, struct pdr_handle,  in pdr_locator_work()  local
472 	mutex_lock(&pdr->lock);  in pdr_locator_work()
473 	if (!pdr->locator_init_complete) {  in pdr_locator_work()
474 		mutex_unlock(&pdr->lock);  in pdr_locator_work()
478 	mutex_unlock(&pdr->lock);  in pdr_locator_work()
480 	mutex_lock(&pdr->list_lock);  in pdr_locator_work()
481 	list_for_each_entry_safe(pds, tmp, &pdr->lookups, node) {  in pdr_locator_work()
485 		ret = pdr_locate_service(pdr, pds);  in pdr_locator_work()
487 			pdr_notify_lookup_failure(pdr, pds, ret);  in pdr_locator_work()
491 		ret = qmi_add_lookup(&pdr->notifier_hdl, pds->service, 1,  in pdr_locator_work()
494 			pdr_notify_lookup_failure(pdr, pds, ret);  in pdr_locator_work()
500 	mutex_unlock(&pdr->list_lock);  in pdr_locator_work()
514 struct pdr_service *pdr_add_lookup(struct pdr_handle *pdr,  in pdr_add_lookup()  argument
521 	if (IS_ERR_OR_NULL(pdr))  in pdr_add_lookup()
537 	mutex_lock(&pdr->list_lock);  in pdr_add_lookup()
538 	list_for_each_entry(tmp, &pdr->lookups, node) {  in pdr_add_lookup()
542 		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()
568 int pdr_restart_pd(struct pdr_handle *pdr, struct pdr_service *pds)  in pdr_restart_pd()  argument
577 	if (IS_ERR_OR_NULL(pdr) || IS_ERR_OR_NULL(pds))  in pdr_restart_pd()
580 	mutex_lock(&pdr->list_lock);  in pdr_restart_pd()
581 	list_for_each_entry(tmp, &pdr->lookups, node) {  in pdr_restart_pd()
593 	mutex_unlock(&pdr->list_lock);  in pdr_restart_pd()
598 	ret = qmi_txn_init(&pdr->notifier_hdl, &txn,  in pdr_restart_pd()
604 	ret = qmi_send_request(&pdr->notifier_hdl, &addr,  in pdr_restart_pd()
652 	struct pdr_handle *pdr;  in pdr_handle_alloc()  local
658 	pdr = kzalloc(sizeof(*pdr), GFP_KERNEL);  in pdr_handle_alloc()
659 	if (!pdr)  in pdr_handle_alloc()
662 	pdr->status = status;  in pdr_handle_alloc()
663 	pdr->priv = priv;  in pdr_handle_alloc()
665 	mutex_init(&pdr->status_lock);  in pdr_handle_alloc()
666 	mutex_init(&pdr->list_lock);  in pdr_handle_alloc()
667 	mutex_init(&pdr->lock);  in pdr_handle_alloc()
669 	INIT_LIST_HEAD(&pdr->lookups);  in pdr_handle_alloc()
670 	INIT_LIST_HEAD(&pdr->indack_list);  in pdr_handle_alloc()
672 	INIT_WORK(&pdr->locator_work, pdr_locator_work);  in pdr_handle_alloc()
673 	INIT_WORK(&pdr->notifier_work, pdr_notifier_work);  in pdr_handle_alloc()
674 	INIT_WORK(&pdr->indack_work, pdr_indack_work);  in pdr_handle_alloc()
676 	pdr->notifier_wq = create_singlethread_workqueue("pdr_notifier_wq");  in pdr_handle_alloc()
677 	if (!pdr->notifier_wq) {  in pdr_handle_alloc()
682 	pdr->indack_wq = alloc_ordered_workqueue("pdr_indack_wq", WQ_HIGHPRI);  in pdr_handle_alloc()
683 	if (!pdr->indack_wq) {  in pdr_handle_alloc()
688 	ret = qmi_handle_init(&pdr->locator_hdl,  in pdr_handle_alloc()
694 	ret = qmi_add_lookup(&pdr->locator_hdl, SERVREG_LOCATOR_SERVICE, 1, 1);  in pdr_handle_alloc()
698 	ret = qmi_handle_init(&pdr->notifier_hdl,  in pdr_handle_alloc()
705 	return pdr;  in pdr_handle_alloc()
708 	qmi_handle_release(&pdr->locator_hdl);  in pdr_handle_alloc()
710 	destroy_workqueue(pdr->indack_wq);  in pdr_handle_alloc()
712 	destroy_workqueue(pdr->notifier_wq);  in pdr_handle_alloc()
714 	kfree(pdr);  in pdr_handle_alloc()
726 void pdr_handle_release(struct pdr_handle *pdr)  in pdr_handle_release()  argument
730 	if (IS_ERR_OR_NULL(pdr))  in pdr_handle_release()
733 	mutex_lock(&pdr->list_lock);  in pdr_handle_release()
734 	list_for_each_entry_safe(pds, tmp, &pdr->lookups, node) {  in pdr_handle_release()
738 	mutex_unlock(&pdr->list_lock);  in pdr_handle_release()
740 	cancel_work_sync(&pdr->locator_work);  in pdr_handle_release()
741 	cancel_work_sync(&pdr->notifier_work);  in pdr_handle_release()
742 	cancel_work_sync(&pdr->indack_work);  in pdr_handle_release()
744 	destroy_workqueue(pdr->notifier_wq);  in pdr_handle_release()
745 	destroy_workqueue(pdr->indack_wq);  in pdr_handle_release()
747 	qmi_handle_release(&pdr->locator_hdl);  in pdr_handle_release()
748 	qmi_handle_release(&pdr->notifier_hdl);  in pdr_handle_release()
750 	kfree(pdr);  in pdr_handle_release()