1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
|
/*
* Copyright (c) 2019 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.
*/
#include <vlib/vlib.h>
#include <netlink/route/link.h>
#include <netlink/route/route.h>
#include <netlink/route/neighbour.h>
#include <netlink/route/addr.h>
typedef void (*nl_rt_link_cb_t) (struct rtnl_link *rl, void *ctx);
typedef void (*nl_rt_link_sync_cb_t) (void);
typedef void (*nl_rt_addr_cb_t) (struct rtnl_addr *ra);
typedef void (*nl_rt_addr_sync_cb_t) (void);
typedef void (*nl_rt_neigh_cb_t) (struct rtnl_neigh *rr);
typedef void (*nl_rt_neigh_sync_cb_t) (void);
typedef void (*nl_rt_route_add_cb_t) (struct rtnl_route *rn, int is_replace);
typedef void (*nl_rt_route_del_cb_t) (struct rtnl_route *rn);
typedef void (*nl_rt_route_sync_cb_t) (void);
#define NL_RT_COMMON uword is_mp_safe
typedef struct nl_rt_link_t_
{
NL_RT_COMMON;
nl_rt_link_cb_t cb;
} nl_rt_link_t;
typedef struct nl_rt_link_sync_t_
{
NL_RT_COMMON;
nl_rt_link_sync_cb_t cb;
} nl_rt_link_sync_t;
typedef struct nl_rt_addr_t_
{
NL_RT_COMMON;
nl_rt_addr_cb_t cb;
} nl_rt_addr_t;
typedef struct nl_rt_addr_sync_t_
{
NL_RT_COMMON;
nl_rt_addr_sync_cb_t cb;
} nl_rt_addr_sync_t;
typedef struct nl_rt_neigh_t_
{
NL_RT_COMMON;
nl_rt_neigh_cb_t cb;
} nl_rt_neigh_t;
typedef struct nl_rt_neigh_sync_t_
{
NL_RT_COMMON;
nl_rt_neigh_sync_cb_t cb;
} nl_rt_neigh_sync_t;
typedef struct nl_rt_route_add_t_
{
NL_RT_COMMON;
nl_rt_route_add_cb_t cb;
} nl_rt_route_add_t;
typedef struct nl_rt_route_del_t_
{
NL_RT_COMMON;
nl_rt_route_del_cb_t cb;
} nl_rt_route_del_t;
typedef struct nl_rt_route_sync_t_
{
NL_RT_COMMON;
nl_rt_route_sync_cb_t cb;
} nl_rt_route_sync_t;
#undef NL_RT_COMMON
typedef struct nl_vft_t_
{
nl_rt_link_t nvl_rt_link_add;
nl_rt_link_t nvl_rt_link_del;
nl_rt_link_sync_t nvl_rt_link_sync_begin;
nl_rt_link_sync_t nvl_rt_link_sync_end;
nl_rt_addr_t nvl_rt_addr_add;
nl_rt_addr_t nvl_rt_addr_del;
nl_rt_addr_sync_t nvl_rt_addr_sync_begin;
nl_rt_addr_sync_t nvl_rt_addr_sync_end;
nl_rt_neigh_t nvl_rt_neigh_add;
nl_rt_neigh_t nvl_rt_neigh_del;
nl_rt_neigh_sync_t nvl_rt_neigh_sync_begin;
nl_rt_neigh_sync_t nvl_rt_neigh_sync_end;
nl_rt_route_add_t nvl_rt_route_add;
nl_rt_route_del_t nvl_rt_route_del;
nl_rt_route_sync_t nvl_rt_route_sync_begin;
nl_rt_route_sync_t nvl_rt_route_sync_end;
} nl_vft_t;
extern void nl_register_vft (const nl_vft_t *nv);
typedef enum lcp_nl_obj_t_
{
LCP_NL_LINK,
LCP_NL_ADDR,
LCP_NL_NEIGH,
LCP_NL_ROUTE,
} lcp_nl_obj_t;
/* struct type to hold context on the netlink message being processed.
*
* At creation of a pair, a tap/tun is created and configured to match its
* corresponding hardware interface (MAC address, link state, MTU). Netlink
* messages are sent announcing the creation and subsequent configuration.
* We do not need to (and should not) act on those messages since applying
* those same configurations again is unnecessary and can be disruptive. So
* a timestamp for a message is stored and can be compared against the time
* the interface came under linux-cp management in order to figure out
* whether we should apply any configuration.
*/
typedef struct nl_msg_info
{
struct nl_msg *msg;
f64 ts;
} nl_msg_info_t;
#define LCP_NL_N_OBJS (LCP_NL_ROUTE + 1)
extern struct nl_cache *lcp_nl_get_cache (lcp_nl_obj_t t);
extern int lcp_nl_drain_messages (void);
extern void lcp_nl_set_buffer_size (u32 buf_size);
extern void lcp_nl_set_batch_size (u32 batch_size);
extern void lcp_nl_set_batch_delay (u32 batch_delay_ms);
/*
* fd.io coding-style-patch-verification: ON
*
* Local Variables:
* eval: (c-set-style "gnu")
* End:
*/
|
