1 /* $OpenBSD: session.h,v 1.150 2021/02/16 08:29:16 claudio Exp $ */ 2 3 /* 4 * Copyright (c) 2003, 2004 Henning Brauer <henning@openbsd.org> 5 * 6 * Permission to use, copy, modify, and distribute this software for any 7 * purpose with or without fee is hereby granted, provided that the above 8 * copyright notice and this permission notice appear in all copies. 9 * 10 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES 11 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF 12 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR 13 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES 14 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN 15 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF 16 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. 17 */ 18 19 #include <sys/types.h> 20 #include <sys/socket.h> 21 #include <time.h> 22 23 #define MAX_BACKLOG 5 24 #define INTERVAL_CONNECTRETRY 120 25 #define INTERVAL_HOLD_INITIAL 240 26 #define INTERVAL_HOLD 90 27 #define INTERVAL_IDLE_HOLD_INITIAL 30 28 #define INTERVAL_HOLD_CLONED 3600 29 #define INTERVAL_HOLD_DEMOTED 60 30 #define MAX_IDLE_HOLD 3600 31 #define MSGSIZE_HEADER 19 32 #define MSGSIZE_HEADER_MARKER 16 33 #define MSGSIZE_NOTIFICATION_MIN 21 /* 19 hdr + 1 code + 1 sub */ 34 #define MSGSIZE_OPEN_MIN 29 35 #define MSGSIZE_UPDATE_MIN 23 36 #define MSGSIZE_KEEPALIVE MSGSIZE_HEADER 37 #define MSGSIZE_RREFRESH MSGSIZE_HEADER + 4 38 #define MSG_PROCESS_LIMIT 25 39 #define SESSION_CLEAR_DELAY 5 40 41 enum session_state { 42 STATE_NONE, 43 STATE_IDLE, 44 STATE_CONNECT, 45 STATE_ACTIVE, 46 STATE_OPENSENT, 47 STATE_OPENCONFIRM, 48 STATE_ESTABLISHED 49 }; 50 51 enum session_events { 52 EVNT_NONE, 53 EVNT_START, 54 EVNT_STOP, 55 EVNT_CON_OPEN, 56 EVNT_CON_CLOSED, 57 EVNT_CON_OPENFAIL, 58 EVNT_CON_FATAL, 59 EVNT_TIMER_CONNRETRY, 60 EVNT_TIMER_HOLDTIME, 61 EVNT_TIMER_KEEPALIVE, 62 EVNT_TIMER_SENDHOLD, 63 EVNT_RCVD_OPEN, 64 EVNT_RCVD_KEEPALIVE, 65 EVNT_RCVD_UPDATE, 66 EVNT_RCVD_NOTIFICATION 67 }; 68 69 enum msg_type { 70 OPEN = 1, 71 UPDATE, 72 NOTIFICATION, 73 KEEPALIVE, 74 RREFRESH 75 }; 76 77 enum suberr_header { 78 ERR_HDR_SYNC = 1, 79 ERR_HDR_LEN, 80 ERR_HDR_TYPE 81 }; 82 83 enum suberr_open { 84 ERR_OPEN_VERSION = 1, 85 ERR_OPEN_AS, 86 ERR_OPEN_BGPID, 87 ERR_OPEN_OPT, 88 ERR_OPEN_AUTH, 89 ERR_OPEN_HOLDTIME, 90 ERR_OPEN_CAPA, 91 ERR_OPEN_GROUP_CONFLICT, /* draft-ietf-idr-bgp-multisession-07 */ 92 ERR_OPEN_GROUP_REQUIRED /* draft-ietf-idr-bgp-multisession-07 */ 93 }; 94 95 enum suberr_fsm { 96 ERR_FSM_UNSPECIFIC = 0, 97 ERR_FSM_UNEX_OPENSENT, 98 ERR_FSM_UNEX_OPENCONFIRM, 99 ERR_FSM_UNEX_ESTABLISHED 100 }; 101 102 enum opt_params { 103 OPT_PARAM_NONE, 104 OPT_PARAM_AUTH, 105 OPT_PARAM_CAPABILITIES 106 }; 107 108 enum capa_codes { 109 CAPA_NONE, 110 CAPA_MP, 111 CAPA_REFRESH, 112 CAPA_RESTART = 64, 113 CAPA_AS4BYTE = 65 114 }; 115 116 struct bgp_msg { 117 struct ibuf *buf; 118 enum msg_type type; 119 u_int16_t len; 120 }; 121 122 struct msg_header { 123 u_char marker[MSGSIZE_HEADER_MARKER]; 124 u_int16_t len; 125 u_int8_t type; 126 }; 127 128 struct msg_open { 129 struct msg_header header; 130 u_int32_t bgpid; 131 u_int16_t myas; 132 u_int16_t holdtime; 133 u_int8_t version; 134 u_int8_t optparamlen; 135 }; 136 137 struct bgpd_sysdep { 138 u_int8_t no_pfkey; 139 u_int8_t no_md5sig; 140 }; 141 142 struct ctl_conn { 143 TAILQ_ENTRY(ctl_conn) entry; 144 struct imsgbuf ibuf; 145 int restricted; 146 int throttled; 147 int terminate; 148 }; 149 150 struct peer_stats { 151 unsigned long long msg_rcvd_open; 152 unsigned long long msg_rcvd_update; 153 unsigned long long msg_rcvd_notification; 154 unsigned long long msg_rcvd_keepalive; 155 unsigned long long msg_rcvd_rrefresh; 156 unsigned long long msg_sent_open; 157 unsigned long long msg_sent_update; 158 unsigned long long msg_sent_notification; 159 unsigned long long msg_sent_keepalive; 160 unsigned long long msg_sent_rrefresh; 161 unsigned long long prefix_rcvd_update; 162 unsigned long long prefix_rcvd_withdraw; 163 unsigned long long prefix_rcvd_eor; 164 unsigned long long prefix_sent_update; 165 unsigned long long prefix_sent_withdraw; 166 unsigned long long prefix_sent_eor; 167 time_t last_updown; 168 time_t last_read; 169 time_t last_write; 170 u_int32_t prefix_cnt; 171 u_int32_t prefix_out_cnt; 172 u_int8_t last_sent_errcode; 173 u_int8_t last_sent_suberr; 174 u_int8_t last_rcvd_errcode; 175 u_int8_t last_rcvd_suberr; 176 char last_reason[REASON_LEN]; 177 }; 178 179 enum Timer { 180 Timer_None, 181 Timer_ConnectRetry, 182 Timer_Keepalive, 183 Timer_Hold, 184 Timer_SendHold, 185 Timer_IdleHold, 186 Timer_IdleHoldReset, 187 Timer_CarpUndemote, 188 Timer_RestartTimeout, 189 Timer_Rtr_Refresh, 190 Timer_Rtr_Retry, 191 Timer_Rtr_Expire, 192 Timer_Max 193 }; 194 195 struct timer { 196 TAILQ_ENTRY(timer) entry; 197 enum Timer type; 198 time_t val; 199 }; 200 201 TAILQ_HEAD(timer_head, timer); 202 203 struct peer { 204 struct peer_config conf; 205 struct peer_stats stats; 206 RB_ENTRY(peer) entry; 207 struct { 208 struct capabilities ann; 209 struct capabilities peer; 210 struct capabilities neg; 211 } capa; 212 struct { 213 struct bgpd_addr local_addr; 214 u_int32_t spi_in; 215 u_int32_t spi_out; 216 enum auth_method method; 217 u_int8_t established; 218 } auth; 219 struct bgpd_addr local; 220 struct bgpd_addr local_alt; 221 struct bgpd_addr remote; 222 struct timer_head timers; 223 struct msgbuf wbuf; 224 struct ibuf_read *rbuf; 225 struct peer *template; 226 int fd; 227 int lasterr; 228 u_int errcnt; 229 u_int IdleHoldTime; 230 u_int32_t remote_bgpid; 231 enum session_state state; 232 enum session_state prev_state; 233 enum reconf_action reconf_action; 234 u_int16_t short_as; 235 u_int16_t holdtime; 236 u_int16_t local_port; 237 u_int16_t remote_port; 238 u_int8_t depend_ok; 239 u_int8_t demoted; 240 u_int8_t passive; 241 u_int8_t throttled; 242 u_int8_t rpending; 243 }; 244 245 extern time_t pauseaccept; 246 247 struct ctl_timer { 248 enum Timer type; 249 time_t val; 250 }; 251 252 /* carp.c */ 253 int carp_demote_init(char *, int); 254 void carp_demote_shutdown(void); 255 int carp_demote_get(char *); 256 int carp_demote_set(char *, int); 257 258 /* config.c */ 259 void merge_config(struct bgpd_config *, struct bgpd_config *); 260 int prepare_listeners(struct bgpd_config *); 261 262 /* control.c */ 263 int control_check(char *); 264 int control_init(int, char *); 265 int control_listen(int); 266 size_t control_fill_pfds(struct pollfd *, size_t); 267 void control_shutdown(int); 268 int control_dispatch_msg(struct pollfd *, struct peer_head *); 269 unsigned int control_accept(int, int); 270 271 /* log.c */ 272 char *log_fmt_peer(const struct peer_config *); 273 void log_statechange(struct peer *, enum session_state, 274 enum session_events); 275 void log_notification(const struct peer *, u_int8_t, u_int8_t, 276 u_char *, u_int16_t, const char *); 277 void log_conn_attempt(const struct peer *, struct sockaddr *, 278 socklen_t); 279 280 /* mrt.c */ 281 void mrt_dump_bgp_msg(struct mrt *, void *, u_int16_t, 282 struct peer *); 283 void mrt_dump_state(struct mrt *, u_int16_t, u_int16_t, 284 struct peer *); 285 void mrt_done(struct mrt *); 286 287 /* pfkey.c */ 288 int pfkey_read(int, struct sadb_msg *); 289 int pfkey_establish(struct peer *); 290 int pfkey_remove(struct peer *); 291 int pfkey_init(void); 292 int tcp_md5_check(int, struct peer *); 293 int tcp_md5_set(int, struct peer *); 294 int tcp_md5_prep_listener(struct listen_addr *, struct peer_head *); 295 void tcp_md5_add_listener(struct bgpd_config *, struct peer *); 296 void tcp_md5_del_listener(struct bgpd_config *, struct peer *); 297 298 /* printconf.c */ 299 void print_config(struct bgpd_config *, struct rib_names *); 300 301 /* rde.c */ 302 void rde_main(int, int); 303 304 /* rtr_proto.c */ 305 struct rtr_session; 306 size_t rtr_count(void); 307 void rtr_check_events(struct pollfd *, size_t); 308 size_t rtr_poll_events(struct pollfd *, size_t, time_t *); 309 struct rtr_session *rtr_new(uint32_t, char *); 310 struct rtr_session *rtr_get(uint32_t); 311 void rtr_free(struct rtr_session *); 312 void rtr_open(struct rtr_session *, int); 313 struct roa_tree *rtr_get_roa(struct rtr_session *); 314 void rtr_config_prep(void); 315 void rtr_config_merge(void); 316 void rtr_config_keep(struct rtr_session *); 317 void rtr_roa_merge(struct roa_tree *); 318 void rtr_shutdown(void); 319 void rtr_show(struct rtr_session *, pid_t); 320 321 /* rtr.c */ 322 void roa_insert(struct roa_tree *, struct roa *); 323 void rtr_main(int, int); 324 void rtr_imsg_compose(int, uint32_t, pid_t, void *, size_t); 325 void rtr_recalc(void); 326 327 /* session.c */ 328 RB_PROTOTYPE(peer_head, peer, entry, peer_compare); 329 330 void session_main(int, int); 331 void bgp_fsm(struct peer *, enum session_events); 332 int session_neighbor_rrefresh(struct peer *p); 333 struct peer *getpeerbydesc(struct bgpd_config *, const char *); 334 struct peer *getpeerbyip(struct bgpd_config *, struct sockaddr *); 335 struct peer *getpeerbyid(struct bgpd_config *, u_int32_t); 336 int peer_matched(struct peer *, struct ctl_neighbor *); 337 int imsg_ctl_parent(int, u_int32_t, pid_t, void *, u_int16_t); 338 int imsg_ctl_rde(int, pid_t, void *, u_int16_t); 339 void session_stop(struct peer *, u_int8_t); 340 341 /* timer.c */ 342 struct timer *timer_get(struct timer_head *, enum Timer); 343 struct timer *timer_nextisdue(struct timer_head *, time_t); 344 time_t timer_nextduein(struct timer_head *, time_t); 345 int timer_running(struct timer_head *, enum Timer, time_t *); 346 void timer_set(struct timer_head *, enum Timer, u_int); 347 void timer_stop(struct timer_head *, enum Timer); 348 void timer_remove(struct timer_head *, enum Timer); 349 void timer_remove_all(struct timer_head *); 350