summaryrefslogtreecommitdiffstats
path: root/ldpd/ldpd.h
blob: fd0097ca5e76eb0625b398d701b9c71895727002 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
/*	$OpenBSD$ */

/*
 * Copyright (c) 2013, 2016 Renato Westphal <renato@openbsd.org>
 * Copyright (c) 2009 Michele Marchetto <michele@openbsd.org>
 * Copyright (c) 2004 Esben Norby <norby@openbsd.org>
 * Copyright (c) 2003, 2004 Henning Brauer <henning@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 _LDPD_H_
#define _LDPD_H_

#include "queue.h"
#include "openbsd-tree.h"
#include "imsg.h"
#include "thread.h"
#include "qobj.h"
#include "prefix.h"
#include "filter.h"
#include "vty.h"
#include "pw.h"
#include "zclient.h"

#include "ldp.h"
#include "lib/ldp_sync.h"

#define CONF_FILE		"/etc/ldpd.conf"
#define LDPD_USER		"_ldpd"

#define LDPD_FD_ASYNC		3
#define LDPD_FD_SYNC		4

#define LDPD_OPT_VERBOSE	0x00000001
#define LDPD_OPT_VERBOSE2	0x00000002
#define LDPD_OPT_NOACTION	0x00000004

#define TCP_MD5_KEY_LEN		80

#define	RT_BUF_SIZE		16384
#define	MAX_RTSOCK_BUF		128 * 1024
#define	LDP_BACKLOG		128

#define	F_LDPD_INSERTED		0x0001
#define	F_CONNECTED		0x0002
#define	F_STATIC		0x0004
#define	F_DYNAMIC		0x0008
#define	F_REJECT		0x0010
#define	F_BLACKHOLE		0x0020
#define	F_REDISTRIBUTED		0x0040

struct evbuf {
	struct msgbuf		 wbuf;
	struct thread		*ev;
	void (*handler)(struct thread *);
	void			*arg;
};

struct imsgev {
	struct imsgbuf		 ibuf;
	void (*handler_write)(struct thread *);
	struct thread		*ev_write;
	void (*handler_read)(struct thread *);
	struct thread		*ev_read;
};

enum imsg_type {
	IMSG_NONE,
	IMSG_CTL_RELOAD,
	IMSG_CTL_SHOW_INTERFACE,
	IMSG_CTL_SHOW_DISCOVERY,
	IMSG_CTL_SHOW_DISCOVERY_DTL,
	IMSG_CTL_SHOW_DISC_IFACE,
	IMSG_CTL_SHOW_DISC_TNBR,
	IMSG_CTL_SHOW_DISC_ADJ,
	IMSG_CTL_SHOW_NBR,
	IMSG_CTL_SHOW_NBR_DISC,
	IMSG_CTL_SHOW_NBR_END,
	IMSG_CTL_SHOW_LIB,
	IMSG_CTL_SHOW_LIB_BEGIN,
	IMSG_CTL_SHOW_LIB_SENT,
	IMSG_CTL_SHOW_LIB_RCVD,
	IMSG_CTL_SHOW_LIB_END,
	IMSG_CTL_SHOW_L2VPN_PW,
	IMSG_CTL_SHOW_L2VPN_BINDING,
	IMSG_CTL_SHOW_LDP_SYNC,
	IMSG_CTL_CLEAR_NBR,
	IMSG_CTL_FIB_COUPLE,
	IMSG_CTL_FIB_DECOUPLE,
	IMSG_CTL_KROUTE,
	IMSG_CTL_KROUTE_ADDR,
	IMSG_CTL_IFINFO,
	IMSG_CTL_END,
	IMSG_CTL_LOG_VERBOSE,
	IMSG_KLABEL_CHANGE,
	IMSG_KLABEL_DELETE,
	IMSG_KPW_ADD,
	IMSG_KPW_DELETE,
	IMSG_KPW_SET,
	IMSG_KPW_UNSET,
	IMSG_IFSTATUS,
	IMSG_NEWADDR,
	IMSG_DELADDR,
	IMSG_RTRID_UPDATE,
	IMSG_LABEL_MAPPING,
	IMSG_LABEL_MAPPING_FULL,
	IMSG_LABEL_REQUEST,
	IMSG_LABEL_RELEASE,
	IMSG_LABEL_WITHDRAW,
	IMSG_LABEL_ABORT,
	IMSG_REQUEST_ADD,
	IMSG_REQUEST_ADD_END,
	IMSG_MAPPING_ADD,
	IMSG_MAPPING_ADD_END,
	IMSG_RELEASE_ADD,
	IMSG_RELEASE_ADD_END,
	IMSG_WITHDRAW_ADD,
	IMSG_WITHDRAW_ADD_END,
	IMSG_ADDRESS_ADD,
	IMSG_ADDRESS_DEL,
	IMSG_NOTIFICATION,
	IMSG_NOTIFICATION_SEND,
	IMSG_NEIGHBOR_UP,
	IMSG_NEIGHBOR_DOWN,
	IMSG_NETWORK_ADD,
	IMSG_NETWORK_UPDATE,
	IMSG_SOCKET_IPC,
	IMSG_SOCKET_NET,
	IMSG_CLOSE_SOCKETS,
	IMSG_REQUEST_SOCKETS,
	IMSG_SETUP_SOCKETS,
	IMSG_RECONF_CONF,
	IMSG_RECONF_IFACE,
	IMSG_RECONF_TNBR,
	IMSG_RECONF_NBRP,
	IMSG_RECONF_L2VPN,
	IMSG_RECONF_L2VPN_IF,
	IMSG_RECONF_L2VPN_PW,
	IMSG_RECONF_L2VPN_IPW,
	IMSG_RECONF_END,
	IMSG_DEBUG_UPDATE,
	IMSG_LOG,
	IMSG_ACL_CHECK,
	IMSG_INIT,
	IMSG_PW_UPDATE,
	IMSG_FILTER_UPDATE,
	IMSG_NBR_SHUTDOWN,
	IMSG_LDP_SYNC_IF_STATE_REQUEST,
	IMSG_LDP_SYNC_IF_STATE_UPDATE,
	IMSG_RLFA_REG,
	IMSG_RLFA_UNREG_ALL,
	IMSG_RLFA_LABELS,
	IMSG_AGENTX_ENABLED,
};

struct ldpd_init {
	char		 user[256];
	char		 group[256];
	char		 ctl_sock_path[MAXPATHLEN];
	char		 zclient_serv_path[MAXPATHLEN];
	unsigned short instance;
};

struct ldp_access {
	char			 name[ACL_NAMSIZ];
};

union ldpd_addr {
	struct in_addr	v4;
	struct in6_addr	v6;
};

#define IN6_IS_SCOPE_EMBED(a)   \
	((IN6_IS_ADDR_LINKLOCAL(a)) ||  \
	 (IN6_IS_ADDR_MC_LINKLOCAL(a)) || \
	 (IN6_IS_ADDR_MC_INTFACELOCAL(a)))

/* interface states */
#define	IF_STA_DOWN		0x01
#define	IF_STA_ACTIVE		0x02

/* targeted neighbor states */
#define	TNBR_STA_DOWN		0x01
#define	TNBR_STA_ACTIVE		0x02

/* interface types */
enum iface_type {
	IF_TYPE_POINTOPOINT,
	IF_TYPE_BROADCAST
};

/* neighbor states */
#define	NBR_STA_PRESENT		0x0001
#define	NBR_STA_INITIAL		0x0002
#define	NBR_STA_OPENREC		0x0004
#define	NBR_STA_OPENSENT	0x0008
#define	NBR_STA_OPER		0x0010
#define	NBR_STA_SESSION		(NBR_STA_INITIAL | NBR_STA_OPENREC | \
				NBR_STA_OPENSENT | NBR_STA_OPER)

/* neighbor events */
enum nbr_event {
	NBR_EVT_NOTHING,
	NBR_EVT_MATCH_ADJ,
	NBR_EVT_CONNECT_UP,
	NBR_EVT_CLOSE_SESSION,
	NBR_EVT_INIT_RCVD,
	NBR_EVT_KEEPALIVE_RCVD,
	NBR_EVT_PDU_RCVD,
	NBR_EVT_PDU_SENT,
	NBR_EVT_INIT_SENT
};

/* neighbor actions */
enum nbr_action {
	NBR_ACT_NOTHING,
	NBR_ACT_RST_KTIMEOUT,
	NBR_ACT_SESSION_EST,
	NBR_ACT_RST_KTIMER,
	NBR_ACT_CONNECT_SETUP,
	NBR_ACT_PASSIVE_INIT,
	NBR_ACT_KEEPALIVE_SEND,
	NBR_ACT_CLOSE_SESSION
};

/* LDP IGP Sync states */
#define	LDP_SYNC_STA_UNKNOWN	0x0000
#define	LDP_SYNC_STA_NOT_ACH 	0x0001
#define	LDP_SYNC_STA_ACH	0x0002

/* LDP IGP Sync events */
enum ldp_sync_event {
	LDP_SYNC_EVT_NOTHING,
	LDP_SYNC_EVT_LDP_SYNC_START,
	LDP_SYNC_EVT_LDP_SYNC_COMPLETE,
	LDP_SYNC_EVT_CONFIG_LDP_OFF,
	LDP_SYNC_EVT_ADJ_DEL,
	LDP_SYNC_EVT_ADJ_NEW,
	LDP_SYNC_EVT_SESSION_CLOSE,
	LDP_SYNC_EVT_CONFIG_LDP_ON,
	LDP_SYNC_EVT_IFACE_SHUTDOWN
};

/* LDP IGP Sync actions */
enum ldp_sync_action {
	LDP_SYNC_ACT_NOTHING,
	LDP_SYNC_ACT_IFACE_START_SYNC,
	LDP_SYNC_ACT_LDP_START_SYNC,
	LDP_SYNC_ACT_LDP_COMPLETE_SYNC,
	LDP_SYNC_ACT_CONFIG_LDP_OFF,
	LDP_SYNC_ACT_IFACE_SHUTDOWN
};

/* forward declarations */
RB_HEAD(global_adj_head, adj);
RB_HEAD(nbr_adj_head, adj);
RB_HEAD(ia_adj_head, adj);

struct map {
	uint8_t		type;
	uint32_t	msg_id;
	union {
		struct {
			uint16_t	af;
			union ldpd_addr	prefix;
			uint8_t		prefixlen;
		} prefix;
		struct {
			uint16_t	type;
			uint32_t	pwid;
			uint32_t	group_id;
			uint16_t	ifmtu;
		} pwid;
		struct {
			uint8_t		type;
			union {
				uint16_t	prefix_af;
				uint16_t	pw_type;
			} u;
		} twcard;
	} fec;
	struct {
		uint32_t	status_code;
		uint32_t	msg_id;
		uint16_t	msg_type;
	} st;
	uint32_t	label;
	uint32_t	requestid;
	uint32_t	pw_status;
	uint8_t		flags;
};
#define F_MAP_REQ_ID	0x01	/* optional request message id present */
#define F_MAP_STATUS	0x02	/* status */
#define F_MAP_PW_CWORD	0x04	/* pseudowire control word */
#define F_MAP_PW_ID	0x08	/* pseudowire connection id */
#define F_MAP_PW_IFMTU	0x10	/* pseudowire interface parameter */
#define F_MAP_PW_STATUS	0x20	/* pseudowire status */

struct notify_msg {
	uint32_t	status_code;
	uint32_t	msg_id;		/* network byte order */
	uint16_t	msg_type;	/* network byte order */
	uint32_t	pw_status;
	struct map	fec;
	struct {
		uint16_t	 type;
		uint16_t	 length;
		char		*data;
	} rtlvs;
	uint8_t		flags;
};
#define F_NOTIF_PW_STATUS	0x01	/* pseudowire status tlv present */
#define F_NOTIF_FEC		0x02	/* fec tlv present */
#define F_NOTIF_RETURNED_TLVS	0x04	/* returned tlvs present */

struct if_addr {
	LIST_ENTRY(if_addr)	 entry;
	int			 af;
	union ldpd_addr		 addr;
	uint8_t			 prefixlen;
	union ldpd_addr		 dstbrd;
};
LIST_HEAD(if_addr_head, if_addr);

struct iface_af {
	struct iface		*iface;
	int			 af;
	int			 enabled;
	int			 state;
	struct ia_adj_head	 adj_tree;
	time_t			 uptime;
	struct thread		*hello_timer;
	uint16_t		 hello_holdtime;
	uint16_t		 hello_interval;
};

struct iface_ldp_sync {
	int			 state;
	struct thread           *wait_for_sync_timer;
};

struct iface {
	RB_ENTRY(iface)		 entry;
	char			 name[IF_NAMESIZE];
	ifindex_t		 ifindex;
	struct if_addr_head	 addr_list;
	struct in6_addr		 linklocal;
	enum iface_type		 type;
	int			 operative;
	struct iface_af		 ipv4;
	struct iface_af		 ipv6;
	struct iface_ldp_sync	 ldp_sync;
	QOBJ_FIELDS;
};
RB_HEAD(iface_head, iface);
RB_PROTOTYPE(iface_head, iface, entry, iface_compare);
DECLARE_QOBJ_TYPE(iface);

/* source of targeted hellos */
struct tnbr {
	RB_ENTRY(tnbr)		 entry;
	struct thread		*hello_timer;
	struct adj		*adj;
	int			 af;
	union ldpd_addr		 addr;
	int			 state;
	uint16_t		 pw_count;
	uint32_t		 rlfa_count;
	uint8_t			 flags;
	QOBJ_FIELDS;
};
RB_HEAD(tnbr_head, tnbr);
RB_PROTOTYPE(tnbr_head, tnbr, entry, tnbr_compare);
DECLARE_QOBJ_TYPE(tnbr);
#define F_TNBR_CONFIGURED	 0x01
#define F_TNBR_DYNAMIC		 0x02

enum auth_method {
	AUTH_NONE,
	AUTH_MD5SIG
};

/* neighbor specific parameters */
struct nbr_params {
	RB_ENTRY(nbr_params)	 entry;
	struct in_addr		 lsr_id;
	uint16_t		 keepalive;
	int			 gtsm_enabled;
	uint8_t			 gtsm_hops;
	struct {
		enum auth_method	 method;
		char			 md5key[TCP_MD5_KEY_LEN];
		uint8_t			 md5key_len;
	} auth;
	uint8_t			 flags;
	QOBJ_FIELDS;
};
RB_HEAD(nbrp_head, nbr_params);
RB_PROTOTYPE(nbrp_head, nbr_params, entry, nbr_params_compare);
DECLARE_QOBJ_TYPE(nbr_params);
#define F_NBRP_KEEPALIVE	 0x01
#define F_NBRP_GTSM		 0x02
#define F_NBRP_GTSM_HOPS	 0x04

struct ldp_stats {
	uint32_t		 kalive_sent;
	uint32_t		 kalive_rcvd;
	uint32_t		 addr_sent;
	uint32_t		 addr_rcvd;
	uint32_t		 addrwdraw_sent;
	uint32_t		 addrwdraw_rcvd;
	uint32_t		 notif_sent;
	uint32_t		 notif_rcvd;
	uint32_t		 capability_sent;
	uint32_t		 capability_rcvd;
	uint32_t		 labelmap_sent;
	uint32_t		 labelmap_rcvd;
	uint32_t		 labelreq_sent;
	uint32_t		 labelreq_rcvd;
	uint32_t		 labelwdraw_sent;
	uint32_t		 labelwdraw_rcvd;
	uint32_t		 labelrel_sent;
	uint32_t		 labelrel_rcvd;
	uint32_t		 labelabreq_sent;
	uint32_t		 labelabreq_rcvd;
	uint32_t		 unknown_tlv;
	uint32_t		 unknown_msg;

};

struct ldp_entity_stats {
	uint32_t		 session_attempts;
	uint32_t		 session_rejects_hello;
	uint32_t		 session_rejects_ad;
	uint32_t		 session_rejects_max_pdu;
	uint32_t		 session_rejects_lr;
	uint32_t		 bad_ldp_id;
	uint32_t		 bad_pdu_len;
	uint32_t		 bad_msg_len;
	uint32_t		 bad_tlv_len;
	uint32_t		 malformed_tlv;
	uint32_t		 keepalive_timer_exp;
	uint32_t		 shutdown_rcv_notify;
	uint32_t		 shutdown_send_notify;
};

struct l2vpn_if {
	RB_ENTRY(l2vpn_if)	 entry;
	struct l2vpn		*l2vpn;
	char			 ifname[IF_NAMESIZE];
	ifindex_t		 ifindex;
	int			 operative;
	uint8_t			 mac[ETH_ALEN];
	QOBJ_FIELDS;
};
RB_HEAD(l2vpn_if_head, l2vpn_if);
RB_PROTOTYPE(l2vpn_if_head, l2vpn_if, entry, l2vpn_if_compare);
DECLARE_QOBJ_TYPE(l2vpn_if);

struct l2vpn_pw {
	RB_ENTRY(l2vpn_pw)	 entry;
	struct l2vpn		*l2vpn;
	struct in_addr		 lsr_id;
	int			 af;
	union ldpd_addr		 addr;
	uint32_t		 pwid;
	char			 ifname[IF_NAMESIZE];
	ifindex_t		 ifindex;
	bool			 enabled;
	uint32_t		 remote_group;
	uint16_t		 remote_mtu;
	uint32_t		 local_status;
	uint32_t		 remote_status;
	uint8_t			 flags;
	uint8_t			 reason;
	QOBJ_FIELDS;
};
RB_HEAD(l2vpn_pw_head, l2vpn_pw);
RB_PROTOTYPE(l2vpn_pw_head, l2vpn_pw, entry, l2vpn_pw_compare);
DECLARE_QOBJ_TYPE(l2vpn_pw);
#define F_PW_STATUSTLV_CONF	0x01	/* status tlv configured */
#define F_PW_STATUSTLV		0x02	/* status tlv negotiated */
#define F_PW_CWORD_CONF		0x04	/* control word configured */
#define F_PW_CWORD		0x08	/* control word negotiated */
#define F_PW_STATIC_NBR_ADDR	0x10	/* static neighbor address configured */

#define F_PW_NO_ERR             0x00	/* no error reported */
#define F_PW_LOCAL_NOT_FWD      0x01	/* locally can't forward over PW */
#define F_PW_REMOTE_NOT_FWD     0x02	/* remote end of PW reported fwd error*/
#define F_PW_NO_REMOTE_LABEL    0x03	/* have not recvd label from peer */
#define F_PW_MTU_MISMATCH       0x04	/* mtu mismatch between peers */

struct l2vpn {
	RB_ENTRY(l2vpn)		 entry;
	char			 name[L2VPN_NAME_LEN];
	int			 type;
	int			 pw_type;
	int			 mtu;
	char			 br_ifname[IF_NAMESIZE];
	ifindex_t		 br_ifindex;
	struct l2vpn_if_head	 if_tree;
	struct l2vpn_pw_head	 pw_tree;
	struct l2vpn_pw_head	 pw_inactive_tree;
	QOBJ_FIELDS;
};
RB_HEAD(l2vpn_head, l2vpn);
RB_PROTOTYPE(l2vpn_head, l2vpn, entry, l2vpn_compare);
DECLARE_QOBJ_TYPE(l2vpn);
#define L2VPN_TYPE_VPWS		1
#define L2VPN_TYPE_VPLS		2

/* ldp_conf */
extern enum ldpd_process {
	PROC_MAIN,
	PROC_LDP_ENGINE,
	PROC_LDE_ENGINE
} ldpd_process;

static const char * const log_procnames[] = {
	"parent",
	"ldpe",
	"lde"
};

enum socket_type {
	LDP_SOCKET_DISC,
	LDP_SOCKET_EDISC,
	LDP_SOCKET_SESSION
};

enum hello_type {
	HELLO_LINK,
	HELLO_TARGETED
};

struct ldpd_af_conf {
	uint16_t		 keepalive;
	uint16_t		 lhello_holdtime;
	uint16_t		 lhello_interval;
	uint16_t		 thello_holdtime;
	uint16_t		 thello_interval;
	union ldpd_addr		 trans_addr;
	char			 acl_thello_accept_from[ACL_NAMSIZ];
	char			 acl_label_allocate_for[ACL_NAMSIZ];
	char			 acl_label_advertise_to[ACL_NAMSIZ];
	char			 acl_label_advertise_for[ACL_NAMSIZ];
	char			 acl_label_expnull_for[ACL_NAMSIZ];
	char			 acl_label_accept_from[ACL_NAMSIZ];
	char			 acl_label_accept_for[ACL_NAMSIZ];
	int			 flags;
};
#define	F_LDPD_AF_ENABLED	0x0001
#define	F_LDPD_AF_THELLO_ACCEPT	0x0002
#define	F_LDPD_AF_EXPNULL	0x0004
#define	F_LDPD_AF_NO_GTSM	0x0008
#define	F_LDPD_AF_ALLOCHOSTONLY	0x0010

struct ldpd_conf {
	struct in_addr		 rtr_id;
	struct ldpd_af_conf	 ipv4;
	struct ldpd_af_conf	 ipv6;
	struct iface_head	 iface_tree;
	struct tnbr_head	 tnbr_tree;
	struct nbrp_head	 nbrp_tree;
	struct l2vpn_head	 l2vpn_tree;
	uint16_t		 lhello_holdtime;
	uint16_t		 lhello_interval;
	uint16_t		 thello_holdtime;
	uint16_t		 thello_interval;
	uint16_t		 trans_pref;
	uint16_t		 wait_for_sync_interval;
	int			 flags;
	time_t			 config_change_time;
	struct ldp_entity_stats  stats;
	QOBJ_FIELDS;
};
DECLARE_QOBJ_TYPE(ldpd_conf);
#define	F_LDPD_NO_FIB_UPDATE	0x0001
#define	F_LDPD_DS_CISCO_INTEROP	0x0002
#define	F_LDPD_ENABLED		0x0004
#define	F_LDPD_ORDERED_CONTROL  0x0008
#define	F_LDPD_ALLOW_BROKEN_LSP 0x0010

struct ldpd_af_global {
	struct thread		*disc_ev;
	struct thread		*edisc_ev;
	int			 ldp_disc_socket;
	int			 ldp_edisc_socket;
	int			 ldp_session_socket;
};

struct ldpd_global {
	int			 cmd_opts;
	struct in_addr		 rtr_id;
	struct ldpd_af_global	 ipv4;
	struct ldpd_af_global	 ipv6;
	uint32_t		 conf_seqnum;
	int			 pfkeysock;
	struct if_addr_head	 addr_list;
	struct global_adj_head	 adj_tree;
	struct in_addr		 mcast_addr_v4;
	struct in6_addr		 mcast_addr_v6;
	TAILQ_HEAD(, pending_conn) pending_conns;
};

/* kroute */
struct kroute {
	int			 af;
	union ldpd_addr		 prefix;
	uint8_t			 prefixlen;
	union ldpd_addr		 nexthop;
	uint32_t		 local_label;
	uint32_t		 remote_label;
	ifindex_t		 ifindex;
	uint8_t			 route_type;
	uint8_t			 route_instance;
	uint16_t		 flags;
};

struct kaddr {
	char			 ifname[IF_NAMESIZE];
	ifindex_t		 ifindex;
	int			 af;
	union ldpd_addr		 addr;
	uint8_t			 prefixlen;
	union ldpd_addr	 	 dstbrd;
};

struct kif {
	char			 ifname[IF_NAMESIZE];
	ifindex_t		 ifindex;
	int			 flags;
	int			 operative;
	uint8_t			 mac[ETH_ALEN];
	int			 mtu;
};

struct acl_check {
	char			 acl[ACL_NAMSIZ];
	int			 af;
	union ldpd_addr		 addr;
	uint8_t			 prefixlen;
};

/* control data structures */
struct ctl_iface {
	int			 af;
	char			 name[IF_NAMESIZE];
	ifindex_t		 ifindex;
	int			 state;
	enum iface_type		 type;
	uint16_t		 hello_holdtime;
	uint16_t		 hello_interval;
	time_t			 uptime;
	uint16_t		 adj_cnt;
};

struct ctl_disc_if {
	char			 name[IF_NAMESIZE];
	int			 active_v4;
	int			 active_v6;
	int			 no_adj;
};

struct ctl_disc_tnbr {
	int			 af;
	union ldpd_addr		 addr;
	int			 no_adj;
};

struct ctl_adj {
	int			 af;
	struct in_addr		 id;
	enum hello_type		 type;
	char			 ifname[IF_NAMESIZE];
	union ldpd_addr		 src_addr;
	uint16_t		 holdtime;
	uint16_t		 holdtime_remaining;
	union ldpd_addr		 trans_addr;
	int			 ds_tlv;
};

struct ctl_nbr {
	int			 af;
	struct in_addr		 id;
	union ldpd_addr		 laddr;
	in_port_t		 lport;
	union ldpd_addr		 raddr;
	in_port_t		 rport;
	enum auth_method	 auth_method;
	uint16_t		 holdtime;
	time_t			 uptime;
	int			 nbr_state;
	struct ldp_stats	 stats;
	int			 flags;
	uint16_t		 max_pdu_len;
	uint16_t		 hold_time_remaining;
};

struct ctl_rt {
	int			 af;
	union ldpd_addr		 prefix;
	uint8_t			 prefixlen;
	struct in_addr		 nexthop;	/* lsr-id */
	uint32_t		 local_label;
	uint32_t		 remote_label;
	uint8_t			 flags;
	uint8_t			 in_use;
	int			 no_downstream;
};

struct ctl_pw {
	uint16_t		 type;
	char			 l2vpn_name[L2VPN_NAME_LEN];
	char			 ifname[IF_NAMESIZE];
	uint32_t		 pwid;
	struct in_addr		 lsr_id;
	uint32_t		 local_label;
	uint32_t		 local_gid;
	uint16_t		 local_ifmtu;
	uint8_t			 local_cword;
	uint32_t		 remote_label;
	uint32_t		 remote_gid;
	uint16_t		 remote_ifmtu;
	uint8_t			 remote_cword;
	uint32_t		 status;
	uint8_t			 reason;
};

struct ctl_ldp_sync {
	char			 name[IF_NAMESIZE];
	ifindex_t		 ifindex;
	bool			 in_sync;
	bool			 timer_running;
	uint16_t		 wait_time;
	uint16_t		 wait_time_remaining;
	struct in_addr		 peer_ldp_id;
};

extern struct ldpd_conf		*ldpd_conf, *vty_conf;
extern struct ldpd_global	 global;
extern struct ldpd_init		 init;

/* parse.y */
struct ldpd_conf	*parse_config(char *);
int			 cmdline_symset(char *);

/* kroute.c */
void		 pw2zpw(struct l2vpn_pw *, struct zapi_pw *);
void		 kif_redistribute(const char *);
int		 kr_change(struct kroute *);
int		 kr_delete(struct kroute *);
int		 kmpw_add(struct zapi_pw *);
int		 kmpw_del(struct zapi_pw *);
int		 kmpw_set(struct zapi_pw *);
int		 kmpw_unset(struct zapi_pw *);

/* util.c */
uint8_t		 mask2prefixlen(in_addr_t);
uint8_t		 mask2prefixlen6(struct sockaddr_in6 *);
in_addr_t	 prefixlen2mask(uint8_t);
struct in6_addr	*prefixlen2mask6(uint8_t);
void		 ldp_applymask(int, union ldpd_addr *,
		    const union ldpd_addr *, int);
int		 ldp_addrcmp(int, const union ldpd_addr *,
		    const union ldpd_addr *);
int		 ldp_addrisset(int, const union ldpd_addr *);
int		 ldp_prefixcmp(int, const union ldpd_addr *,
		    const union ldpd_addr *, uint8_t);
int		 bad_addr_v4(struct in_addr);
int		 bad_addr_v6(struct in6_addr *);
int		 bad_addr(int, union ldpd_addr *);
void		 embedscope(struct sockaddr_in6 *);
void		 recoverscope(struct sockaddr_in6 *);
void		 addscope(struct sockaddr_in6 *, uint32_t);
void		 clearscope(struct in6_addr *);
void		 addr2sa(int af, const union ldpd_addr *, uint16_t,
		    union sockunion *su);
void		 sa2addr(struct sockaddr *, int *, union ldpd_addr *,
		    in_port_t *);
socklen_t	 sockaddr_len(struct sockaddr *);

/* ldpd.c */
void ldp_write_handler(struct thread *thread);
void			 main_imsg_compose_ldpe(int, pid_t, void *, uint16_t);
void			 main_imsg_compose_lde(int, pid_t, void *, uint16_t);
int			 main_imsg_compose_both(enum imsg_type, void *,
			    uint16_t);
void			 imsg_event_add(struct imsgev *);
int			 imsg_compose_event(struct imsgev *, uint16_t, uint32_t,
			    pid_t, int, void *, uint16_t);
void			 evbuf_enqueue(struct evbuf *, struct ibuf *);
void			 evbuf_event_add(struct evbuf *);
void evbuf_init(struct evbuf *, int, void (*)(struct thread *), void *);
void			 evbuf_clear(struct evbuf *);
int			 ldp_acl_request(struct imsgev *, char *, int,
			    union ldpd_addr *, uint8_t);
void			 ldp_acl_reply(struct imsgev *, struct acl_check *);
struct ldpd_af_conf	*ldp_af_conf_get(struct ldpd_conf *, int);
struct ldpd_af_global	*ldp_af_global_get(struct ldpd_global *, int);
int			 ldp_is_dual_stack(struct ldpd_conf *);
in_addr_t		 ldp_rtr_id_get(struct ldpd_conf *);
int			 ldp_config_apply(struct vty *, struct ldpd_conf *);
void			 ldp_clear_config(struct ldpd_conf *);
void			 merge_config(struct ldpd_conf *, struct ldpd_conf *);
struct ldpd_conf	*config_new_empty(void);
void			 config_clear(struct ldpd_conf *);

/* ldp_vty_conf.c */
/* NOTE: the parameters' names should be preserved because of codegen */
struct iface		*iface_new_api(struct ldpd_conf *conf,
			    const char *name);
void			 iface_del_api(struct ldpd_conf *conf,
			    struct iface *iface);
struct tnbr		*tnbr_new_api(struct ldpd_conf *conf, int af,
			    union ldpd_addr *addr);
void			 tnbr_del_api(struct ldpd_conf *conf, struct tnbr *tnbr);
struct nbr_params	*nbrp_new_api(struct ldpd_conf *conf,
			    struct in_addr lsr_id);
void			 nbrp_del_api(struct ldpd_conf *conf,
			    struct nbr_params *nbrp);
struct l2vpn		*l2vpn_new_api(struct ldpd_conf *conf, const char *name);
void			 l2vpn_del_api(struct ldpd_conf *conf,
			    struct l2vpn *l2vpn);
struct l2vpn_if		*l2vpn_if_new_api(struct ldpd_conf *conf,
			    struct l2vpn *l2vpn, const char *ifname);
void			 l2vpn_if_del_api(struct l2vpn *l2vpn,
			   struct l2vpn_if *lif);
struct l2vpn_pw		*l2vpn_pw_new_api(struct ldpd_conf *conf,
			    struct l2vpn *l2vpn, const char *ifname);
void			 l2vpn_pw_del_api(struct l2vpn *l2vpn,
			    struct l2vpn_pw *pw);

/* socket.c */
int		 ldp_create_socket(int, enum socket_type);
void		 sock_set_nonblock(int);
void		 sock_set_cloexec(int);
void		 sock_set_recvbuf(int);
int		 sock_set_reuse(int, int);
int		 sock_set_bindany(int, int);
int		 sock_set_md5sig(int, int, union ldpd_addr *, const char *);
int		 sock_set_ipv4_tos(int, int);
int		 sock_set_ipv4_pktinfo(int, int);
int		 sock_set_ipv4_recvdstaddr(int fd, ifindex_t ifindex);
int		 sock_set_ipv4_recvif(int, int);
int		 sock_set_ipv4_minttl(int, int);
int		 sock_set_ipv4_ucast_ttl(int fd, int);
int		 sock_set_ipv4_mcast_ttl(int, uint8_t);
int		 sock_set_ipv4_mcast(struct iface *);
int		 sock_set_ipv4_mcast_loop(int);
int		 sock_set_ipv6_dscp(int, int);
int		 sock_set_ipv6_pktinfo(int, int);
int		 sock_set_ipv6_minhopcount(int, int);
int		 sock_set_ipv6_ucast_hops(int, int);
int		 sock_set_ipv6_mcast_hops(int, int);
int		 sock_set_ipv6_mcast(struct iface *);
int		 sock_set_ipv6_mcast_loop(int);

/* logmsg.h */
struct in6_addr;
union ldpd_addr;
struct hello_source;
struct fec;

const char	*log_sockaddr(void *);
const char	*log_in6addr(const struct in6_addr *);
const char	*log_in6addr_scope(const struct in6_addr *addr,
				   ifindex_t ifidx);
const char	*log_addr(int, const union ldpd_addr *);
char		*log_label(uint32_t);
const char	*log_time(time_t);
char		*log_hello_src(const struct hello_source *);
const char	*log_map(const struct map *);
const char	*log_fec(const struct fec *);
const char	*af_name(int);
const char	*socket_name(int);
const char	*nbr_state_name(int);
const char	*if_state_name(int);
const char	*if_type_name(enum iface_type);
const char	*msg_name(uint16_t);
const char	*status_code_name(uint32_t);
const char	*pw_type_name(uint16_t);
const char	*pw_error_code(uint8_t);

/* quagga */
extern struct thread_master	*master;
extern char			 ctl_sock_path[MAXPATHLEN];

/* ldp_zebra.c */
void		 ldp_zebra_init(struct thread_master *);
void		 ldp_zebra_destroy(void);
int		 ldp_sync_zebra_send_state_update(struct ldp_igp_sync_if_state *);
int		 ldp_zebra_send_rlfa_labels(struct zapi_rlfa_response *
		    rlfa_labels);

void ldp_zebra_regdereg_zebra_info(bool want_register);

/* compatibility */
#ifndef __OpenBSD__
#define __IPV6_ADDR_MC_SCOPE(a)		((a)->s6_addr[1] & 0x0f)
#define __IPV6_ADDR_SCOPE_INTFACELOCAL	0x01
#define	IN6_IS_ADDR_MC_INTFACELOCAL(a)	\
	(IN6_IS_ADDR_MULTICAST(a) &&	\
	(__IPV6_ADDR_MC_SCOPE(a) == __IPV6_ADDR_SCOPE_INTFACELOCAL))
#endif

DECLARE_HOOK(ldp_register_mib, (struct thread_master * tm), (tm));

extern void ldp_agentx_enabled(void);

#endif	/* _LDPD_H_ */