1 /* $OpenBSD: logmsg.c,v 1.14 2024/05/20 10:00:00 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 <errno.h> 20 #include <stdarg.h> 21 #include <stdio.h> 22 #include <stdlib.h> 23 #include <string.h> 24 #include <sys/types.h> 25 #include <syslog.h> 26 27 #include "bgpd.h" 28 #include "session.h" 29 #include "log.h" 30 31 char * 32 log_fmt_peer(const struct peer_config *peer) 33 { 34 const char *ip; 35 char *pfmt, *p; 36 37 ip = log_addr(&peer->remote_addr); 38 if ((peer->remote_addr.aid == AID_INET && peer->remote_masklen != 32) || 39 (peer->remote_addr.aid == AID_INET6 && 40 peer->remote_masklen != 128)) { 41 if (asprintf(&p, "%s/%u", ip, peer->remote_masklen) == -1) 42 fatal(NULL); 43 } else { 44 if ((p = strdup(ip)) == NULL) 45 fatal(NULL); 46 } 47 48 if (peer->descr[0]) { 49 if (asprintf(&pfmt, "neighbor %s (%s)", p, peer->descr) == 50 -1) 51 fatal(NULL); 52 } else { 53 if (asprintf(&pfmt, "neighbor %s", p) == -1) 54 fatal(NULL); 55 } 56 free(p); 57 return (pfmt); 58 } 59 60 void 61 log_peer_info(const struct peer_config *peer, const char *emsg, ...) 62 { 63 char *p, *msg; 64 va_list ap; 65 66 p = log_fmt_peer(peer); 67 va_start(ap, emsg); 68 if (vasprintf(&msg, emsg, ap) == -1) 69 fatal(NULL); 70 va_end(ap); 71 logit(LOG_INFO, "%s: %s", p, msg); 72 free(msg); 73 free(p); 74 } 75 76 void 77 log_peer_warn(const struct peer_config *peer, const char *emsg, ...) 78 { 79 char *p, *msg; 80 va_list ap; 81 int saved_errno = errno; 82 83 p = log_fmt_peer(peer); 84 if (emsg == NULL) { 85 logit(LOG_ERR, "%s: %s", p, strerror(saved_errno)); 86 } else { 87 va_start(ap, emsg); 88 if (vasprintf(&msg, emsg, ap) == -1) 89 fatal(NULL); 90 va_end(ap); 91 logit(LOG_ERR, "%s: %s: %s", p, msg, strerror(saved_errno)); 92 free(msg); 93 } 94 free(p); 95 } 96 97 void 98 log_peer_warnx(const struct peer_config *peer, const char *emsg, ...) 99 { 100 char *p, *msg; 101 va_list ap; 102 103 p = log_fmt_peer(peer); 104 va_start(ap, emsg); 105 if (vasprintf(&msg, emsg, ap) == -1) 106 fatal(NULL); 107 va_end(ap); 108 logit(LOG_ERR, "%s: %s", p, msg); 109 free(msg); 110 free(p); 111 } 112 113 void 114 log_statechange(struct peer *peer, enum session_state nstate, 115 enum session_events event) 116 { 117 char *p; 118 119 /* don't clutter the logs with constant Connect -> Active -> Connect */ 120 if (nstate == STATE_CONNECT && peer->state == STATE_ACTIVE && 121 peer->prev_state == STATE_CONNECT) 122 return; 123 if (nstate == STATE_ACTIVE && peer->state == STATE_CONNECT && 124 peer->prev_state == STATE_ACTIVE) 125 return; 126 127 peer->lasterr = 0; 128 p = log_fmt_peer(&peer->conf); 129 logit(LOG_INFO, "%s: state change %s -> %s, reason: %s", 130 p, statenames[peer->state], statenames[nstate], eventnames[event]); 131 free(p); 132 } 133 134 void 135 log_notification(const struct peer *peer, uint8_t errcode, uint8_t subcode, 136 const struct ibuf *data, const char *dir) 137 { 138 struct ibuf ibuf; 139 char *p; 140 const char *suberrname = NULL; 141 int uk = 0; 142 143 if (data != NULL) 144 ibuf_from_ibuf(&ibuf, data); 145 else 146 ibuf_from_buffer(&ibuf, NULL, 0); 147 148 p = log_fmt_peer(&peer->conf); 149 switch (errcode) { 150 case ERR_HEADER: 151 if (subcode >= sizeof(suberr_header_names) / sizeof(char *) || 152 suberr_header_names[subcode] == NULL) 153 uk = 1; 154 else 155 suberrname = suberr_header_names[subcode]; 156 break; 157 case ERR_OPEN: 158 if (subcode >= sizeof(suberr_open_names) / sizeof(char *) || 159 suberr_open_names[subcode] == NULL) 160 uk = 1; 161 else 162 suberrname = suberr_open_names[subcode]; 163 if (errcode == ERR_OPEN && subcode == ERR_OPEN_CAPA) { 164 uint8_t capa_code; 165 166 if (ibuf_get_n8(&ibuf, &capa_code) == -1) 167 break; 168 169 logit(LOG_ERR, "%s: %s notification: %s, %s: %s", 170 p, dir, errnames[errcode], suberrname, 171 log_capability(capa_code)); 172 free(p); 173 return; 174 } 175 break; 176 case ERR_UPDATE: 177 if (subcode >= sizeof(suberr_update_names) / sizeof(char *) || 178 suberr_update_names[subcode] == NULL) 179 uk = 1; 180 else 181 suberrname = suberr_update_names[subcode]; 182 break; 183 case ERR_CEASE: 184 if (subcode >= sizeof(suberr_cease_names) / sizeof(char *) || 185 suberr_cease_names[subcode] == NULL) 186 uk = 1; 187 else 188 suberrname = suberr_cease_names[subcode]; 189 190 if (subcode == ERR_CEASE_ADMIN_DOWN || 191 subcode == ERR_CEASE_ADMIN_RESET) { 192 uint8_t len; 193 /* check if shutdown reason is included */ 194 if (ibuf_get_n8(&ibuf, &len) != -1 && len != 0) { 195 char *s; 196 if ((s = ibuf_get_string(&ibuf, len)) != NULL) { 197 logit(LOG_ERR, "%s: %s notification: " 198 "%s, %s: reason \"%s\"", p, dir, 199 errnames[errcode], suberrname, 200 log_reason(s)); 201 free(s); 202 free(p); 203 return; 204 } 205 } 206 } 207 break; 208 case ERR_HOLDTIMEREXPIRED: 209 if (subcode != 0) 210 uk = 1; 211 break; 212 case ERR_FSM: 213 if (subcode >= sizeof(suberr_fsm_names) / sizeof(char *) || 214 suberr_fsm_names[subcode] == NULL) 215 uk = 1; 216 else 217 suberrname = suberr_fsm_names[subcode]; 218 break; 219 case ERR_RREFRESH: 220 if (subcode >= sizeof(suberr_rrefresh_names) / sizeof(char *) || 221 suberr_rrefresh_names[subcode] == NULL) 222 uk = 1; 223 else 224 suberrname = suberr_rrefresh_names[subcode]; 225 break; 226 default: 227 logit(LOG_ERR, "%s: %s notification, unknown errcode " 228 "%u, subcode %u", p, dir, errcode, subcode); 229 free(p); 230 return; 231 } 232 233 if (uk) 234 logit(LOG_ERR, "%s: %s notification: %s, unknown subcode %u", 235 p, dir, errnames[errcode], subcode); 236 else { 237 if (suberrname == NULL) 238 logit(LOG_ERR, "%s: %s notification: %s", p, 239 dir, errnames[errcode]); 240 else 241 logit(LOG_ERR, "%s: %s notification: %s, %s", 242 p, dir, errnames[errcode], suberrname); 243 } 244 free(p); 245 } 246 247 void 248 log_conn_attempt(const struct peer *peer, struct sockaddr *sa, socklen_t len) 249 { 250 char *p; 251 252 if (peer == NULL) { /* connection from non-peer, drop */ 253 if (log_getverbose()) 254 logit(LOG_INFO, "connection from non-peer %s refused", 255 log_sockaddr(sa, len)); 256 } else { 257 /* only log if there is a chance that the session may come up */ 258 if (peer->conf.down && peer->state == STATE_IDLE) 259 return; 260 p = log_fmt_peer(&peer->conf); 261 logit(LOG_INFO, "Connection attempt from %s while session is " 262 "in state %s", p, statenames[peer->state]); 263 free(p); 264 } 265 } 266