ldpd/lde.h

   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
  24 #include "queue.h"
  25 #include "openbsd-tree.h"
  26 #include "if.h"
  27
  28 enum fec_type {
  29         FEC_TYPE_IPV4,
  30         FEC_TYPE_IPV6,
  31         FEC_TYPE_PWID
  32 };
  33
  34 struct 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 };
  53 RB_HEAD(fec_tree, fec);
  54 RB_PROTOTYPE(fec_tree, fec, entry, fec_compare)
  55
  56 /* request entries */
  57 struct lde_req {
  58         struct fec               fec;
  59         uint32_t                 msg_id;
  60 };
  61
  62 /* mapping entries */
  63 struct lde_map {
  64         struct fec               fec;
  65         struct lde_map_head     *head;  /* fec_node's upstream/downstream */
  66         RB_ENTRY(lde_map)        entry;
  67         struct lde_nbr          *nexthop;
  68         struct map               map;
  69 };
  70 RB_HEAD(lde_map_head, lde_map);
  71 RB_PROTOTYPE(lde_map_head, lde_map, entry, lde_map_cmp);
  72
  73 /* withdraw entries */
  74 struct lde_wdraw {
  75         struct fec               fec;
  76         uint32_t                 label;
  77 };
  78
  79 /* Addresses belonging to neighbor */
  80 struct lde_addr {
  81         TAILQ_ENTRY(lde_addr)    entry;
  82         int                      af;
  83         union ldpd_addr          addr;
  84 };
  85
  86 /* just the info LDE needs */
  87 struct 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         int                      flags;         /* capabilities */
  94         struct fec_tree          recv_req;
  95         struct fec_tree          sent_req;
  96         struct fec_tree          recv_map;
  97         struct fec_tree          sent_map;
  98         struct fec_tree          sent_map_pending;
  99         struct fec_tree          sent_wdraw;
 100         TAILQ_HEAD(, lde_addr)   addr_list;
 101 };
 102 RB_HEAD(nbr_tree, lde_nbr);
 103 RB_PROTOTYPE(nbr_tree, lde_nbr, entry, lde_nbr_compare)
 104
 105 struct fec_nh {
 106         LIST_ENTRY(fec_nh)       entry;
 107         int                      af;
 108         union ldpd_addr          nexthop;
 109         ifindex_t                ifindex;
 110         uint32_t                 remote_label;
 111         uint8_t                  priority;
 112         uint8_t                  flags;
 113 };
 114 #define F_FEC_NH_NEW            0x01
 115 #define F_FEC_NH_CONNECTED      0x02
 116
 117 struct fec_node {
 118         struct fec               fec;
 119
 120         LIST_HEAD(, fec_nh)      nexthops;      /* fib nexthops */
 121         struct lde_map_head      downstream;    /* recv mappings */
 122         struct lde_map_head      upstream;      /* sent mappings */
 123
 124         uint32_t                 local_label;
 125         void                    *data;          /* fec specific data */
 126 };
 127
 128 #define CHUNK_SIZE              64
 129 struct label_chunk {
 130         uint32_t                 start;
 131         uint32_t                 end;
 132         uint64_t                 used_mask;
 133 };
 134
 135 #define LDE_GC_INTERVAL 300
 136
 137 extern struct ldpd_conf *ldeconf;
 138 extern struct fec_tree   ft;
 139 extern struct nbr_tree   lde_nbrs;
 140 extern struct thread    *gc_timer;
 141
 142 /* lde.c */
 143 void             lde(void);
 144 void             lde_init(struct ldpd_init *);
 145 int              lde_imsg_compose_parent(int, pid_t, void *, uint16_t);
 146 void             lde_imsg_compose_parent_sync(int, pid_t, void *, uint16_t);
 147 int              lde_imsg_compose_ldpe(int, uint32_t, pid_t, void *, uint16_t);
 148 int              lde_acl_check(char *, int, union ldpd_addr *, uint8_t);
 149 uint32_t         lde_update_label(struct fec_node *);
 150 void             lde_send_change_klabel(struct fec_node *, struct fec_nh *);
 151 void             lde_send_delete_klabel(struct fec_node *, struct fec_nh *);
 152 void             lde_fec2map(struct fec *, struct map *);
 153 void             lde_map2fec(struct map *, struct in_addr, struct fec *);
 154 void             lde_send_labelmapping(struct lde_nbr *, struct fec_node *,
 155                     int);
 156 void             lde_send_labelwithdraw(struct lde_nbr *, struct fec_node *,
 157                     struct map *, struct status_tlv *);
 158 void             lde_send_labelwithdraw_wcard(struct lde_nbr *, uint32_t);
 159 void             lde_send_labelwithdraw_twcard_prefix(struct lde_nbr *,
 160                     uint16_t, uint32_t);
 161 void             lde_send_labelwithdraw_twcard_pwid(struct lde_nbr *, uint16_t,
 162                     uint32_t);
 163 void             lde_send_labelwithdraw_pwid_wcard(struct lde_nbr *, uint16_t,
 164                     uint32_t);
 165 void             lde_send_labelrelease(struct lde_nbr *, struct fec_node *,
 166                     struct map *, uint32_t);
 167 void             lde_send_notification(struct lde_nbr *, uint32_t, uint32_t,
 168                     uint16_t);
 169 void             lde_send_notification_eol_prefix(struct lde_nbr *, int);
 170 void             lde_send_notification_eol_pwid(struct lde_nbr *, uint16_t);
 171 struct lde_nbr  *lde_nbr_find_by_lsrid(struct in_addr);
 172 struct lde_nbr  *lde_nbr_find_by_addr(int, union ldpd_addr *);
 173 struct lde_map  *lde_map_add(struct lde_nbr *, struct fec_node *, int);
 174 void             lde_map_del(struct lde_nbr *, struct lde_map *, int);
 175 struct fec      *lde_map_pending_add(struct lde_nbr *, struct fec_node *);
 176 void             lde_map_pending_del(struct lde_nbr *, struct fec *);
 177 struct lde_req  *lde_req_add(struct lde_nbr *, struct fec *, int);
 178 void             lde_req_del(struct lde_nbr *, struct lde_req *, int);
 179 struct lde_wdraw *lde_wdraw_add(struct lde_nbr *, struct fec_node *);
 180 void             lde_wdraw_del(struct lde_nbr *, struct lde_wdraw *);
 181 void             lde_change_egress_label(int);
 182 struct lde_addr *lde_address_find(struct lde_nbr *, int,
 183                     union ldpd_addr *);
 184
 185 /* lde_lib.c */
 186 void             fec_init(struct fec_tree *);
 187 struct fec      *fec_find(struct fec_tree *, struct fec *);
 188 int              fec_insert(struct fec_tree *, struct fec *);
 189 int              fec_remove(struct fec_tree *, struct fec *);
 190 void             fec_clear(struct fec_tree *, void (*)(void *));
 191 void             rt_dump(pid_t);
 192 void             fec_snap(struct lde_nbr *);
 193 void             fec_tree_clear(void);
 194 struct fec_nh   *fec_nh_find(struct fec_node *, int, union ldpd_addr *,
 195                     ifindex_t, uint8_t);
 196 void             lde_kernel_insert(struct fec *, int, union ldpd_addr *,
 197                     ifindex_t, uint8_t, int, void *);
 198 void             lde_kernel_remove(struct fec *, int, union ldpd_addr *,
 199                     ifindex_t, uint8_t);
 200 void             lde_kernel_update(struct fec *);
 201 void             lde_check_mapping(struct map *, struct lde_nbr *);
 202 void             lde_check_request(struct map *, struct lde_nbr *);
 203 void             lde_check_request_wcard(struct map *, struct lde_nbr *);
 204 void             lde_check_release(struct map *, struct lde_nbr *);
 205 void             lde_check_release_wcard(struct map *, struct lde_nbr *);
 206 void             lde_check_withdraw(struct map *, struct lde_nbr *);
 207 void             lde_check_withdraw_wcard(struct map *, struct lde_nbr *);
 208 int              lde_wildcard_apply(struct map *, struct fec *,
 209                     struct lde_map *);
 210 int              lde_gc_timer(struct thread *);
 211 void             lde_gc_start_timer(void);
 212 void             lde_gc_stop_timer(void);
 213
 214 /* l2vpn.c */
 215 struct l2vpn    *l2vpn_new(const char *);
 216 struct l2vpn    *l2vpn_find(struct ldpd_conf *, const char *);
 217 void             l2vpn_del(struct l2vpn *);
 218 void             l2vpn_init(struct l2vpn *);
 219 void             l2vpn_exit(struct l2vpn *);
 220 struct l2vpn_if *l2vpn_if_new(struct l2vpn *, const char *);
 221 struct l2vpn_if *l2vpn_if_find(struct l2vpn *, const char *);
 222 void             l2vpn_if_update_info(struct l2vpn_if *, struct kif *);
 223 void             l2vpn_if_update(struct l2vpn_if *);
 224 struct l2vpn_pw *l2vpn_pw_new(struct l2vpn *, const char *);
 225 struct l2vpn_pw *l2vpn_pw_find(struct l2vpn *, const char *);
 226 struct l2vpn_pw *l2vpn_pw_find_active(struct l2vpn *, const char *);
 227 struct l2vpn_pw *l2vpn_pw_find_inactive(struct l2vpn *, const char *);
 228 void             l2vpn_pw_update_info(struct l2vpn_pw *, struct kif *);
 229 void             l2vpn_pw_init(struct l2vpn_pw *);
 230 void             l2vpn_pw_exit(struct l2vpn_pw *);
 231 void             l2vpn_pw_reset(struct l2vpn_pw *);
 232 int              l2vpn_pw_ok(struct l2vpn_pw *, struct fec_nh *);
 233 int              l2vpn_pw_negotiate(struct lde_nbr *, struct fec_node *,
 234                     struct map *);
 235 void             l2vpn_send_pw_status(struct lde_nbr *, uint32_t, struct fec *);
 236 void             l2vpn_send_pw_status_wcard(struct lde_nbr *, uint32_t,
 237                     uint16_t, uint32_t);
 238 void             l2vpn_recv_pw_status(struct lde_nbr *, struct notify_msg *);
 239 void             l2vpn_recv_pw_status_wcard(struct lde_nbr *,
 240                     struct notify_msg *);
 241 int              l2vpn_pw_status_update(struct zapi_pw_status *);
 242 void             l2vpn_pw_ctl(pid_t);
 243 void             l2vpn_binding_ctl(pid_t);
 244
 245 #endif  /* _LDE_H_ */