^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 1) /* SPDX-License-Identifier: GPL-2.0-only */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 2) /*
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 3) * Copyright (c) 2007-2014 Nicira, Inc.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 4) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 5)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 6) #ifndef DATAPATH_H
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 7) #define DATAPATH_H 1
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 8)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 9) #include <asm/page.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 10) #include <linux/kernel.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 11) #include <linux/mutex.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 12) #include <linux/netdevice.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 13) #include <linux/skbuff.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 14) #include <linux/u64_stats_sync.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 15) #include <net/ip_tunnels.h>
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 16)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 17) #include "conntrack.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 18) #include "flow.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 19) #include "flow_table.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 20) #include "meter.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 21) #include "vport-internal_dev.h"
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 22)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 23) #define DP_MAX_PORTS USHRT_MAX
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 24) #define DP_VPORT_HASH_BUCKETS 1024
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 25) #define DP_MASKS_REBALANCE_INTERVAL 4000
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 26)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 27) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 28) * struct dp_stats_percpu - per-cpu packet processing statistics for a given
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 29) * datapath.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 30) * @n_hit: Number of received packets for which a matching flow was found in
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 31) * the flow table.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 32) * @n_miss: Number of received packets that had no matching flow in the flow
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 33) * table. The sum of @n_hit and @n_miss is the number of packets that have
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 34) * been received by the datapath.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 35) * @n_lost: Number of received packets that had no matching flow in the flow
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 36) * table that could not be sent to userspace (normally due to an overflow in
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 37) * one of the datapath's queues).
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 38) * @n_mask_hit: Number of masks looked up for flow match.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 39) * @n_mask_hit / (@n_hit + @n_missed) will be the average masks looked
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 40) * up per packet.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 41) * @n_cache_hit: The number of received packets that had their mask found using
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 42) * the mask cache.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 43) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 44) struct dp_stats_percpu {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 45) u64 n_hit;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 46) u64 n_missed;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 47) u64 n_lost;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 48) u64 n_mask_hit;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 49) u64 n_cache_hit;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 50) struct u64_stats_sync syncp;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 51) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 52)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 53) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 54) * struct datapath - datapath for flow-based packet switching
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 55) * @rcu: RCU callback head for deferred destruction.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 56) * @list_node: Element in global 'dps' list.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 57) * @table: flow table.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 58) * @ports: Hash table for ports. %OVSP_LOCAL port always exists. Protected by
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 59) * ovs_mutex and RCU.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 60) * @stats_percpu: Per-CPU datapath statistics.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 61) * @net: Reference to net namespace.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 62) * @max_headroom: the maximum headroom of all vports in this datapath; it will
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 63) * be used by all the internal vports in this dp.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 64) *
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 65) * Context: See the comment on locking at the top of datapath.c for additional
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 66) * locking information.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 67) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 68) struct datapath {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 69) struct rcu_head rcu;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 70) struct list_head list_node;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 71)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 72) /* Flow table. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 73) struct flow_table table;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 74)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 75) /* Switch ports. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 76) struct hlist_head *ports;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 77)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 78) /* Stats. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 79) struct dp_stats_percpu __percpu *stats_percpu;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 80)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 81) /* Network namespace ref. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 82) possible_net_t net;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 83)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 84) u32 user_features;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 85)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 86) u32 max_headroom;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 87)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 88) /* Switch meters. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 89) struct dp_meter_table meter_tbl;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 90) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 91)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 92) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 93) * struct ovs_skb_cb - OVS data in skb CB
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 94) * @input_vport: The original vport packet came in on. This value is cached
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 95) * when a packet is received by OVS.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 96) * @mru: The maximum received fragement size; 0 if the packet is not
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 97) * fragmented.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 98) * @acts_origlen: The netlink size of the flow actions applied to this skb.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 99) * @cutlen: The number of bytes from the packet end to be removed.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 100) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 101) struct ovs_skb_cb {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 102) struct vport *input_vport;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 103) u16 mru;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 104) u16 acts_origlen;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 105) u32 cutlen;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 106) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 107) #define OVS_CB(skb) ((struct ovs_skb_cb *)(skb)->cb)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 108)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 109) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 110) * struct dp_upcall - metadata to include with a packet to send to userspace
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 111) * @cmd: One of %OVS_PACKET_CMD_*.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 112) * @userdata: If nonnull, its variable-length value is passed to userspace as
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 113) * %OVS_PACKET_ATTR_USERDATA.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 114) * @portid: Netlink portid to which packet should be sent. If @portid is 0
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 115) * then no packet is sent and the packet is accounted in the datapath's @n_lost
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 116) * counter.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 117) * @egress_tun_info: If nonnull, becomes %OVS_PACKET_ATTR_EGRESS_TUN_KEY.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 118) * @mru: If not zero, Maximum received IP fragment size.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 119) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 120) struct dp_upcall_info {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 121) struct ip_tunnel_info *egress_tun_info;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 122) const struct nlattr *userdata;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 123) const struct nlattr *actions;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 124) int actions_len;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 125) u32 portid;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 126) u8 cmd;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 127) u16 mru;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 128) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 129)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 130) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 131) * struct ovs_net - Per net-namespace data for ovs.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 132) * @dps: List of datapaths to enable dumping them all out.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 133) * Protected by genl_mutex.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 134) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 135) struct ovs_net {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 136) struct list_head dps;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 137) struct work_struct dp_notify_work;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 138) struct delayed_work masks_rebalance;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 139) #if IS_ENABLED(CONFIG_NETFILTER_CONNCOUNT)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 140) struct ovs_ct_limit_info *ct_limit_info;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 141) #endif
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 142)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 143) /* Module reference for configuring conntrack. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 144) bool xt_label;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 145) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 146)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 147) /**
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 148) * enum ovs_pkt_hash_types - hash info to include with a packet
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 149) * to send to userspace.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 150) * @OVS_PACKET_HASH_SW_BIT: indicates hash was computed in software stack.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 151) * @OVS_PACKET_HASH_L4_BIT: indicates hash is a canonical 4-tuple hash
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 152) * over transport ports.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 153) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 154) enum ovs_pkt_hash_types {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 155) OVS_PACKET_HASH_SW_BIT = (1ULL << 32),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 156) OVS_PACKET_HASH_L4_BIT = (1ULL << 33),
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 157) };
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 158)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 159) extern unsigned int ovs_net_id;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 160) void ovs_lock(void);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 161) void ovs_unlock(void);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 162)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 163) #ifdef CONFIG_LOCKDEP
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 164) int lockdep_ovsl_is_held(void);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 165) #else
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 166) #define lockdep_ovsl_is_held() 1
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 167) #endif
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 168)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 169) #define ASSERT_OVSL() WARN_ON(!lockdep_ovsl_is_held())
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 170) #define ovsl_dereference(p) \
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 171) rcu_dereference_protected(p, lockdep_ovsl_is_held())
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 172) #define rcu_dereference_ovsl(p) \
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 173) rcu_dereference_check(p, lockdep_ovsl_is_held())
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 174)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 175) static inline struct net *ovs_dp_get_net(const struct datapath *dp)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 176) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 177) return read_pnet(&dp->net);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 178) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 179)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 180) static inline void ovs_dp_set_net(struct datapath *dp, struct net *net)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 181) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 182) write_pnet(&dp->net, net);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 183) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 184)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 185) struct vport *ovs_lookup_vport(const struct datapath *dp, u16 port_no);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 186)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 187) static inline struct vport *ovs_vport_rcu(const struct datapath *dp, int port_no)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 188) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 189) WARN_ON_ONCE(!rcu_read_lock_held());
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 190) return ovs_lookup_vport(dp, port_no);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 191) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 192)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 193) static inline struct vport *ovs_vport_ovsl_rcu(const struct datapath *dp, int port_no)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 194) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 195) WARN_ON_ONCE(!rcu_read_lock_held() && !lockdep_ovsl_is_held());
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 196) return ovs_lookup_vport(dp, port_no);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 197) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 198)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 199) static inline struct vport *ovs_vport_ovsl(const struct datapath *dp, int port_no)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 200) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 201) ASSERT_OVSL();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 202) return ovs_lookup_vport(dp, port_no);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 203) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 204)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 205) /* Must be called with rcu_read_lock. */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 206) static inline struct datapath *get_dp_rcu(struct net *net, int dp_ifindex)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 207) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 208) struct net_device *dev = dev_get_by_index_rcu(net, dp_ifindex);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 209)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 210) if (dev) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 211) struct vport *vport = ovs_internal_dev_get_vport(dev);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 212)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 213) if (vport)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 214) return vport->dp;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 215) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 216)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 217) return NULL;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 218) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 219)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 220) /* The caller must hold either ovs_mutex or rcu_read_lock to keep the
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 221) * returned dp pointer valid.
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 222) */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 223) static inline struct datapath *get_dp(struct net *net, int dp_ifindex)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 224) {
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 225) struct datapath *dp;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 226)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 227) WARN_ON_ONCE(!rcu_read_lock_held() && !lockdep_ovsl_is_held());
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 228) rcu_read_lock();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 229) dp = get_dp_rcu(net, dp_ifindex);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 230) rcu_read_unlock();
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 231)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 232) return dp;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 233) }
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 234)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 235) extern struct notifier_block ovs_dp_device_notifier;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 236) extern struct genl_family dp_vport_genl_family;
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 237)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 238) DECLARE_STATIC_KEY_FALSE(tc_recirc_sharing_support);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 239)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 240) void ovs_dp_process_packet(struct sk_buff *skb, struct sw_flow_key *key);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 241) void ovs_dp_detach_port(struct vport *);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 242) int ovs_dp_upcall(struct datapath *, struct sk_buff *,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 243) const struct sw_flow_key *, const struct dp_upcall_info *,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 244) uint32_t cutlen);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 245)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 246) const char *ovs_dp_name(const struct datapath *dp);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 247) struct sk_buff *ovs_vport_cmd_build_info(struct vport *vport, struct net *net,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 248) u32 portid, u32 seq, u8 cmd);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 249)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 250) int ovs_execute_actions(struct datapath *dp, struct sk_buff *skb,
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 251) const struct sw_flow_actions *, struct sw_flow_key *);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 252)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 253) void ovs_dp_notify_wq(struct work_struct *work);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 254)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 255) int action_fifos_init(void);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 256) void action_fifos_exit(void);
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 257)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 258) /* 'KEY' must not have any bits set outside of the 'MASK' */
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 259) #define OVS_MASKED(OLD, KEY, MASK) ((KEY) | ((OLD) & ~(MASK)))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 260) #define OVS_SET_MASKED(OLD, KEY, MASK) ((OLD) = OVS_MASKED(OLD, KEY, MASK))
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 261)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 262) #define OVS_NLERR(logging_allowed, fmt, ...) \
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 263) do { \
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 264) if (logging_allowed && net_ratelimit()) \
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 265) pr_info("netlink: " fmt "\n", ##__VA_ARGS__); \
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 266) } while (0)
^8f3ce5b39 (kx 2023-10-28 12:00:06 +0300 267) #endif /* datapath.h */
Orange Pi5 kernel
Deprecated Linux kernel 5.10.110 for OrangePi 5/5B/5+ boards
3 Commits
0 Branches
0 Tags