xref: /openbsd-src/usr.sbin/bgpd/logmsg.c (revision 1ad61ae0a79a724d2d3ec69e69c8e1d1ff6b53a0)
1 /*	$OpenBSD: logmsg.c,v 1.10 2023/10/14 09:46:14 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     u_char *data, uint16_t datalen, const char *dir)
137 {
138 	char		*p;
139 	const char	*suberrname = NULL;
140 	int		 uk = 0;
141 
142 	p = log_fmt_peer(&peer->conf);
143 	switch (errcode) {
144 	case ERR_HEADER:
145 		if (subcode >= sizeof(suberr_header_names) / sizeof(char *) ||
146 		    suberr_header_names[subcode] == NULL)
147 			uk = 1;
148 		else
149 			suberrname = suberr_header_names[subcode];
150 		break;
151 	case ERR_OPEN:
152 		if (subcode >= sizeof(suberr_open_names) / sizeof(char *) ||
153 		    suberr_open_names[subcode] == NULL)
154 			uk = 1;
155 		else
156 			suberrname = suberr_open_names[subcode];
157 		break;
158 	case ERR_UPDATE:
159 		if (subcode >= sizeof(suberr_update_names) / sizeof(char *) ||
160 		    suberr_update_names[subcode] == NULL)
161 			uk = 1;
162 		else
163 			suberrname = suberr_update_names[subcode];
164 		break;
165 	case ERR_CEASE:
166 		if (subcode >= sizeof(suberr_cease_names) / sizeof(char *) ||
167 		    suberr_cease_names[subcode] == NULL)
168 			uk = 1;
169 		else
170 			suberrname = suberr_cease_names[subcode];
171 		break;
172 	case ERR_HOLDTIMEREXPIRED:
173 		if (subcode != 0)
174 			uk = 1;
175 		break;
176 	case ERR_FSM:
177 		if (subcode >= sizeof(suberr_fsm_names) / sizeof(char *) ||
178 		    suberr_fsm_names[subcode] == NULL)
179 			uk = 1;
180 		else
181 			suberrname = suberr_fsm_names[subcode];
182 		break;
183 	case ERR_RREFRESH:
184 		if (subcode >= sizeof(suberr_rrefresh_names) / sizeof(char *) ||
185 		    suberr_rrefresh_names[subcode] == NULL)
186 			uk = 1;
187 		else
188 			suberrname = suberr_rrefresh_names[subcode];
189 		break;
190 	default:
191 		logit(LOG_ERR, "%s: %s notification, unknown errcode "
192 		    "%u, subcode %u", p, dir, errcode, subcode);
193 		free(p);
194 		return;
195 	}
196 
197 	if (uk)
198 		logit(LOG_ERR, "%s: %s notification: %s, unknown subcode %u",
199 		    p, dir, errnames[errcode], subcode);
200 	else {
201 		if (suberrname == NULL)
202 			logit(LOG_ERR, "%s: %s notification: %s", p,
203 			    dir, errnames[errcode]);
204 		else
205 			logit(LOG_ERR, "%s: %s notification: %s, %s",
206 			    p, dir, errnames[errcode], suberrname);
207 	}
208 	free(p);
209 }
210 
211 void
212 log_conn_attempt(const struct peer *peer, struct sockaddr *sa, socklen_t len)
213 {
214 	char		*p;
215 
216 	if (peer == NULL) {	/* connection from non-peer, drop */
217 		if (log_getverbose())
218 			logit(LOG_INFO, "connection from non-peer %s refused",
219 			    log_sockaddr(sa, len));
220 	} else {
221 		/* only log if there is a chance that the session may come up */
222 		if (peer->conf.down && peer->state == STATE_IDLE)
223 			return;
224 		p = log_fmt_peer(&peer->conf);
225 		logit(LOG_INFO, "Connection attempt from %s while session is "
226 		    "in state %s", p, statenames[peer->state]);
227 		free(p);
228 	}
229 }
230