qca-nss-drv/nss_rmnet_rx.c

/*
 **************************************************************************
 * Copyright (c) 2019-2020, The Linux Foundation. All rights reserved.
 *
 * Permission to use, copy, modify, and/or distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 **************************************************************************
 */

/*
 * nss_rmnet_rx.c
 *	NSS rmnet receive handler APIs
 */

#include "nss_tx_rx_common.h"
#include "nss_rmnet_rx_stats.h"
#include <net/arp.h>

#define NSS_RMNET_RX_TX_TIMEOUT			3000 /* 3 Seconds */
#define NSS_RMNET_RX_GET_INDEX(if_num)	(if_num - NSS_DYNAMIC_IF_START)

/*
 * Spinlock to protect the global data structure rmnet handle.
 */
DEFINE_SPINLOCK(nss_rmnet_rx_lock);

extern int nss_ctl_redirect;

/*
 * Data structure that holds theinterface context.
 */
struct nss_rmnet_rx_handle *rmnet_rx_handle[NSS_MAX_DYNAMIC_INTERFACES];

/*
 * nss_rmnet_rx_verify_if_num()
 *	Verify if_num passed to us.
 */
bool nss_rmnet_rx_verify_if_num(uint32_t if_num)
{
	enum nss_dynamic_interface_type type = nss_dynamic_interface_get_type(nss_rmnet_rx_get_context(), if_num);

	return type == NSS_DYNAMIC_INTERFACE_TYPE_RMNET_RX_N2H
		|| type == NSS_DYNAMIC_INTERFACE_TYPE_RMNET_RX_H2N;
}

/*
 * nss_rmnet_rx_msg_handler()
 *	Handle msg responses from the FW on interfaces
 */
static void nss_rmnet_rx_msg_handler(struct nss_ctx_instance *nss_ctx,
					struct nss_cmn_msg *ncm,
					void *app_data)
{
	struct nss_rmnet_rx_msg *nvim = (struct nss_rmnet_rx_msg *)ncm;
	int32_t if_num;

	nss_rmnet_rx_msg_callback_t cb;
	struct nss_rmnet_rx_handle *handle = NULL;

	/*
	 * Sanity check the message type
	 */
	if (ncm->type > NSS_RMNET_RX_MAX_MSG_TYPES) {
		nss_warning("%px: message type out of range: %d", nss_ctx, ncm->type);
		return;
	}

	/*
	 * Messages value that are within the base class are handled by the base class.
	 */
	if (ncm->type < NSS_IF_MAX_MSG_TYPES) {
		return nss_if_msg_handler(nss_ctx, ncm, app_data);
	}

	if (!nss_rmnet_rx_verify_if_num(ncm->interface)) {
		nss_warning("%px: response for another interface: %d", nss_ctx, ncm->interface);
		return;
	}

	if_num = NSS_RMNET_RX_GET_INDEX(ncm->interface);

	spin_lock_bh(&nss_rmnet_rx_lock);
	if (!rmnet_rx_handle[if_num]) {
		spin_unlock_bh(&nss_rmnet_rx_lock);
		nss_warning("%px: rmnet_rx handle is NULL\n", nss_ctx);
		return;
	}

	handle = rmnet_rx_handle[if_num];
	spin_unlock_bh(&nss_rmnet_rx_lock);

	switch (nvim->cm.type) {
	case NSS_RMNET_RX_STATS_SYNC_MSG:
		nss_rmnet_rx_stats_sync(handle, &nvim->msg.stats, ncm->interface);
		break;
	}

	/*
	 * Log failures
	 */
	nss_core_log_msg_failures(nss_ctx, ncm);

	/*
	 * Update the callback and app_data for NOTIFY messages, IPv4 sends all notify messages
	 * to the same callback/app_data.
	 *
	 * TODO: RMNet driver does not provide a registration for a notifier callback.
	 * Since dynamic interface are allocated on both cores and since the array for
	 * registered callback is not core specific, we call the Wi-Fi callback
	 * inappropriately. Disable the callback locally until we have per-core
	 * callback registrations.
	 */
	if (ncm->response == NSS_CMN_RESPONSE_NOTIFY) {
		ncm->cb = (nss_ptr_t)NULL;
		ncm->app_data = (nss_ptr_t)nss_ctx->subsys_dp_register[ncm->interface].ndev;
	}

	/*
	 * Do we have a callback?
	 */
	if (!ncm->cb) {
		return;
	}

	/*
	 * Callback
	 */
	cb = (nss_rmnet_rx_msg_callback_t)ncm->cb;
	cb((void *)ncm->app_data, ncm);
}

/*
 * nss_rmnet_rx_callback
 *	Callback to handle the completion of NSS ->HLOS messages.
 */
static void nss_rmnet_rx_callback(void *app_data, struct nss_cmn_msg *ncm)
{
	struct nss_rmnet_rx_handle *handle = (struct nss_rmnet_rx_handle *)app_data;
	struct nss_rmnet_rx_pvt *nvip = handle->pvt;

	if (ncm->response != NSS_CMN_RESPONSE_ACK) {
		nss_warning("%px: rmnet_rx Error response %d\n", handle->nss_ctx, ncm->response);
		nvip->response = NSS_TX_FAILURE;
		complete(&nvip->complete);
		return;
	}

	nvip->response = NSS_TX_SUCCESS;
	complete(&nvip->complete);
}

/*
 * nss_rmnet_rx_tx_msg_sync
 *	Send a message from HLOS to NSS synchronously.
 */
static nss_tx_status_t nss_rmnet_rx_tx_msg_sync(struct nss_rmnet_rx_handle *handle,
						struct nss_rmnet_rx_msg *nvim)
{
	nss_tx_status_t status;
	int ret = 0;
	struct nss_rmnet_rx_pvt *nwip = handle->pvt;
	struct nss_ctx_instance *nss_ctx = handle->nss_ctx;

	down(&nwip->sem);

	status = nss_rmnet_rx_tx_msg(nss_ctx, nvim);
	if (status != NSS_TX_SUCCESS) {
		nss_warning("%px: nss_rmnet_rx_msg failed\n", nss_ctx);
		up(&nwip->sem);
		return status;
	}

	ret = wait_for_completion_timeout(&nwip->complete,
						msecs_to_jiffies(NSS_RMNET_RX_TX_TIMEOUT));
	if (!ret) {
		nss_warning("%px: rmnet_rx tx failed due to timeout\n", nss_ctx);
		nwip->response = NSS_TX_FAILURE;
	}

	status = nwip->response;
	up(&nwip->sem);

	return status;
}

/*
 * nss_rmnet_rx_msg_init()
 *	Initialize virt specific message structure.
 */
static void nss_rmnet_rx_msg_init(struct nss_rmnet_rx_msg *nvim,
					uint16_t if_num,
					uint32_t type,
					uint32_t len,
					nss_rmnet_rx_msg_callback_t cb,
					struct nss_rmnet_rx_handle *app_data)
{
	nss_cmn_msg_init(&nvim->cm, if_num, type, len, (void *)cb, (void *)app_data);
}

/*
 * nss_rmnet_rx_handle_destroy_sync()
 *	Destroy the virt handle either due to request from user or due to error, synchronously.
 */
static int nss_rmnet_rx_handle_destroy_sync(struct nss_rmnet_rx_handle *handle)
{
	nss_tx_status_t status;
	int32_t if_num_n2h = handle->if_num_n2h;
	int32_t if_num_h2n = handle->if_num_h2n;
	int32_t index_n2h;
	int32_t index_h2n;

	if (!nss_rmnet_rx_verify_if_num(if_num_n2h) || !nss_rmnet_rx_verify_if_num(if_num_h2n)) {
		nss_warning("%px: bad interface numbers %d %d\n", handle->nss_ctx, if_num_n2h, if_num_h2n);
		return NSS_TX_FAILURE_BAD_PARAM;
	}

	index_n2h = NSS_RMNET_RX_GET_INDEX(if_num_n2h);
	index_h2n = NSS_RMNET_RX_GET_INDEX(if_num_h2n);

	status = nss_dynamic_interface_dealloc_node(if_num_n2h, NSS_DYNAMIC_INTERFACE_TYPE_RMNET_RX_N2H);
	if (status != NSS_TX_SUCCESS) {
		nss_warning("%px: Dynamic interface destroy failed status %d\n", handle->nss_ctx, status);
		return status;
	}

	status = nss_dynamic_interface_dealloc_node(if_num_h2n, NSS_DYNAMIC_INTERFACE_TYPE_RMNET_RX_H2N);
	if (status != NSS_TX_SUCCESS) {
		nss_warning("%px: Dynamic interface destroy failed status %d\n", handle->nss_ctx, status);
		return status;
	}

	spin_lock_bh(&nss_rmnet_rx_lock);
	rmnet_rx_handle[index_n2h] = NULL;
	rmnet_rx_handle[index_h2n] = NULL;
	spin_unlock_bh(&nss_rmnet_rx_lock);

	kfree(handle->pvt);
	kfree(handle);

	return status;
}

/*
 * nss_rmnet_rx_handle_create_sync()
 *	Initialize virt handle which holds the if_num and stats per interface.
 */
static struct nss_rmnet_rx_handle *nss_rmnet_rx_handle_create_sync(struct nss_ctx_instance *nss_ctx, int32_t if_num_n2h, int32_t if_num_h2n, int32_t *cmd_rsp)
{
	int32_t index_n2h;
	int32_t index_h2n;
	struct nss_rmnet_rx_handle *handle;

	if (!nss_rmnet_rx_verify_if_num(if_num_n2h) || !nss_rmnet_rx_verify_if_num(if_num_h2n)) {
		nss_warning("%px: bad interface numbers %d %d\n", nss_ctx, if_num_n2h, if_num_h2n);
		return NULL;
	}

	index_n2h = NSS_RMNET_RX_GET_INDEX(if_num_n2h);
	index_h2n = NSS_RMNET_RX_GET_INDEX(if_num_h2n);

	handle = (struct nss_rmnet_rx_handle *)kzalloc(sizeof(struct nss_rmnet_rx_handle),
									GFP_KERNEL);
	if (!handle) {
		nss_warning("%px: handle memory alloc failed\n", nss_ctx);
		*cmd_rsp = NSS_RMNET_RX_ALLOC_FAILURE;
		goto error1;
	}

	handle->nss_ctx = nss_ctx;
	handle->if_num_n2h = if_num_n2h;
	handle->if_num_h2n = if_num_h2n;
	handle->pvt = (struct nss_rmnet_rx_pvt *)kzalloc(sizeof(struct nss_rmnet_rx_pvt),
								GFP_KERNEL);
	if (!handle->pvt) {
		nss_warning("%px: failure allocating memory for nss_rmnet_rx_pvt\n", nss_ctx);
		*cmd_rsp = NSS_RMNET_RX_ALLOC_FAILURE;
		goto error2;
	}

	handle->stats_n2h = (uint64_t *)kzalloc(sizeof(uint64_t) * NSS_RMNET_RX_STATS_MAX,
								GFP_KERNEL);
	if (!handle->stats_n2h) {
		nss_warning("%px: failure allocating memory for N2H stats\n", nss_ctx);
		*cmd_rsp = NSS_RMNET_RX_ALLOC_FAILURE;
		goto error3;
	}

	handle->stats_h2n = (uint64_t *)kzalloc(sizeof(uint64_t) * NSS_RMNET_RX_STATS_MAX,
								GFP_KERNEL);
	if (!handle->stats_h2n) {
		nss_warning("%px: failure allocating memory for H2N stats\n", nss_ctx);
		*cmd_rsp = NSS_RMNET_RX_ALLOC_FAILURE;
		goto error4;
	}

	handle->cb = NULL;
	handle->app_data = NULL;

	spin_lock_bh(&nss_rmnet_rx_lock);
	rmnet_rx_handle[index_n2h] = handle;
	rmnet_rx_handle[index_h2n] = handle;
	spin_unlock_bh(&nss_rmnet_rx_lock);

	*cmd_rsp = NSS_RMNET_RX_SUCCESS;

	return handle;

error4:
	kfree(handle->stats_n2h);
error3:
	kfree(handle->pvt);
error2:
	kfree(handle);
error1:
	return NULL;
}

/*
 * nss_rmnet_rx_register_handler_sync()
 *	register msg handler for interface and initialize semaphore and completion.
 */
static uint32_t nss_rmnet_rx_register_handler_sync(struct nss_ctx_instance *nss_ctx, struct nss_rmnet_rx_handle *handle)
{
	uint32_t ret;
	struct nss_rmnet_rx_pvt *nvip = NULL;
	int32_t if_num_n2h = handle->if_num_n2h;
	int32_t if_num_h2n = handle->if_num_h2n;

	ret = nss_core_register_handler(nss_ctx, if_num_n2h, nss_rmnet_rx_msg_handler, NULL);
	if (ret != NSS_CORE_STATUS_SUCCESS) {
		nss_warning("%px: Failed to register message handler for redir_n2h interface %d\n", nss_ctx, if_num_n2h);
		return NSS_RMNET_RX_REG_FAILURE;
	}

	ret = nss_core_register_handler(nss_ctx, if_num_h2n, nss_rmnet_rx_msg_handler, NULL);
	if (ret != NSS_CORE_STATUS_SUCCESS) {
		nss_core_unregister_handler(nss_ctx, if_num_n2h);
		nss_warning("%px: Failed to register message handler for redir_h2n interface %d\n", nss_ctx, if_num_h2n);
		return NSS_RMNET_RX_REG_FAILURE;
	}

	nvip = handle->pvt;
	if (!nvip->sem_init_done) {
		sema_init(&nvip->sem, 1);
		init_completion(&nvip->complete);
		nvip->sem_init_done = 1;
	}

	nss_rmnet_rx_stats_dentry_create();
	return NSS_RMNET_RX_SUCCESS;
}

/*
 * nss_rmnet_rx_destroy_sync()
 *	Destroy the virt interface associated with the interface number, synchronously.
 */
nss_tx_status_t nss_rmnet_rx_destroy_sync(struct nss_rmnet_rx_handle *handle)
{
	nss_tx_status_t status;
	struct net_device *dev;
	int32_t if_num_n2h;
	int32_t if_num_h2n;
	struct nss_ctx_instance *nss_ctx;
	uint32_t ret;

	if (!handle) {
		nss_warning("handle is NULL\n");
		return NSS_TX_FAILURE_BAD_PARAM;
	}

	if_num_n2h = handle->if_num_n2h;
	if_num_h2n = handle->if_num_h2n;
	nss_ctx = handle->nss_ctx;

	if (unlikely(nss_ctx->state != NSS_CORE_STATE_INITIALIZED)) {
		nss_warning("%px: Interface could not be destroyed as core not ready\n", nss_ctx);
		return NSS_TX_FAILURE_NOT_READY;
	}

	spin_lock_bh(&nss_top_main.lock);
	if (!nss_ctx->subsys_dp_register[if_num_n2h].ndev || !nss_ctx->subsys_dp_register[if_num_h2n].ndev) {
		spin_unlock_bh(&nss_top_main.lock);
		nss_warning("%px: Unregister virt interface %d %d: no context\n", nss_ctx, if_num_n2h, if_num_h2n);
		return NSS_TX_FAILURE_BAD_PARAM;
	}

	dev = nss_ctx->subsys_dp_register[if_num_n2h].ndev;
	nss_assert(dev == nss_ctx->subsys_dp_register[if_num_h2n].ndev);
	nss_core_unregister_subsys_dp(nss_ctx, if_num_n2h);
	nss_core_unregister_subsys_dp(nss_ctx, if_num_h2n);
	spin_unlock_bh(&nss_top_main.lock);
	dev_put(dev);

	status = nss_rmnet_rx_handle_destroy_sync(handle);
	if (status != NSS_TX_SUCCESS) {
		nss_warning("%px: handle destroy failed for if_num_n2h %d and if_num_h2n %d\n", nss_ctx, if_num_n2h, if_num_h2n);
		return NSS_TX_FAILURE;
	}

	ret = nss_core_unregister_handler(nss_ctx, if_num_n2h);
	if (ret != NSS_CORE_STATUS_SUCCESS) {
		nss_warning("%px: Not able to unregister handler for redir_n2h interface %d with NSS core\n", nss_ctx, if_num_n2h);
		return NSS_TX_FAILURE_BAD_PARAM;
	}

	ret = nss_core_unregister_handler(nss_ctx, if_num_h2n);
	if (ret != NSS_CORE_STATUS_SUCCESS) {
		nss_warning("%px: Not able to unregister handler for redir_h2n interface %d with NSS core\n", nss_ctx, if_num_h2n);
		return NSS_TX_FAILURE_BAD_PARAM;
	}

	return status;
}
EXPORT_SYMBOL(nss_rmnet_rx_destroy_sync);

/*
 * nss_rmnet_rx_create_sync_nexthop()
 *	Create redir_n2h and redir_h2n interfaces, synchronously and associate it with same netdev.
 */
struct nss_rmnet_rx_handle *nss_rmnet_rx_create_sync_nexthop(struct net_device *netdev, uint32_t nexthop_n2h, uint32_t nexthop_h2n)
{
	struct nss_ctx_instance *nss_ctx = nss_rmnet_rx_get_context();
	struct nss_rmnet_rx_msg nvim;
	struct nss_rmnet_rx_config_msg *nvcm;
	uint32_t ret;
	struct nss_rmnet_rx_handle *handle = NULL;
	int32_t if_num_n2h, if_num_h2n;

	if (unlikely(nss_ctx->state != NSS_CORE_STATE_INITIALIZED)) {
		nss_warning("%px: Interface could not be created as core not ready\n", nss_ctx);
		return NULL;
	}

	if_num_n2h = nss_dynamic_interface_alloc_node(NSS_DYNAMIC_INTERFACE_TYPE_RMNET_RX_N2H);
	if (if_num_n2h < 0) {
		nss_warning("%px: failure allocating redir_n2h\n", nss_ctx);
		return NULL;
	}

	if_num_h2n = nss_dynamic_interface_alloc_node(NSS_DYNAMIC_INTERFACE_TYPE_RMNET_RX_H2N);
	if (if_num_h2n < 0) {
		nss_warning("%px: failure allocating redir_h2n\n", nss_ctx);
		nss_dynamic_interface_dealloc_node(if_num_n2h, NSS_DYNAMIC_INTERFACE_TYPE_RMNET_RX_N2H);
		return NULL;
	}

	handle = nss_rmnet_rx_handle_create_sync(nss_ctx, if_num_n2h, if_num_h2n, &ret);
	if (!handle) {
		nss_warning("%px: rmnet_rx handle creation failed ret %d\n", nss_ctx, ret);
		nss_dynamic_interface_dealloc_node(if_num_n2h, NSS_DYNAMIC_INTERFACE_TYPE_RMNET_RX_N2H);
		nss_dynamic_interface_dealloc_node(if_num_h2n, NSS_DYNAMIC_INTERFACE_TYPE_RMNET_RX_H2N);
		return NULL;
	}

	/*
	 * Initializes the semaphore and also sets the msg handler for if_num.
	 */
	ret = nss_rmnet_rx_register_handler_sync(nss_ctx, handle);
	if (ret != NSS_RMNET_RX_SUCCESS) {
		nss_warning("%px: Registration handler failed reason: %d\n", nss_ctx, ret);
		goto error1;
	}

	nss_rmnet_rx_msg_init(&nvim, handle->if_num_n2h, NSS_RMNET_RX_TX_CONFIG_MSG,
				sizeof(struct nss_rmnet_rx_config_msg), nss_rmnet_rx_callback, handle);

	nvcm = &nvim.msg.if_config;
	nvcm->flags = 0;
	nvcm->sibling = if_num_h2n;
	nvcm->nexthop = nexthop_n2h;
	nvcm->no_channel = 0;

	ret = nss_rmnet_rx_tx_msg_sync(handle, &nvim);
	if (ret != NSS_TX_SUCCESS) {
		nss_warning("%px: nss_rmnet_rx_tx_msg_sync failed %u\n", nss_ctx, ret);
		goto error2;
	}

	nvim.cm.interface = if_num_h2n;
	nvcm->sibling = if_num_n2h;
	nvcm->nexthop = nexthop_h2n;
	nvcm->no_channel = NSS_RMNET_RX_CHANNEL_MAX;

	ret = nss_rmnet_rx_tx_msg_sync(handle, &nvim);
	if (ret != NSS_TX_SUCCESS) {
		nss_warning("%px: nss_rmnet_rx_tx_msg_sync failed %u\n", nss_ctx, ret);
		goto error2;
	}

	nss_core_register_subsys_dp(nss_ctx, (uint32_t)if_num_n2h, NULL, NULL, NULL, netdev, 0);
	nss_core_register_subsys_dp(nss_ctx, (uint32_t)if_num_h2n, NULL, NULL, NULL, netdev, 0);

	nss_core_set_subsys_dp_type(nss_ctx, netdev, if_num_n2h, NSS_RMNET_RX_DP_N2H);
	nss_core_set_subsys_dp_type(nss_ctx, netdev, if_num_h2n, NSS_RMNET_RX_DP_H2N);

	/*
	 * Hold a reference to the net_device
	 */
	dev_hold(netdev);

	/*
	 * The context returned is the handle interface # which contains all the info related to
	 * the interface if_num.
	 */

	return handle;

error2:
	nss_core_unregister_handler(nss_ctx, if_num_n2h);
	nss_core_unregister_handler(nss_ctx, if_num_h2n);

error1:
	nss_rmnet_rx_handle_destroy_sync(handle);
	return NULL;
}
EXPORT_SYMBOL(nss_rmnet_rx_create_sync_nexthop);

/*
 * nss_rmnet_rx_create()
 *	Create rmnet_n2h and rmnet_h2n interfaces with generic next hops and associate it with same netdev.
 *
 * When rmnet and eth_rx is running at the same core, we directly send packets to eth_rx node.
 * When they are running at different cores, the packets needs to arrive eth_rx through C2C.
 */
struct nss_rmnet_rx_handle *nss_rmnet_rx_create(struct net_device *netdev)
{
	uint32_t nexthop_n2h = NSS_N2H_INTERFACE;
	uint32_t nexthop_h2n = NSS_C2C_TX_INTERFACE;

	if (nss_top_main.rmnet_rx_handler_id == 0) {
		nexthop_h2n = NSS_ETH_RX_INTERFACE;
	}


	return nss_rmnet_rx_create_sync_nexthop(netdev, nexthop_n2h, nexthop_h2n);
}
EXPORT_SYMBOL(nss_rmnet_rx_create);

/*
 * nss_rmnet_rx_tx_buf()
 *	HLOS interface has received a packet which we redirect to the NSS, if appropriate to do so.
 */
nss_tx_status_t nss_rmnet_rx_tx_buf(struct nss_rmnet_rx_handle *handle,
						struct sk_buff *skb)
{
	int32_t if_num = handle->if_num_h2n;
	struct nss_ctx_instance *nss_ctx = handle->nss_ctx;
	int cpu = 0;

	if (unlikely(nss_ctl_redirect == 0)) {
		return NSS_TX_FAILURE_NOT_ENABLED;
	}

	if (unlikely(skb->vlan_tci)) {
		return NSS_TX_FAILURE_NOT_SUPPORTED;
	}

	if (!nss_rmnet_rx_verify_if_num(if_num)) {
		nss_warning("%px: bad interface number %d\n", nss_ctx, if_num);
		return NSS_TX_FAILURE_BAD_PARAM;
	}

	nss_trace("%px: RmnetRx packet, if_num:%d, skb:%px", nss_ctx, if_num, skb);

	/*
	 * Sanity check the SKB to ensure that it's suitable for us
	 */
	if (unlikely(skb->len <= ETH_HLEN)) {
		nss_warning("%px: Rmnet Rx packet: %px too short", nss_ctx, skb);
		return NSS_TX_FAILURE_TOO_SHORT;
	}

	/*
	 * set skb queue mapping
	 */
	cpu = get_cpu();
	put_cpu();
	skb_set_queue_mapping(skb, cpu);

	return nss_core_send_packet(nss_ctx, skb, if_num, H2N_BIT_FLAG_VIRTUAL_BUFFER);
}
EXPORT_SYMBOL(nss_rmnet_rx_tx_buf);

/*
 * nss_rmnet_rx_tx_msg()
 */
nss_tx_status_t nss_rmnet_rx_tx_msg(struct nss_ctx_instance *nss_ctx, struct nss_rmnet_rx_msg *nvim)
{
	struct nss_cmn_msg *ncm = &nvim->cm;

	/*
	 * Sanity check the message
	 */
	if (!nss_rmnet_rx_verify_if_num(ncm->interface)) {
		nss_warning("%px: tx request for another interface: %d", nss_ctx, ncm->interface);
		return NSS_TX_FAILURE;
	}

	if (ncm->type > NSS_RMNET_RX_MAX_MSG_TYPES) {
		nss_warning("%px: message type out of range: %d", nss_ctx, ncm->type);
		return NSS_TX_FAILURE;
	}

	return nss_core_send_cmd(nss_ctx, nvim, sizeof(*nvim), NSS_NBUF_PAYLOAD_SIZE);
}
EXPORT_SYMBOL(nss_rmnet_rx_tx_msg);

/*
 * nss_rmnet_rx_xmit_callback_unregister()
 *	Unregister interface xmit callback.
 */
void nss_rmnet_rx_xmit_callback_unregister(struct nss_rmnet_rx_handle *handle)
{
	struct nss_ctx_instance *nss_ctx;
	struct nss_subsystem_dataplane_register *reg;

	if (!handle) {
		nss_warning("handle is NULL\n");
		return;
	}

	nss_ctx = handle->nss_ctx;
	NSS_VERIFY_CTX_MAGIC(nss_ctx);

	if (!nss_rmnet_rx_verify_if_num(handle->if_num_n2h)) {
		nss_warning("if_num is invalid\n");
		return;
	}

	reg = &nss_ctx->subsys_dp_register[handle->if_num_n2h];
	reg->xmit_cb = NULL;
}
EXPORT_SYMBOL(nss_rmnet_rx_xmit_callback_unregister);

/*
 * nss_rmnet_rx_xmit_callback_register()
 *	Register interface xmit callback.
 */
void nss_rmnet_rx_xmit_callback_register(struct nss_rmnet_rx_handle *handle,
				nss_rmnet_rx_xmit_callback_t cb)
{
	struct nss_ctx_instance *nss_ctx;
	struct nss_subsystem_dataplane_register *reg;

	if (!handle) {
		nss_warning("handle is NULL\n");
		return;
	}

	nss_ctx = handle->nss_ctx;
	NSS_VERIFY_CTX_MAGIC(nss_ctx);

	if (!nss_rmnet_rx_verify_if_num(handle->if_num_n2h)) {
		nss_warning("if_num is invalid\n");
		return;
	}

	reg = &nss_ctx->subsys_dp_register[handle->if_num_n2h];
	reg->xmit_cb = cb;
}
EXPORT_SYMBOL(nss_rmnet_rx_xmit_callback_register);

/*
 * nss_rmnet_rx_unregister()
 */
void nss_rmnet_rx_unregister(struct nss_rmnet_rx_handle *handle)
{
	struct nss_ctx_instance *nss_ctx;
	int32_t if_num;

	if (!handle) {
		nss_warning("handle is NULL\n");
		return;
	}

	nss_ctx = handle->nss_ctx;
	NSS_VERIFY_CTX_MAGIC(nss_ctx);

	if (!nss_rmnet_rx_verify_if_num(handle->if_num_n2h)) {
		nss_warning("if_num is invalid\n");
		return;
	}

	if_num = handle->if_num_n2h;

	nss_core_unregister_subsys_dp(nss_ctx, if_num);
}
EXPORT_SYMBOL(nss_rmnet_rx_unregister);

/*
 * nss_rmnet_rx_register()
 */
void nss_rmnet_rx_register(struct nss_rmnet_rx_handle *handle,
				nss_rmnet_rx_data_callback_t data_callback,
				struct net_device *netdev)
{
	struct nss_ctx_instance *nss_ctx;
	int32_t if_num;

	if (!handle) {
		nss_warning("handle is NULL\n");
		return;
	}

	nss_ctx = handle->nss_ctx;
	NSS_VERIFY_CTX_MAGIC(nss_ctx);

	if (!nss_rmnet_rx_verify_if_num(handle->if_num_n2h)) {
		nss_warning("if_num is invalid\n");
		return;
	}

	if_num = handle->if_num_n2h;

	nss_core_register_subsys_dp(nss_ctx, if_num, data_callback, NULL, NULL, netdev, (uint32_t)netdev->features);
}
EXPORT_SYMBOL(nss_rmnet_rx_register);

/*
 * nss_rmnet_rx_get_ifnum_with_core_id()
 *	Append core id to rmnet interface number
 */
int32_t nss_rmnet_rx_get_ifnum_with_core_id(int32_t if_num)
{
	struct nss_ctx_instance *nss_ctx = nss_rmnet_rx_get_context();

	NSS_VERIFY_CTX_MAGIC(nss_ctx);
	if (nss_rmnet_rx_verify_if_num(if_num) == false) {
		nss_info("%px: if_num: %u is not RMNET interface\n", nss_ctx, if_num);
		return -1;
	}
	return NSS_INTERFACE_NUM_APPEND_COREID(nss_ctx, if_num);
}
EXPORT_SYMBOL(nss_rmnet_rx_get_ifnum_with_core_id);

/*
 * nss_rmnet_rx_get_ifnum()
 *	Return rmnet interface number with core ID
 */
int32_t nss_rmnet_rx_get_ifnum(struct net_device *dev)
{
	int32_t ifnum = nss_cmn_get_interface_number_by_dev(dev);
	return nss_rmnet_rx_get_ifnum_with_core_id(ifnum);
}
EXPORT_SYMBOL(nss_rmnet_rx_get_ifnum);

/*
 * nss_rmnet_rx_get_interface_num()
 *	Get interface number for an interface
 */
int32_t nss_rmnet_rx_get_interface_num(struct nss_rmnet_rx_handle *handle)
{
	if (!handle) {
		nss_warning("rmnet_rx handle is NULL\n");
		return -1;
	}

	/*
	 * Return if_num_n2h whose datapath type is 0.
	 */
	return handle->if_num_n2h;
}
EXPORT_SYMBOL(nss_rmnet_rx_get_interface_num);

/*
 * nss_rmnet_rx_get_context()
 */
struct nss_ctx_instance *nss_rmnet_rx_get_context(void)
{
	return &nss_top_main.nss[nss_top_main.rmnet_rx_handler_id];
}
EXPORT_SYMBOL(nss_rmnet_rx_get_context);