1 // SPDX-License-Identifier: GPL-2.0-or-later
5 * Copyright (C) 1997-1999 Kunihiro Ishiguro
6 * Copyright (C) 2015-2018 Cumulus Networks, Inc.
10 #ifndef _ZEBRA_ZSERV_H
11 #define _ZEBRA_ZSERV_H
13 /* clang-format off */
14 #include <stdint.h> /* for uint32_t, uint8_t */
15 #include <time.h> /* for time_t */
17 #include "lib/route_types.h" /* for ZEBRA_ROUTE_MAX */
18 #include "lib/zebra.h" /* for AFI_MAX */
19 #include "lib/vrf.h" /* for vrf_bitmap_t */
20 #include "lib/zclient.h" /* for redist_proto */
21 #include "lib/stream.h" /* for stream, stream_fifo */
22 #include "frrevent.h" /* for thread, thread_master */
23 #include "lib/linklist.h" /* for list */
24 #include "lib/workqueue.h" /* for work_queue */
25 #include "lib/hook.h" /* for DECLARE_HOOK, DECLARE_KOOH */
34 /* Default port information. */
35 #define ZEBRA_VTY_PORT 2601
37 /* Default configuration filename. */
38 #define DEFAULT_CONFIG_FILE "zebra.conf"
40 #define ZEBRA_RMAP_DEFAULT_UPDATE_TIMER 5 /* disabled by default */
43 /* Stale route marker timer */
44 #define ZEBRA_DEFAULT_STALE_UPDATE_DELAY 1
46 /* Count of stale routes processed in timer context */
47 #define ZEBRA_MAX_STALE_ROUTE_COUNT 50000
49 /* Graceful Restart information */
50 struct client_gr_info
{
51 /* VRF for which GR enabled */
57 /* Stale time and GR cap */
58 uint32_t stale_removal_time
;
59 enum zserv_client_capabilities capabilities
;
66 /* Route sync and enable flags for AFI/SAFI */
67 bool af_enabled
[AFI_MAX
][SAFI_MAX
];
68 bool route_sync
[AFI_MAX
][SAFI_MAX
];
71 struct prefix
*current_prefix
;
72 void *stale_client_ptr
;
73 struct event
*t_stale_removal
;
75 TAILQ_ENTRY(client_gr_info
) gr_info
;
78 /* Client structure. */
81 struct frr_pthread
*pthread
;
83 /* Client file descriptor. */
86 /* Attributes used to permit access to zapi clients from
87 * other pthreads: the client has a busy counter, and a
88 * 'closed' flag. These attributes are managed using a
89 * lock, via the acquire_client() and release_client() apis.
94 /* Input/output buffer to the client. */
95 pthread_mutex_t ibuf_mtx
;
96 struct stream_fifo
*ibuf_fifo
;
97 pthread_mutex_t obuf_mtx
;
98 struct stream_fifo
*obuf_fifo
;
100 /* Private I/O buffers */
101 struct stream
*ibuf_work
;
102 struct stream
*obuf_work
;
104 /* Buffer of data waiting to be written to client. */
107 /* Threads for read/write. */
108 struct event
*t_read
;
109 struct event
*t_write
;
111 /* Event for message processing, for the main pthread */
112 struct event
*t_process
;
114 /* Event for the main pthread */
115 struct event
*t_cleanup
;
117 /* This client's redistribute flag. */
118 struct redist_proto mi_redist
[AFI_MAX
][ZEBRA_ROUTE_MAX
];
119 vrf_bitmap_t redist
[AFI_MAX
][ZEBRA_ROUTE_MAX
];
121 /* Redistribute default route flag. */
122 vrf_bitmap_t redist_default
[AFI_MAX
];
124 /* Router-id information. */
125 vrf_bitmap_t ridinfo
[AFI_MAX
];
127 /* Router-id information. */
128 vrf_bitmap_t nhrp_neighinfo
[AFI_MAX
];
132 /* Indicates if client is synchronous. */
135 /* client's protocol and session info */
141 * Interested for MLAG Updates, and also stores the client
142 * interested message mask
144 bool mlag_updates_interested
;
145 uint32_t mlag_reg_mask1
;
148 uint32_t redist_v4_add_cnt
;
149 uint32_t redist_v4_del_cnt
;
150 uint32_t redist_v6_add_cnt
;
151 uint32_t redist_v6_del_cnt
;
152 uint32_t v4_route_add_cnt
;
153 uint32_t v4_route_upd8_cnt
;
154 uint32_t v4_route_del_cnt
;
155 uint32_t v6_route_add_cnt
;
156 uint32_t v6_route_del_cnt
;
157 uint32_t v6_route_upd8_cnt
;
158 uint32_t connected_rt_add_cnt
;
159 uint32_t connected_rt_del_cnt
;
165 uint32_t bfd_peer_add_cnt
;
166 uint32_t bfd_peer_upd8_cnt
;
167 uint32_t bfd_peer_del_cnt
;
168 uint32_t bfd_peer_replay_cnt
;
171 uint32_t if_vrfchg_cnt
;
172 uint32_t bfd_client_reg_cnt
;
175 uint32_t l3vniadd_cnt
;
176 uint32_t l3vnidel_cnt
;
177 uint32_t macipadd_cnt
;
178 uint32_t macipdel_cnt
;
179 uint32_t prefixadd_cnt
;
180 uint32_t prefixdel_cnt
;
181 uint32_t v4_nh_watch_add_cnt
;
182 uint32_t v4_nh_watch_rem_cnt
;
183 uint32_t v6_nh_watch_add_cnt
;
184 uint32_t v6_nh_watch_rem_cnt
;
185 uint32_t vxlan_sg_add_cnt
;
186 uint32_t vxlan_sg_del_cnt
;
187 uint32_t local_es_add_cnt
;
188 uint32_t local_es_del_cnt
;
189 uint32_t local_es_evi_add_cnt
;
190 uint32_t local_es_evi_del_cnt
;
194 time_t nh_dereg_time
;
195 time_t nh_last_upd_time
;
198 * Session information.
200 * These are not synchronous with respect to each other. For instance,
201 * last_read_cmd may contain a value that has been read in the future
202 * relative to last_read_time.
205 pthread_mutex_t stats_mtx
;
206 /* BEGIN covered by stats_mtx */
208 /* monotime of client creation */
209 uint64_t connect_time
;
210 /* monotime of last message received */
211 uint64_t last_read_time
;
212 /* monotime of last message sent */
213 uint64_t last_write_time
;
214 /* command code of last message read */
215 uint64_t last_read_cmd
;
216 /* command code of last message written */
217 uint64_t last_write_cmd
;
219 /* END covered by stats_mtx */
222 * Number of instances configured with
225 uint32_t gr_instance_count
;
229 * Graceful restart information for
232 TAILQ_HEAD(info_list
, client_gr_info
) gr_info_queue
;
235 #define ZAPI_HANDLER_ARGS \
236 struct zserv *client, struct zmsghdr *hdr, struct stream *msg, \
237 struct zebra_vrf *zvrf
239 /* Hooks for client connect / disconnect */
240 DECLARE_HOOK(zserv_client_connect
, (struct zserv
*client
), (client
));
241 DECLARE_KOOH(zserv_client_close
, (struct zserv
*client
), (client
));
243 #define DYNAMIC_CLIENT_GR_DISABLED(_client) \
244 ((_client->proto <= ZEBRA_ROUTE_CONNECT) \
245 || !(_client->gr_instance_count))
248 * Initialize Zebra API server.
250 * Installs CLI commands and creates the client list.
252 extern void zserv_init(void);
255 * Stop the Zebra API server.
259 extern void zserv_close(void);
262 * Start Zebra API server.
264 * Allocates resources, creates the server socket and begins listening on the
268 * where to place the Unix domain socket
270 extern void zserv_start(char *path
);
273 * Send a message to a connected Zebra API client.
276 * the client to send to
279 * the message to send
281 extern int zserv_send_message(struct zserv
*client
, struct stream
*msg
);
284 * Send a batch of messages to a connected Zebra API client.
287 * the client to send to
290 * the list of messages to send
292 extern int zserv_send_batch(struct zserv
*client
, struct stream_fifo
*fifo
);
295 * Retrieve a client by its protocol and instance number.
304 * The Zebra API client.
306 extern struct zserv
*zserv_find_client(uint8_t proto
, unsigned short instance
);
309 * Retrieve a client by its protocol, instance number, and session id.
321 * The Zebra API client.
323 struct zserv
*zserv_find_client_session(uint8_t proto
, unsigned short instance
,
324 uint32_t session_id
);
327 * Retrieve a client object by the complete tuple of
328 * {protocol, instance, session}. This version supports use
329 * from a different pthread: the object will be returned marked
330 * in-use. The caller *must* release the client object with the
331 * release_client() api, to ensure that the in-use marker is cleared properly.
334 * The Zebra API client.
336 extern struct zserv
*zserv_acquire_client(uint8_t proto
,
337 unsigned short instance
,
338 uint32_t session_id
);
341 * Release a client object that was acquired with the acquire_client() api.
342 * After this has been called, the pointer must not be used - it may be freed
343 * in another pthread if the client has closed.
345 extern void zserv_release_client(struct zserv
*client
);
350 * Kills a client's thread, removes the client from the client list and cleans
354 * the client to close
356 extern void zserv_close_client(struct zserv
*client
);
359 * Free memory for a zserv client object - note that this does not
360 * clean up the internal allocations associated with the zserv client,
361 * this just free the struct's memory.
363 void zserv_client_delete(struct zserv
*client
);
366 * Log a ZAPI message hexdump.
369 * Error message to include with packet hexdump
377 void zserv_log_message(const char *errmsg
, struct stream
*msg
,
378 struct zmsghdr
*hdr
);
381 __attribute__((__noreturn__
)) void zebra_finalize(struct event
*event
);
384 * Graceful restart functions.
386 extern int zebra_gr_client_disconnect(struct zserv
*client
);
387 extern void zebra_gr_client_reconnect(struct zserv
*client
);
388 extern void zebra_gr_stale_client_cleanup(struct list
*client_list
);
389 extern void zread_client_capabilities(struct zserv
*client
, struct zmsghdr
*hdr
,
391 struct zebra_vrf
*zvrf
);
397 #endif /* _ZEBRA_ZEBRA_H */