forked from Minki/linux
abfcdc1de9
Previously there was no way of updating flow rule stats after they have been offloaded to hardware. This is solved by keeping track of stats received from hardware and providing this to the TC handler on request. Signed-off-by: Pieter Jansen van Vuuren <pieter.jansenvanvuuren@netronome.com> Signed-off-by: Simon Horman <simon.horman@netronome.com> Signed-off-by: David S. Miller <davem@davemloft.net>
154 lines
4.1 KiB
C
154 lines
4.1 KiB
C
/*
|
|
* Copyright (C) 2015-2017 Netronome Systems, Inc.
|
|
*
|
|
* This software is dual licensed under the GNU General License Version 2,
|
|
* June 1991 as shown in the file COPYING in the top-level directory of this
|
|
* source tree or the BSD 2-Clause License provided below. You have the
|
|
* option to license this software under the complete terms of either license.
|
|
*
|
|
* The BSD 2-Clause License:
|
|
*
|
|
* Redistribution and use in source and binary forms, with or
|
|
* without modification, are permitted provided that the following
|
|
* conditions are met:
|
|
*
|
|
* 1. Redistributions of source code must retain the above
|
|
* copyright notice, this list of conditions and the following
|
|
* disclaimer.
|
|
*
|
|
* 2. Redistributions in binary form must reproduce the above
|
|
* copyright notice, this list of conditions and the following
|
|
* disclaimer in the documentation and/or other materials
|
|
* provided with the distribution.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
|
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
|
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
|
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
|
|
* BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
|
|
* ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
|
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
* SOFTWARE.
|
|
*/
|
|
|
|
#include <linux/bitfield.h>
|
|
#include <linux/netdevice.h>
|
|
#include <linux/skbuff.h>
|
|
#include <net/dst_metadata.h>
|
|
|
|
#include "../nfpcore/nfp_cpp.h"
|
|
#include "../nfp_net_repr.h"
|
|
#include "./cmsg.h"
|
|
|
|
#define nfp_flower_cmsg_warn(app, fmt, args...) \
|
|
do { \
|
|
if (net_ratelimit()) \
|
|
nfp_warn((app)->cpp, fmt, ## args); \
|
|
} while (0)
|
|
|
|
static struct nfp_flower_cmsg_hdr *
|
|
nfp_flower_cmsg_get_hdr(struct sk_buff *skb)
|
|
{
|
|
return (struct nfp_flower_cmsg_hdr *)skb->data;
|
|
}
|
|
|
|
static struct sk_buff *
|
|
nfp_flower_cmsg_alloc(struct nfp_app *app, unsigned int size,
|
|
enum nfp_flower_cmsg_type_port type)
|
|
{
|
|
struct nfp_flower_cmsg_hdr *ch;
|
|
struct sk_buff *skb;
|
|
|
|
size += NFP_FLOWER_CMSG_HLEN;
|
|
|
|
skb = nfp_app_ctrl_msg_alloc(app, size, GFP_KERNEL);
|
|
if (!skb)
|
|
return NULL;
|
|
|
|
ch = nfp_flower_cmsg_get_hdr(skb);
|
|
ch->pad = 0;
|
|
ch->version = NFP_FLOWER_CMSG_VER1;
|
|
ch->type = type;
|
|
skb_put(skb, size);
|
|
|
|
return skb;
|
|
}
|
|
|
|
int nfp_flower_cmsg_portmod(struct nfp_repr *repr, bool carrier_ok)
|
|
{
|
|
struct nfp_flower_cmsg_portmod *msg;
|
|
struct sk_buff *skb;
|
|
|
|
skb = nfp_flower_cmsg_alloc(repr->app, sizeof(*msg),
|
|
NFP_FLOWER_CMSG_TYPE_PORT_MOD);
|
|
if (!skb)
|
|
return -ENOMEM;
|
|
|
|
msg = nfp_flower_cmsg_get_data(skb);
|
|
msg->portnum = cpu_to_be32(repr->dst->u.port_info.port_id);
|
|
msg->reserved = 0;
|
|
msg->info = carrier_ok;
|
|
msg->mtu = cpu_to_be16(repr->netdev->mtu);
|
|
|
|
nfp_ctrl_tx(repr->app->ctrl, skb);
|
|
|
|
return 0;
|
|
}
|
|
|
|
static void
|
|
nfp_flower_cmsg_portmod_rx(struct nfp_app *app, struct sk_buff *skb)
|
|
{
|
|
struct nfp_flower_cmsg_portmod *msg;
|
|
struct net_device *netdev;
|
|
bool link;
|
|
|
|
msg = nfp_flower_cmsg_get_data(skb);
|
|
link = msg->info & NFP_FLOWER_CMSG_PORTMOD_INFO_LINK;
|
|
|
|
rcu_read_lock();
|
|
netdev = nfp_app_repr_get(app, be32_to_cpu(msg->portnum));
|
|
if (!netdev) {
|
|
nfp_flower_cmsg_warn(app, "ctrl msg for unknown port 0x%08x\n",
|
|
be32_to_cpu(msg->portnum));
|
|
rcu_read_unlock();
|
|
return;
|
|
}
|
|
|
|
if (link) {
|
|
netif_carrier_on(netdev);
|
|
rtnl_lock();
|
|
dev_set_mtu(netdev, be16_to_cpu(msg->mtu));
|
|
rtnl_unlock();
|
|
} else {
|
|
netif_carrier_off(netdev);
|
|
}
|
|
rcu_read_unlock();
|
|
}
|
|
|
|
void nfp_flower_cmsg_rx(struct nfp_app *app, struct sk_buff *skb)
|
|
{
|
|
struct nfp_flower_cmsg_hdr *cmsg_hdr;
|
|
enum nfp_flower_cmsg_type_port type;
|
|
|
|
cmsg_hdr = nfp_flower_cmsg_get_hdr(skb);
|
|
|
|
if (unlikely(cmsg_hdr->version != NFP_FLOWER_CMSG_VER1)) {
|
|
nfp_flower_cmsg_warn(app, "Cannot handle repr control version %u\n",
|
|
cmsg_hdr->version);
|
|
goto out;
|
|
}
|
|
|
|
type = cmsg_hdr->type;
|
|
switch (type) {
|
|
case NFP_FLOWER_CMSG_TYPE_PORT_MOD:
|
|
nfp_flower_cmsg_portmod_rx(app, skb);
|
|
break;
|
|
default:
|
|
nfp_flower_cmsg_warn(app, "Cannot handle invalid repr control type %u\n",
|
|
type);
|
|
}
|
|
|
|
out:
|
|
dev_kfree_skb_any(skb);
|
|
}
|