4 * Copyright (C) 1997-1999 Kunihiro Ishiguro
5 * Copyright (C) 2015-2018 Cumulus Networks, Inc.
8 * This program is free software; you can redistribute it and/or modify it
9 * under the terms of the GNU General Public License as published by the Free
10 * Software Foundation; either version 2 of the License, or (at your option)
13 * This program is distributed in the hope that it will be useful, but WITHOUT
14 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
15 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
18 * You should have received a copy of the GNU General Public License along
19 * with this program; see the file COPYING; if not, write to the Free Software
20 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
23 #ifndef _ZEBRA_ZSERV_H
24 #define _ZEBRA_ZSERV_H
26 /* clang-format off */
27 #include <stdint.h> /* for uint32_t, uint8_t */
28 #include <time.h> /* for time_t */
30 #include "lib/route_types.h" /* for ZEBRA_ROUTE_MAX */
31 #include "lib/zebra.h" /* for AFI_MAX */
32 #include "lib/vrf.h" /* for vrf_bitmap_t */
33 #include "lib/zclient.h" /* for redist_proto */
34 #include "lib/stream.h" /* for stream, stream_fifo */
35 #include "lib/thread.h" /* for thread, thread_master */
36 #include "lib/linklist.h" /* for list */
37 #include "lib/workqueue.h" /* for work_queue */
38 #include "lib/hook.h" /* for DECLARE_HOOK, DECLARE_KOOH */
40 #include "zebra/zebra_vrf.h" /* for zebra_vrf */
47 /* Default port information. */
48 #define ZEBRA_VTY_PORT 2601
50 /* Default configuration filename. */
51 #define DEFAULT_CONFIG_FILE "zebra.conf"
53 #define ZEBRA_RMAP_DEFAULT_UPDATE_TIMER 5 /* disabled by default */
56 /* Stale route marker timer */
57 #define ZEBRA_DEFAULT_STALE_UPDATE_DELAY 1
59 /* Count of stale routes processed in timer context */
60 #define ZEBRA_MAX_STALE_ROUTE_COUNT 50000
62 /* Graceful Restart information */
63 struct client_gr_info
{
64 /* VRF for which GR enabled */
70 /* Stale time and GR cap */
71 uint32_t stale_removal_time
;
72 enum zserv_client_capabilities capabilities
;
79 /* Route sync and enable flags for AFI/SAFI */
80 bool af_enabled
[AFI_MAX
][SAFI_MAX
];
81 bool route_sync
[AFI_MAX
][SAFI_MAX
];
84 struct prefix
*current_prefix
;
85 void *stale_client_ptr
;
86 struct thread
*t_stale_removal
;
88 TAILQ_ENTRY(client_gr_info
) gr_info
;
91 /* Client structure. */
94 struct frr_pthread
*pthread
;
96 /* Client file descriptor. */
99 /* Input/output buffer to the client. */
100 pthread_mutex_t ibuf_mtx
;
101 struct stream_fifo
*ibuf_fifo
;
102 pthread_mutex_t obuf_mtx
;
103 struct stream_fifo
*obuf_fifo
;
105 /* Private I/O buffers */
106 struct stream
*ibuf_work
;
107 struct stream
*obuf_work
;
109 /* Buffer of data waiting to be written to client. */
112 /* Threads for read/write. */
113 struct thread
*t_read
;
114 struct thread
*t_write
;
116 /* Event for message processing, for the main pthread */
117 struct thread
*t_process
;
119 /* Threads for the main pthread */
120 struct thread
*t_cleanup
;
122 /* This client's redistribute flag. */
123 struct redist_proto mi_redist
[AFI_MAX
][ZEBRA_ROUTE_MAX
];
124 vrf_bitmap_t redist
[AFI_MAX
][ZEBRA_ROUTE_MAX
];
126 /* Redistribute default route flag. */
127 vrf_bitmap_t redist_default
[AFI_MAX
];
129 /* Router-id information. */
130 vrf_bitmap_t ridinfo
;
134 /* client's protocol */
139 * Interested for MLAG Updates, and also stores the client
140 * interested message mask
142 bool mlag_updates_interested
;
143 uint32_t mlag_reg_mask1
;
146 uint32_t redist_v4_add_cnt
;
147 uint32_t redist_v4_del_cnt
;
148 uint32_t redist_v6_add_cnt
;
149 uint32_t redist_v6_del_cnt
;
150 uint32_t v4_route_add_cnt
;
151 uint32_t v4_route_upd8_cnt
;
152 uint32_t v4_route_del_cnt
;
153 uint32_t v6_route_add_cnt
;
154 uint32_t v6_route_del_cnt
;
155 uint32_t v6_route_upd8_cnt
;
156 uint32_t connected_rt_add_cnt
;
157 uint32_t connected_rt_del_cnt
;
163 uint32_t bfd_peer_add_cnt
;
164 uint32_t bfd_peer_upd8_cnt
;
165 uint32_t bfd_peer_del_cnt
;
166 uint32_t bfd_peer_replay_cnt
;
169 uint32_t if_vrfchg_cnt
;
170 uint32_t bfd_client_reg_cnt
;
173 uint32_t l3vniadd_cnt
;
174 uint32_t l3vnidel_cnt
;
175 uint32_t macipadd_cnt
;
176 uint32_t macipdel_cnt
;
177 uint32_t prefixadd_cnt
;
178 uint32_t prefixdel_cnt
;
179 uint32_t v4_nh_watch_add_cnt
;
180 uint32_t v4_nh_watch_rem_cnt
;
181 uint32_t v6_nh_watch_add_cnt
;
182 uint32_t v6_nh_watch_rem_cnt
;
183 uint32_t vxlan_sg_add_cnt
;
184 uint32_t vxlan_sg_del_cnt
;
188 time_t nh_dereg_time
;
189 time_t nh_last_upd_time
;
192 * Session information.
194 * These are not synchronous with respect to each other. For instance,
195 * last_read_cmd may contain a value that has been read in the future
196 * relative to last_read_time.
199 /* monotime of client creation */
200 _Atomic
uint32_t connect_time
;
201 /* monotime of last message received */
202 _Atomic
uint32_t last_read_time
;
203 /* monotime of last message sent */
204 _Atomic
uint32_t last_write_time
;
205 /* command code of last message read */
206 _Atomic
uint32_t last_read_cmd
;
207 /* command code of last message written */
208 _Atomic
uint32_t last_write_cmd
;
211 * Number of instances configured with
214 uint32_t gr_instance_count
;
218 * Graceful restart information for
221 TAILQ_HEAD(info_list
, client_gr_info
) gr_info_queue
;
224 #define ZAPI_HANDLER_ARGS \
225 struct zserv *client, struct zmsghdr *hdr, struct stream *msg, \
226 struct zebra_vrf *zvrf
228 /* Hooks for client connect / disconnect */
229 DECLARE_HOOK(zserv_client_connect
, (struct zserv
*client
), (client
));
230 DECLARE_KOOH(zserv_client_close
, (struct zserv
*client
), (client
));
232 #define DYNAMIC_CLIENT_GR_DISABLED(_client) \
233 ((_client->proto <= ZEBRA_ROUTE_CONNECT) \
234 || !(_client->gr_instance_count))
237 * Initialize Zebra API server.
239 * Installs CLI commands and creates the client list.
241 extern void zserv_init(void);
244 * Stop the Zebra API server.
248 extern void zserv_close(void);
251 * Start Zebra API server.
253 * Allocates resources, creates the server socket and begins listening on the
257 * where to place the Unix domain socket
259 extern void zserv_start(char *path
);
262 * Send a message to a connected Zebra API client.
265 * the client to send to
268 * the message to send
270 extern int zserv_send_message(struct zserv
*client
, struct stream
*msg
);
273 * Retrieve a client by its protocol and instance number.
282 * The Zebra API client.
284 extern struct zserv
*zserv_find_client(uint8_t proto
, unsigned short instance
);
289 * Kills a client's thread, removes the client from the client list and cleans
293 * the client to close
295 extern void zserv_close_client(struct zserv
*client
);
298 * Log a ZAPI message hexdump.
301 * Error message to include with packet hexdump
309 void zserv_log_message(const char *errmsg
, struct stream
*msg
,
310 struct zmsghdr
*hdr
);
312 #if defined(HANDLE_ZAPI_FUZZING)
313 extern void zserv_read_file(char *input
);
317 int zebra_finalize(struct thread
*event
);
320 * Graceful restart functions.
322 extern int zebra_gr_client_disconnect(struct zserv
*client
);
323 extern void zebra_gr_client_reconnect(struct zserv
*client
);
324 extern void zebra_gr_stale_client_cleanup(struct list
*client_list
);
325 extern void zread_client_capabilities(struct zserv
*client
, struct zmsghdr
*hdr
,
327 struct zebra_vrf
*zvrf
);
333 #endif /* _ZEBRA_ZEBRA_H */