]> git.proxmox.com Git - mirror_frr.git/blame - ldpd/lde.h
ldpd: fix processing of Label Withdraw messages
[mirror_frr.git] / ldpd / lde.h
CommitLineData
8429abe0
RW
1/* $OpenBSD$ */
2
3/*
4 * Copyright (c) 2013, 2016 Renato Westphal <renato@openbsd.org>
5 * Copyright (c) 2009 Michele Marchetto <michele@openbsd.org>
6 * Copyright (c) 2004, 2005 Esben Norby <norby@openbsd.org>
7 *
8 * Permission to use, copy, modify, and distribute this software for any
9 * purpose with or without fee is hereby granted, provided that the above
10 * copyright notice and this permission notice appear in all copies.
11 *
12 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
13 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
14 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
15 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
16 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
17 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
18 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
19 */
20
21#ifndef _LDE_H_
22#define _LDE_H_
23
eac6e3f0
RW
24#include "openbsd-queue.h"
25#include "openbsd-tree.h"
88d88a9c 26#include "if.h"
8429abe0
RW
27
28enum fec_type {
29 FEC_TYPE_IPV4,
30 FEC_TYPE_IPV6,
31 FEC_TYPE_PWID
32};
33
34struct fec {
35 RB_ENTRY(fec) entry;
36 enum fec_type type;
37 union {
38 struct {
39 struct in_addr prefix;
40 uint8_t prefixlen;
41 } ipv4;
42 struct {
43 struct in6_addr prefix;
44 uint8_t prefixlen;
45 } ipv6;
46 struct {
47 uint16_t type;
48 uint32_t pwid;
49 struct in_addr lsr_id;
50 } pwid;
51 } u;
52};
53RB_HEAD(fec_tree, fec);
54RB_PROTOTYPE(fec_tree, fec, entry, fec_compare)
55
56/* request entries */
57struct lde_req {
58 struct fec fec;
59 uint32_t msg_id;
60};
61
62/* mapping entries */
63struct lde_map {
64 struct fec fec;
d3e1887a
RW
65 struct lde_map_head *head; /* fec_node's upstream/downstream */
66 RB_ENTRY(lde_map) entry;
8429abe0
RW
67 struct lde_nbr *nexthop;
68 struct map map;
69};
d3e1887a
RW
70RB_HEAD(lde_map_head, lde_map);
71RB_PROTOTYPE(lde_map_head, lde_map, entry, lde_map_cmp);
8429abe0
RW
72
73/* withdraw entries */
74struct lde_wdraw {
75 struct fec fec;
76 uint32_t label;
77};
78
79/* Addresses belonging to neighbor */
80struct lde_addr {
81 TAILQ_ENTRY(lde_addr) entry;
82 int af;
83 union ldpd_addr addr;
84};
85
86/* just the info LDE needs */
87struct lde_nbr {
88 RB_ENTRY(lde_nbr) entry;
89 uint32_t peerid;
90 struct in_addr id;
91 int v4_enabled; /* announce/process v4 msgs */
92 int v6_enabled; /* announce/process v6 msgs */
93 struct fec_tree recv_req;
94 struct fec_tree sent_req;
95 struct fec_tree recv_map;
96 struct fec_tree sent_map;
97 struct fec_tree sent_wdraw;
98 TAILQ_HEAD(, lde_addr) addr_list;
99};
100RB_HEAD(nbr_tree, lde_nbr);
101RB_PROTOTYPE(nbr_tree, lde_nbr, entry, lde_nbr_compare)
102
103struct fec_nh {
104 LIST_ENTRY(fec_nh) entry;
105 int af;
106 union ldpd_addr nexthop;
88d88a9c 107 ifindex_t ifindex;
8429abe0
RW
108 uint32_t remote_label;
109 uint8_t priority;
134970a2 110 uint8_t flags;
8429abe0 111};
134970a2 112#define F_FEC_NH_NEW 0x01
8cb1fc45 113#define F_FEC_NH_CONNECTED 0x02
8429abe0
RW
114
115struct fec_node {
116 struct fec fec;
117
118 LIST_HEAD(, fec_nh) nexthops; /* fib nexthops */
d3e1887a
RW
119 struct lde_map_head downstream; /* recv mappings */
120 struct lde_map_head upstream; /* sent mappings */
8429abe0
RW
121
122 uint32_t local_label;
123 void *data; /* fec specific data */
124};
125
126#define LDE_GC_INTERVAL 300
127
128extern struct ldpd_conf *ldeconf;
129extern struct fec_tree ft;
130extern struct nbr_tree lde_nbrs;
eac6e3f0 131extern struct thread *gc_timer;
8429abe0
RW
132
133/* lde.c */
eac6e3f0
RW
134void lde(const char *, const char *);
135int lde_imsg_compose_parent(int, pid_t, void *, uint16_t);
8429abe0 136int lde_imsg_compose_ldpe(int, uint32_t, pid_t, void *, uint16_t);
45a8eba9 137int lde_acl_check(char *, int, union ldpd_addr *, uint8_t);
8cb1fc45 138uint32_t lde_update_label(struct fec_node *);
8429abe0
RW
139void lde_send_change_klabel(struct fec_node *, struct fec_nh *);
140void lde_send_delete_klabel(struct fec_node *, struct fec_nh *);
141void lde_fec2map(struct fec *, struct map *);
142void lde_map2fec(struct map *, struct in_addr, struct fec *);
143void lde_send_labelmapping(struct lde_nbr *, struct fec_node *,
144 int);
145void lde_send_labelwithdraw(struct lde_nbr *, struct fec_node *,
146 uint32_t, struct status_tlv *);
147void lde_send_labelwithdraw_all(struct fec_node *, uint32_t);
148void lde_send_labelrelease(struct lde_nbr *, struct fec_node *,
149 uint32_t);
05aac414
RW
150void lde_send_notification(struct lde_nbr *, uint32_t, uint32_t,
151 uint16_t);
8429abe0
RW
152struct lde_nbr *lde_nbr_find_by_lsrid(struct in_addr);
153struct lde_nbr *lde_nbr_find_by_addr(int, union ldpd_addr *);
154struct lde_map *lde_map_add(struct lde_nbr *, struct fec_node *, int);
155void lde_map_del(struct lde_nbr *, struct lde_map *, int);
156struct lde_req *lde_req_add(struct lde_nbr *, struct fec *, int);
157void lde_req_del(struct lde_nbr *, struct lde_req *, int);
158struct lde_wdraw *lde_wdraw_add(struct lde_nbr *, struct fec_node *);
159void lde_wdraw_del(struct lde_nbr *, struct lde_wdraw *);
45a8eba9 160void lde_change_egress_label(int);
8429abe0
RW
161struct lde_addr *lde_address_find(struct lde_nbr *, int,
162 union ldpd_addr *);
163
164/* lde_lib.c */
165void fec_init(struct fec_tree *);
166struct fec *fec_find(struct fec_tree *, struct fec *);
167int fec_insert(struct fec_tree *, struct fec *);
168int fec_remove(struct fec_tree *, struct fec *);
169void fec_clear(struct fec_tree *, void (*)(void *));
170void rt_dump(pid_t);
171void fec_snap(struct lde_nbr *);
172void fec_tree_clear(void);
173struct fec_nh *fec_nh_find(struct fec_node *, int, union ldpd_addr *,
88d88a9c 174 ifindex_t, uint8_t);
8429abe0 175void lde_kernel_insert(struct fec *, int, union ldpd_addr *,
88d88a9c 176 ifindex_t, uint8_t, int, void *);
8429abe0 177void lde_kernel_remove(struct fec *, int, union ldpd_addr *,
88d88a9c 178 ifindex_t, uint8_t);
8cb1fc45 179void lde_kernel_update(struct fec *);
8429abe0
RW
180void lde_check_mapping(struct map *, struct lde_nbr *);
181void lde_check_request(struct map *, struct lde_nbr *);
182void lde_check_release(struct map *, struct lde_nbr *);
183void lde_check_release_wcard(struct map *, struct lde_nbr *);
184void lde_check_withdraw(struct map *, struct lde_nbr *);
185void lde_check_withdraw_wcard(struct map *, struct lde_nbr *);
eac6e3f0 186int lde_gc_timer(struct thread *);
8429abe0
RW
187void lde_gc_start_timer(void);
188void lde_gc_stop_timer(void);
189
190/* l2vpn.c */
191struct l2vpn *l2vpn_new(const char *);
192struct l2vpn *l2vpn_find(struct ldpd_conf *, const char *);
193void l2vpn_del(struct l2vpn *);
194void l2vpn_init(struct l2vpn *);
195void l2vpn_exit(struct l2vpn *);
196struct l2vpn_if *l2vpn_if_new(struct l2vpn *, struct kif *);
197struct l2vpn_if *l2vpn_if_find(struct l2vpn *, unsigned int);
eac6e3f0 198struct l2vpn_if *l2vpn_if_find_name(struct l2vpn *, const char *);
8429abe0
RW
199struct l2vpn_pw *l2vpn_pw_new(struct l2vpn *, struct kif *);
200struct l2vpn_pw *l2vpn_pw_find(struct l2vpn *, unsigned int);
eac6e3f0 201struct l2vpn_pw *l2vpn_pw_find_name(struct l2vpn *, const char *);
8429abe0
RW
202void l2vpn_pw_init(struct l2vpn_pw *);
203void l2vpn_pw_exit(struct l2vpn_pw *);
204void l2vpn_pw_reset(struct l2vpn_pw *);
205int l2vpn_pw_ok(struct l2vpn_pw *, struct fec_nh *);
206int l2vpn_pw_negotiate(struct lde_nbr *, struct fec_node *,
207 struct map *);
208void l2vpn_send_pw_status(uint32_t, uint32_t, struct fec *);
209void l2vpn_recv_pw_status(struct lde_nbr *, struct notify_msg *);
210void l2vpn_sync_pws(int, union ldpd_addr *);
211void l2vpn_pw_ctl(pid_t);
212void l2vpn_binding_ctl(pid_t);
213
214#endif /* _LDE_H_ */