from scapy.layers.l2 import Dot1Q
import abc
import six
from vpp_pg_interface import VppPGInterface
from vpp_interface import VppInterface
from vpp_papi import VppEnum
class L2_VTR_OP:
L2_DISABLED = 0
L2_PUSH_1 = 1
L2_PUSH_2 = 2
L2_POP_1 = 3
L2_POP_2 = 4
L2_TRANSLATE_1_1 = 5
L2_TRANSLATE_1_2 = 6
L2_TRANSLATE_2_1 = 7
L2_TRANSLATE_2_2 = 8
@six.add_metaclass(abc.ABCMeta)
class VppSubInterface(VppPGInterface):
@property
def parent(self):
"""Parent interface for this sub-interface"""
return self._parent
@property
def sub_id(self):
"""Sub-interface ID"""
return self._sub_id
@property
def tag1(self):
return self._tag1
@property
def tag2(self):
return self._tag2
@property
def vtr(self):
return self._vtr
def __init__(self, test, parent, sub_id):
VppInterface.__init__(self, test)
self._parent = parent
self._parent.add_sub_if(self
@media only all and (prefers-color-scheme: dark) {
.highlight .hll { background-color: #49483e }
.highlight .c { color: #75715e } /* Comment */
.highlight .err { color: #960050; background-color: #1e0010 } /* Error */
.highlight .k { color: #66d9ef } /* Keyword */
.highlight .l { color: #ae81ff } /* Literal */
.highlight .n { color: #f8f8f2 } /* Name */
.highlight .o { color: #f92672 } /* Operator */
.highlight .p { color: #f8f8f2 } /* Punctuation */
.highlight .ch { color: #75715e } /* Comment.Hashbang */
.highlight .cm { color: #75715e } /* Comment.Multiline */
.highlight .cp { color: #75715e } /* Comment.Preproc */
.highlight .cpf { color: #75715e } /* Comment.PreprocFile */
.highlight .c1 { color: #75715e } /* Comment.Single */
.highlight .cs { color: #75715e } /* Comment.Special */
.highlight .gd { color: #f92672 } /* Generic.Deleted */
.highlight .ge { font-style: italic } /* Generic.Emph */
.highlight .gi { color: #a6e22e } /* Generic.Inserted */
.highlight .gs { font-weight: bold } /* Generic.Strong */
.highlight .gu { color: #75715e } /* Generic.Subheading */
.highlight .kc { color: #66d9ef } /* Keyword.Constant */
.highlight .kd { color: #66d9ef } /* Keyword.Declaration */
.highlight .kn { color: #f92672 } /* Keyword.Namespace */
.highlight .kp { color: #66d9ef } /* Keyword.Pseudo */
.highlight .kr { color: #66d9ef } /* Keyword.Reserved */
.highlight .kt { color: #66d9ef } /* Keyword.Type */
.highlight .ld { color: #e6db74 } /* Literal.Date */
.highlight .m { color: #ae81ff } /* Literal.Number */
.highlight .s { color: #e6db74 } /* Literal.String */
.highlight .na { color: #a6e22e } /* Name.Attribute */
.highlight .nb { color: #f8f8f2 } /* Name.Builtin */
.highlight .nc { color: #a6e22e } /* Name.Class */
.highlight .no { color: #66d9ef } /* Name.Constant */
.highlight .nd { color: #a6e22e } /* Name.Decorator */
.highlight .ni { color: #f8f8f2 } /* Name.Entity */
.highlight .ne { color: #a6e22e } /* Name.Exception */
.highlight .nf { color: #a6e22e } /* Name.Function */
.highlight .nl { color: #f8f8f2 } /* Name.Label */
.highlight .nn { color: #f8f8f2 } /* Name.Namespace */
.highlight .nx { color: #a6e22e } /* Name.Other */
.highlight .py { color: #f8f8f2 } /* Name.Property */
.highlight .nt { color: #f92672 } /* Name.Tag */
.highlight .nv { color: #f8f8f2 } /* Name.Variable */
.highlight .ow { color: #f92672 } /* Operator.Word */
.highlight .w { color: #f8f8f2 } /* Text.Whitespace */
.highlight .mb { color: #ae81ff } /* Literal.Number.Bin */
.highlight .mf { color: #ae81ff } /* Literal.Number.Float */
.highlight .mh { color: #ae81ff } /* Literal.Number.Hex */
.highlight .mi { color: #ae81ff } /* Literal.Number.Integer */
.highlight .mo { color: #ae81ff } /* Literal.Number.Oct */
.highlight .sa { color: #e6db74 } /* Literal.String.Affix */
.highlight .sb { color: #e6db74 } /* Literal.String.Backtick */
.highlight .sc { color: #e6db74 } /* Literal.String.Char */
.highlight .dl { color: #e6db74 } /* Literal.String.Delimiter */
.highlight .sd { color: #e6db74 } /* Literal.String.Doc */
.highlight .s2 { color: #e6db74 } /* Literal.String.Double */
.highlight .se { color: #ae81ff } /* Literal.String.Escape */
.highlight .sh { color: #e6db74 } /* Literal.String.Heredoc */
.highlight .si { color: #e6db74 } /* Literal.String.Interpol */
.highlight .sx { color: #e6db74 } /* Literal.String.Other */
.highlight .sr { color: #e6db74 } /* Literal.String.Regex */
.highlight .s1 { color: #e6db74 } /* Literal.String.Single */
.highlight .ss { color: #e6db74 } /* Literal.String.Symbol */
.highlight .bp { color: #f8f8f2 } /* Name.Builtin.Pseudo */
.highlight .fm { color: #a6e22e } /* Name.Function.Magic */
.highlight .vc { color: #f8f8f2 } /* Name.Variable.Class */
.highlight .vg { color: #f8f8f2 } /* Name.Variable.Global */
.highlight .vi { color: #f8f8f2 } /* Name.Variable.Instance */
.highlight .vm { color: #f8f8f2 } /* Name.Variable.Magic */
.highlight .il { color: #ae81ff } /* Literal.Number.Integer.Long */
}
@media (prefers-color-scheme: light) {
.highlight .hll { background-color: #ffffcc }
.highlight .c { color: #888888 } /* Comment */
.highlight .err { color: #a61717; background-color: #e3d2d2 } /* Error */
.highlight .k { color: #008800; font-weight: bold } /* Keyword */
.highlight .ch { color: #888888 } /* Comment.Hashbang */
.highlight .cm { color: #888888 } /* Comment.Multiline */
.highlight .cp { color: #cc0000; font-weight: bold } /* Comment.Preproc */
.highlight .cpf { color: #888888 } /* Comment.PreprocFile */
.highlight .c1 { color: #888888 } /* Comment.Single */
.highlight .cs { color: #cc0000; font-weight: bold; background-color: #fff0f0 } /* Comment.Special */
.highlight .gd { color: #000000; background-color: #ffdddd } /* Generic.Deleted */
.highlight .ge { font-style: italic } /* Generic.Emph */
.highlight .gr { color: #aa0000 } /* Generic.Error */
.highlight .gh { color: #333333 } /* Generic.Heading */
.highlight .gi { color: #000000; background-color: #ddffdd } /* Generic.Inserted */
.highlight .go { color: #888888 } /* Generic.Output */
.highlight .gp { color: #555555 } /* Generic.Prompt */
.highlight .gs { font-weight: bold } /* Generic.Strong */
.highlight .gu { color: #666666 } /* Generic.Subheading */
.highlight .gt { color: #aa0000 } /* Generic.Traceback */
.highlight .kc { color: #008800; font-weight: bold } /* Keyword.Constant */
.highlight .kd { color: #008800; font-weight: bold } /* Keyword.Declaration */
.highlight .kn { color: #008800; font-weight: bold } /* Keyword.Namespace */
.highlight .kp { color: #008800 } /* Keyword.Pseudo */
.highlight .kr { color: #008800; font-weight: bold } /* Keyword.Reserved */
.highlight .kt { color: #888888; font-weight: bold } /* Keyword.Type */
.highlight .m { color: #0000DD; font-weight: bold } /* Literal.Number */
.highlight .s { color: #dd2200; background-color: #fff0f0 } /* Literal.String */
.highlight .na { color: #336699 } /* Name.Attribute */
.highlight .nb { color: #003388 } /* Name.Builtin */
.highlight .nc { color: #bb0066; font-weight: bold } /* Name.Class */
.highlight .no { color: #003366; font-weight: bold } /* Name.Constant */
.highlight .nd { color: #555555 } /* Name.Decorator */
.highlight .ne { color: #bb0066; font-weight: bold } /* Name.Exception */
.highlight .nf { color: #0066bb; font-weight: bold } /* Name.Function */
.highlight .nl { color: #336699; font-style: italic } /* Name.Label */
.highlight .nn { color: #bb0066; font-weight: bold } /* Name.Namespace */
.highlight .py { color: #336699; font-weight: bold } /* Name.Property */
.highlight .nt { color: #bb0066; font-weight: bold } /* Name.Tag */
.highlight .nv { color: #336699 } /* Name.Variable */
.highlight .ow { color: #008800 } /* Operator.Word */
.highlight .w { color: #bbbbbb } /* Text.Whitespace */
.highlight .mb { color: #0000DD; font-weight: bold } /* Literal.Number.Bin */
.highlight .mf { color: #0000DD; font-weight: bold } /* Literal.Number.Float */
.highlight .mh { color: #0000DD; font-weight: bold } /* Literal.Number.Hex */
.highlight .mi { color: #0000DD; font-weight: bold } /* Literal.Number.Integer */
.highlight .mo { color: #0000DD; font-weight: bold } /* Literal.Number.Oct */
.highlight .sa { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Affix */
.highlight .sb { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Backtick */
.highlight .sc { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Char */
.highlight .dl { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Delimiter */
.highlight .sd { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Doc */
.highlight .s2 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Double */
.highlight .se { color: #0044dd; background-color: #fff0f0 } /* Literal.String.Escape */
.highlight .sh { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Heredoc */
.highlight .si { color: #3333bb; background-color: #fff0f0 } /* Literal.String.Interpol */
.highlight .sx { color: #22bb22; background-color: #f0fff0 } /* Literal.String.Other */
.highlight .sr { color: #008800; background-color: #fff0ff } /* Literal.String.Regex */
.highlight .s1 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Single */
.highlight .ss { color: #aa6600; background-color: #fff0f0 } /* Literal.String.Symbol */
.highlight .bp { color: #003388 } /* Name.Builtin.Pseudo */
.highlight .fm { color: #0066bb; font-weight: bold } /* Name.Function.Magic */
.highlight .vc { color: #336699 } /* Name.Variable.Class */
.highlight .vg { color: #dd7700 } /* Name.Variable.Global */
.highlight .vi { color: #3333bb } /* Name.Variable.Instance */
.highlight .vm { color: #336699 } /* Name.Variable.Magic */
.highlight .il { color: #0000DD; font-weight: bold } /* Literal.Number.Integer.Long */
}
/*
* Copyright (c) 2016 Cisco and/or its affiliates.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/**
* lb-plugin implements a MagLev-like load balancer.
* http://research.google.com/pubs/pub44824.html
*
* It hasn't been tested for interoperability with the original MagLev
* but intends to provide similar functionality.
* The load-balancer receives traffic destined to VIP (Virtual IP)
* addresses from one or multiple(ECMP) routers.
* The load-balancer tunnels the traffic toward many application servers
* ensuring session stickyness (i.e. that a single sessions is tunneled
* towards a single application server).
*
*/
#ifndef LB_PLUGIN_LB_LB_H_
#define LB_PLUGIN_LB_LB_H_
#include <lb/util.h>
#include <vnet/util/refcount.h>
#include <vnet/vnet.h>
#include <vnet/ip/ip.h>
#include <vnet/dpo/dpo.h>
#include <vnet/fib/fib_table.h>
#include <vppinfra/hash.h>
#include <vppinfra/bihash_8_8.h>
#include <vppinfra/bihash_24_8.h>
#include <lb/lbhash.h>
#include <vppinfra/lock.h>
#define LB_DEFAULT_PER_CPU_STICKY_BUCKETS 1 << 10
#define LB_DEFAULT_FLOW_TIMEOUT 40
#define LB_MAPPING_BUCKETS 1024
#define LB_MAPPING_MEMORY_SIZE 64<<20
#define LB_VIP_PER_PORT_BUCKETS 1024
#define LB_VIP_PER_PORT_MEMORY_SIZE 64<<20
typedef enum {
LB_NEXT_DROP,
LB_N_NEXT,
} lb_next_t;
typedef enum {
LB_NAT4_IN2OUT_NEXT_DROP,
LB_NAT4_IN2OUT_NEXT_LOOKUP,
LB_NAT4_IN2OUT_N_NEXT,
} LB_nat4_in2out_next_t;
typedef enum {
LB_NAT6_IN2OUT_NEXT_DROP,
LB_NAT6_IN2OUT_NEXT_LOOKUP,
LB_NAT6_IN2OUT_N_NEXT,
} LB_nat6_in2out_next_t;
#define foreach_lb_nat_in2out_error \
_(UNSUPPORTED_PROTOCOL, "Unsupported protocol") \
_(IN2OUT_PACKETS, "Good in2out packets processed") \
_(NO_TRANSLATION, "No translation")
typedef enum {
#define _(sym,str) LB_NAT_IN2OUT_ERROR_##sym,
foreach_lb_nat_in2out_error
#undef _
LB_NAT_IN2OUT_N_ERROR,
} lb_nat_in2out_error_t;
/**
* lb for kube-proxy supports three types of service
*/
typedef enum {
LB_SRV_TYPE_CLUSTERIP,
LB_SRV_TYPE_NODEPORT,
LB_SRV_N_TYPES,
} lb_svr_type_t;
typedef enum {
LB4_NODEPORT_NEXT_IP4_NAT4,
LB4_NODEPORT_NEXT_DROP,
LB4_NODEPORT_N_NEXT,
} lb4_nodeport_next_t;
typedef enum {
LB6_NODEPORT_NEXT_IP6_NAT6,
LB6_NODEPORT_NEXT_DROP,
LB6_NODEPORT_N_NEXT,
} lb6_nodeport_next_t;
/**
* Each VIP is configured with a set of
* application server.
*/
typedef struct {
/**
* Registration to FIB event.
*/
fib_node_t fib_node;
/**
* Destination address used to tunnel traffic towards
* that application server.
* The address is also used as ID and pseudo-random
* seed for the load-balancing process.
*/
ip46_address_t address;
/**
* ASs are indexed by address and VIP Index.
* Which means there will be duplicated if the same server
* address is used for multiple VIPs.
*/
u32 vip_index;
/**
* Some per-AS flags.
* For now only LB_AS_FLAGS_USED is defined.
*/
u8 flags;
#define LB_AS_FLAGS_USED 0x1
/**
* Rotating timestamp of when LB_AS_FLAGS_USED flag was last set.
*
* AS removal is based on garbage collection and reference counting.
* When an AS is removed, there is a race between configuration core
* and worker cores which may still add a reference while it should not
* be used. This timestamp is used to not remove the AS while a race condition
* may happen.
*/
u32 last_used;
/**
* The FIB entry index for the next-hop
*/
fib_node_index_t next_hop_fib_entry_index;
/**
* The child index on the FIB entry
*/
u32 next_hop_child_index;
/**
* The next DPO in the graph to follow.
*/
dpo_id_t dpo;
} lb_as_t;
format_function_t format_lb_as;
typedef struct {
u32 as_index;
} lb_new_flow_entry_t;
#define lb_foreach_vip_counter \
_(NEXT_PACKET, "packet from existing sessions", 0) \
_(FIRST_PACKET, "first session packet", 1) \
_(UNTRACKED_PACKET, "untracked packet", 2) \
_(NO_SERVER, "no server configured", 3)
typedef enum {
#define _(a,b,c) LB_VIP_COUNTER_##a = c,
lb_foreach_vip_counter
#undef _
LB_N_VIP_COUNTERS
} lb_vip_counter_t;
typedef enum {
LB_ENCAP_TYPE_GRE4,
LB_ENCAP_TYPE_GRE6,
LB_ENCAP_TYPE_L3DSR,
LB_ENCAP_TYPE_NAT4,
LB_ENCAP_TYPE_NAT6,
LB_ENCAP_N_TYPES,
} lb_encap_type_t;
/**
* Lookup type
*/
typedef enum {
LB_LKP_SAME_IP_PORT,
LB_LKP_DIFF_IP_PORT,
LB_LKP_ALL_PORT_IP,
LB_LKP_N_TYPES,
} lb_lkp_type_t;
/**
* The load balancer supports IPv4 and IPv6 traffic
* and GRE4, GRE6, L3DSR and NAT4, NAT6 encap.
*/
typedef enum {
LB_VIP_TYPE_IP6_GRE6,
LB_VIP_TYPE_IP6_GRE4,
LB_VIP_TYPE_IP4_GRE6,
LB_VIP_TYPE_IP4_GRE4,
LB_VIP_TYPE_IP4_L3DSR,
LB_VIP_TYPE_IP4_NAT4,
LB_VIP_TYPE_IP6_NAT6,
LB_VIP_N_TYPES,
} lb_vip_type_t;
format_function_t format_lb_vip_type;
unformat_function_t unformat_lb_vip_type;
/* args for different vip encap types */
typedef struct {
union
{
struct
{
/* Service type. clusterip or nodeport */
u8 srv_type;
/* Pod's port corresponding to specific service. network byte order */
u16 target_port;
};
/* DSCP bits for L3DSR */
u8 dscp;
u64 as_u64;
};
} lb_vip_encap_args_t;
typedef struct {
/* all fields in NET byte order */
union {
struct {
u32 vip_prefix_index;
u16 port;
u8 protocol;
u8 rsv;
};
u64 as_u64;
};
} vip_port_key_t;
/**
* Load balancing service is provided per VIP+protocol+port.
* In this data model, a VIP can be a whole prefix.
* But load balancing only
* occurs on a per-source-address/port basis. Meaning that if a given source
* reuses the same port for multiple destinations within the same VIP,
* they will be considered as a single flow.
*/
typedef struct {
//Runtime
/**
* Vector mapping (flow-hash & new_connect_table_mask) to AS index.
* This is used for new flows.
*/
lb_new_flow_entry_t *new_flow_table;
/**
* New flows table length - 1
* (length MUST be a power of 2)
*/
u32 new_flow_table_mask;
/**
* Last time garbage collection was run to free the ASs.
*/
u32 last_garbage_collection;
//Not runtime
/**
* A Virtual IP represents a given service delivered
* by a set of application servers. It can be a single
* address or a prefix.
* IPv4 prefixes are encoded using IPv4-in-IPv6 embedded address
* (i.e. ::/96 prefix).
*/
ip46_address_t prefix;
/**
* The VIP prefix length.
* In case of IPv4, plen = 96 + ip4_plen.
*/
u8 plen;
/* tcp or udp. If not per-port vip, set to ~0 */
u8 protocol;
/* tcp port or udp port. If not per-port vip, set to ~0 */
u16 port;
/* Valid for per-port vip */
u32 vip_prefix_index;
/**
* The type of traffic for this.
* LB_TYPE_UNDEFINED if unknown.
*/
lb_vip_type_t type;
/* args for different vip encap types */
lb_vip_encap_args_t encap_args;
/**
* Flags related to this VIP.
* LB_VIP_FLAGS_USED means the VIP is active.
* When it is not set, the VIP in the process of being removed.
* We cannot immediately remove a VIP because the VIP index still may be stored
* in the adjacency index.
*/
u8 flags;
#define LB_VIP_FLAGS_USED 0x1
/**
* Pool of AS indexes used for this VIP.
* This also includes ASs that have been removed (but are still referenced).
*/
u32 *as_indexes;
} lb_vip_t;
#define lb_vip_is_ip4(type) (type == LB_VIP_TYPE_IP4_GRE6 \
|| type == LB_VIP_TYPE_IP4_GRE4 \
|| type == LB_VIP_TYPE_IP4_L3DSR \
|| type == LB_VIP_TYPE_IP4_NAT4 )
#define lb_vip_is_ip6(type) (type == LB_VIP_TYPE_IP6_GRE6 \
|| type == LB_VIP_TYPE_IP6_GRE4 \
|| type == LB_VIP_TYPE_IP6_NAT6 )
#define lb_encap_is_ip4(vip) ((vip)->type == LB_VIP_TYPE_IP6_GRE4 \
|| (vip)->type == LB_VIP_TYPE_IP4_GRE4 \
|| (vip)->type == LB_VIP_TYPE_IP4_L3DSR \
|| (vip)->type == LB_VIP_TYPE_IP4_NAT4 )
#define lb_vip_is_gre4(vip) (((vip)->type == LB_VIP_TYPE_IP6_GRE4 \
|| (vip)->type == LB_VIP_TYPE_IP4_GRE4) \
&& ((vip)->port == 0))
#define lb_vip_is_gre6(vip) (((vip)->type == LB_VIP_TYPE_IP6_GRE6 \
|| (vip)->type == LB_VIP_TYPE_IP4_GRE6) \
&& ((vip)->port == 0))
#define lb_vip_is_gre4_port(vip) (((vip)->type == LB_VIP_TYPE_IP6_GRE4 \
|| (vip)->type == LB_VIP_TYPE_IP4_GRE4) \
&& ((vip)->port != 0))
#define lb_vip_is_gre6_port(vip) (((vip)->type == LB_VIP_TYPE_IP6_GRE6 \
|| (vip)->type == LB_VIP_TYPE_IP4_GRE6) \
&& ((vip)->port != 0))
always_inline bool
lb_vip_is_l3dsr(const lb_vip_t *vip)
{
return (vip->type == LB_VIP_TYPE_IP4_L3DSR && vip->port ==0);
}
always_inline bool
lb_vip_is_l3dsr_port(const lb_vip_t *vip)
{
return (vip->type == LB_VIP_TYPE_IP4_L3DSR && vip->port !=0);
}
always_inline bool
lb_vip_is_nat4_port(const lb_vip_t *vip)
{
return (vip->type == LB_VIP_TYPE_IP4_NAT4 && vip->port !=0);
}
always_inline bool
lb_vip_is_nat6_port(const lb_vip_t *vip)
{
return (vip->type == LB_VIP_TYPE_IP6_NAT6 && vip->port !=0);
}
format_function_t format_lb_vip;
format_function_t format_lb_vip_detailed;
#define foreach_lb_nat_protocol \
_(UDP, 0, udp, "udp") \
_(TCP, 1, tcp, "tcp")
typedef enum {
#define _(N, i, n, s) LB_NAT_PROTOCOL_##N = i,
foreach_lb_nat_protocol
#undef _
} lb_nat_protocol_t;
always_inline u32
lb_ip_proto_to_nat_proto (u8 ip_proto)
{
u32 nat_proto = ~0;
nat_proto = (ip_proto == IP_PROTOCOL_UDP) ? LB_NAT_PROTOCOL_UDP : nat_proto;
nat_proto = (ip_proto == IP_PROTOCOL_TCP) ? LB_NAT_PROTOCOL_TCP : nat_proto;
return nat_proto;
}
/* Key for Pod's egress SNAT */
typedef struct {
union
{
struct
{
ip4_address_t addr;
u16 port;
u16 protocol:3,
fib_index:13;
};
u64 as_u64;
};
} lb_snat4_key_t;
typedef struct
{
union
{
struct
{
ip6_address_t addr;
u16 port;
u16 protocol;
u32 fib_index;
};
u64 as_u64[3];
};
} lb_snat6_key_t;
typedef struct {
/**
* for vip + port case, src_ip = vip;
* for node ip + node_port, src_ip = node_ip
*/
ip46_address_t src_ip;
ip46_address_t as_ip;
u8 src_ip_is_ipv6;
u8 as_ip_is_ipv6;
/**
* Network byte order
* for vip + port case, src_port = port;
* for node ip + node_port, src_port = node_port
*/
u16 src_port;
u16 target_port; /* Network byte order */
u32 vrf_id;
u32 fib_index;
} lb_snat_mapping_t;
typedef struct {
/**
* Each CPU has its own sticky flow hash table.
* One single table is used for all VIPs.
*/
lb_hash_t *sticky_ht;
} lb_per_cpu_t;
typedef struct {
/**
* Pool of all Virtual IPs
*/
lb_vip_t *vips;
/**
* bitmap for vip prefix to support per-port vip
*/
uword *vip_prefix_indexes;
/**
* Pool of ASs.
* ASs are referenced by address and vip index.
* The first element (index 0) is special and used only to fill
* new_flow_tables when no AS has been configured.
*/
lb_as_t *ass;
/**
* Each AS has an associated reference counter.
* As ass[0] has a special meaning, its associated counter
* starts at 0 and is decremented instead. i.e. do not use it.
*/
vlib_refcount_t as_refcount;
/* hash lookup vip_index by key: {u16: nodeport} */
uword * vip_index_by_nodeport;
/**
* Some global data is per-cpu
*/
lb_per_cpu_t *per_cpu;
/**
* Node next index for IP adjacencies, for each of the traffic types.
*/
u32 ip_lookup_next_index[LB_VIP_N_TYPES];
/**
* Source address used in IPv6 encapsulated traffic
*/
ip6_address_t ip6_src_address;
/**
* Source address used for IPv4 encapsulated traffic
*/
ip4_address_t ip4_src_address;
/**
* Number of buckets in the per-cpu sticky hash table.
*/
u32 per_cpu_sticky_buckets;
/**
* Flow timeout in seconds.
*/
u32 flow_timeout;
/**
* Per VIP counter
*/
vlib_simple_counter_main_t vip_counters[LB_N_VIP_COUNTERS];
/**
* DPO used to send packet from IP4/6 lookup to LB node.
*/
dpo_type_t dpo_gre4_type;
dpo_type_t dpo_gre6_type;
dpo_type_t dpo_gre4_port_type;
dpo_type_t dpo_gre6_port_type;
dpo_type_t dpo_l3dsr_type;
dpo_type_t dpo_l3dsr_port_type;
dpo_type_t dpo_nat4_port_type;
dpo_type_t dpo_nat6_port_type;
/**
* Node type for registering to fib changes.
*/
fib_node_type_t fib_node_type;
/* lookup per_port vip by key */
clib_bihash_8_8_t vip_index_per_port;
/* Find a static mapping by AS IP : target_port */
clib_bihash_8_8_t mapping_by_as4;
clib_bihash_24_8_t mapping_by_as6;
/* Static mapping pool */
lb_snat_mapping_t * snat_mappings;
/**
* API dynamically registered base ID.
*/
u16 msg_id_base;
clib_spinlock_t writer_lock;
/* convenience */
vlib_main_t *vlib_main;
vnet_main_t *vnet_main;
} lb_main_t;
/* args for different vip encap types */
typedef struct {
ip46_address_t prefix;
u8 plen;
u8 protocol;
u16 port;
lb_vip_type_t type;
u32 new_length;
lb_vip_encap_args_t encap_args;
} lb_vip_add_args_t;
extern lb_main_t lb_main;
extern vlib_node_registration_t lb4_node;
extern vlib_node_registration_t lb6_node;
extern vlib_node_registration_t lb4_nodeport_node;
extern vlib_node_registration_t lb6_nodeport_node;
extern vlib_node_registration_t lb_nat4_in2out_node;
extern vlib_node_registration_t lb_nat6_in2out_node;
/**
* Fix global load-balancer parameters.
* @param ip4_address IPv4 source address used for encapsulated traffic
* @param ip6_address IPv6 source address used for encapsulated traffic
* @return 0 on success. VNET_LB_ERR_XXX on error
*/
int lb_conf(ip4_address_t *ip4_address, ip6_address_t *ip6_address,
u32 sticky_buckets, u32 flow_timeout);
int lb_vip_add(lb_vip_add_args_t args, u32 *vip_index);
int lb_vip_del(u32 vip_index);
int lb_vip_find_index(ip46_address_t *prefix, u8 plen, u8 protocol,
u16 port, u32 *vip_index);
#define lb_vip_get_by_index(index) (pool_is_free_index(lb_main.vips, index)?NULL:pool_elt_at_index(lb_main.vips, index))
int lb_vip_add_ass(u32 vip_index, ip46_address_t *addresses, u32 n);
int lb_vip_del_ass(u32 vip_index, ip46_address_t *addresses, u32 n, u8 flush);
int lb_flush_vip_as (u32 vip_index, u32 as_index);
u32 lb_hash_time_now(vlib_main_t * vm);
void lb_garbage_collection();
int lb_nat4_interface_add_del (u32 sw_if_index, int is_del);
int lb_nat6_interface_add_del (u32 sw_if_index, int is_del);
format_function_t format_lb_main;
#endif /* LB_PLUGIN_LB_LB_H_ */