// SPDX-License-Identifier: GPL-2.0/* * Copyright (C) 2017 Linaro Ltd. */#include <linux/kernel.h>#include <linux/module.h>#include <linux/device.h>#include <linux/qrtr.h>#include <linux/net.h>#include <linux/completion.h>#include <linux/idr.h>#include <linux/string.h>#include <net/sock.h>#include <linux/workqueue.h>#include <trace/events/sock.h>#include <linux/soc/qcom/qmi.h> static struct socket *qmi_sock_create(struct qmi_handle *qmi, struct sockaddr_qrtr *sq); /** * qmi_recv_new_server() - handler of NEW_SERVER control message * @qmi: qmi handle * @service: service id of the new server * @instance: instance id of the new server * @node: node of the new server * @port: port of the new server * * Calls the new_server callback to inform the client about a newly registered * server matching the currently registered service lookup. */static void qmi_recv_new_server(struct qmi_handle *qmi, unsigned int service, unsigned int instance, unsigned int node, unsigned int port){ struct qmi_ops *ops = &qmi->ops; struct qmi_service *svc; int ret; if (!ops->new_server) return; /* Ignore EOF marker */ if (!node && !port) return; svc = kzalloc_obj(*svc); if (!svc) return; svc->service = service; svc->version = instance & 0xff; svc->instance = instance >> 8; svc->node = node; svc->port = port; ret = ops->new_server(qmi, svc); if (ret < 0) kfree(svc); else list_add(&svc->list_node, &qmi->lookup_results);} /** * qmi_recv_del_server() - handler of DEL_SERVER control message * @qmi: qmi handle * @node: node of the dying server, a value of -1 matches all nodes * @port: port of the dying server, a value of -1 matches all ports * * Calls the del_server callback for each previously seen server, allowing the * client to react to the disappearing server. */static void qmi_recv_del_server(struct qmi_handle *qmi, unsigned int node, unsigned int port){ struct qmi_ops *ops = &qmi->ops; struct qmi_service *svc; struct qmi_service *tmp; list_for_each_entry_safe(svc, tmp, &qmi->lookup_results, list_node) { if (node != -1 && svc->node != node) continue; if (port != -1 && svc->port != port) continue; if (ops->del_server) ops->del_server(qmi, svc); list_del(&svc->list_node); kfree(svc); }} /** * qmi_recv_bye() - handler of BYE control message * @qmi: qmi handle * @node: id of the dying node * * Signals the client that all previously registered services on this node are * now gone and then calls the bye callback to allow the client further * cleaning up resources associated with this remote. */static void qmi_recv_bye(struct qmi_handle *qmi, unsigned int node){ struct qmi_ops *ops = &qmi->ops; qmi_recv_del_server(qmi, node, -1); if (ops->bye) ops->bye(qmi, node);} /** * qmi_recv_del_client() - handler of DEL_CLIENT control message * @qmi: qmi handle * @node: node of the dying client * @port: port of the dying client * * Signals the client about a dying client, by calling the del_client callback. */static void qmi_recv_del_client(struct qmi_handle *qmi, unsigned int node, unsigned int port){ struct qmi_ops *ops = &qmi->ops; if (ops->del_client) ops->del_client(qmi, node, port);} static void qmi_recv_ctrl_pkt(struct qmi_handle *qmi, const void *buf, size_t len){ const struct qrtr_ctrl_pkt *pkt = buf; if (len < sizeof(struct qrtr_ctrl_pkt)) { pr_debug("ignoring short control packet\n"); return; } switch (le32_to_cpu(pkt->cmd)) { case QRTR_TYPE_BYE: qmi_recv_bye(qmi, le32_to_cpu(pkt->client.node)); break; case QRTR_TYPE_NEW_SERVER: qmi_recv_new_server(qmi, le32_to_cpu(pkt->server.service), le32_to_cpu(pkt->server.instance), le32_to_cpu(pkt->server.node), le32_to_cpu(pkt->server.port)); break; case QRTR_TYPE_DEL_SERVER: qmi_recv_del_server(qmi, le32_to_cpu(pkt->server.node), le32_to_cpu(pkt->server.port)); break; case QRTR_TYPE_DEL_CLIENT: qmi_recv_del_client(qmi, le32_to_cpu(pkt->client.node), le32_to_cpu(pkt->client.port)); break; }} static void qmi_send_new_lookup(struct qmi_handle *qmi, struct qmi_service *svc){ struct qrtr_ctrl_pkt pkt; struct sockaddr_qrtr sq; struct msghdr msg = { }; struct kvec iv = { &pkt, sizeof(pkt) }; int ret; memset(&pkt, 0, sizeof(pkt)); pkt.cmd = cpu_to_le32(QRTR_TYPE_NEW_LOOKUP); pkt.server.service = cpu_to_le32(svc->service); pkt.server.instance = cpu_to_le32(svc->version | svc->instance << 8); sq.sq_family = qmi->sq.sq_family; sq.sq_node = qmi->sq.sq_node; sq.sq_port = QRTR_PORT_CTRL; msg.msg_name = &sq; msg.msg_namelen = sizeof(sq); mutex_lock(&qmi->sock_lock); if (qmi->sock) { ret = kernel_sendmsg(qmi->sock, &msg, &iv, 1, sizeof(pkt)); if (ret < 0) pr_err("failed to send lookup registration: %d\n", ret); } mutex_unlock(&qmi->sock_lock);} /** * qmi_add_lookup() - register a new lookup with the name service * @qmi: qmi handle * @service: service id of the request * @version: version number of the request * @instance: instance id of the request * * Registering a lookup query with the name server will cause the name server * to send NEW_SERVER and DEL_SERVER control messages to this socket as * matching services are registered. * * Return: 0 on success, negative errno on failure. */int qmi_add_lookup(struct qmi_handle *qmi, unsigned int service, unsigned int version, unsigned int instance){ struct qmi_service *svc; svc = kzalloc_obj(*svc); if (!svc) return -ENOMEM; svc->service = service; svc->version = version; svc->instance = instance; list_add(&svc->list_node, &qmi->lookups); qmi_send_new_lookup(qmi, svc); return 0;}EXPORT_SYMBOL_GPL(qmi_add_lookup); static void qmi_send_new_server(struct qmi_handle *qmi, struct qmi_service *svc){ struct qrtr_ctrl_pkt pkt; struct sockaddr_qrtr sq; struct msghdr msg = { }; struct kvec iv = { &pkt, sizeof(pkt) }; int ret; memset(&pkt, 0, sizeof(pkt)); pkt.cmd = cpu_to_le32(QRTR_TYPE_NEW_SERVER); pkt.server.service = cpu_to_le32(svc->service); pkt.server.instance = cpu_to_le32(svc->version | svc->instance << 8); pkt.server.node = cpu_to_le32(qmi->sq.sq_node); pkt.server.port = cpu_to_le32(qmi->sq.sq_port); sq.sq_family = qmi->sq.sq_family; sq.sq_node = qmi->sq.sq_node; sq.sq_port = QRTR_PORT_CTRL; msg.msg_name = &sq; msg.msg_namelen = sizeof(sq); mutex_lock(&qmi->sock_lock); if (qmi->sock) { ret = kernel_sendmsg(qmi->sock, &msg, &iv, 1, sizeof(pkt)); if (ret < 0) pr_err("send service registration failed: %d\n", ret); } mutex_unlock(&qmi->sock_lock);} /** * qmi_add_server() - register a service with the name service * @qmi: qmi handle * @service: type of the service * @instance: instance of the service * @version: version of the service * * Register a new service with the name service. This allows clients to find * and start sending messages to the client associated with @qmi. * * Return: 0 on success, negative errno on failure. */int qmi_add_server(struct qmi_handle *qmi, unsigned int service, unsigned int version, unsigned int instance){ struct qmi_service *svc; svc = kzalloc_obj(*svc); if (!svc) return -ENOMEM; svc->service = service; svc->version = version; svc->instance = instance; list_add(&svc->list_node, &qmi->services); qmi_send_new_server(qmi, svc); return 0;}EXPORT_SYMBOL_GPL(qmi_add_server); /** * qmi_txn_init() - allocate transaction id within the given QMI handle * @qmi: QMI handle * @txn: transaction context * @ei: description of how to decode a matching response (optional) * @c_struct: pointer to the object to decode the response into (optional) * * This allocates a transaction id within the QMI handle. If @ei and @c_struct * are specified any responses to this transaction will be decoded as described * by @ei into @c_struct. * * A client calling qmi_txn_init() must call either qmi_txn_wait() or * qmi_txn_cancel() to free up the allocated resources. * * Return: Transaction id on success, negative errno on failure. */int qmi_txn_init(struct qmi_handle *qmi, struct qmi_txn *txn, const struct qmi_elem_info *ei, void *c_struct){ int ret; memset(txn, 0, sizeof(*txn)); mutex_init(&txn->lock); init_completion(&txn->completion); txn->qmi = qmi; txn->ei = ei; txn->dest = c_struct; mutex_lock(&qmi->txn_lock); ret = idr_alloc_cyclic(&qmi->txns, txn, 0, U16_MAX, GFP_KERNEL); if (ret < 0) pr_err("failed to allocate transaction id\n"); txn->id = ret; mutex_unlock(&qmi->txn_lock); return ret;}EXPORT_SYMBOL_GPL(qmi_txn_init); /** * qmi_txn_wait() - wait for a response on a transaction * @txn: transaction handle * @timeout: timeout, in jiffies * * If the transaction is decoded by the means of @ei and @c_struct the return * value will be the returned value of qmi_decode_message(), otherwise it's up * to the specified message handler to fill out the result. * * Return: the transaction response on success, negative errno on failure. */int qmi_txn_wait(struct qmi_txn *txn, unsigned long timeout){ struct qmi_handle *qmi = txn->qmi; int ret; ret = wait_for_completion_timeout(&txn->completion, timeout); mutex_lock(&qmi->txn_lock); mutex_lock(&txn->lock); idr_remove(&qmi->txns, txn->id); mutex_unlock(&txn->lock); mutex_unlock(&qmi->txn_lock); if (ret == 0) return -ETIMEDOUT; else return txn->result;}EXPORT_SYMBOL_GPL(qmi_txn_wait); /** * qmi_txn_cancel() - cancel an ongoing transaction * @txn: transaction id */void qmi_txn_cancel(struct qmi_txn *txn){ struct qmi_handle *qmi = txn->qmi; mutex_lock(&qmi->txn_lock); mutex_lock(&txn->lock); idr_remove(&qmi->txns, txn->id); mutex_unlock(&txn->lock); mutex_unlock(&qmi->txn_lock);}EXPORT_SYMBOL_GPL(qmi_txn_cancel); /** * qmi_invoke_handler() - find and invoke a handler for a message * @qmi: qmi handle * @sq: sockaddr of the sender * @txn: transaction object for the message * @buf: buffer containing the message * @len: length of @buf * * Find handler and invoke handler for the incoming message. */static void qmi_invoke_handler(struct qmi_handle *qmi, struct sockaddr_qrtr *sq, struct qmi_txn *txn, const void *buf, size_t len){ const struct qmi_msg_handler *handler; const struct qmi_header *hdr = buf; void *dest; int ret; if (!qmi->handlers) return; for (handler = qmi->handlers; handler->fn; handler++) { if (handler->type == hdr->type && handler->msg_id == le16_to_cpu(hdr->msg_id)) break; } if (!handler->fn) return; dest = kzalloc(handler->decoded_size, GFP_KERNEL); if (!dest) return; ret = qmi_decode_message(buf, len, handler->ei, dest); if (ret < 0) pr_err("failed to decode incoming message\n"); else handler->fn(qmi, sq, txn, dest); kfree(dest);} /** * qmi_handle_net_reset() - invoked to handle ENETRESET on a QMI handle * @qmi: the QMI context * * As a result of registering a name service with the QRTR all open sockets are * flagged with ENETRESET and this function will be called. The typical case is * the initial boot, where this signals that the local node id has been * configured and as such any bound sockets needs to be rebound. So close the * socket, inform the client and re-initialize the socket. * * For clients it's generally sufficient to react to the del_server callbacks, * but server code is expected to treat the net_reset callback as a "bye" from * all nodes. * * Finally the QMI handle will send out registration requests for any lookups * and services. */static void qmi_handle_net_reset(struct qmi_handle *qmi){ struct sockaddr_qrtr sq; struct qmi_service *svc; struct socket *sock; sock = qmi_sock_create(qmi, &sq); if (IS_ERR(sock)) return; mutex_lock(&qmi->sock_lock); sock_release(qmi->sock); qmi->sock = NULL; mutex_unlock(&qmi->sock_lock); qmi_recv_del_server(qmi, -1, -1); if (qmi->ops.net_reset) qmi->ops.net_reset(qmi); mutex_lock(&qmi->sock_lock); qmi->sock = sock; qmi->sq = sq; mutex_unlock(&qmi->sock_lock); list_for_each_entry(svc, &qmi->lookups, list_node) qmi_send_new_lookup(qmi, svc); list_for_each_entry(svc, &qmi->services, list_node) qmi_send_new_server(qmi, svc);} static void qmi_handle_message(struct qmi_handle *qmi, struct sockaddr_qrtr *sq, const void *buf, size_t len){ const struct qmi_header *hdr; struct qmi_txn tmp_txn; struct qmi_txn *txn = NULL; int ret; if (len < sizeof(*hdr)) { pr_err("ignoring short QMI packet\n"); return; } hdr = buf; /* If this is a response, find the matching transaction handle */ if (hdr->type == QMI_RESPONSE) { mutex_lock(&qmi->txn_lock); txn = idr_find(&qmi->txns, le16_to_cpu(hdr->txn_id)); /* Ignore unexpected responses */ if (!txn) { mutex_unlock(&qmi->txn_lock); return; } mutex_lock(&txn->lock); mutex_unlock(&qmi->txn_lock);Lines 1–500 of 854. Load more
// SPDX-License-Identifier: GPL-2.0 /* * Copyright (C) 2017 Linaro Ltd. */ #include <linux/kernel.h> #include <linux/module.h> #include <linux/device.h> #include <linux/qrtr.h> #include <linux/net.h> #include <linux/completion.h> #include <linux/idr.h> #include <linux/string.h> #include <net/sock.h> #include <linux/workqueue.h> #include <trace/events/sock.h> #include <linux/soc/qcom/qmi.h> static struct socket *qmi_sock_create(struct qmi_handle *qmi, struct sockaddr_qrtr *sq); /** * qmi_recv_new_server() - handler of NEW_SERVER control message * @qmi: qmi handle * @service: service id of the new server * @instance: instance id of the new server * @node: node of the new server * @port: port of the new server * * Calls the new_server callback to inform the client about a newly registered * server matching the currently registered service lookup. */ static void qmi_recv_new_server(struct qmi_handle *qmi, unsigned int service, unsigned int instance, unsigned int node, unsigned int port) { struct qmi_ops *ops = &qmi->ops; struct qmi_service *svc; int ret; if (!ops->new_server) return; /* Ignore EOF marker */ if (!node && !port) return; svc = kzalloc_obj(*svc); if (!svc) return; svc->service = service; svc->version = instance & 0xff; svc->instance = instance >> 8; svc->node = node; svc->port = port; ret = ops->new_server(qmi, svc); if (ret < 0) kfree(svc); else list_add(&svc->list_node, &qmi->lookup_results); } /** * qmi_recv_del_server() - handler of DEL_SERVER control message * @qmi: qmi handle * @node: node of the dying server, a value of -1 matches all nodes * @port: port of the dying server, a value of -1 matches all ports * * Calls the del_server callback for each previously seen server, allowing the * client to react to the disappearing server. */ static void qmi_recv_del_server(struct qmi_handle *qmi, unsigned int node, unsigned int port) { struct qmi_ops *ops = &qmi->ops; struct qmi_service *svc; struct qmi_service *tmp; list_for_each_entry_safe(svc, tmp, &qmi->lookup_results, list_node) { if (node != -1 && svc->node != node) continue; if (port != -1 && svc->port != port) continue; if (ops->del_server) ops->del_server(qmi, svc); list_del(&svc->list_node); kfree(svc); } } /** * qmi_recv_bye() - handler of BYE control message * @qmi: qmi handle * @node: id of the dying node * * Signals the client that all previously registered services on this node are * now gone and then calls the bye callback to allow the client further * cleaning up resources associated with this remote. */ static void qmi_recv_bye(struct qmi_handle *qmi, unsigned int node) { struct qmi_ops *ops = &qmi->ops; qmi_recv_del_server(qmi, node, -1); if (ops->bye) ops->bye(qmi, node); } /** * qmi_recv_del_client() - handler of DEL_CLIENT control message * @qmi: qmi handle * @node: node of the dying client * @port: port of the dying client * * Signals the client about a dying client, by calling the del_client callback. */ static void qmi_recv_del_client(struct qmi_handle *qmi, unsigned int node, unsigned int port) { struct qmi_ops *ops = &qmi->ops; if (ops->del_client) ops->del_client(qmi, node, port); } static void qmi_recv_ctrl_pkt(struct qmi_handle *qmi, const void *buf, size_t len) { const struct qrtr_ctrl_pkt *pkt = buf; if (len < sizeof(struct qrtr_ctrl_pkt)) { pr_debug("ignoring short control packet\n"); return; } switch (le32_to_cpu(pkt->cmd)) { case QRTR_TYPE_BYE: qmi_recv_bye(qmi, le32_to_cpu(pkt->client.node)); break; case QRTR_TYPE_NEW_SERVER: qmi_recv_new_server(qmi, le32_to_cpu(pkt->server.service), le32_to_cpu(pkt->server.instance), le32_to_cpu(pkt->server.node), le32_to_cpu(pkt->server.port)); break; case QRTR_TYPE_DEL_SERVER: qmi_recv_del_server(qmi, le32_to_cpu(pkt->server.node), le32_to_cpu(pkt->server.port)); break; case QRTR_TYPE_DEL_CLIENT: qmi_recv_del_client(qmi, le32_to_cpu(pkt->client.node), le32_to_cpu(pkt->client.port)); break; } } static void qmi_send_new_lookup(struct qmi_handle *qmi, struct qmi_service *svc) { struct qrtr_ctrl_pkt pkt; struct sockaddr_qrtr sq; struct msghdr msg = { }; struct kvec iv = { &pkt, sizeof(pkt) }; int ret; memset(&pkt, 0, sizeof(pkt)); pkt.cmd = cpu_to_le32(QRTR_TYPE_NEW_LOOKUP); pkt.server.service = cpu_to_le32(svc->service); pkt.server.instance = cpu_to_le32(svc->version | svc->instance << 8); sq.sq_family = qmi->sq.sq_family; sq.sq_node = qmi->sq.sq_node; sq.sq_port = QRTR_PORT_CTRL; msg.msg_name = &sq; msg.msg_namelen = sizeof(sq); mutex_lock(&qmi->sock_lock); if (qmi->sock) { ret = kernel_sendmsg(qmi->sock, &msg, &iv, 1, sizeof(pkt)); if (ret < 0) pr_err("failed to send lookup registration: %d\n", ret); } mutex_unlock(&qmi->sock_lock); } /** * qmi_add_lookup() - register a new lookup with the name service * @qmi: qmi handle * @service: service id of the request * @version: version number of the request * @instance: instance id of the request * * Registering a lookup query with the name server will cause the name server * to send NEW_SERVER and DEL_SERVER control messages to this socket as * matching services are registered. * * Return: 0 on success, negative errno on failure. */ int qmi_add_lookup(struct qmi_handle *qmi, unsigned int service, unsigned int version, unsigned int instance) { struct qmi_service *svc; svc = kzalloc_obj(*svc); if (!svc) return -ENOMEM; svc->service = service; svc->version = version; svc->instance = instance; list_add(&svc->list_node, &qmi->lookups); qmi_send_new_lookup(qmi, svc); return 0; } EXPORT_SYMBOL_GPL(qmi_add_lookup); static void qmi_send_new_server(struct qmi_handle *qmi, struct qmi_service *svc) { struct qrtr_ctrl_pkt pkt; struct sockaddr_qrtr sq; struct msghdr msg = { }; struct kvec iv = { &pkt, sizeof(pkt) }; int ret; memset(&pkt, 0, sizeof(pkt)); pkt.cmd = cpu_to_le32(QRTR_TYPE_NEW_SERVER); pkt.server.service = cpu_to_le32(svc->service); pkt.server.instance = cpu_to_le32(svc->version | svc->instance << 8); pkt.server.node = cpu_to_le32(qmi->sq.sq_node); pkt.server.port = cpu_to_le32(qmi->sq.sq_port); sq.sq_family = qmi->sq.sq_family; sq.sq_node = qmi->sq.sq_node; sq.sq_port = QRTR_PORT_CTRL; msg.msg_name = &sq; msg.msg_namelen = sizeof(sq); mutex_lock(&qmi->sock_lock); if (qmi->sock) { ret = kernel_sendmsg(qmi->sock, &msg, &iv, 1, sizeof(pkt)); if (ret < 0) pr_err("send service registration failed: %d\n", ret); } mutex_unlock(&qmi->sock_lock); } /** * qmi_add_server() - register a service with the name service * @qmi: qmi handle * @service: type of the service * @instance: instance of the service * @version: version of the service * * Register a new service with the name service. This allows clients to find * and start sending messages to the client associated with @qmi. * * Return: 0 on success, negative errno on failure. */ int qmi_add_server(struct qmi_handle *qmi, unsigned int service, unsigned int version, unsigned int instance) { struct qmi_service *svc; svc = kzalloc_obj(*svc); if (!svc) return -ENOMEM; svc->service = service; svc->version = version; svc->instance = instance; list_add(&svc->list_node, &qmi->services); qmi_send_new_server(qmi, svc); return 0; } EXPORT_SYMBOL_GPL(qmi_add_server); /** * qmi_txn_init() - allocate transaction id within the given QMI handle * @qmi: QMI handle * @txn: transaction context * @ei: description of how to decode a matching response (optional) * @c_struct: pointer to the object to decode the response into (optional) * * This allocates a transaction id within the QMI handle. If @ei and @c_struct * are specified any responses to this transaction will be decoded as described * by @ei into @c_struct. * * A client calling qmi_txn_init() must call either qmi_txn_wait() or * qmi_txn_cancel() to free up the allocated resources. * * Return: Transaction id on success, negative errno on failure. */ int qmi_txn_init(struct qmi_handle *qmi, struct qmi_txn *txn, const struct qmi_elem_info *ei, void *c_struct) { int ret; memset(txn, 0, sizeof(*txn)); mutex_init(&txn->lock); init_completion(&txn->completion); txn->qmi = qmi; txn->ei = ei; txn->dest = c_struct; mutex_lock(&qmi->txn_lock); ret = idr_alloc_cyclic(&qmi->txns, txn, 0, U16_MAX, GFP_KERNEL); if (ret < 0) pr_err("failed to allocate transaction id\n"); txn->id = ret; mutex_unlock(&qmi->txn_lock); return ret; } EXPORT_SYMBOL_GPL(qmi_txn_init); /** * qmi_txn_wait() - wait for a response on a transaction * @txn: transaction handle * @timeout: timeout, in jiffies * * If the transaction is decoded by the means of @ei and @c_struct the return * value will be the returned value of qmi_decode_message(), otherwise it's up * to the specified message handler to fill out the result. * * Return: the transaction response on success, negative errno on failure. */ int qmi_txn_wait(struct qmi_txn *txn, unsigned long timeout) { struct qmi_handle *qmi = txn->qmi; int ret; ret = wait_for_completion_timeout(&txn->completion, timeout); mutex_lock(&qmi->txn_lock); mutex_lock(&txn->lock); idr_remove(&qmi->txns, txn->id); mutex_unlock(&txn->lock); mutex_unlock(&qmi->txn_lock); if (ret == 0) return -ETIMEDOUT; else return txn->result; } EXPORT_SYMBOL_GPL(qmi_txn_wait); /** * qmi_txn_cancel() - cancel an ongoing transaction * @txn: transaction id */ void qmi_txn_cancel(struct qmi_txn *txn) { struct qmi_handle *qmi = txn->qmi; mutex_lock(&qmi->txn_lock); mutex_lock(&txn->lock); idr_remove(&qmi->txns, txn->id); mutex_unlock(&txn->lock); mutex_unlock(&qmi->txn_lock); } EXPORT_SYMBOL_GPL(qmi_txn_cancel); /** * qmi_invoke_handler() - find and invoke a handler for a message * @qmi: qmi handle * @sq: sockaddr of the sender * @txn: transaction object for the message * @buf: buffer containing the message * @len: length of @buf * * Find handler and invoke handler for the incoming message. */ static void qmi_invoke_handler(struct qmi_handle *qmi, struct sockaddr_qrtr *sq, struct qmi_txn *txn, const void *buf, size_t len) { const struct qmi_msg_handler *handler; const struct qmi_header *hdr = buf; void *dest; int ret; if (!qmi->handlers) return; for (handler = qmi->handlers; handler->fn; handler++) { if (handler->type == hdr->type && handler->msg_id == le16_to_cpu(hdr->msg_id)) break; } if (!handler->fn) return; dest = kzalloc(handler->decoded_size, GFP_KERNEL); if (!dest) return; ret = qmi_decode_message(buf, len, handler->ei, dest); if (ret < 0) pr_err("failed to decode incoming message\n"); else handler->fn(qmi, sq, txn, dest); kfree(dest); } /** * qmi_handle_net_reset() - invoked to handle ENETRESET on a QMI handle * @qmi: the QMI context * * As a result of registering a name service with the QRTR all open sockets are * flagged with ENETRESET and this function will be called. The typical case is * the initial boot, where this signals that the local node id has been * configured and as such any bound sockets needs to be rebound. So close the * socket, inform the client and re-initialize the socket. * * For clients it's generally sufficient to react to the del_server callbacks, * but server code is expected to treat the net_reset callback as a "bye" from * all nodes. * * Finally the QMI handle will send out registration requests for any lookups * and services. */ static void qmi_handle_net_reset(struct qmi_handle *qmi) { struct sockaddr_qrtr sq; struct qmi_service *svc; struct socket *sock; sock = qmi_sock_create(qmi, &sq); if (IS_ERR(sock)) return; mutex_lock(&qmi->sock_lock); sock_release(qmi->sock); qmi->sock = NULL; mutex_unlock(&qmi->sock_lock); qmi_recv_del_server(qmi, -1, -1); if (qmi->ops.net_reset) qmi->ops.net_reset(qmi); mutex_lock(&qmi->sock_lock); qmi->sock = sock; qmi->sq = sq; mutex_unlock(&qmi->sock_lock); list_for_each_entry(svc, &qmi->lookups, list_node) qmi_send_new_lookup(qmi, svc); list_for_each_entry(svc, &qmi->services, list_node) qmi_send_new_server(qmi, svc); } static void qmi_handle_message(struct qmi_handle *qmi, struct sockaddr_qrtr *sq, const void *buf, size_t len) { const struct qmi_header *hdr; struct qmi_txn tmp_txn; struct qmi_txn *txn = NULL; int ret; if (len < sizeof(*hdr)) { pr_err("ignoring short QMI packet\n"); return; } hdr = buf; /* If this is a response, find the matching transaction handle */ if (hdr->type == QMI_RESPONSE) { mutex_lock(&qmi->txn_lock); txn = idr_find(&qmi->txns, le16_to_cpu(hdr->txn_id)); /* Ignore unexpected responses */ if (!txn) { mutex_unlock(&qmi->txn_lock); return; } mutex_lock(&txn->lock); mutex_unlock(&qmi->txn_lock);