pimd/pim_msdp.h

   1 /*
   2  * IP MSDP for Quagga
   3  * Copyright (C) 2016 Cumulus Networks, Inc.
   4  *
   5  * This program is free software; you can redistribute it and/or modify
   6  * it under the terms of the GNU General Public License as published by
   7  * the Free Software Foundation; either version 2 of the License, or
   8  * (at your option) any later version.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU General Public License
  16  * along with this program; see the file COPYING; if not, write to the
  17  * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston,
  18  * MA 02110-1301 USA
  19  */
  20 #ifndef PIM_MSDP_H
  21 #define PIM_MSDP_H
  22
  23 enum pim_msdp_peer_state {
  24   PIM_MSDP_DISABLED,
  25   PIM_MSDP_INACTIVE,
  26   PIM_MSDP_LISTEN,
  27   PIM_MSDP_CONNECTING,
  28   PIM_MSDP_ESTABLISHED
  29 };
  30
  31 /* SA and KA TLVs are processed; rest ignored */
  32 enum pim_msdp_tlv {
  33   PIM_MSDP_V4_SOURCE_ACTIVE = 1,
  34   PIM_MSDP_V4_SOURCE_ACTIVE_REQUEST,
  35   PIM_MSDP_V4_SOURCE_ACTIVE_RESPONSE,
  36   PIM_MSDP_KEEPALIVE,
  37   PIM_MSDP_RESERVED,
  38   PIM_MSDP_TRACEROUTE_PROGRESS,
  39   PIM_MSDP_TRACEROUTE_REPLY,
  40 };
  41
  42 /* MSDP error codes */
  43 enum pim_msdp_err {
  44   PIM_MSDP_ERR_NONE = 0,
  45   PIM_MSDP_ERR_OOM = -1,
  46   PIM_MSDP_ERR_PEER_EXISTS = -2,
  47   PIM_MSDP_ERR_MAX_MESH_GROUPS = -3,
  48   PIM_MSDP_ERR_NO_PEER = -4,
  49   PIM_MSDP_ERR_MG_MBR_EXISTS = -5,
  50   PIM_MSDP_ERR_NO_MG = -6,
  51   PIM_MSDP_ERR_NO_MG_MBR = -7,
  52   PIM_MSDP_ERR_SIP_EQ_DIP = -8,
  53 };
  54
  55 #define PIM_MSDP_STATE_STRLEN 16
  56 #define PIM_MSDP_PEER_KEY_STRLEN 80
  57 #define PIM_MSDP_SA_KEY_STRLEN 80
  58 #define PIM_MSDP_UPTIME_STRLEN 80
  59 #define PIM_MSDP_TIMER_STRLEN 12
  60 #define PIM_MSDP_TCP_PORT 639
  61 #define PIM_MSDP_SOCKET_SNDBUF_SIZE 65536
  62
  63 enum pim_msdp_sa_flags {
  64   PIM_MSDP_SAF_NONE = 0,
  65   /* There are two cases where we can pickup an active source locally -
  66    * 1. We are RP and got a source-register from the FHR
  67    * 2. We are RP and FHR and learnt a new directly connected source on a
  68    * DR interface */
  69   PIM_MSDP_SAF_LOCAL = (1 << 0),
  70   /* We got this in the MSDP SA TLV from a peer (and this passed peer-RPF
  71    * checks) */
  72   PIM_MSDP_SAF_PEER = (1 << 1),
  73   PIM_MSDP_SAF_REF = (PIM_MSDP_SAF_LOCAL | PIM_MSDP_SAF_PEER),
  74   PIM_MSDP_SAF_STALE = (1 << 2) /* local entries can get kicked out on
  75                                  * misc pim events such as RP change */
  76 };
  77
  78 struct pim_msdp_sa {
  79   struct prefix_sg sg;
  80   struct in_addr rp; /* Last RP address associated with this SA */
  81   struct in_addr peer; /* last peer from who we heard this SA */
  82   enum pim_msdp_sa_flags flags;
  83
  84   /* rfc-3618 is missing default value for SA-hold-down-Period. pulled
  85    * this number from industry-standards */
  86 #define PIM_MSDP_SA_HOLD_TIME ((3*60)+30)
  87   struct thread *sa_state_timer;  // 5.6
  88   int64_t uptime;
  89
  90   struct pim_upstream *up;
  91 };
  92
  93 enum pim_msdp_peer_flags {
  94   PIM_MSDP_PEERF_NONE = 0,
  95   PIM_MSDP_PEERF_LISTENER = (1 << 0),
  96 #define PIM_MSDP_PEER_IS_LISTENER(mp) (mp->flags & PIM_MSDP_PEERF_LISTENER)
  97   PIM_MSDP_PEERF_SA_JUST_SENT = (1 << 1)
  98 };
  99
 100 struct pim_msdp_peer {
 101   /* configuration */
 102   struct in_addr local;
 103   struct in_addr peer;
 104   char *mesh_group_name;
 105
 106   /* state */
 107   enum pim_msdp_peer_state state;
 108   enum pim_msdp_peer_flags flags;
 109
 110   /* TCP socket info */
 111   union sockunion su_local;
 112   union sockunion su_peer;
 113   int fd;
 114
 115   /* protocol timers */
 116 #define PIM_MSDP_PEER_HOLD_TIME 75
 117   struct thread *hold_timer;   // 5.4
 118 #define PIM_MSDP_PEER_KA_TIME 60
 119   struct thread *ka_timer;  // 5.5
 120 #define PIM_MSDP_PEER_CONNECT_RETRY_TIME 30
 121   struct thread *cr_timer;  // 5.6
 122
 123   /* packet thread and buffers */
 124   uint32_t packet_size;
 125   struct stream *ibuf;
 126   struct stream_fifo *obuf;
 127   struct thread *t_read;
 128   struct thread *t_write;
 129
 130   /* stats */
 131   uint32_t conn_attempts;
 132   uint32_t est_flaps;
 133 #define PIM_MSDP_PEER_LAST_RESET_STR 20
 134   char last_reset[PIM_MSDP_PEER_LAST_RESET_STR];
 135
 136   /* packet stats */
 137   uint32_t ka_tx_cnt;
 138   uint32_t sa_tx_cnt;
 139   uint32_t ka_rx_cnt;
 140   uint32_t sa_rx_cnt;
 141   uint32_t unk_rx_cnt;
 142
 143   /* timestamps */
 144   int64_t uptime;
 145 };
 146
 147 struct pim_msdp_mg_mbr {
 148   struct in_addr mbr_ip;
 149   struct pim_msdp_peer *mp;
 150 };
 151
 152 /* PIM MSDP mesh-group */
 153 struct pim_msdp_mg {
 154   char *mesh_group_name;
 155   struct in_addr src_ip;
 156   uint32_t mbr_cnt;
 157   struct list *mbr_list;
 158 };
 159
 160 enum pim_msdp_flags {
 161   PIM_MSDPF_NONE = 0,
 162   PIM_MSDPF_ENABLE = (1 << 0),
 163   PIM_MSDPF_LISTENER = (1 << 1)
 164 };
 165
 166 struct pim_msdp_listener {
 167   int fd;
 168   union sockunion su;
 169   struct thread *thread;
 170 };
 171
 172 struct pim_msdp {
 173   enum pim_msdp_flags flags;
 174   struct thread_master *master;
 175   struct pim_msdp_listener listener;
 176   uint32_t rejected_accepts;
 177
 178   /* MSDP peer info */
 179   struct hash *peer_hash;
 180   struct list *peer_list;
 181
 182   /* MSDP active-source info */
 183 #define PIM_MSDP_SA_ADVERTISMENT_TIME 60
 184   struct thread *sa_adv_timer;  // 5.6
 185   struct hash *sa_hash;
 186   struct list *sa_list;
 187   uint32_t local_cnt;
 188
 189   /* keep a scratch pad for building SA TLVs */
 190   struct stream *work_obuf;
 191
 192   struct in_addr originator_id;
 193
 194   /* currently only one mesh-group is supported - so just stash it here */
 195   struct pim_msdp_mg *mg;
 196 };
 197
 198 #define PIM_MSDP_PEER_READ_ON(mp) THREAD_READ_ON(msdp->master, mp->t_read, pim_msdp_read, mp, mp->fd);
 199 #define PIM_MSDP_PEER_WRITE_ON(mp) THREAD_WRITE_ON(msdp->master, mp->t_write, pim_msdp_write, mp, mp->fd);
 200
 201 #define PIM_MSDP_PEER_READ_OFF(mp) THREAD_READ_OFF(mp->t_read)
 202 #define PIM_MSDP_PEER_WRITE_OFF(mp) THREAD_WRITE_OFF(mp->t_write)
 203
 204 extern struct pim_msdp *msdp;
 205 void pim_msdp_init(struct thread_master *master);
 206 void pim_msdp_exit(void);
 207 enum pim_msdp_err pim_msdp_peer_add(struct in_addr peer, struct in_addr local, const char *mesh_group_name, struct pim_msdp_peer **mp_p);
 208 enum pim_msdp_err pim_msdp_peer_del(struct in_addr peer_addr);
 209 char *pim_msdp_state_dump(enum pim_msdp_peer_state state, char *buf, int buf_size);
 210 struct pim_msdp_peer *pim_msdp_peer_find(struct in_addr peer_addr);
 211 void pim_msdp_peer_established(struct pim_msdp_peer *mp);
 212 void pim_msdp_peer_pkt_rxed(struct pim_msdp_peer *mp);
 213 void pim_msdp_peer_stop_tcp_conn(struct pim_msdp_peer *mp, bool chg_state);
 214 void pim_msdp_peer_reset_tcp_conn(struct pim_msdp_peer *mp, const char *rc_str);
 215 int pim_msdp_write(struct thread *thread);
 216 char *pim_msdp_peer_key_dump(struct pim_msdp_peer *mp, char *buf, int buf_size, bool long_format);
 217 int pim_msdp_config_write(struct vty *vty);
 218 void pim_msdp_peer_pkt_txed(struct pim_msdp_peer *mp);
 219 char *pim_msdp_sa_key_dump(struct pim_msdp_sa *sa, char *buf, int buf_size, bool long_format);
 220 void pim_msdp_sa_ref(struct pim_msdp_peer *mp, struct prefix_sg *sg, struct in_addr rp);
 221 void pim_msdp_sa_local_add(struct prefix_sg *sg);
 222 void pim_msdp_sa_local_del(struct prefix_sg *sg);
 223 void pim_msdp_i_am_rp_changed(void);
 224 bool pim_msdp_peer_rpf_check(struct pim_msdp_peer *mp, struct in_addr rp);
 225 void pim_msdp_up_join_state_changed(struct pim_upstream *xg_up);
 226 void pim_msdp_up_xg_del(struct prefix_sg *sg);
 227 enum pim_msdp_err pim_msdp_mg_mbr_add(const char *mesh_group_name, struct in_addr mbr_ip);
 228 enum pim_msdp_err pim_msdp_mg_mbr_del(const char *mesh_group_name, struct in_addr mbr_ip);
 229 enum pim_msdp_err pim_msdp_mg_src_del(const char *mesh_group_name);
 230 enum pim_msdp_err pim_msdp_mg_src_add(const char *mesh_group_name, struct in_addr src_ip);
 231 enum pim_msdp_err pim_msdp_mg_del(const char *mesh_group_name);
 232 #endif