diff options
Diffstat (limited to 'pimd/pim_msdp.h')
| -rw-r--r-- | pimd/pim_msdp.h | 270 |
1 files changed, 142 insertions, 128 deletions
diff --git a/pimd/pim_msdp.h b/pimd/pim_msdp.h index 308b437a63..66e5457df4 100644 --- a/pimd/pim_msdp.h +++ b/pimd/pim_msdp.h @@ -20,35 +20,35 @@ #define PIM_MSDP_H enum pim_msdp_peer_state { - PIM_MSDP_DISABLED, - PIM_MSDP_INACTIVE, - PIM_MSDP_LISTEN, - PIM_MSDP_CONNECTING, - PIM_MSDP_ESTABLISHED + PIM_MSDP_DISABLED, + PIM_MSDP_INACTIVE, + PIM_MSDP_LISTEN, + PIM_MSDP_CONNECTING, + PIM_MSDP_ESTABLISHED }; /* SA and KA TLVs are processed; rest ignored */ enum pim_msdp_tlv { - PIM_MSDP_V4_SOURCE_ACTIVE = 1, - PIM_MSDP_V4_SOURCE_ACTIVE_REQUEST, - PIM_MSDP_V4_SOURCE_ACTIVE_RESPONSE, - PIM_MSDP_KEEPALIVE, - PIM_MSDP_RESERVED, - PIM_MSDP_TRACEROUTE_PROGRESS, - PIM_MSDP_TRACEROUTE_REPLY, + PIM_MSDP_V4_SOURCE_ACTIVE = 1, + PIM_MSDP_V4_SOURCE_ACTIVE_REQUEST, + PIM_MSDP_V4_SOURCE_ACTIVE_RESPONSE, + PIM_MSDP_KEEPALIVE, + PIM_MSDP_RESERVED, + PIM_MSDP_TRACEROUTE_PROGRESS, + PIM_MSDP_TRACEROUTE_REPLY, }; /* MSDP error codes */ enum pim_msdp_err { - PIM_MSDP_ERR_NONE = 0, - PIM_MSDP_ERR_OOM = -1, - PIM_MSDP_ERR_PEER_EXISTS = -2, - PIM_MSDP_ERR_MAX_MESH_GROUPS = -3, - PIM_MSDP_ERR_NO_PEER = -4, - PIM_MSDP_ERR_MG_MBR_EXISTS = -5, - PIM_MSDP_ERR_NO_MG = -6, - PIM_MSDP_ERR_NO_MG_MBR = -7, - PIM_MSDP_ERR_SIP_EQ_DIP = -8, + PIM_MSDP_ERR_NONE = 0, + PIM_MSDP_ERR_OOM = -1, + PIM_MSDP_ERR_PEER_EXISTS = -2, + PIM_MSDP_ERR_MAX_MESH_GROUPS = -3, + PIM_MSDP_ERR_NO_PEER = -4, + PIM_MSDP_ERR_MG_MBR_EXISTS = -5, + PIM_MSDP_ERR_NO_MG = -6, + PIM_MSDP_ERR_NO_MG_MBR = -7, + PIM_MSDP_ERR_SIP_EQ_DIP = -8, }; #define PIM_MSDP_STATE_STRLEN 16 @@ -58,149 +58,155 @@ enum pim_msdp_err { #define PIM_MSDP_SOCKET_SNDBUF_SIZE 65536 enum pim_msdp_sa_flags { - PIM_MSDP_SAF_NONE = 0, - /* There are two cases where we can pickup an active source locally - - * 1. We are RP and got a source-register from the FHR - * 2. We are RP and FHR and learnt a new directly connected source on a - * DR interface */ - PIM_MSDP_SAF_LOCAL = (1 << 0), - /* We got this in the MSDP SA TLV from a peer (and this passed peer-RPF - * checks) */ - PIM_MSDP_SAF_PEER = (1 << 1), - PIM_MSDP_SAF_REF = (PIM_MSDP_SAF_LOCAL | PIM_MSDP_SAF_PEER), - PIM_MSDP_SAF_STALE = (1 << 2), /* local entries can get kicked out on - * misc pim events such as RP change */ - PIM_MSDP_SAF_UP_DEL_IN_PROG = (1 << 3) + PIM_MSDP_SAF_NONE = 0, + /* There are two cases where we can pickup an active source locally - + * 1. We are RP and got a source-register from the FHR + * 2. We are RP and FHR and learnt a new directly connected source on a + * DR interface */ + PIM_MSDP_SAF_LOCAL = (1 << 0), + /* We got this in the MSDP SA TLV from a peer (and this passed peer-RPF + * checks) */ + PIM_MSDP_SAF_PEER = (1 << 1), + PIM_MSDP_SAF_REF = (PIM_MSDP_SAF_LOCAL | PIM_MSDP_SAF_PEER), + PIM_MSDP_SAF_STALE = (1 << 2), /* local entries can get kicked out on + * misc pim events such as RP change */ + PIM_MSDP_SAF_UP_DEL_IN_PROG = (1 << 3) }; struct pim_msdp_sa { - struct prefix_sg sg; - char sg_str[PIM_SG_LEN]; - struct in_addr rp; /* Last RP address associated with this SA */ - struct in_addr peer; /* last peer from who we heard this SA */ - enum pim_msdp_sa_flags flags; - - /* rfc-3618 is missing default value for SA-hold-down-Period. pulled - * this number from industry-standards */ + struct prefix_sg sg; + char sg_str[PIM_SG_LEN]; + struct in_addr rp; /* Last RP address associated with this SA */ + struct in_addr peer; /* last peer from who we heard this SA */ + enum pim_msdp_sa_flags flags; + +/* rfc-3618 is missing default value for SA-hold-down-Period. pulled + * this number from industry-standards */ #define PIM_MSDP_SA_HOLD_TIME ((3*60)+30) - struct thread *sa_state_timer; // 5.6 - int64_t uptime; + struct thread *sa_state_timer; // 5.6 + int64_t uptime; - struct pim_upstream *up; + struct pim_upstream *up; }; enum pim_msdp_peer_flags { - PIM_MSDP_PEERF_NONE = 0, - PIM_MSDP_PEERF_LISTENER = (1 << 0), + PIM_MSDP_PEERF_NONE = 0, + PIM_MSDP_PEERF_LISTENER = (1 << 0), #define PIM_MSDP_PEER_IS_LISTENER(mp) (mp->flags & PIM_MSDP_PEERF_LISTENER) - PIM_MSDP_PEERF_SA_JUST_SENT = (1 << 1) + PIM_MSDP_PEERF_SA_JUST_SENT = (1 << 1) }; struct pim_msdp_peer { - /* configuration */ - struct in_addr local; - struct in_addr peer; - char *mesh_group_name; - char key_str[INET_ADDRSTRLEN]; - - /* state */ - enum pim_msdp_peer_state state; - enum pim_msdp_peer_flags flags; - - /* TCP socket info */ - union sockunion su_local; - union sockunion su_peer; - int fd; - - /* protocol timers */ + /* configuration */ + struct in_addr local; + struct in_addr peer; + char *mesh_group_name; + char key_str[INET_ADDRSTRLEN]; + + /* state */ + enum pim_msdp_peer_state state; + enum pim_msdp_peer_flags flags; + + /* TCP socket info */ + union sockunion su_local; + union sockunion su_peer; + int fd; + +/* protocol timers */ #define PIM_MSDP_PEER_HOLD_TIME 75 - struct thread *hold_timer; // 5.4 + struct thread *hold_timer; // 5.4 + /* $FRR indent$ */ +/* clang-format off */ #define PIM_MSDP_PEER_KA_TIME 60 - struct thread *ka_timer; // 5.5 + struct thread *ka_timer; // 5.5 + /* $FRR indent$ */ + /* clang-format off */ #define PIM_MSDP_PEER_CONNECT_RETRY_TIME 30 - struct thread *cr_timer; // 5.6 - - /* packet thread and buffers */ - uint32_t packet_size; - struct stream *ibuf; - struct stream_fifo *obuf; - struct thread *t_read; - struct thread *t_write; - - /* stats */ - uint32_t conn_attempts; - uint32_t est_flaps; - uint32_t sa_cnt; /* number of SAs attributed to this peer */ + struct thread *cr_timer; // 5.6 + + /* packet thread and buffers */ + uint32_t packet_size; + struct stream *ibuf; + struct stream_fifo *obuf; + struct thread *t_read; + struct thread *t_write; + + /* stats */ + uint32_t conn_attempts; + uint32_t est_flaps; + uint32_t sa_cnt; /* number of SAs attributed to this peer */ + /* $FRR indent$ */ + /* clang-format off */ #define PIM_MSDP_PEER_LAST_RESET_STR 20 - char last_reset[PIM_MSDP_PEER_LAST_RESET_STR]; + char last_reset[PIM_MSDP_PEER_LAST_RESET_STR]; - /* packet stats */ - uint32_t ka_tx_cnt; - uint32_t sa_tx_cnt; - uint32_t ka_rx_cnt; - uint32_t sa_rx_cnt; - uint32_t unk_rx_cnt; + /* packet stats */ + uint32_t ka_tx_cnt; + uint32_t sa_tx_cnt; + uint32_t ka_rx_cnt; + uint32_t sa_rx_cnt; + uint32_t unk_rx_cnt; - /* timestamps */ - int64_t uptime; + /* timestamps */ + int64_t uptime; }; struct pim_msdp_mg_mbr { - struct in_addr mbr_ip; - struct pim_msdp_peer *mp; + struct in_addr mbr_ip; + struct pim_msdp_peer *mp; }; /* PIM MSDP mesh-group */ struct pim_msdp_mg { - char *mesh_group_name; - struct in_addr src_ip; - uint32_t mbr_cnt; - struct list *mbr_list; + char *mesh_group_name; + struct in_addr src_ip; + uint32_t mbr_cnt; + struct list *mbr_list; }; enum pim_msdp_flags { - PIM_MSDPF_NONE = 0, - PIM_MSDPF_ENABLE = (1 << 0), - PIM_MSDPF_LISTENER = (1 << 1) + PIM_MSDPF_NONE = 0, + PIM_MSDPF_ENABLE = (1 << 0), + PIM_MSDPF_LISTENER = (1 << 1) }; struct pim_msdp_listener { - int fd; - union sockunion su; - struct thread *thread; + int fd; + union sockunion su; + struct thread *thread; }; struct pim_msdp { - enum pim_msdp_flags flags; - struct thread_master *master; - struct pim_msdp_listener listener; - uint32_t rejected_accepts; + enum pim_msdp_flags flags; + struct thread_master *master; + struct pim_msdp_listener listener; + uint32_t rejected_accepts; - /* MSDP peer info */ - struct hash *peer_hash; - struct list *peer_list; + /* MSDP peer info */ + struct hash *peer_hash; + struct list *peer_list; - /* MSDP active-source info */ +/* MSDP active-source info */ #define PIM_MSDP_SA_ADVERTISMENT_TIME 60 - struct thread *sa_adv_timer; // 5.6 - struct hash *sa_hash; - struct list *sa_list; - uint32_t local_cnt; + struct thread *sa_adv_timer; // 5.6 + struct hash *sa_hash; + struct list *sa_list; + uint32_t local_cnt; - /* keep a scratch pad for building SA TLVs */ - struct stream *work_obuf; + /* keep a scratch pad for building SA TLVs */ + struct stream *work_obuf; - struct in_addr originator_id; + struct in_addr originator_id; - /* currently only one mesh-group is supported - so just stash it here */ - struct pim_msdp_mg *mg; + /* currently only one mesh-group is supported - so just stash it here */ + struct pim_msdp_mg *mg; }; -#define PIM_MSDP_PEER_READ_ON(mp) \ - thread_add_read (msdp->master, pim_msdp_read, mp, mp->fd, &mp->t_read) +#define PIM_MSDP_PEER_READ_ON(mp) \ + thread_add_read(msdp->master, pim_msdp_read, mp, mp->fd, &mp->t_read) -#define PIM_MSDP_PEER_WRITE_ON(mp) \ - thread_add_write (msdp->master, pim_msdp_write, mp, mp->fd, &mp->t_write) +#define PIM_MSDP_PEER_WRITE_ON(mp) \ + thread_add_write(msdp->master, pim_msdp_write, mp, mp->fd, &mp->t_write) #define PIM_MSDP_PEER_READ_OFF(mp) THREAD_READ_OFF(mp->t_read) #define PIM_MSDP_PEER_WRITE_OFF(mp) THREAD_WRITE_OFF(mp->t_write) @@ -208,28 +214,36 @@ struct pim_msdp { extern struct pim_msdp *msdp; void pim_msdp_init(struct thread_master *master); void pim_msdp_exit(void); -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); +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); enum pim_msdp_err pim_msdp_peer_del(struct in_addr peer_addr); -char *pim_msdp_state_dump(enum pim_msdp_peer_state state, char *buf, int buf_size); +char *pim_msdp_state_dump(enum pim_msdp_peer_state state, char *buf, + int buf_size); struct pim_msdp_peer *pim_msdp_peer_find(struct in_addr peer_addr); void pim_msdp_peer_established(struct pim_msdp_peer *mp); void pim_msdp_peer_pkt_rxed(struct pim_msdp_peer *mp); void pim_msdp_peer_stop_tcp_conn(struct pim_msdp_peer *mp, bool chg_state); void pim_msdp_peer_reset_tcp_conn(struct pim_msdp_peer *mp, const char *rc_str); int pim_msdp_write(struct thread *thread); -char *pim_msdp_peer_key_dump(struct pim_msdp_peer *mp, char *buf, int buf_size, bool long_format); +char *pim_msdp_peer_key_dump(struct pim_msdp_peer *mp, char *buf, int buf_size, + bool long_format); int pim_msdp_config_write(struct vty *vty); void pim_msdp_peer_pkt_txed(struct pim_msdp_peer *mp); -void pim_msdp_sa_ref(struct pim_msdp_peer *mp, struct prefix_sg *sg, struct in_addr rp); +void pim_msdp_sa_ref(struct pim_msdp_peer *mp, struct prefix_sg *sg, + struct in_addr rp); void pim_msdp_sa_local_update(struct pim_upstream *up); void pim_msdp_sa_local_del(struct prefix_sg *sg); void pim_msdp_i_am_rp_changed(void); bool pim_msdp_peer_rpf_check(struct pim_msdp_peer *mp, struct in_addr rp); void pim_msdp_up_join_state_changed(struct pim_upstream *xg_up); void pim_msdp_up_del(struct prefix_sg *sg); -enum pim_msdp_err pim_msdp_mg_mbr_add(const char *mesh_group_name, struct in_addr mbr_ip); -enum pim_msdp_err pim_msdp_mg_mbr_del(const char *mesh_group_name, struct in_addr mbr_ip); +enum pim_msdp_err pim_msdp_mg_mbr_add(const char *mesh_group_name, + struct in_addr mbr_ip); +enum pim_msdp_err pim_msdp_mg_mbr_del(const char *mesh_group_name, + struct in_addr mbr_ip); enum pim_msdp_err pim_msdp_mg_src_del(const char *mesh_group_name); -enum pim_msdp_err pim_msdp_mg_src_add(const char *mesh_group_name, struct in_addr src_ip); +enum pim_msdp_err pim_msdp_mg_src_add(const char *mesh_group_name, + struct in_addr src_ip); enum pim_msdp_err pim_msdp_mg_del(const char *mesh_group_name); #endif |