// 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) { … } /** * 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) { … } /** * 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) { … } /** * 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) { … } static void qmi_recv_ctrl_pkt(struct qmi_handle *qmi, const void *buf, size_t len) { … } static void qmi_send_new_lookup(struct qmi_handle *qmi, struct qmi_service *svc) { … } /** * qmi_add_lookup() - register a new lookup with the name service * @qmi: qmi handle * @service: service id of the request * @instance: instance id of the request * @version: version number 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) { … } EXPORT_SYMBOL_GPL(…); static void qmi_send_new_server(struct qmi_handle *qmi, struct qmi_service *svc) { … } /** * 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) { … } EXPORT_SYMBOL_GPL(…); /** * 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) { … } EXPORT_SYMBOL_GPL(…); /** * 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) { … } EXPORT_SYMBOL_GPL(…); /** * qmi_txn_cancel() - cancel an ongoing transaction * @txn: transaction id */ void qmi_txn_cancel(struct qmi_txn *txn) { … } EXPORT_SYMBOL_GPL(…); /** * 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) { … } /** * 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) { … } static void qmi_handle_message(struct qmi_handle *qmi, struct sockaddr_qrtr *sq, const void *buf, size_t len) { … } static void qmi_data_ready_work(struct work_struct *work) { … } static void qmi_data_ready(struct sock *sk) { … } static struct socket *qmi_sock_create(struct qmi_handle *qmi, struct sockaddr_qrtr *sq) { … } /** * qmi_handle_init() - initialize a QMI client handle * @qmi: QMI handle to initialize * @recv_buf_size: maximum size of incoming message * @ops: reference to callbacks for QRTR notifications * @handlers: NULL-terminated list of QMI message handlers * * This initializes the QMI client handle to allow sending and receiving QMI * messages. As messages are received the appropriate handler will be invoked. * * Return: 0 on success, negative errno on failure. */ int qmi_handle_init(struct qmi_handle *qmi, size_t recv_buf_size, const struct qmi_ops *ops, const struct qmi_msg_handler *handlers) { … } EXPORT_SYMBOL_GPL(…); /** * qmi_handle_release() - release the QMI client handle * @qmi: QMI client handle * * This closes the underlying socket and stops any handling of QMI messages. */ void qmi_handle_release(struct qmi_handle *qmi) { … } EXPORT_SYMBOL_GPL(…); /** * qmi_send_message() - send a QMI message * @qmi: QMI client handle * @sq: destination sockaddr * @txn: transaction object to use for the message * @type: type of message to send * @msg_id: message id * @len: max length of the QMI message * @ei: QMI message description * @c_struct: object to be encoded * * This function encodes @c_struct using @ei into a message of type @type, * with @msg_id and @txn into a buffer of maximum size @len, and sends this to * @sq. * * Return: 0 on success, negative errno on failure. */ static ssize_t qmi_send_message(struct qmi_handle *qmi, struct sockaddr_qrtr *sq, struct qmi_txn *txn, int type, int msg_id, size_t len, const struct qmi_elem_info *ei, const void *c_struct) { … } /** * qmi_send_request() - send a request QMI message * @qmi: QMI client handle * @sq: destination sockaddr * @txn: transaction object to use for the message * @msg_id: message id * @len: max length of the QMI message * @ei: QMI message description * @c_struct: object to be encoded * * Return: 0 on success, negative errno on failure. */ ssize_t qmi_send_request(struct qmi_handle *qmi, struct sockaddr_qrtr *sq, struct qmi_txn *txn, int msg_id, size_t len, const struct qmi_elem_info *ei, const void *c_struct) { … } EXPORT_SYMBOL_GPL(…); /** * qmi_send_response() - send a response QMI message * @qmi: QMI client handle * @sq: destination sockaddr * @txn: transaction object to use for the message * @msg_id: message id * @len: max length of the QMI message * @ei: QMI message description * @c_struct: object to be encoded * * Return: 0 on success, negative errno on failure. */ ssize_t qmi_send_response(struct qmi_handle *qmi, struct sockaddr_qrtr *sq, struct qmi_txn *txn, int msg_id, size_t len, const struct qmi_elem_info *ei, const void *c_struct) { … } EXPORT_SYMBOL_GPL(…); /** * qmi_send_indication() - send an indication QMI message * @qmi: QMI client handle * @sq: destination sockaddr * @msg_id: message id * @len: max length of the QMI message * @ei: QMI message description * @c_struct: object to be encoded * * Return: 0 on success, negative errno on failure. */ ssize_t qmi_send_indication(struct qmi_handle *qmi, struct sockaddr_qrtr *sq, int msg_id, size_t len, const struct qmi_elem_info *ei, const void *c_struct) { … } EXPORT_SYMBOL_GPL(…);
Codebase Browser
linux