17 static struct socket *qmi_sock_create(struct qmi_handle *qmi,
31 static void qmi_recv_new_server(struct qmi_handle *qmi,  in qmi_recv_new_server()  argument
35 	struct qmi_ops *ops = &qmi->ops;  in qmi_recv_new_server()
56 	ret = ops->new_server(qmi, svc);  in qmi_recv_new_server()
60 		list_add(&svc->list_node, &qmi->lookup_results);  in qmi_recv_new_server()
72 static void qmi_recv_del_server(struct qmi_handle *qmi,  in qmi_recv_del_server()  argument
75 	struct qmi_ops *ops = &qmi->ops;  in qmi_recv_del_server()
79 	list_for_each_entry_safe(svc, tmp, &qmi->lookup_results, list_node) {  in qmi_recv_del_server()
86 			ops->del_server(qmi, svc);  in qmi_recv_del_server()
102 static void qmi_recv_bye(struct qmi_handle *qmi,  in qmi_recv_bye()  argument
105 	struct qmi_ops *ops = &qmi->ops;  in qmi_recv_bye()
107 	qmi_recv_del_server(qmi, node, -1);  in qmi_recv_bye()
110 		ops->bye(qmi, node);  in qmi_recv_bye()
121 static void qmi_recv_del_client(struct qmi_handle *qmi,  in qmi_recv_del_client()  argument
124 	struct qmi_ops *ops = &qmi->ops;  in qmi_recv_del_client()
127 		ops->del_client(qmi, node, port);  in qmi_recv_del_client()
130 static void qmi_recv_ctrl_pkt(struct qmi_handle *qmi,  in qmi_recv_ctrl_pkt()  argument
142 		qmi_recv_bye(qmi, le32_to_cpu(pkt->client.node));  in qmi_recv_ctrl_pkt()
145 		qmi_recv_new_server(qmi,  in qmi_recv_ctrl_pkt()
152 		qmi_recv_del_server(qmi,  in qmi_recv_ctrl_pkt()
157 		qmi_recv_del_client(qmi,  in qmi_recv_ctrl_pkt()
164 static void qmi_send_new_lookup(struct qmi_handle *qmi, struct qmi_service *svc)  in qmi_send_new_lookup()  argument
177 	sq.sq_family = qmi->sq.sq_family;  in qmi_send_new_lookup()
178 	sq.sq_node = qmi->sq.sq_node;  in qmi_send_new_lookup()
184 	mutex_lock(&qmi->sock_lock);  in qmi_send_new_lookup()
185 	if (qmi->sock) {  in qmi_send_new_lookup()
186 		ret = kernel_sendmsg(qmi->sock, &msg, &iv, 1, sizeof(pkt));  in qmi_send_new_lookup()
190 	mutex_unlock(&qmi->sock_lock);  in qmi_send_new_lookup()
206 int qmi_add_lookup(struct qmi_handle *qmi, unsigned int service,  in qmi_add_lookup()  argument
219 	list_add(&svc->list_node, &qmi->lookups);  in qmi_add_lookup()
221 	qmi_send_new_lookup(qmi, svc);  in qmi_add_lookup()
227 static void qmi_send_new_server(struct qmi_handle *qmi, struct qmi_service *svc)  in qmi_send_new_server()  argument
239 	pkt.server.node = cpu_to_le32(qmi->sq.sq_node);  in qmi_send_new_server()
240 	pkt.server.port = cpu_to_le32(qmi->sq.sq_port);  in qmi_send_new_server()
242 	sq.sq_family = qmi->sq.sq_family;  in qmi_send_new_server()
243 	sq.sq_node = qmi->sq.sq_node;  in qmi_send_new_server()
249 	mutex_lock(&qmi->sock_lock);  in qmi_send_new_server()
250 	if (qmi->sock) {  in qmi_send_new_server()
251 		ret = kernel_sendmsg(qmi->sock, &msg, &iv, 1, sizeof(pkt));  in qmi_send_new_server()
255 	mutex_unlock(&qmi->sock_lock);  in qmi_send_new_server()
270 int qmi_add_server(struct qmi_handle *qmi, unsigned int service,  in qmi_add_server()  argument
283 	list_add(&svc->list_node, &qmi->services);  in qmi_add_server()
285 	qmi_send_new_server(qmi, svc);  in qmi_add_server()
307 int qmi_txn_init(struct qmi_handle *qmi, struct qmi_txn *txn,  in qmi_txn_init()  argument
316 	txn->qmi = qmi;  in qmi_txn_init()
320 	mutex_lock(&qmi->txn_lock);  in qmi_txn_init()
321 	ret = idr_alloc_cyclic(&qmi->txns, txn, 0, INT_MAX, GFP_KERNEL);  in qmi_txn_init()
326 	mutex_unlock(&qmi->txn_lock);  in qmi_txn_init()
345 	struct qmi_handle *qmi = txn->qmi;  in qmi_txn_wait()  local
351 	mutex_lock(&qmi->txn_lock);  in qmi_txn_wait()
353 	idr_remove(&qmi->txns, txn->id);  in qmi_txn_wait()
355 	mutex_unlock(&qmi->txn_lock);  in qmi_txn_wait()
372 	struct qmi_handle *qmi = txn->qmi;  in qmi_txn_cancel()  local
374 	mutex_lock(&qmi->txn_lock);  in qmi_txn_cancel()
376 	idr_remove(&qmi->txns, txn->id);  in qmi_txn_cancel()
378 	mutex_unlock(&qmi->txn_lock);  in qmi_txn_cancel()
392 static void qmi_invoke_handler(struct qmi_handle *qmi, struct sockaddr_qrtr *sq,  in qmi_invoke_handler()  argument
400 	if (!qmi->handlers)  in qmi_invoke_handler()
403 	for (handler = qmi->handlers; handler->fn; handler++) {  in qmi_invoke_handler()
420 		handler->fn(qmi, sq, txn, dest);  in qmi_invoke_handler()
442 static void qmi_handle_net_reset(struct qmi_handle *qmi)  in qmi_handle_net_reset()  argument
448 	sock = qmi_sock_create(qmi, &sq);  in qmi_handle_net_reset()
452 	mutex_lock(&qmi->sock_lock);  in qmi_handle_net_reset()
453 	sock_release(qmi->sock);  in qmi_handle_net_reset()
454 	qmi->sock = NULL;  in qmi_handle_net_reset()
455 	mutex_unlock(&qmi->sock_lock);  in qmi_handle_net_reset()
457 	qmi_recv_del_server(qmi, -1, -1);  in qmi_handle_net_reset()
459 	if (qmi->ops.net_reset)  in qmi_handle_net_reset()
460 		qmi->ops.net_reset(qmi);  in qmi_handle_net_reset()
462 	mutex_lock(&qmi->sock_lock);  in qmi_handle_net_reset()
463 	qmi->sock = sock;  in qmi_handle_net_reset()
464 	qmi->sq = sq;  in qmi_handle_net_reset()
465 	mutex_unlock(&qmi->sock_lock);  in qmi_handle_net_reset()
467 	list_for_each_entry(svc, &qmi->lookups, list_node)  in qmi_handle_net_reset()
468 		qmi_send_new_lookup(qmi, svc);  in qmi_handle_net_reset()
470 	list_for_each_entry(svc, &qmi->services, list_node)  in qmi_handle_net_reset()
471 		qmi_send_new_server(qmi, svc);  in qmi_handle_net_reset()
474 static void qmi_handle_message(struct qmi_handle *qmi,  in qmi_handle_message()  argument
492 		mutex_lock(&qmi->txn_lock);  in qmi_handle_message()
493 		txn = idr_find(&qmi->txns, hdr->txn_id);  in qmi_handle_message()
497 			mutex_unlock(&qmi->txn_lock);  in qmi_handle_message()
502 		mutex_unlock(&qmi->txn_lock);  in qmi_handle_message()
512 			qmi_invoke_handler(qmi, sq, txn, buf, len);  in qmi_handle_message()
521 		qmi_invoke_handler(qmi, sq, &tmp_txn, buf, len);  in qmi_handle_message()
527 	struct qmi_handle *qmi = container_of(work, struct qmi_handle, work);  in qmi_data_ready_work()  local
528 	struct qmi_ops *ops = &qmi->ops;  in qmi_data_ready_work()
535 		iv.iov_base = qmi->recv_buf;  in qmi_data_ready_work()
536 		iv.iov_len = qmi->recv_buf_size;  in qmi_data_ready_work()
538 		mutex_lock(&qmi->sock_lock);  in qmi_data_ready_work()
539 		if (qmi->sock)  in qmi_data_ready_work()
540 			msglen = kernel_recvmsg(qmi->sock, &msg, &iv, 1,  in qmi_data_ready_work()
544 		mutex_unlock(&qmi->sock_lock);  in qmi_data_ready_work()
549 			qmi_handle_net_reset(qmi);  in qmi_data_ready_work()
560 		if (sq.sq_node == qmi->sq.sq_node &&  in qmi_data_ready_work()
562 			qmi_recv_ctrl_pkt(qmi, qmi->recv_buf, msglen);  in qmi_data_ready_work()
564 			ops->msg_handler(qmi, &sq, qmi->recv_buf, msglen);  in qmi_data_ready_work()
566 			qmi_handle_message(qmi, &sq, qmi->recv_buf, msglen);  in qmi_data_ready_work()
573 	struct qmi_handle *qmi = sk->sk_user_data;  in qmi_data_ready()  local
579 	if (!qmi)  in qmi_data_ready()
582 	queue_work(qmi->wq, &qmi->work);  in qmi_data_ready()
585 static struct socket *qmi_sock_create(struct qmi_handle *qmi,  in qmi_sock_create()  argument
602 	sock->sk->sk_user_data = qmi;  in qmi_sock_create()
621 int qmi_handle_init(struct qmi_handle *qmi, size_t recv_buf_size,  in qmi_handle_init()  argument
627 	mutex_init(&qmi->txn_lock);  in qmi_handle_init()
628 	mutex_init(&qmi->sock_lock);  in qmi_handle_init()
630 	idr_init(&qmi->txns);  in qmi_handle_init()
632 	INIT_LIST_HEAD(&qmi->lookups);  in qmi_handle_init()
633 	INIT_LIST_HEAD(&qmi->lookup_results);  in qmi_handle_init()
634 	INIT_LIST_HEAD(&qmi->services);  in qmi_handle_init()
636 	INIT_WORK(&qmi->work, qmi_data_ready_work);  in qmi_handle_init()
638 	qmi->handlers = handlers;  in qmi_handle_init()
640 		qmi->ops = *ops;  in qmi_handle_init()
648 	qmi->recv_buf_size = recv_buf_size;  in qmi_handle_init()
649 	qmi->recv_buf = kzalloc(recv_buf_size, GFP_KERNEL);  in qmi_handle_init()
650 	if (!qmi->recv_buf)  in qmi_handle_init()
653 	qmi->wq = alloc_workqueue("qmi_msg_handler", WQ_UNBOUND, 1);  in qmi_handle_init()
654 	if (!qmi->wq) {  in qmi_handle_init()
659 	qmi->sock = qmi_sock_create(qmi, &qmi->sq);  in qmi_handle_init()
660 	if (IS_ERR(qmi->sock)) {  in qmi_handle_init()
662 		ret = PTR_ERR(qmi->sock);  in qmi_handle_init()
669 	destroy_workqueue(qmi->wq);  in qmi_handle_init()
671 	kfree(qmi->recv_buf);  in qmi_handle_init()
683 void qmi_handle_release(struct qmi_handle *qmi)  in qmi_handle_release()  argument
685 	struct socket *sock = qmi->sock;  in qmi_handle_release()
689 	cancel_work_sync(&qmi->work);  in qmi_handle_release()
691 	qmi_recv_del_server(qmi, -1, -1);  in qmi_handle_release()
693 	mutex_lock(&qmi->sock_lock);  in qmi_handle_release()
695 	qmi->sock = NULL;  in qmi_handle_release()
696 	mutex_unlock(&qmi->sock_lock);  in qmi_handle_release()
698 	destroy_workqueue(qmi->wq);  in qmi_handle_release()
700 	idr_destroy(&qmi->txns);  in qmi_handle_release()
702 	kfree(qmi->recv_buf);  in qmi_handle_release()
705 	list_for_each_entry_safe(svc, tmp, &qmi->lookups, list_node) {  in qmi_handle_release()
711 	list_for_each_entry_safe(svc, tmp, &qmi->services, list_node) {  in qmi_handle_release()
735 static ssize_t qmi_send_message(struct qmi_handle *qmi,  in qmi_send_message()  argument
760 	mutex_lock(&qmi->sock_lock);  in qmi_send_message()
761 	if (qmi->sock) {  in qmi_send_message()
762 		ret = kernel_sendmsg(qmi->sock, &msghdr, &iv, 1, len);  in qmi_send_message()
768 	mutex_unlock(&qmi->sock_lock);  in qmi_send_message()
787 ssize_t qmi_send_request(struct qmi_handle *qmi, struct sockaddr_qrtr *sq,  in qmi_send_request()  argument
791 	return qmi_send_message(qmi, sq, txn, QMI_REQUEST, msg_id, len, ei,  in qmi_send_request()
808 ssize_t qmi_send_response(struct qmi_handle *qmi, struct sockaddr_qrtr *sq,  in qmi_send_response()  argument
812 	return qmi_send_message(qmi, sq, txn, QMI_RESPONSE, msg_id, len, ei,  in qmi_send_response()
828 ssize_t qmi_send_indication(struct qmi_handle *qmi, struct sockaddr_qrtr *sq,  in qmi_send_indication()  argument
836 	ret = qmi_txn_init(qmi, &txn, NULL, NULL);  in qmi_send_indication()
840 	rval = qmi_send_message(qmi, sq, &txn, QMI_INDICATION, msg_id, len, ei,  in qmi_send_indication()