linux-imx

/*

 * Copyright (c) 2007-2014 Nicira, Inc.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of version 2 of the GNU General Public

 * License as published by the Free Software Foundation.

 *

 * This program is distributed in the hope that it will be useful, but

 * WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU

 * General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA

 * 02110-1301, USA

 */

​

#include <linux/uaccess.h>

#include <linux/netdevice.h>

#include <linux/etherdevice.h>

#include <linux/if_ether.h>

#include <linux/if_vlan.h>

#include <net/llc_pdu.h>

#include <linux/kernel.h>

#include <linux/jhash.h>

#include <linux/jiffies.h>

#include <linux/llc.h>

#include <linux/module.h>

#include <linux/in.h>

#include <linux/rcupdate.h>

#include <linux/cpumask.h>

#include <linux/if_arp.h>

#include <linux/ip.h>

#include <linux/ipv6.h>

#include <linux/mpls.h>

#include <linux/sctp.h>

#include <linux/smp.h>

#include <linux/tcp.h>

#include <linux/udp.h>

#include <linux/icmp.h>

#include <linux/icmpv6.h>

#include <linux/rculist.h>

#include <net/ip.h>

#include <net/ip_tunnels.h>

#include <net/ipv6.h>

#include <net/mpls.h>

#include <net/ndisc.h>

#include <net/nsh.h>

​

#include "conntrack.h"

#include "datapath.h"

#include "flow.h"

#include "flow_netlink.h"

#include "vport.h"

​

u64 ovs_flow_used_time(unsigned long flow_jiffies)

{

    struct timespec64 cur_ts;

    u64 cur_ms, idle_ms;

​

    ktime_get_ts64(&cur_ts);

    idle_ms = jiffies_to_msecs(jiffies - flow_jiffies);

    cur_ms = (u64)(u32)cur_ts.tv_sec * MSEC_PER_SEC +

         cur_ts.tv_nsec / NSEC_PER_MSEC;

​

    return cur_ms - idle_ms;

}

​

#define TCP_FLAGS_BE16(tp) (*(__be16 *)&tcp_flag_word(tp) & htons(0x0FFF))

​

void ovs_flow_stats_update(struct sw_flow *flow, __be16 tcp_flags,

               const struct sk_buff *skb)

{

    struct flow_stats *stats;

    unsigned int cpu = smp_processor_id();

    int len = skb->len + (skb_vlan_tag_present(skb) ? VLAN_HLEN : 0);

​

    stats = rcu_dereference(flow->stats[cpu]);

​

    /* Check if already have CPU-specific stats. */

    if (likely(stats)) {

        spin_lock(&stats->lock);

        /* Mark if we write on the pre-allocated stats. */

        if (cpu == 0 && unlikely(flow->stats_last_writer != cpu))

            flow->stats_last_writer = cpu;

    } else {

        stats = rcu_dereference(flow->stats[0]); /* Pre-allocated. */

        spin_lock(&stats->lock);

​

        /* If the current CPU is the only writer on the

         * pre-allocated stats keep using them.