zebra/zserv.h

   1 /*
   2  * Zebra API server.
   3  * Portions:
   4  *   Copyright (C) 1997-1999  Kunihiro Ishiguro
   5  *   Copyright (C) 2015-2018  Cumulus Networks, Inc.
   6  *   et al.
   7  *
   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)
  11  * any later version.
  12  *
  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
  16  * more details.
  17  *
  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
  21  */
  22
  23 #ifndef _ZEBRA_ZSERV_H
  24 #define _ZEBRA_ZSERV_H
  25
  26 /* clang-format off */
  27 #include <stdint.h>           /* for uint32_t, uint8_t */
  28 #include <time.h>             /* for time_t */
  29
  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 */
  39
  40 #include "zebra/zebra_vrf.h"  /* for zebra_vrf */
  41 /* clang-format on */
  42
  43 #ifdef __cplusplus
  44 extern "C" {
  45 #endif
  46
  47 /* Default port information. */
  48 #define ZEBRA_VTY_PORT                2601
  49
  50 /* Default configuration filename. */
  51 #define DEFAULT_CONFIG_FILE "zebra.conf"
  52
  53 #define ZEBRA_RMAP_DEFAULT_UPDATE_TIMER 5 /* disabled by default */
  54
  55 /* Client structure. */
  56 struct zserv {
  57         /* Client pthread */
  58         struct frr_pthread *pthread;
  59
  60         /* Client file descriptor. */
  61         int sock;
  62
  63         /* Input/output buffer to the client. */
  64         pthread_mutex_t ibuf_mtx;
  65         struct stream_fifo *ibuf_fifo;
  66         pthread_mutex_t obuf_mtx;
  67         struct stream_fifo *obuf_fifo;
  68
  69         /* Private I/O buffers */
  70         struct stream *ibuf_work;
  71         struct stream *obuf_work;
  72
  73         /* Buffer of data waiting to be written to client. */
  74         struct buffer *wb;
  75
  76         /* Threads for read/write. */
  77         struct thread *t_read;
  78         struct thread *t_write;
  79
  80         /* Event for message processing, for the main pthread */
  81         struct thread *t_process;
  82
  83         /* Threads for the main pthread */
  84         struct thread *t_cleanup;
  85
  86         /* This client's redistribute flag. */
  87         struct redist_proto mi_redist[AFI_MAX][ZEBRA_ROUTE_MAX];
  88         vrf_bitmap_t redist[AFI_MAX][ZEBRA_ROUTE_MAX];
  89
  90         /* Redistribute default route flag. */
  91         vrf_bitmap_t redist_default[AFI_MAX];
  92
  93         /* Router-id information. */
  94         vrf_bitmap_t ridinfo;
  95
  96         bool notify_owner;
  97
  98         /* client's protocol */
  99         uint8_t proto;
 100         uint16_t instance;
 101
 102         /*
 103          * Interested for MLAG Updates, and also stores the client
 104          * interested message mask
 105          */
 106         bool mlag_updates_interested;
 107         uint32_t mlag_reg_mask1;
 108
 109         /* Statistics */
 110         uint32_t redist_v4_add_cnt;
 111         uint32_t redist_v4_del_cnt;
 112         uint32_t redist_v6_add_cnt;
 113         uint32_t redist_v6_del_cnt;
 114         uint32_t v4_route_add_cnt;
 115         uint32_t v4_route_upd8_cnt;
 116         uint32_t v4_route_del_cnt;
 117         uint32_t v6_route_add_cnt;
 118         uint32_t v6_route_del_cnt;
 119         uint32_t v6_route_upd8_cnt;
 120         uint32_t connected_rt_add_cnt;
 121         uint32_t connected_rt_del_cnt;
 122         uint32_t ifup_cnt;
 123         uint32_t ifdown_cnt;
 124         uint32_t ifadd_cnt;
 125         uint32_t ifdel_cnt;
 126         uint32_t if_bfd_cnt;
 127         uint32_t bfd_peer_add_cnt;
 128         uint32_t bfd_peer_upd8_cnt;
 129         uint32_t bfd_peer_del_cnt;
 130         uint32_t bfd_peer_replay_cnt;
 131         uint32_t vrfadd_cnt;
 132         uint32_t vrfdel_cnt;
 133         uint32_t if_vrfchg_cnt;
 134         uint32_t bfd_client_reg_cnt;
 135         uint32_t vniadd_cnt;
 136         uint32_t vnidel_cnt;
 137         uint32_t l3vniadd_cnt;
 138         uint32_t l3vnidel_cnt;
 139         uint32_t macipadd_cnt;
 140         uint32_t macipdel_cnt;
 141         uint32_t prefixadd_cnt;
 142         uint32_t prefixdel_cnt;
 143         uint32_t v4_nh_watch_add_cnt;
 144         uint32_t v4_nh_watch_rem_cnt;
 145         uint32_t v6_nh_watch_add_cnt;
 146         uint32_t v6_nh_watch_rem_cnt;
 147         uint32_t vxlan_sg_add_cnt;
 148         uint32_t vxlan_sg_del_cnt;
 149         uint32_t error_cnt;
 150
 151         time_t nh_reg_time;
 152         time_t nh_dereg_time;
 153         time_t nh_last_upd_time;
 154
 155         /*
 156          * Session information.
 157          *
 158          * These are not synchronous with respect to each other. For instance,
 159          * last_read_cmd may contain a value that has been read in the future
 160          * relative to last_read_time.
 161          */
 162
 163         /* monotime of client creation */
 164         _Atomic uint32_t connect_time;
 165         /* monotime of last message received */
 166         _Atomic uint32_t last_read_time;
 167         /* monotime of last message sent */
 168         _Atomic uint32_t last_write_time;
 169         /* command code of last message read */
 170         _Atomic uint32_t last_read_cmd;
 171         /* command code of last message written */
 172         _Atomic uint32_t last_write_cmd;
 173 };
 174
 175 #define ZAPI_HANDLER_ARGS                                                      \
 176         struct zserv *client, struct zmsghdr *hdr, struct stream *msg,         \
 177                 struct zebra_vrf *zvrf
 178
 179 /* Hooks for client connect / disconnect */
 180 DECLARE_HOOK(zserv_client_connect, (struct zserv *client), (client));
 181 DECLARE_KOOH(zserv_client_close, (struct zserv *client), (client));
 182
 183 /*
 184  * Initialize Zebra API server.
 185  *
 186  * Installs CLI commands and creates the client list.
 187  */
 188 extern void zserv_init(void);
 189
 190 /*
 191  * Stop the Zebra API server.
 192  *
 193  * closes the socket
 194  */
 195 extern void zserv_close(void);
 196
 197 /*
 198  * Start Zebra API server.
 199  *
 200  * Allocates resources, creates the server socket and begins listening on the
 201  * socket.
 202  *
 203  * path
 204  *    where to place the Unix domain socket
 205  */
 206 extern void zserv_start(char *path);
 207
 208 /*
 209  * Send a message to a connected Zebra API client.
 210  *
 211  * client
 212  *    the client to send to
 213  *
 214  * msg
 215  *    the message to send
 216  */
 217 extern int zserv_send_message(struct zserv *client, struct stream *msg);
 218
 219 /*
 220  * Retrieve a client by its protocol and instance number.
 221  *
 222  * proto
 223  *    protocol number
 224  *
 225  * instance
 226  *    instance number
 227  *
 228  * Returns:
 229  *    The Zebra API client.
 230  */
 231 extern struct zserv *zserv_find_client(uint8_t proto, unsigned short instance);
 232
 233
 234 /*
 235  * Close a client.
 236  *
 237  * Kills a client's thread, removes the client from the client list and cleans
 238  * up its resources.
 239  *
 240  * client
 241  *    the client to close
 242  */
 243 extern void zserv_close_client(struct zserv *client);
 244
 245
 246 /*
 247  * Log a ZAPI message hexdump.
 248  *
 249  * errmsg
 250  *    Error message to include with packet hexdump
 251  *
 252  * msg
 253  *    Message to log
 254  *
 255  * hdr
 256  *    Message header
 257  */
 258 void zserv_log_message(const char *errmsg, struct stream *msg,
 259                        struct zmsghdr *hdr);
 260
 261 #if defined(HANDLE_ZAPI_FUZZING)
 262 extern void zserv_read_file(char *input);
 263 #endif
 264
 265 /* TODO */
 266 int zebra_finalize(struct thread *event);
 267
 268 #ifdef __cplusplus
 269 }
 270 #endif
 271
 272 #endif /* _ZEBRA_ZEBRA_H */