2 * Copyright (c) 2020 Doc.ai and/or its affiliates.
3 * Copyright (c) 2020 Cisco and/or its affiliates.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at:
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
17 #include <vnet/adj/adj_midchain.h>
18 #include <vnet/fib/fib_table.h>
19 #include <wireguard/wireguard_peer.h>
20 #include <wireguard/wireguard_if.h>
21 #include <wireguard/wireguard_messages.h>
22 #include <wireguard/wireguard_key.h>
23 #include <wireguard/wireguard_send.h>
24 #include <wireguard/wireguard.h>
26 wg_peer_t *wg_peer_pool;
28 index_t *wg_peer_by_adj_index;
31 wg_peer_endpoint_reset (wg_peer_endpoint_t * ep)
33 ip46_address_reset (&ep->addr);
38 wg_peer_endpoint_init (wg_peer_endpoint_t *ep, const ip46_address_t *addr,
41 ip46_address_copy (&ep->addr, addr);
46 wg_peer_clear (vlib_main_t * vm, wg_peer_t * peer)
48 wg_timers_stop (peer);
49 for (int i = 0; i < WG_N_TIMERS; i++)
52 peer->timers_dispatched[i] = 0;
55 peer->last_sent_handshake = vlib_time_now (vm) - (REKEY_TIMEOUT + 1);
57 clib_memset (&peer->cookie_maker, 0, sizeof (peer->cookie_maker));
59 wg_peer_endpoint_reset (&peer->src);
60 wg_peer_endpoint_reset (&peer->dst);
62 adj_index_t *adj_index;
63 vec_foreach (adj_index, peer->adj_indices)
65 if (INDEX_INVALID != *adj_index)
67 wg_peer_by_adj_index[*adj_index] = INDEX_INVALID;
70 peer->input_thread_index = ~0;
71 peer->output_thread_index = ~0;
72 peer->timer_wheel = 0;
73 peer->persistent_keepalive_interval = 0;
74 peer->timer_handshake_attempts = 0;
75 peer->last_sent_packet = 0;
76 peer->last_received_packet = 0;
77 peer->session_derived = 0;
78 peer->rehandshake_started = 0;
79 peer->new_handshake_interval_tick = 0;
80 peer->rehandshake_interval_tick = 0;
81 peer->timer_need_another_keepalive = false;
83 vec_free (peer->allowed_ips);
84 vec_free (peer->adj_indices);
88 wg_peer_init (vlib_main_t * vm, wg_peer_t * peer)
90 wg_peer_clear (vm, peer);
94 wg_peer_build_rewrite (const wg_peer_t * peer)
97 ip4_udp_header_t *hdr;
100 vec_validate (rewrite, sizeof (*hdr) - 1);
101 hdr = (ip4_udp_header_t *) rewrite;
103 hdr->ip4.ip_version_and_header_length = 0x45;
105 hdr->ip4.src_address = peer->src.addr.ip4;
106 hdr->ip4.dst_address = peer->dst.addr.ip4;
107 hdr->ip4.protocol = IP_PROTOCOL_UDP;
108 hdr->ip4.checksum = ip4_header_checksum (&hdr->ip4);
110 hdr->udp.src_port = clib_host_to_net_u16 (peer->src.port);
111 hdr->udp.dst_port = clib_host_to_net_u16 (peer->dst.port);
112 hdr->udp.checksum = 0;
118 wg_peer_adj_stack (wg_peer_t *peer, adj_index_t ai)
124 if (!adj_is_valid (ai))
128 sw_if_index = adj->rewrite_header.sw_if_index;
130 wgi = wg_if_get (wg_if_find_by_sw_if_index (sw_if_index));
135 if (!vnet_sw_interface_is_admin_up (vnet_get_main (), wgi->sw_if_index))
137 adj_midchain_delegate_unstack (ai);
144 .fp_proto = FIB_PROTOCOL_IP4,
145 .fp_addr = peer->dst.addr,
150 fib_index = fib_table_find (FIB_PROTOCOL_IP4, peer->table_id);
152 adj_midchain_delegate_stack (ai, fib_index, &dst);
157 wg_peer_if_admin_state_change (index_t peeri, void *data)
160 adj_index_t *adj_index;
161 peer = wg_peer_get (peeri);
162 vec_foreach (adj_index, peer->adj_indices)
164 wg_peer_adj_stack (peer, *adj_index);
166 return (WALK_CONTINUE);
170 wg_peer_if_adj_change (index_t peeri, void *data)
172 adj_index_t *adj_index = data;
175 fib_prefix_t *allowed_ip;
177 adj = adj_get (*adj_index);
179 peer = wg_peer_get (peeri);
180 vec_foreach (allowed_ip, peer->allowed_ips)
182 if (fib_prefix_is_cover_addr_4 (allowed_ip,
183 &adj->sub_type.nbr.next_hop.ip4))
185 vec_add1 (peer->adj_indices, *adj_index);
186 vec_validate_init_empty (wg_peer_by_adj_index, *adj_index,
188 wg_peer_by_adj_index[*adj_index] = peer - wg_peer_pool;
190 adj_nbr_midchain_update_rewrite (*adj_index, NULL, NULL,
191 ADJ_FLAG_MIDCHAIN_IP_STACK,
192 vec_dup (peer->rewrite));
194 wg_peer_adj_stack (peer, *adj_index);
199 return (WALK_CONTINUE);
203 wg_peer_adj_walk (adj_index_t ai, void *data)
205 return wg_peer_if_adj_change ((*(index_t *) (data)), &ai) == WALK_CONTINUE ?
206 ADJ_WALK_RC_CONTINUE :
211 wg_peer_if_delete (index_t peeri, void *data)
213 wg_peer_remove (peeri);
214 return (WALK_CONTINUE);
218 wg_peer_fill (vlib_main_t *vm, wg_peer_t *peer, u32 table_id,
219 const ip46_address_t *dst, u16 port,
220 u16 persistent_keepalive_interval,
221 const fib_prefix_t *allowed_ips, u32 wg_sw_if_index)
223 wg_peer_endpoint_init (&peer->dst, dst, port);
225 peer->table_id = table_id;
226 peer->wg_sw_if_index = wg_sw_if_index;
227 peer->timer_wheel = &wg_main.timer_wheel;
228 peer->persistent_keepalive_interval = persistent_keepalive_interval;
229 peer->last_sent_handshake = vlib_time_now (vm) - (REKEY_TIMEOUT + 1);
230 peer->is_dead = false;
232 const wg_if_t *wgi = wg_if_get (wg_if_find_by_sw_if_index (wg_sw_if_index));
235 return (VNET_API_ERROR_INVALID_INTERFACE);
237 ip_address_to_46 (&wgi->src_ip, &peer->src.addr);
238 peer->src.port = wgi->port;
239 peer->rewrite = wg_peer_build_rewrite (peer);
242 vec_validate (peer->allowed_ips, vec_len (allowed_ips) - 1);
243 vec_foreach_index (ii, allowed_ips)
245 peer->allowed_ips[ii] = allowed_ips[ii];
248 index_t perri = peer - wg_peer_pool;
249 fib_protocol_t proto;
250 FOR_EACH_FIB_IP_PROTOCOL (proto)
252 adj_nbr_walk (wg_sw_if_index, proto, wg_peer_adj_walk, &perri);
258 wg_peer_add (u32 tun_sw_if_index, const u8 public_key[NOISE_PUBLIC_KEY_LEN],
259 u32 table_id, const ip46_address_t *endpoint,
260 const fib_prefix_t *allowed_ips, u16 port,
261 u16 persistent_keepalive, u32 *peer_index)
267 vlib_main_t *vm = vlib_get_main ();
269 if (tun_sw_if_index == ~0)
270 return (VNET_API_ERROR_INVALID_SW_IF_INDEX);
272 wg_if = wg_if_get (wg_if_find_by_sw_if_index (tun_sw_if_index));
274 return (VNET_API_ERROR_INVALID_SW_IF_INDEX);
277 pool_foreach (peer, wg_peer_pool)
279 if (!memcmp (peer->remote.r_public, public_key, NOISE_PUBLIC_KEY_LEN))
281 return (VNET_API_ERROR_ENTRY_ALREADY_EXISTS);
286 if (pool_elts (wg_peer_pool) > MAX_PEERS)
287 return (VNET_API_ERROR_LIMIT_EXCEEDED);
289 pool_get (wg_peer_pool, peer);
291 wg_peer_init (vm, peer);
293 rv = wg_peer_fill (vm, peer, table_id, endpoint, (u16) port,
294 persistent_keepalive, allowed_ips, tun_sw_if_index);
298 wg_peer_clear (vm, peer);
299 pool_put (wg_peer_pool, peer);
303 noise_remote_init (&peer->remote, peer - wg_peer_pool, public_key,
305 cookie_maker_init (&peer->cookie_maker, public_key);
307 if (peer->persistent_keepalive_interval != 0)
309 wg_send_keepalive (vm, peer);
312 *peer_index = peer - wg_peer_pool;
313 wg_if_peer_add (wg_if, *peer_index);
319 wg_peer_remove (index_t peeri)
321 wg_main_t *wmp = &wg_main;
322 wg_peer_t *peer = NULL;
325 if (pool_is_free_index (wg_peer_pool, peeri))
326 return VNET_API_ERROR_NO_SUCH_ENTRY;
328 peer = pool_elt_at_index (wg_peer_pool, peeri);
330 wgi = wg_if_get (wg_if_find_by_sw_if_index (peer->wg_sw_if_index));
331 wg_if_peer_remove (wgi, peeri);
333 noise_remote_clear (wmp->vlib_main, &peer->remote);
334 wg_peer_clear (wmp->vlib_main, peer);
335 pool_put (wg_peer_pool, peer);
341 wg_peer_walk (wg_peer_walk_cb_t fn, void *data)
346 pool_foreach_index (peeri, wg_peer_pool)
348 if (WALK_STOP == fn(peeri, data))
352 return INDEX_INVALID;
356 format_wg_peer_endpoint (u8 * s, va_list * args)
358 wg_peer_endpoint_t *ep = va_arg (*args, wg_peer_endpoint_t *);
360 s = format (s, "%U:%d", format_ip46_address, &ep->addr, IP46_TYPE_ANY,
367 format_wg_peer (u8 * s, va_list * va)
369 index_t peeri = va_arg (*va, index_t);
370 fib_prefix_t *allowed_ip;
371 adj_index_t *adj_index;
372 u8 key[NOISE_KEY_LEN_BASE64];
375 peer = wg_peer_get (peeri);
376 key_to_base64 (peer->remote.r_public, NOISE_PUBLIC_KEY_LEN, key);
378 s = format (s, "[%d] endpoint:[%U->%U] %U keep-alive:%d", peeri,
379 format_wg_peer_endpoint, &peer->src, format_wg_peer_endpoint,
380 &peer->dst, format_vnet_sw_if_index_name, vnet_get_main (),
381 peer->wg_sw_if_index, peer->persistent_keepalive_interval);
382 s = format (s, "\n adj:");
383 vec_foreach (adj_index, peer->adj_indices)
385 s = format (s, " %d", adj_index);
387 s = format (s, "\n key:%=s %U", key, format_hex_bytes,
388 peer->remote.r_public, NOISE_PUBLIC_KEY_LEN);
389 s = format (s, "\n allowed-ips:");
390 vec_foreach (allowed_ip, peer->allowed_ips)
392 s = format (s, " %U", format_fib_prefix, allowed_ip);
399 * fd.io coding-style-patch-verification: ON
402 * eval: (c-set-style "gnu")