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 *
log_fmt_peer(const struct peer_config * peer)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
log_peer_info(const struct peer_config * peer,const char * emsg,...)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
log_peer_warn(const struct peer_config * peer,const char * emsg,...)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
log_peer_warnx(const struct peer_config * peer,const char * emsg,...)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
log_statechange(struct peer * peer,enum session_state nstate,enum session_events event)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
log_notification(const struct peer * peer,uint8_t errcode,uint8_t subcode,const struct ibuf * data,const char * dir)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
log_conn_attempt(const struct peer * peer,struct sockaddr * sa,socklen_t len)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