ldpd/ldpd.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 Esben Norby <norby@openbsd.org>
   7  * Copyright (c) 2003, 2004 Henning Brauer <henning@openbsd.org>
   8  *
   9  * Permission to use, copy, modify, and distribute this software for any
  10  * purpose with or without fee is hereby granted, provided that the above
  11  * copyright notice and this permission notice appear in all copies.
  12  *
  13  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
  14  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
  15  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
  16  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  17  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  18  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
  19  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  20  */
  21
  22 #ifndef _LDPD_H_
  23 #define _LDPD_H_
  24
  25 #include "queue.h"
  26 #include "openbsd-tree.h"
  27 #include "imsg.h"
  28 #include "thread.h"
  29 #include "qobj.h"
  30 #include "prefix.h"
  31 #include "filter.h"
  32 #include "vty.h"
  33 #include "pw.h"
  34 #include "zclient.h"
  35
  36 #include "ldp.h"
  37 #include "lib/ldp_sync.h"
  38
  39 #define CONF_FILE               "/etc/ldpd.conf"
  40 #define LDPD_USER               "_ldpd"
  41
  42 #define LDPD_FD_ASYNC           3
  43 #define LDPD_FD_SYNC            4
  44
  45 #define LDPD_OPT_VERBOSE        0x00000001
  46 #define LDPD_OPT_VERBOSE2       0x00000002
  47 #define LDPD_OPT_NOACTION       0x00000004
  48
  49 #define TCP_MD5_KEY_LEN         80
  50
  51 #define RT_BUF_SIZE             16384
  52 #define MAX_RTSOCK_BUF          128 * 1024
  53 #define LDP_BACKLOG             128
  54
  55 #define F_LDPD_INSERTED         0x0001
  56 #define F_CONNECTED             0x0002
  57 #define F_STATIC                0x0004
  58 #define F_DYNAMIC               0x0008
  59 #define F_REJECT                0x0010
  60 #define F_BLACKHOLE             0x0020
  61 #define F_REDISTRIBUTED         0x0040
  62
  63 struct evbuf {
  64         struct msgbuf            wbuf;
  65         struct thread           *ev;
  66         void (*handler)(struct thread *);
  67         void                    *arg;
  68 };
  69
  70 struct imsgev {
  71         struct imsgbuf           ibuf;
  72         void (*handler_write)(struct thread *);
  73         struct thread           *ev_write;
  74         void (*handler_read)(struct thread *);
  75         struct thread           *ev_read;
  76 };
  77
  78 enum imsg_type {
  79         IMSG_NONE,
  80         IMSG_CTL_RELOAD,
  81         IMSG_CTL_SHOW_INTERFACE,
  82         IMSG_CTL_SHOW_DISCOVERY,
  83         IMSG_CTL_SHOW_DISCOVERY_DTL,
  84         IMSG_CTL_SHOW_DISC_IFACE,
  85         IMSG_CTL_SHOW_DISC_TNBR,
  86         IMSG_CTL_SHOW_DISC_ADJ,
  87         IMSG_CTL_SHOW_NBR,
  88         IMSG_CTL_SHOW_NBR_DISC,
  89         IMSG_CTL_SHOW_NBR_END,
  90         IMSG_CTL_SHOW_LIB,
  91         IMSG_CTL_SHOW_LIB_BEGIN,
  92         IMSG_CTL_SHOW_LIB_SENT,
  93         IMSG_CTL_SHOW_LIB_RCVD,
  94         IMSG_CTL_SHOW_LIB_END,
  95         IMSG_CTL_SHOW_L2VPN_PW,
  96         IMSG_CTL_SHOW_L2VPN_BINDING,
  97         IMSG_CTL_SHOW_LDP_SYNC,
  98         IMSG_CTL_CLEAR_NBR,
  99         IMSG_CTL_FIB_COUPLE,
 100         IMSG_CTL_FIB_DECOUPLE,
 101         IMSG_CTL_KROUTE,
 102         IMSG_CTL_KROUTE_ADDR,
 103         IMSG_CTL_IFINFO,
 104         IMSG_CTL_END,
 105         IMSG_CTL_LOG_VERBOSE,
 106         IMSG_KLABEL_CHANGE,
 107         IMSG_KLABEL_DELETE,
 108         IMSG_KPW_ADD,
 109         IMSG_KPW_DELETE,
 110         IMSG_KPW_SET,
 111         IMSG_KPW_UNSET,
 112         IMSG_IFSTATUS,
 113         IMSG_NEWADDR,
 114         IMSG_DELADDR,
 115         IMSG_RTRID_UPDATE,
 116         IMSG_LABEL_MAPPING,
 117         IMSG_LABEL_MAPPING_FULL,
 118         IMSG_LABEL_REQUEST,
 119         IMSG_LABEL_RELEASE,
 120         IMSG_LABEL_WITHDRAW,
 121         IMSG_LABEL_ABORT,
 122         IMSG_REQUEST_ADD,
 123         IMSG_REQUEST_ADD_END,
 124         IMSG_MAPPING_ADD,
 125         IMSG_MAPPING_ADD_END,
 126         IMSG_RELEASE_ADD,
 127         IMSG_RELEASE_ADD_END,
 128         IMSG_WITHDRAW_ADD,
 129         IMSG_WITHDRAW_ADD_END,
 130         IMSG_ADDRESS_ADD,
 131         IMSG_ADDRESS_DEL,
 132         IMSG_NOTIFICATION,
 133         IMSG_NOTIFICATION_SEND,
 134         IMSG_NEIGHBOR_UP,
 135         IMSG_NEIGHBOR_DOWN,
 136         IMSG_NETWORK_ADD,
 137         IMSG_NETWORK_UPDATE,
 138         IMSG_SOCKET_IPC,
 139         IMSG_SOCKET_NET,
 140         IMSG_CLOSE_SOCKETS,
 141         IMSG_REQUEST_SOCKETS,
 142         IMSG_SETUP_SOCKETS,
 143         IMSG_RECONF_CONF,
 144         IMSG_RECONF_IFACE,
 145         IMSG_RECONF_TNBR,
 146         IMSG_RECONF_NBRP,
 147         IMSG_RECONF_L2VPN,
 148         IMSG_RECONF_L2VPN_IF,
 149         IMSG_RECONF_L2VPN_PW,
 150         IMSG_RECONF_L2VPN_IPW,
 151         IMSG_RECONF_END,
 152         IMSG_DEBUG_UPDATE,
 153         IMSG_LOG,
 154         IMSG_ACL_CHECK,
 155         IMSG_INIT,
 156         IMSG_PW_UPDATE,
 157         IMSG_FILTER_UPDATE,
 158         IMSG_NBR_SHUTDOWN,
 159         IMSG_LDP_SYNC_IF_STATE_REQUEST,
 160         IMSG_LDP_SYNC_IF_STATE_UPDATE,
 161         IMSG_RLFA_REG,
 162         IMSG_RLFA_UNREG_ALL,
 163         IMSG_RLFA_LABELS,
 164         IMSG_AGENTX_ENABLED,
 165 };
 166
 167 struct ldpd_init {
 168         char             user[256];
 169         char             group[256];
 170         char             ctl_sock_path[MAXPATHLEN];
 171         char             zclient_serv_path[MAXPATHLEN];
 172         unsigned short instance;
 173 };
 174
 175 struct ldp_access {
 176         char                     name[ACL_NAMSIZ];
 177 };
 178
 179 union ldpd_addr {
 180         struct in_addr  v4;
 181         struct in6_addr v6;
 182 };
 183
 184 #define IN6_IS_SCOPE_EMBED(a)   \
 185         ((IN6_IS_ADDR_LINKLOCAL(a)) ||  \
 186          (IN6_IS_ADDR_MC_LINKLOCAL(a)) || \
 187          (IN6_IS_ADDR_MC_INTFACELOCAL(a)))
 188
 189 /* interface states */
 190 #define IF_STA_DOWN             0x01
 191 #define IF_STA_ACTIVE           0x02
 192
 193 /* targeted neighbor states */
 194 #define TNBR_STA_DOWN           0x01
 195 #define TNBR_STA_ACTIVE         0x02
 196
 197 /* interface types */
 198 enum iface_type {
 199         IF_TYPE_POINTOPOINT,
 200         IF_TYPE_BROADCAST
 201 };
 202
 203 /* neighbor states */
 204 #define NBR_STA_PRESENT         0x0001
 205 #define NBR_STA_INITIAL         0x0002
 206 #define NBR_STA_OPENREC         0x0004
 207 #define NBR_STA_OPENSENT        0x0008
 208 #define NBR_STA_OPER            0x0010
 209 #define NBR_STA_SESSION         (NBR_STA_INITIAL | NBR_STA_OPENREC | \
 210                                 NBR_STA_OPENSENT | NBR_STA_OPER)
 211
 212 /* neighbor events */
 213 enum nbr_event {
 214         NBR_EVT_NOTHING,
 215         NBR_EVT_MATCH_ADJ,
 216         NBR_EVT_CONNECT_UP,
 217         NBR_EVT_CLOSE_SESSION,
 218         NBR_EVT_INIT_RCVD,
 219         NBR_EVT_KEEPALIVE_RCVD,
 220         NBR_EVT_PDU_RCVD,
 221         NBR_EVT_PDU_SENT,
 222         NBR_EVT_INIT_SENT
 223 };
 224
 225 /* neighbor actions */
 226 enum nbr_action {
 227         NBR_ACT_NOTHING,
 228         NBR_ACT_RST_KTIMEOUT,
 229         NBR_ACT_SESSION_EST,
 230         NBR_ACT_RST_KTIMER,
 231         NBR_ACT_CONNECT_SETUP,
 232         NBR_ACT_PASSIVE_INIT,
 233         NBR_ACT_KEEPALIVE_SEND,
 234         NBR_ACT_CLOSE_SESSION
 235 };
 236
 237 /* LDP IGP Sync states */
 238 #define LDP_SYNC_STA_UNKNOWN    0x0000
 239 #define LDP_SYNC_STA_NOT_ACH    0x0001
 240 #define LDP_SYNC_STA_ACH        0x0002
 241
 242 /* LDP IGP Sync events */
 243 enum ldp_sync_event {
 244         LDP_SYNC_EVT_NOTHING,
 245         LDP_SYNC_EVT_LDP_SYNC_START,
 246         LDP_SYNC_EVT_LDP_SYNC_COMPLETE,
 247         LDP_SYNC_EVT_CONFIG_LDP_OFF,
 248         LDP_SYNC_EVT_ADJ_DEL,
 249         LDP_SYNC_EVT_ADJ_NEW,
 250         LDP_SYNC_EVT_SESSION_CLOSE,
 251         LDP_SYNC_EVT_CONFIG_LDP_ON,
 252         LDP_SYNC_EVT_IFACE_SHUTDOWN
 253 };
 254
 255 /* LDP IGP Sync actions */
 256 enum ldp_sync_action {
 257         LDP_SYNC_ACT_NOTHING,
 258         LDP_SYNC_ACT_IFACE_START_SYNC,
 259         LDP_SYNC_ACT_LDP_START_SYNC,
 260         LDP_SYNC_ACT_LDP_COMPLETE_SYNC,
 261         LDP_SYNC_ACT_CONFIG_LDP_OFF,
 262         LDP_SYNC_ACT_IFACE_SHUTDOWN
 263 };
 264
 265 /* forward declarations */
 266 RB_HEAD(global_adj_head, adj);
 267 RB_HEAD(nbr_adj_head, adj);
 268 RB_HEAD(ia_adj_head, adj);
 269
 270 struct map {
 271         uint8_t         type;
 272         uint32_t        msg_id;
 273         union {
 274                 struct {
 275                         uint16_t        af;
 276                         union ldpd_addr prefix;
 277                         uint8_t         prefixlen;
 278                 } prefix;
 279                 struct {
 280                         uint16_t        type;
 281                         uint32_t        pwid;
 282                         uint32_t        group_id;
 283                         uint16_t        ifmtu;
 284                 } pwid;
 285                 struct {
 286                         uint8_t         type;
 287                         union {
 288                                 uint16_t        prefix_af;
 289                                 uint16_t        pw_type;
 290                         } u;
 291                 } twcard;
 292         } fec;
 293         struct {
 294                 uint32_t        status_code;
 295                 uint32_t        msg_id;
 296                 uint16_t        msg_type;
 297         } st;
 298         uint32_t        label;
 299         uint32_t        requestid;
 300         uint32_t        pw_status;
 301         uint8_t         flags;
 302 };
 303 #define F_MAP_REQ_ID    0x01    /* optional request message id present */
 304 #define F_MAP_STATUS    0x02    /* status */
 305 #define F_MAP_PW_CWORD  0x04    /* pseudowire control word */
 306 #define F_MAP_PW_ID     0x08    /* pseudowire connection id */
 307 #define F_MAP_PW_IFMTU  0x10    /* pseudowire interface parameter */
 308 #define F_MAP_PW_STATUS 0x20    /* pseudowire status */
 309
 310 struct notify_msg {
 311         uint32_t        status_code;
 312         uint32_t        msg_id;         /* network byte order */
 313         uint16_t        msg_type;       /* network byte order */
 314         uint32_t        pw_status;
 315         struct map      fec;
 316         struct {
 317                 uint16_t         type;
 318                 uint16_t         length;
 319                 char            *data;
 320         } rtlvs;
 321         uint8_t         flags;
 322 };
 323 #define F_NOTIF_PW_STATUS       0x01    /* pseudowire status tlv present */
 324 #define F_NOTIF_FEC             0x02    /* fec tlv present */
 325 #define F_NOTIF_RETURNED_TLVS   0x04    /* returned tlvs present */
 326
 327 struct if_addr {
 328         LIST_ENTRY(if_addr)      entry;
 329         int                      af;
 330         union ldpd_addr          addr;
 331         uint8_t                  prefixlen;
 332         union ldpd_addr          dstbrd;
 333 };
 334 LIST_HEAD(if_addr_head, if_addr);
 335
 336 struct iface_af {
 337         struct iface            *iface;
 338         int                      af;
 339         int                      enabled;
 340         int                      state;
 341         struct ia_adj_head       adj_tree;
 342         time_t                   uptime;
 343         struct thread           *hello_timer;
 344         uint16_t                 hello_holdtime;
 345         uint16_t                 hello_interval;
 346 };
 347
 348 struct iface_ldp_sync {
 349         int                      state;
 350         struct thread           *wait_for_sync_timer;
 351 };
 352
 353 struct iface {
 354         RB_ENTRY(iface)          entry;
 355         char                     name[INTERFACE_NAMSIZ];
 356         ifindex_t                ifindex;
 357         struct if_addr_head      addr_list;
 358         struct in6_addr          linklocal;
 359         enum iface_type          type;
 360         int                      operative;
 361         struct iface_af          ipv4;
 362         struct iface_af          ipv6;
 363         struct iface_ldp_sync    ldp_sync;
 364         QOBJ_FIELDS;
 365 };
 366 RB_HEAD(iface_head, iface);
 367 RB_PROTOTYPE(iface_head, iface, entry, iface_compare);
 368 DECLARE_QOBJ_TYPE(iface);
 369
 370 /* source of targeted hellos */
 371 struct tnbr {
 372         RB_ENTRY(tnbr)           entry;
 373         struct thread           *hello_timer;
 374         struct adj              *adj;
 375         int                      af;
 376         union ldpd_addr          addr;
 377         int                      state;
 378         uint16_t                 pw_count;
 379         uint32_t                 rlfa_count;
 380         uint8_t                  flags;
 381         QOBJ_FIELDS;
 382 };
 383 RB_HEAD(tnbr_head, tnbr);
 384 RB_PROTOTYPE(tnbr_head, tnbr, entry, tnbr_compare);
 385 DECLARE_QOBJ_TYPE(tnbr);
 386 #define F_TNBR_CONFIGURED        0x01
 387 #define F_TNBR_DYNAMIC           0x02
 388
 389 enum auth_method {
 390         AUTH_NONE,
 391         AUTH_MD5SIG
 392 };
 393
 394 /* neighbor specific parameters */
 395 struct nbr_params {
 396         RB_ENTRY(nbr_params)     entry;
 397         struct in_addr           lsr_id;
 398         uint16_t                 keepalive;
 399         int                      gtsm_enabled;
 400         uint8_t                  gtsm_hops;
 401         struct {
 402                 enum auth_method         method;
 403                 char                     md5key[TCP_MD5_KEY_LEN];
 404                 uint8_t                  md5key_len;
 405         } auth;
 406         uint8_t                  flags;
 407         QOBJ_FIELDS;
 408 };
 409 RB_HEAD(nbrp_head, nbr_params);
 410 RB_PROTOTYPE(nbrp_head, nbr_params, entry, nbr_params_compare);
 411 DECLARE_QOBJ_TYPE(nbr_params);
 412 #define F_NBRP_KEEPALIVE         0x01
 413 #define F_NBRP_GTSM              0x02
 414 #define F_NBRP_GTSM_HOPS         0x04
 415
 416 struct ldp_stats {
 417         uint32_t                 kalive_sent;
 418         uint32_t                 kalive_rcvd;
 419         uint32_t                 addr_sent;
 420         uint32_t                 addr_rcvd;
 421         uint32_t                 addrwdraw_sent;
 422         uint32_t                 addrwdraw_rcvd;
 423         uint32_t                 notif_sent;
 424         uint32_t                 notif_rcvd;
 425         uint32_t                 capability_sent;
 426         uint32_t                 capability_rcvd;
 427         uint32_t                 labelmap_sent;
 428         uint32_t                 labelmap_rcvd;
 429         uint32_t                 labelreq_sent;
 430         uint32_t                 labelreq_rcvd;
 431         uint32_t                 labelwdraw_sent;
 432         uint32_t                 labelwdraw_rcvd;
 433         uint32_t                 labelrel_sent;
 434         uint32_t                 labelrel_rcvd;
 435         uint32_t                 labelabreq_sent;
 436         uint32_t                 labelabreq_rcvd;
 437         uint32_t                 unknown_tlv;
 438         uint32_t                 unknown_msg;
 439
 440 };
 441
 442 struct ldp_entity_stats {
 443         uint32_t                 session_attempts;
 444         uint32_t                 session_rejects_hello;
 445         uint32_t                 session_rejects_ad;
 446         uint32_t                 session_rejects_max_pdu;
 447         uint32_t                 session_rejects_lr;
 448         uint32_t                 bad_ldp_id;
 449         uint32_t                 bad_pdu_len;
 450         uint32_t                 bad_msg_len;
 451         uint32_t                 bad_tlv_len;
 452         uint32_t                 malformed_tlv;
 453         uint32_t                 keepalive_timer_exp;
 454         uint32_t                 shutdown_rcv_notify;
 455         uint32_t                 shutdown_send_notify;
 456 };
 457
 458 struct l2vpn_if {
 459         RB_ENTRY(l2vpn_if)       entry;
 460         struct l2vpn            *l2vpn;
 461         char                     ifname[INTERFACE_NAMSIZ];
 462         ifindex_t                ifindex;
 463         int                      operative;
 464         uint8_t                  mac[ETH_ALEN];
 465         QOBJ_FIELDS;
 466 };
 467 RB_HEAD(l2vpn_if_head, l2vpn_if);
 468 RB_PROTOTYPE(l2vpn_if_head, l2vpn_if, entry, l2vpn_if_compare);
 469 DECLARE_QOBJ_TYPE(l2vpn_if);
 470
 471 struct l2vpn_pw {
 472         RB_ENTRY(l2vpn_pw)       entry;
 473         struct l2vpn            *l2vpn;
 474         struct in_addr           lsr_id;
 475         int                      af;
 476         union ldpd_addr          addr;
 477         uint32_t                 pwid;
 478         char                     ifname[INTERFACE_NAMSIZ];
 479         ifindex_t                ifindex;
 480         bool                     enabled;
 481         uint32_t                 remote_group;
 482         uint16_t                 remote_mtu;
 483         uint32_t                 local_status;
 484         uint32_t                 remote_status;
 485         uint8_t                  flags;
 486         uint8_t                  reason;
 487         QOBJ_FIELDS;
 488 };
 489 RB_HEAD(l2vpn_pw_head, l2vpn_pw);
 490 RB_PROTOTYPE(l2vpn_pw_head, l2vpn_pw, entry, l2vpn_pw_compare);
 491 DECLARE_QOBJ_TYPE(l2vpn_pw);
 492 #define F_PW_STATUSTLV_CONF     0x01    /* status tlv configured */
 493 #define F_PW_STATUSTLV          0x02    /* status tlv negotiated */
 494 #define F_PW_CWORD_CONF         0x04    /* control word configured */
 495 #define F_PW_CWORD              0x08    /* control word negotiated */
 496 #define F_PW_STATIC_NBR_ADDR    0x10    /* static neighbor address configured */
 497
 498 #define F_PW_NO_ERR             0x00    /* no error reported */
 499 #define F_PW_LOCAL_NOT_FWD      0x01    /* locally can't forward over PW */
 500 #define F_PW_REMOTE_NOT_FWD     0x02    /* remote end of PW reported fwd error*/
 501 #define F_PW_NO_REMOTE_LABEL    0x03    /* have not recvd label from peer */
 502 #define F_PW_MTU_MISMATCH       0x04    /* mtu mismatch between peers */
 503
 504 struct l2vpn {
 505         RB_ENTRY(l2vpn)          entry;
 506         char                     name[L2VPN_NAME_LEN];
 507         int                      type;
 508         int                      pw_type;
 509         int                      mtu;
 510         char                     br_ifname[INTERFACE_NAMSIZ];
 511         ifindex_t                br_ifindex;
 512         struct l2vpn_if_head     if_tree;
 513         struct l2vpn_pw_head     pw_tree;
 514         struct l2vpn_pw_head     pw_inactive_tree;
 515         QOBJ_FIELDS;
 516 };
 517 RB_HEAD(l2vpn_head, l2vpn);
 518 RB_PROTOTYPE(l2vpn_head, l2vpn, entry, l2vpn_compare);
 519 DECLARE_QOBJ_TYPE(l2vpn);
 520 #define L2VPN_TYPE_VPWS         1
 521 #define L2VPN_TYPE_VPLS         2
 522
 523 /* ldp_conf */
 524 extern enum ldpd_process {
 525         PROC_MAIN,
 526         PROC_LDP_ENGINE,
 527         PROC_LDE_ENGINE
 528 } ldpd_process;
 529
 530 static const char * const log_procnames[] = {
 531         "parent",
 532         "ldpe",
 533         "lde"
 534 };
 535
 536 enum socket_type {
 537         LDP_SOCKET_DISC,
 538         LDP_SOCKET_EDISC,
 539         LDP_SOCKET_SESSION
 540 };
 541
 542 enum hello_type {
 543         HELLO_LINK,
 544         HELLO_TARGETED
 545 };
 546
 547 struct ldpd_af_conf {
 548         uint16_t                 keepalive;
 549         uint16_t                 lhello_holdtime;
 550         uint16_t                 lhello_interval;
 551         uint16_t                 thello_holdtime;
 552         uint16_t                 thello_interval;
 553         union ldpd_addr          trans_addr;
 554         char                     acl_thello_accept_from[ACL_NAMSIZ];
 555         char                     acl_label_allocate_for[ACL_NAMSIZ];
 556         char                     acl_label_advertise_to[ACL_NAMSIZ];
 557         char                     acl_label_advertise_for[ACL_NAMSIZ];
 558         char                     acl_label_expnull_for[ACL_NAMSIZ];
 559         char                     acl_label_accept_from[ACL_NAMSIZ];
 560         char                     acl_label_accept_for[ACL_NAMSIZ];
 561         int                      flags;
 562 };
 563 #define F_LDPD_AF_ENABLED       0x0001
 564 #define F_LDPD_AF_THELLO_ACCEPT 0x0002
 565 #define F_LDPD_AF_EXPNULL       0x0004
 566 #define F_LDPD_AF_NO_GTSM       0x0008
 567 #define F_LDPD_AF_ALLOCHOSTONLY 0x0010
 568
 569 struct ldpd_conf {
 570         struct in_addr           rtr_id;
 571         struct ldpd_af_conf      ipv4;
 572         struct ldpd_af_conf      ipv6;
 573         struct iface_head        iface_tree;
 574         struct tnbr_head         tnbr_tree;
 575         struct nbrp_head         nbrp_tree;
 576         struct l2vpn_head        l2vpn_tree;
 577         uint16_t                 lhello_holdtime;
 578         uint16_t                 lhello_interval;
 579         uint16_t                 thello_holdtime;
 580         uint16_t                 thello_interval;
 581         uint16_t                 trans_pref;
 582         uint16_t                 wait_for_sync_interval;
 583         int                      flags;
 584         time_t                   config_change_time;
 585         struct ldp_entity_stats  stats;
 586         QOBJ_FIELDS;
 587 };
 588 DECLARE_QOBJ_TYPE(ldpd_conf);
 589 #define F_LDPD_NO_FIB_UPDATE    0x0001
 590 #define F_LDPD_DS_CISCO_INTEROP 0x0002
 591 #define F_LDPD_ENABLED          0x0004
 592 #define F_LDPD_ORDERED_CONTROL  0x0008
 593 #define F_LDPD_ALLOW_BROKEN_LSP 0x0010
 594
 595 struct ldpd_af_global {
 596         struct thread           *disc_ev;
 597         struct thread           *edisc_ev;
 598         int                      ldp_disc_socket;
 599         int                      ldp_edisc_socket;
 600         int                      ldp_session_socket;
 601 };
 602
 603 struct ldpd_global {
 604         int                      cmd_opts;
 605         struct in_addr           rtr_id;
 606         struct ldpd_af_global    ipv4;
 607         struct ldpd_af_global    ipv6;
 608         uint32_t                 conf_seqnum;
 609         int                      pfkeysock;
 610         struct if_addr_head      addr_list;
 611         struct global_adj_head   adj_tree;
 612         struct in_addr           mcast_addr_v4;
 613         struct in6_addr          mcast_addr_v6;
 614         TAILQ_HEAD(, pending_conn) pending_conns;
 615 };
 616
 617 /* kroute */
 618 struct kroute {
 619         int                      af;
 620         union ldpd_addr          prefix;
 621         uint8_t                  prefixlen;
 622         union ldpd_addr          nexthop;
 623         uint32_t                 local_label;
 624         uint32_t                 remote_label;
 625         ifindex_t                ifindex;
 626         uint8_t                  route_type;
 627         uint8_t                  route_instance;
 628         uint16_t                 flags;
 629 };
 630
 631 struct kaddr {
 632         char                     ifname[INTERFACE_NAMSIZ];
 633         ifindex_t                ifindex;
 634         int                      af;
 635         union ldpd_addr          addr;
 636         uint8_t                  prefixlen;
 637         union ldpd_addr          dstbrd;
 638 };
 639
 640 struct kif {
 641         char                     ifname[INTERFACE_NAMSIZ];
 642         ifindex_t                ifindex;
 643         int                      flags;
 644         int                      operative;
 645         uint8_t                  mac[ETH_ALEN];
 646         int                      mtu;
 647 };
 648
 649 struct acl_check {
 650         char                     acl[ACL_NAMSIZ];
 651         int                      af;
 652         union ldpd_addr          addr;
 653         uint8_t                  prefixlen;
 654 };
 655
 656 /* control data structures */
 657 struct ctl_iface {
 658         int                      af;
 659         char                     name[INTERFACE_NAMSIZ];
 660         ifindex_t                ifindex;
 661         int                      state;
 662         enum iface_type          type;
 663         uint16_t                 hello_holdtime;
 664         uint16_t                 hello_interval;
 665         time_t                   uptime;
 666         uint16_t                 adj_cnt;
 667 };
 668
 669 struct ctl_disc_if {
 670         char                     name[INTERFACE_NAMSIZ];
 671         int                      active_v4;
 672         int                      active_v6;
 673         int                      no_adj;
 674 };
 675
 676 struct ctl_disc_tnbr {
 677         int                      af;
 678         union ldpd_addr          addr;
 679         int                      no_adj;
 680 };
 681
 682 struct ctl_adj {
 683         int                      af;
 684         struct in_addr           id;
 685         enum hello_type          type;
 686         char                     ifname[INTERFACE_NAMSIZ];
 687         union ldpd_addr          src_addr;
 688         uint16_t                 holdtime;
 689         uint16_t                 holdtime_remaining;
 690         union ldpd_addr          trans_addr;
 691         int                      ds_tlv;
 692 };
 693
 694 struct ctl_nbr {
 695         int                      af;
 696         struct in_addr           id;
 697         union ldpd_addr          laddr;
 698         in_port_t                lport;
 699         union ldpd_addr          raddr;
 700         in_port_t                rport;
 701         enum auth_method         auth_method;
 702         uint16_t                 holdtime;
 703         time_t                   uptime;
 704         int                      nbr_state;
 705         struct ldp_stats         stats;
 706         int                      flags;
 707         uint16_t                 max_pdu_len;
 708         uint16_t                 hold_time_remaining;
 709 };
 710
 711 struct ctl_rt {
 712         int                      af;
 713         union ldpd_addr          prefix;
 714         uint8_t                  prefixlen;
 715         struct in_addr           nexthop;       /* lsr-id */
 716         uint32_t                 local_label;
 717         uint32_t                 remote_label;
 718         uint8_t                  flags;
 719         uint8_t                  in_use;
 720         int                      no_downstream;
 721 };
 722
 723 struct ctl_pw {
 724         uint16_t                 type;
 725         char                     l2vpn_name[L2VPN_NAME_LEN];
 726         char                     ifname[INTERFACE_NAMSIZ];
 727         uint32_t                 pwid;
 728         struct in_addr           lsr_id;
 729         uint32_t                 local_label;
 730         uint32_t                 local_gid;
 731         uint16_t                 local_ifmtu;
 732         uint8_t                  local_cword;
 733         uint32_t                 remote_label;
 734         uint32_t                 remote_gid;
 735         uint16_t                 remote_ifmtu;
 736         uint8_t                  remote_cword;
 737         uint32_t                 status;
 738         uint8_t                  reason;
 739 };
 740
 741 struct ctl_ldp_sync {
 742         char                     name[INTERFACE_NAMSIZ];
 743         ifindex_t                ifindex;
 744         bool                     in_sync;
 745         bool                     timer_running;
 746         uint16_t                 wait_time;
 747         uint16_t                 wait_time_remaining;
 748         struct in_addr           peer_ldp_id;
 749 };
 750
 751 extern struct ldpd_conf         *ldpd_conf, *vty_conf;
 752 extern struct ldpd_global        global;
 753 extern struct ldpd_init          init;
 754
 755 /* parse.y */
 756 struct ldpd_conf        *parse_config(char *);
 757 int                      cmdline_symset(char *);
 758
 759 /* kroute.c */
 760 void             pw2zpw(struct l2vpn_pw *, struct zapi_pw *);
 761 void             kif_redistribute(const char *);
 762 int              kr_change(struct kroute *);
 763 int              kr_delete(struct kroute *);
 764 int              kmpw_add(struct zapi_pw *);
 765 int              kmpw_del(struct zapi_pw *);
 766 int              kmpw_set(struct zapi_pw *);
 767 int              kmpw_unset(struct zapi_pw *);
 768
 769 /* util.c */
 770 uint8_t          mask2prefixlen(in_addr_t);
 771 uint8_t          mask2prefixlen6(struct sockaddr_in6 *);
 772 in_addr_t        prefixlen2mask(uint8_t);
 773 struct in6_addr *prefixlen2mask6(uint8_t);
 774 void             ldp_applymask(int, union ldpd_addr *,
 775                     const union ldpd_addr *, int);
 776 int              ldp_addrcmp(int, const union ldpd_addr *,
 777                     const union ldpd_addr *);
 778 int              ldp_addrisset(int, const union ldpd_addr *);
 779 int              ldp_prefixcmp(int, const union ldpd_addr *,
 780                     const union ldpd_addr *, uint8_t);
 781 int              bad_addr_v4(struct in_addr);
 782 int              bad_addr_v6(struct in6_addr *);
 783 int              bad_addr(int, union ldpd_addr *);
 784 void             embedscope(struct sockaddr_in6 *);
 785 void             recoverscope(struct sockaddr_in6 *);
 786 void             addscope(struct sockaddr_in6 *, uint32_t);
 787 void             clearscope(struct in6_addr *);
 788 void             addr2sa(int af, const union ldpd_addr *, uint16_t,
 789                     union sockunion *su);
 790 void             sa2addr(struct sockaddr *, int *, union ldpd_addr *,
 791                     in_port_t *);
 792 socklen_t        sockaddr_len(struct sockaddr *);
 793
 794 /* ldpd.c */
 795 void ldp_write_handler(struct thread *thread);
 796 void                     main_imsg_compose_ldpe(int, pid_t, void *, uint16_t);
 797 void                     main_imsg_compose_lde(int, pid_t, void *, uint16_t);
 798 int                      main_imsg_compose_both(enum imsg_type, void *,
 799                             uint16_t);
 800 void                     imsg_event_add(struct imsgev *);
 801 int                      imsg_compose_event(struct imsgev *, uint16_t, uint32_t,
 802                             pid_t, int, void *, uint16_t);
 803 void                     evbuf_enqueue(struct evbuf *, struct ibuf *);
 804 void                     evbuf_event_add(struct evbuf *);
 805 void evbuf_init(struct evbuf *, int, void (*)(struct thread *), void *);
 806 void                     evbuf_clear(struct evbuf *);
 807 int                      ldp_acl_request(struct imsgev *, char *, int,
 808                             union ldpd_addr *, uint8_t);
 809 void                     ldp_acl_reply(struct imsgev *, struct acl_check *);
 810 struct ldpd_af_conf     *ldp_af_conf_get(struct ldpd_conf *, int);
 811 struct ldpd_af_global   *ldp_af_global_get(struct ldpd_global *, int);
 812 int                      ldp_is_dual_stack(struct ldpd_conf *);
 813 in_addr_t                ldp_rtr_id_get(struct ldpd_conf *);
 814 int                      ldp_config_apply(struct vty *, struct ldpd_conf *);
 815 void                     ldp_clear_config(struct ldpd_conf *);
 816 void                     merge_config(struct ldpd_conf *, struct ldpd_conf *);
 817 struct ldpd_conf        *config_new_empty(void);
 818 void                     config_clear(struct ldpd_conf *);
 819
 820 /* ldp_vty_conf.c */
 821 /* NOTE: the parameters' names should be preserved because of codegen */
 822 struct iface            *iface_new_api(struct ldpd_conf *conf,
 823                             const char *name);
 824 void                     iface_del_api(struct ldpd_conf *conf,
 825                             struct iface *iface);
 826 struct tnbr             *tnbr_new_api(struct ldpd_conf *conf, int af,
 827                             union ldpd_addr *addr);
 828 void                     tnbr_del_api(struct ldpd_conf *conf, struct tnbr *tnbr);
 829 struct nbr_params       *nbrp_new_api(struct ldpd_conf *conf,
 830                             struct in_addr lsr_id);
 831 void                     nbrp_del_api(struct ldpd_conf *conf,
 832                             struct nbr_params *nbrp);
 833 struct l2vpn            *l2vpn_new_api(struct ldpd_conf *conf, const char *name);
 834 void                     l2vpn_del_api(struct ldpd_conf *conf,
 835                             struct l2vpn *l2vpn);
 836 struct l2vpn_if         *l2vpn_if_new_api(struct ldpd_conf *conf,
 837                             struct l2vpn *l2vpn, const char *ifname);
 838 void                     l2vpn_if_del_api(struct l2vpn *l2vpn,
 839                            struct l2vpn_if *lif);
 840 struct l2vpn_pw         *l2vpn_pw_new_api(struct ldpd_conf *conf,
 841                             struct l2vpn *l2vpn, const char *ifname);
 842 void                     l2vpn_pw_del_api(struct l2vpn *l2vpn,
 843                             struct l2vpn_pw *pw);
 844
 845 /* socket.c */
 846 int              ldp_create_socket(int, enum socket_type);
 847 void             sock_set_nonblock(int);
 848 void             sock_set_cloexec(int);
 849 void             sock_set_recvbuf(int);
 850 int              sock_set_reuse(int, int);
 851 int              sock_set_bindany(int, int);
 852 int              sock_set_md5sig(int, int, union ldpd_addr *, const char *);
 853 int              sock_set_ipv4_tos(int, int);
 854 int              sock_set_ipv4_pktinfo(int, int);
 855 int              sock_set_ipv4_recvdstaddr(int fd, ifindex_t ifindex);
 856 int              sock_set_ipv4_recvif(int, int);
 857 int              sock_set_ipv4_minttl(int, int);
 858 int              sock_set_ipv4_ucast_ttl(int fd, int);
 859 int              sock_set_ipv4_mcast_ttl(int, uint8_t);
 860 int              sock_set_ipv4_mcast(struct iface *);
 861 int              sock_set_ipv4_mcast_loop(int);
 862 int              sock_set_ipv6_dscp(int, int);
 863 int              sock_set_ipv6_pktinfo(int, int);
 864 int              sock_set_ipv6_minhopcount(int, int);
 865 int              sock_set_ipv6_ucast_hops(int, int);
 866 int              sock_set_ipv6_mcast_hops(int, int);
 867 int              sock_set_ipv6_mcast(struct iface *);
 868 int              sock_set_ipv6_mcast_loop(int);
 869
 870 /* logmsg.h */
 871 struct in6_addr;
 872 union ldpd_addr;
 873 struct hello_source;
 874 struct fec;
 875
 876 const char      *log_sockaddr(void *);
 877 const char      *log_in6addr(const struct in6_addr *);
 878 const char      *log_in6addr_scope(const struct in6_addr *addr,
 879                                    ifindex_t ifidx);
 880 const char      *log_addr(int, const union ldpd_addr *);
 881 char            *log_label(uint32_t);
 882 const char      *log_time(time_t);
 883 char            *log_hello_src(const struct hello_source *);
 884 const char      *log_map(const struct map *);
 885 const char      *log_fec(const struct fec *);
 886 const char      *af_name(int);
 887 const char      *socket_name(int);
 888 const char      *nbr_state_name(int);
 889 const char      *if_state_name(int);
 890 const char      *if_type_name(enum iface_type);
 891 const char      *msg_name(uint16_t);
 892 const char      *status_code_name(uint32_t);
 893 const char      *pw_type_name(uint16_t);
 894 const char      *pw_error_code(uint8_t);
 895
 896 /* quagga */
 897 extern struct thread_master     *master;
 898 extern char                      ctl_sock_path[MAXPATHLEN];
 899
 900 /* ldp_zebra.c */
 901 void             ldp_zebra_init(struct thread_master *);
 902 void             ldp_zebra_destroy(void);
 903 int              ldp_sync_zebra_send_state_update(struct ldp_igp_sync_if_state *);
 904 int              ldp_zebra_send_rlfa_labels(struct zapi_rlfa_response *
 905                     rlfa_labels);
 906
 907 void ldp_zebra_regdereg_zebra_info(bool want_register);
 908
 909 /* compatibility */
 910 #ifndef __OpenBSD__
 911 #define __IPV6_ADDR_MC_SCOPE(a)         ((a)->s6_addr[1] & 0x0f)
 912 #define __IPV6_ADDR_SCOPE_INTFACELOCAL  0x01
 913 #define IN6_IS_ADDR_MC_INTFACELOCAL(a)  \
 914         (IN6_IS_ADDR_MULTICAST(a) &&    \
 915         (__IPV6_ADDR_MC_SCOPE(a) == __IPV6_ADDR_SCOPE_INTFACELOCAL))
 916 #endif
 917
 918 DECLARE_HOOK(ldp_register_mib, (struct thread_master * tm), (tm));
 919
 920 extern void ldp_agentx_enabled(void);
 921
 922 #endif  /* _LDPD_H_ */