[mirror_frr.git] / ldpd / lde.h

/*	$OpenBSD$ */

/*
 * Copyright (c) 2013, 2016 Renato Westphal <renato@openbsd.org>
 * Copyright (c) 2009 Michele Marchetto <michele@openbsd.org>
 * Copyright (c) 2004, 2005 Esben Norby <norby@openbsd.org>
 *
 * Permission to use, copy, modify, and distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */

#ifndef _LDE_H_
#define _LDE_H_

#include "openbsd-queue.h"
#include "openbsd-tree.h"

enum fec_type {
	FEC_TYPE_IPV4,
	FEC_TYPE_IPV6,
	FEC_TYPE_PWID
};

struct fec {
	RB_ENTRY(fec)		entry;
	enum fec_type		type;
	union {
		struct {
			struct in_addr	prefix;
			uint8_t		prefixlen;
		} ipv4;
		struct {
			struct in6_addr	prefix;
			uint8_t		prefixlen;
		} ipv6;
		struct {
			uint16_t	type;
			uint32_t	pwid;
			struct in_addr	lsr_id;
		} pwid;
	} u;
};
RB_HEAD(fec_tree, fec);
RB_PROTOTYPE(fec_tree, fec, entry, fec_compare)

/* request entries */
struct lde_req {
	struct fec		 fec;
	uint32_t		 msg_id;
};

/* mapping entries */
struct lde_map {
	struct fec		 fec;
	LIST_ENTRY(lde_map)	 entry;
	struct lde_nbr		*nexthop;
	struct map		 map;
};

/* withdraw entries */
struct lde_wdraw {
	struct fec		 fec;
	uint32_t		 label;
};

/* Addresses belonging to neighbor */
struct lde_addr {
	TAILQ_ENTRY(lde_addr)	 entry;
	int			 af;
	union ldpd_addr		 addr;
};

/* just the info LDE needs */
struct lde_nbr {
	RB_ENTRY(lde_nbr)	 entry;
	uint32_t		 peerid;
	struct in_addr		 id;
	int			 v4_enabled;	/* announce/process v4 msgs */
	int			 v6_enabled;	/* announce/process v6 msgs */
	struct fec_tree		 recv_req;
	struct fec_tree		 sent_req;
	struct fec_tree		 recv_map;
	struct fec_tree		 sent_map;
	struct fec_tree		 sent_wdraw;
	TAILQ_HEAD(, lde_addr)	 addr_list;
};
RB_HEAD(nbr_tree, lde_nbr);
RB_PROTOTYPE(nbr_tree, lde_nbr, entry, lde_nbr_compare)

struct fec_nh {
	LIST_ENTRY(fec_nh)	 entry;
	int			 af;
	union ldpd_addr		 nexthop;
	uint32_t		 remote_label;
	uint8_t			 priority;
	uint8_t			 flags;
};
#define F_FEC_NH_NEW		0x01

struct fec_node {
	struct fec		 fec;

	LIST_HEAD(, fec_nh)	 nexthops;	/* fib nexthops */
	LIST_HEAD(, lde_map)	 downstream;	/* recv mappings */
	LIST_HEAD(, lde_map)	 upstream;	/* sent mappings */

	uint32_t		 local_label;
	void			*data;		/* fec specific data */
};

#define LDE_GC_INTERVAL 300

extern struct ldpd_conf	*ldeconf;
extern struct fec_tree	 ft;
extern struct nbr_tree	 lde_nbrs;
extern struct thread	*gc_timer;

/* lde.c */
void		 lde(const char *, const char *);
int		 lde_imsg_compose_parent(int, pid_t, void *, uint16_t);
int		 lde_imsg_compose_ldpe(int, uint32_t, pid_t, void *, uint16_t);
uint32_t	 lde_assign_label(void);
void		 lde_send_change_klabel(struct fec_node *, struct fec_nh *);
void		 lde_send_delete_klabel(struct fec_node *, struct fec_nh *);
void		 lde_fec2map(struct fec *, struct map *);
void		 lde_map2fec(struct map *, struct in_addr, struct fec *);
void		 lde_send_labelmapping(struct lde_nbr *, struct fec_node *,
		    int);
void		 lde_send_labelwithdraw(struct lde_nbr *, struct fec_node *,
		    uint32_t, struct status_tlv *);
void		 lde_send_labelwithdraw_all(struct fec_node *, uint32_t);
void		 lde_send_labelrelease(struct lde_nbr *, struct fec_node *,
		    uint32_t);
void		 lde_send_notification(uint32_t, uint32_t, uint32_t, uint16_t);
struct lde_nbr	*lde_nbr_find_by_lsrid(struct in_addr);
struct lde_nbr	*lde_nbr_find_by_addr(int, union ldpd_addr *);
struct lde_map	*lde_map_add(struct lde_nbr *, struct fec_node *, int);
void		 lde_map_del(struct lde_nbr *, struct lde_map *, int);
struct lde_req	*lde_req_add(struct lde_nbr *, struct fec *, int);
void		 lde_req_del(struct lde_nbr *, struct lde_req *, int);
struct lde_wdraw *lde_wdraw_add(struct lde_nbr *, struct fec_node *);
void		 lde_wdraw_del(struct lde_nbr *, struct lde_wdraw *);
void		 lde_change_egress_label(int, int);
struct lde_addr	*lde_address_find(struct lde_nbr *, int,
		    union ldpd_addr *);

/* lde_lib.c */
void		 fec_init(struct fec_tree *);
struct fec	*fec_find(struct fec_tree *, struct fec *);
int		 fec_insert(struct fec_tree *, struct fec *);
int		 fec_remove(struct fec_tree *, struct fec *);
void		 fec_clear(struct fec_tree *, void (*)(void *));
void		 rt_dump(pid_t);
void		 fec_snap(struct lde_nbr *);
void		 fec_tree_clear(void);
struct fec_nh	*fec_nh_find(struct fec_node *, int, union ldpd_addr *,
		    uint8_t);
uint32_t	 egress_label(enum fec_type);
void		 lde_kernel_insert(struct fec *, int, union ldpd_addr *,
		    uint8_t, int, void *);
void		 lde_kernel_remove(struct fec *, int, union ldpd_addr *,
		    uint8_t);
void		 lde_kernel_reevaluate(struct fec *);
void		 lde_check_mapping(struct map *, struct lde_nbr *);
void		 lde_check_request(struct map *, struct lde_nbr *);
void		 lde_check_release(struct map *, struct lde_nbr *);
void		 lde_check_release_wcard(struct map *, struct lde_nbr *);
void		 lde_check_withdraw(struct map *, struct lde_nbr *);
void		 lde_check_withdraw_wcard(struct map *, struct lde_nbr *);
int		 lde_gc_timer(struct thread *);
void		 lde_gc_start_timer(void);
void		 lde_gc_stop_timer(void);

/* l2vpn.c */
struct l2vpn	*l2vpn_new(const char *);
struct l2vpn	*l2vpn_find(struct ldpd_conf *, const char *);
void		 l2vpn_del(struct l2vpn *);
void		 l2vpn_init(struct l2vpn *);
void		 l2vpn_exit(struct l2vpn *);
struct l2vpn_if	*l2vpn_if_new(struct l2vpn *, struct kif *);
struct l2vpn_if	*l2vpn_if_find(struct l2vpn *, unsigned int);
struct l2vpn_if	*l2vpn_if_find_name(struct l2vpn *, const char *);
struct l2vpn_pw	*l2vpn_pw_new(struct l2vpn *, struct kif *);
struct l2vpn_pw *l2vpn_pw_find(struct l2vpn *, unsigned int);
struct l2vpn_pw *l2vpn_pw_find_name(struct l2vpn *, const char *);
void		 l2vpn_pw_init(struct l2vpn_pw *);
void		 l2vpn_pw_exit(struct l2vpn_pw *);
void		 l2vpn_pw_reset(struct l2vpn_pw *);
int		 l2vpn_pw_ok(struct l2vpn_pw *, struct fec_nh *);
int		 l2vpn_pw_negotiate(struct lde_nbr *, struct fec_node *,
		    struct map *);
void		 l2vpn_send_pw_status(uint32_t, uint32_t, struct fec *);
void		 l2vpn_recv_pw_status(struct lde_nbr *, struct notify_msg *);
void		 l2vpn_sync_pws(int, union ldpd_addr *);
void		 l2vpn_pw_ctl(pid_t);
void		 l2vpn_binding_ctl(pid_t);

#endif	/* _LDE_H_ */
Commit	Line	Data
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"
eac6e3f0 RW	25	#include "openbsd-tree.h"
8429abe0 RW	26
	27	enum fec_type {
	28	FEC_TYPE_IPV4,
	29	FEC_TYPE_IPV6,
	30	FEC_TYPE_PWID
	31	};
	32
	33	struct fec {
	34	RB_ENTRY(fec) entry;
	35	enum fec_type type;
	36	union {
	37	struct {
	38	struct in_addr prefix;
	39	uint8_t prefixlen;
	40	} ipv4;
	41	struct {
	42	struct in6_addr prefix;
	43	uint8_t prefixlen;
	44	} ipv6;
	45	struct {
	46	uint16_t type;
	47	uint32_t pwid;
	48	struct in_addr lsr_id;
	49	} pwid;
	50	} u;
	51	};
	52	RB_HEAD(fec_tree, fec);
	53	RB_PROTOTYPE(fec_tree, fec, entry, fec_compare)
	54
	55	/* request entries */
	56	struct lde_req {
	57	struct fec fec;
	58	uint32_t msg_id;
	59	};
	60
	61	/* mapping entries */
	62	struct lde_map {
	63	struct fec fec;
	64	LIST_ENTRY(lde_map) entry;
	65	struct lde_nbr *nexthop;
	66	struct map map;
	67	};
	68
	69	/* withdraw entries */
	70	struct lde_wdraw {
	71	struct fec fec;
	72	uint32_t label;
	73	};
	74
	75	/* Addresses belonging to neighbor */
	76	struct lde_addr {
	77	TAILQ_ENTRY(lde_addr) entry;
	78	int af;
	79	union ldpd_addr addr;
	80	};
	81
	82	/* just the info LDE needs */
	83	struct lde_nbr {
	84	RB_ENTRY(lde_nbr) entry;
	85	uint32_t peerid;
	86	struct in_addr id;
	87	int v4_enabled; /* announce/process v4 msgs */
	88	int v6_enabled; /* announce/process v6 msgs */
	89	struct fec_tree recv_req;
90	struct fec_tree sent_req;
91	struct fec_tree recv_map;
92	struct fec_tree sent_map;
93	struct fec_tree sent_wdraw;
94	TAILQ_HEAD(, lde_addr) addr_list;
95	};
96	RB_HEAD(nbr_tree, lde_nbr);
97	RB_PROTOTYPE(nbr_tree, lde_nbr, entry, lde_nbr_compare)
98
99	struct fec_nh {
100	LIST_ENTRY(fec_nh) entry;
101	int af;
102	union ldpd_addr nexthop;
103	uint32_t remote_label;
104	uint8_t priority;
134970a2	105	uint8_t flags;
8429abe0	106	};
134970a2	107	#define F_FEC_NH_NEW 0x01
8429abe0 RW	108
	109	struct fec_node {
	110	struct fec fec;
	111
	112	LIST_HEAD(, fec_nh) nexthops; /* fib nexthops */
	113	LIST_HEAD(, lde_map) downstream; /* recv mappings */
	114	LIST_HEAD(, lde_map) upstream; /* sent mappings */
	115
	116	uint32_t local_label;
	117	void data; / fec specific data */
	118	};
	119
	120	#define LDE_GC_INTERVAL 300
	121
	122	extern struct ldpd_conf *ldeconf;
	123	extern struct fec_tree ft;
	124	extern struct nbr_tree lde_nbrs;
eac6e3f0	125	extern struct thread *gc_timer;
8429abe0 RW	126
8429abe0 RW	127	/* lde.c */
eac6e3f0 RW	128	void lde(const char , const char );
eac6e3f0 RW	129	int lde_imsg_compose_parent(int, pid_t, void *, uint16_t);
8429abe0 RW	130	int lde_imsg_compose_ldpe(int, uint32_t, pid_t, void *, uint16_t);
	131	uint32_t lde_assign_label(void);
	132	void lde_send_change_klabel(struct fec_node , struct fec_nh );
	133	void lde_send_delete_klabel(struct fec_node , struct fec_nh );
	134	void lde_fec2map(struct fec , struct map );
	135	void lde_map2fec(struct map , struct in_addr, struct fec );
	136	void lde_send_labelmapping(struct lde_nbr , struct fec_node ,
	137	int);
	138	void lde_send_labelwithdraw(struct lde_nbr , struct fec_node ,
	139	uint32_t, struct status_tlv *);
	140	void lde_send_labelwithdraw_all(struct fec_node *, uint32_t);
	141	void lde_send_labelrelease(struct lde_nbr , struct fec_node ,
	142	uint32_t);
	143	void lde_send_notification(uint32_t, uint32_t, uint32_t, uint16_t);
	144	struct lde_nbr *lde_nbr_find_by_lsrid(struct in_addr);
	145	struct lde_nbr lde_nbr_find_by_addr(int, union ldpd_addr );
	146	struct lde_map lde_map_add(struct lde_nbr , struct fec_node *, int);
	147	void lde_map_del(struct lde_nbr , struct lde_map , int);
	148	struct lde_req lde_req_add(struct lde_nbr , struct fec *, int);
	149	void lde_req_del(struct lde_nbr , struct lde_req , int);
	150	struct lde_wdraw lde_wdraw_add(struct lde_nbr , struct fec_node *);
	151	void lde_wdraw_del(struct lde_nbr , struct lde_wdraw );
	152	void lde_change_egress_label(int, int);
	153	struct lde_addr lde_address_find(struct lde_nbr , int,
	154	union ldpd_addr *);
	155
	156	/* lde_lib.c */
	157	void fec_init(struct fec_tree *);
	158	struct fec fec_find(struct fec_tree , struct fec *);
	159	int fec_insert(struct fec_tree , struct fec );
	160	int fec_remove(struct fec_tree , struct fec );
	161	void fec_clear(struct fec_tree , void ()(void *));
	162	void rt_dump(pid_t);
	163	void fec_snap(struct lde_nbr *);
	164	void fec_tree_clear(void);
	165	struct fec_nh fec_nh_find(struct fec_node , int, union ldpd_addr *,
	166	uint8_t);
	167	uint32_t egress_label(enum fec_type);
	168	void lde_kernel_insert(struct fec , int, union ldpd_addr ,
	169	uint8_t, int, void *);
	170	void lde_kernel_remove(struct fec , int, union ldpd_addr ,
	171	uint8_t);
134970a2	172	void lde_kernel_reevaluate(struct fec *);
8429abe0 RW	173	void lde_check_mapping(struct map , struct lde_nbr );
	174	void lde_check_request(struct map , struct lde_nbr );
	175	void lde_check_release(struct map , struct lde_nbr );
	176	void lde_check_release_wcard(struct map , struct lde_nbr );
	177	void lde_check_withdraw(struct map , struct lde_nbr );
	178	void lde_check_withdraw_wcard(struct map , struct lde_nbr );
eac6e3f0	179	int lde_gc_timer(struct thread *);
8429abe0 RW	180	void lde_gc_start_timer(void);
	181	void lde_gc_stop_timer(void);
	182
	183	/* l2vpn.c */
	184	struct l2vpn l2vpn_new(const char );
	185	struct l2vpn l2vpn_find(struct ldpd_conf , const char *);
	186	void l2vpn_del(struct l2vpn *);
	187	void l2vpn_init(struct l2vpn *);
	188	void l2vpn_exit(struct l2vpn *);
	189	struct l2vpn_if l2vpn_if_new(struct l2vpn , struct kif *);
	190	struct l2vpn_if l2vpn_if_find(struct l2vpn , unsigned int);
eac6e3f0	191	struct l2vpn_if l2vpn_if_find_name(struct l2vpn , const char *);
8429abe0 RW	192	struct l2vpn_pw l2vpn_pw_new(struct l2vpn , struct kif *);
8429abe0 RW	193	struct l2vpn_pw l2vpn_pw_find(struct l2vpn , unsigned int);
eac6e3f0	194	struct l2vpn_pw l2vpn_pw_find_name(struct l2vpn , const char *);
8429abe0 RW	195	void l2vpn_pw_init(struct l2vpn_pw *);
	196	void l2vpn_pw_exit(struct l2vpn_pw *);
	197	void l2vpn_pw_reset(struct l2vpn_pw *);
	198	int l2vpn_pw_ok(struct l2vpn_pw , struct fec_nh );
	199	int l2vpn_pw_negotiate(struct lde_nbr , struct fec_node ,
	200	struct map *);
	201	void l2vpn_send_pw_status(uint32_t, uint32_t, struct fec *);
	202	void l2vpn_recv_pw_status(struct lde_nbr , struct notify_msg );
	203	void l2vpn_sync_pws(int, union ldpd_addr *);
	204	void l2vpn_pw_ctl(pid_t);
	205	void l2vpn_binding_ctl(pid_t);
	206
	207	#endif /* _LDE_H_ */