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
|
// SPDX-License-Identifier: GPL-2.0-or-later
/*
* Copyright (C) 2020 Volta Networks, Inc
*
* You should have received a copy of the GNU Lesser General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*
*/
#ifndef _PATH_TED_H
#define _PATH_TED_H
#ifdef __cplusplus
extern "C" {
#endif
#include <zebra.h>
#include <stdbool.h>
#include <debug.h>
#include "linklist.h"
#include "log.h"
#include "command.h"
#include "stream.h"
#include "prefix.h"
#include "zclient.h"
#include "link_state.h"
extern struct ted_state ted_state_g;
#define TIMER_RETRY_DELAY 5 /* Timeout in seconds between ls sync request */
#define TED_KEY 1
#define TED_ASN 1
#define TED_NAME "PATHD TED"
enum igp_import {
IMPORT_UNKNOWN = 0,
IMPORT_ISIS,
IMPORT_OSPFv2,
IMPORT_OSPFv3
};
struct ted_state {
struct event_loop *main;
/* Status of TED: enable or disable */
bool enabled;
/* From which igp is going to receive data */
enum igp_import import;
/* The TED itself as in link_state.h */
struct ls_ted *ted;
/* Timer for ted sync */
struct event *t_link_state_sync;
/* Timer for refresh sid in segment list */
struct event *t_segment_list_refresh;
/* delay interval in seconds */
uint32_t link_state_delay_interval;
/* delay interval refresh in seconds */
uint32_t segment_list_refresh_interval;
struct debug dbg;
};
/* Debug flags. */
#define PATH_TED_DEBUG_BASIC 0x01
#define PATH_TED_DEBUG(fmt, ...) \
do { \
if (DEBUG_FLAGS_CHECK(&ted_state_g.dbg, PATH_TED_DEBUG_BASIC)) \
DEBUGD(&ted_state_g.dbg, "mpls-te: " fmt, ##__VA_ARGS__); \
} while (0)
#define PATH_TED_ERROR(fmt, ...) \
do { \
if (DEBUG_FLAGS_CHECK(&ted_state_g.dbg, PATH_TED_DEBUG_BASIC)) \
DEBUGE(&ted_state_g.dbg, "mpls-te: " fmt, ##__VA_ARGS__); \
} while (0)
#define PATH_TED_WARN(fmt, ...) \
do { \
if (DEBUG_FLAGS_CHECK(&ted_state_g.dbg, PATH_TED_DEBUG_BASIC)) \
DEBUGW(&ted_state_g.dbg, "mpls-te: " fmt, ##__VA_ARGS__); \
} while (0)
#define PATH_TED_INFO(fmt, ...) \
do { \
if (DEBUG_FLAGS_CHECK(&ted_state_g.dbg, PATH_TED_DEBUG_BASIC)) \
DEBUGI(&ted_state_g.dbg, "mpls-te: " fmt, ##__VA_ARGS__); \
} while (0)
/* TED management functions */
bool path_ted_is_initialized(void);
void path_ted_init(struct event_loop *master);
uint32_t path_ted_teardown(void);
void path_ted_timer_sync_cancel(void);
void path_ted_timer_refresh_cancel(void);
int path_ted_segment_list_refresh(void);
/* TED configuration functions */
uint32_t path_ted_config_write(struct vty *vty);
void path_ted_show_debugging(struct vty *vty);
/* TED util functions */
/* clang-format off */
#define LS_MSG_EVENT_PRINT(event) event == LS_MSG_EVENT_ADD?"add"\
: event == LS_MSG_EVENT_DELETE?"del"\
: event == LS_MSG_EVENT_UPDATE?"upd"\
: event == LS_MSG_EVENT_SYNC?"syn"\
: event == LS_MSG_EVENT_SYNC?"und" : "none"
#define LS_MSG_TYPE_PRINT(type) type == LS_MSG_TYPE_NODE?"node"\
: type == LS_MSG_TYPE_ATTRIBUTES?"att"\
: type == LS_MSG_TYPE_PREFIX?"pre" : "none"
#define LS_IGP_PRINT(type) type == ISIS_L1?"ISIS_L1"\
: type == ISIS_L2?"ISIS_L2"\
: type == DIRECT?"DIRECT"\
: type == STATIC?"STATIC"\
: type == OSPFv2?"OSPFv2" : "none"
#define PATH_TED_IGP_PRINT(type) type == IMPORT_OSPFv2?"OSPFv2"\
: type == IMPORT_OSPFv3?"OSPFv3"\
: type == IMPORT_ISIS?"ISIS" : "none"
/* clang-format on */
uint32_t path_ted_get_current_igp(uint32_t);
/* TED Query functions */
/*
* Type of queries from draft-ietf-spring-segment-routing-policy-07 for types
* f,c,e
*/
/**
* Search for sid based in prefix and optional algo
*
* @param prefix Net prefix to resolv
* @param algo Algorithm for link state
*
* @return sid of attribute
*/
uint32_t path_ted_query_type_c(struct prefix *prefix, uint8_t algo);
/**
* Search for sid based in prefix and interface id
*
* @param prefix Net prefix to resolv
* @param iface_id The interface id
*
* @return sid of attribute
*/
uint32_t path_ted_query_type_e(struct prefix *prefix, uint32_t iface_id);
/**
* Search for sid based in local, remote pair
*
* @param local local ip of attribute
* @param remote remote ip of attribute
*
* @return sid of attribute
*/
uint32_t path_ted_query_type_f(struct ipaddr *local, struct ipaddr *remote);
/**
* Handle the received opaque msg
*
* @param msg Holds the ted data
*
* @return sid of attribute
*/
uint32_t path_ted_rcvd_message(struct ls_message *msg);
#ifdef __cplusplus
}
#endif
#endif /* _PATH_TED_H */
|
