/usr/src/usr.sbin/syslogd/syslogd.c

Bug Summary

File:	src/usr.sbin/syslogd/syslogd.c
Warning:	line 567, column 6 Potential leak of memory pointed to by 'path_unix'
Annotated Source Code

Press '?' to see keyboard shortcuts
Show analyzer invocation
clang -cc1 -cc1 -triple amd64-unknown-openbsd7.4 -analyze -disable-free -clear-ast-before-backend -disable-llvm-verifier -discard-value-names -main-file-name syslogd.c -analyzer-checker=core -analyzer-checker=apiModeling -analyzer-checker=unix -analyzer-checker=deadcode -analyzer-checker=security.insecureAPI.UncheckedReturn -analyzer-checker=security.insecureAPI.getpw -analyzer-checker=security.insecureAPI.gets -analyzer-checker=security.insecureAPI.mktemp -analyzer-checker=security.insecureAPI.mkstemp -analyzer-checker=security.insecureAPI.vfork -analyzer-checker=nullability.NullPassedToNonnull -analyzer-checker=nullability.NullReturnedFromNonnull -analyzer-output plist -w -setup-static-analyzer -mrelocation-model pic -pic-level 1 -pic-is-pie -mframe-pointer=all -relaxed-aliasing -ffp-contract=on -fno-rounding-math -mconstructor-aliases -funwind-tables=2 -target-cpu x86-64 -target-feature +retpoline-indirect-calls -target-feature +retpoline-indirect-branches -tune-cpu generic -debugger-tuning=gdb -fcoverage-compilation-dir=/usr/src/usr.sbin/syslogd/obj -resource-dir /usr/local/llvm16/lib/clang/16 -internal-isystem /usr/local/llvm16/lib/clang/16/include -internal-externc-isystem /usr/include -O2 -fdebug-compilation-dir=/usr/src/usr.sbin/syslogd/obj -ferror-limit 19 -fwrapv -D_RET_PROTECTOR -ret-protector -fcf-protection=branch -fno-jump-tables -fgnuc-version=4.2.1 -vectorize-loops -vectorize-slp -fno-builtin-malloc -fno-builtin-calloc -fno-builtin-realloc -fno-builtin-valloc -fno-builtin-free -fno-builtin-strdup -fno-builtin-strndup -analyzer-output=html -faddrsig -D__GCC_HAVE_DWARF2_CFI_ASM=1 -o /home/ben/Projects/scan/2024-01-11-140451-98009-1 -x c /usr/src/usr.sbin/syslogd/syslogd.c
1/*	$OpenBSD: syslogd.c,v 1.280 2024/01/06 19:34:54 bluhm Exp $	*/

3/*
* Copyright (c) 2014-2021 Alexander Bluhm <bluhm@genua.de>
*
* Permission to use, copy, modify, and distribute this software for any
* purpose with or without fee is hereby granted, provided that the above
* copyright notice and this permission notice appear in all copies.
*
* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
* ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/

19/*
* Copyright (c) 1983, 1988, 1993, 1994
*	The Regents of the University of California.  All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
*    notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
*    notice, this list of conditions and the following disclaimer in the
*    documentation and/or other materials provided with the distribution.
* 3. Neither the name of the University nor the names of its contributors
*    may be used to endorse or promote products derived from this software
*    without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
*/

48/*
*  syslogd -- log system messages
*
* This program implements a system log. It takes a series of lines.
* Each line may have a priority, signified as "<n>" as
* the first characters of the line.  If this is
* not present, a default priority is used.
*
* To kill syslogd, send a signal 15 (terminate).  A signal 1 (hup) will
* cause it to reread its configuration file.
*
* Defined Constants:
*
* MAXLINE -- the maximum line length that can be handled.
* DEFUPRI -- the default priority for user messages
* DEFSPRI -- the default priority for kernel messages
*
* Author: Eric Allman
* extensive changes by Ralph Campbell
* more extensive changes by Eric Allman (again)
* memory buffer logging by Damien Miller
* IPv6, libevent, syslog over TCP and TLS by Alexander Bluhm
*/

72#define MAX_UDPMSG1180	1180		/* maximum UDP send size */
73#define MIN_MEMBUF(8192 * 4)	(LOG_MAXLINE8192 * 4) /* Minimum memory buffer size */
74#define MAX_MEMBUF(256 * 1024)	(256 * 1024)	/* Maximum memory buffer size */
75#define MAX_MEMBUF_NAME64	64		/* Max length of membuf log name */
76#define MAX_TCPBUF(256 * 1024)	(256 * 1024)	/* Maximum tcp event buffer size */
77#define	MAXSVLINE120	120		/* maximum saved line length */
78#define FD_RESERVE5	5		/* file descriptors not accepted */
79#define DEFUPRI((1<<3)|5)		(LOG_USER(1<<3)|LOG_NOTICE5)
80#define DEFSPRI((0<<3)|2)		(LOG_KERN(0<<3)|LOG_CRIT2)
81#define TIMERINTVL30	30		/* interval for checking flush, mark */

83#include <sys/ioctl.h>
84#include <sys/stat.h>
85#include <sys/msgbuf.h>
86#include <sys/queue.h>
87#include <sys/sysctl.h>
88#include <sys/un.h>
89#include <sys/time.h>
90#include <sys/resource.h>

92#include <netinet/in.h>
93#include <netdb.h>
94#include <arpa/inet.h>

96#include <ctype.h>
97#include <err.h>
98#include <errno(*__errno()).h>
99#include <event.h>
100#include <fcntl.h>
101#include <fnmatch.h>
102#include <limits.h>
103#include <paths.h>
104#include <signal.h>
105#include <stdio.h>
106#include <stdlib.h>
107#include <string.h>
108#include <tls.h>
109#include <unistd.h>
110#include <utmp.h>
111#include <vis.h>

113#define MAXIMUM(a, b)(((a) > (b)) ? (a) : (b))	(((a) > (b)) ? (a) : (b))
114#define MINIMUM(a, b)(((a) < (b)) ? (a) : (b))	(((a) < (b)) ? (a) : (b))

116#define SYSLOG_NAMES
117#include <sys/syslog.h>

119#include "log.h"
120#include "syslogd.h"
121#include "evbuffer_tls.h"
122#include "parsemsg.h"

124char *ConfFile = _PATH_LOGCONF"/etc/syslog.conf";
125const char ctty[] = _PATH_CONSOLE"/dev/console";

127#define MAXUNAMES20	20	/* maximum number of user names */


130/*
* Flags to logmsg().
*/

134#define IGN_CONS0x001	0x001	/* don't print on console */
135#define SYNC_FILE0x002	0x002	/* do fsync on file after printing */
136#define MARK0x008		0x008	/* this message is a mark */

138/*
* This structure represents the files that will have log
* copies printed.
*/

143struct filed {
SIMPLEQ_ENTRY(filed)struct { struct filed *sqe_next; } f_next;	/* next in linked list */
int	f_type;			/* entry type, see below */
int	f_file;			/* file descriptor */
time_t	f_time;			/* time this was last written */
u_char	f_pmask[LOG_NFACILITIES24+1];	/* priority mask */
char	*f_program;		/* program this applies to */
char	*f_hostname;		/* host this applies to */
union {
char	f_uname[MAXUNAMES20][UT_NAMESIZE32+1];
struct {
	char	f_loghost[1+4+3+1+NI_MAXHOST256+1+NI_MAXSERV32];
		/* @proto46://[hostname]:servname\0 */
	struct sockaddr_storage	 f_addr;
	struct buffertls	 f_buftls;
	struct bufferevent	*f_bufev;
	struct event		 f_ev;
	struct tls		*f_ctx;
	char			*f_ipproto;
	char			*f_host;
	char			*f_port;
	int			 f_retrywait;
} f_forw;		/* forwarding address */
char	f_fname[PATH_MAX1024];
struct {
	char	f_mname[MAX_MEMBUF_NAME64];
	struct ringbuf *f_rb;
	int	f_overflow;
	int	f_attached;
	size_t	f_len;
} f_mb;		/* Memory buffer */
} f_un;
char	f_prevline[MAXSVLINE120];		/* last message logged */
char	f_lasttime[33];			/* time of last occurrence */
char	f_prevhost[HOST_NAME_MAX255+1];	/* host from which recd. */
int	f_prevpri;			/* pri of f_prevline */
int	f_prevlen;			/* length of f_prevline */
int	f_prevcount;			/* repetition cnt of prevline */
unsigned int f_repeatcount;		/* number of "repeated" msgs */
int	f_quick;			/* abort when matched */
int	f_dropped;			/* warn, dropped message */
time_t	f_lasterrtime;			/* last error was reported */
185};

187/*
* Intervals at which we flush out "message repeated" messages,
* in seconds after previous message is logged.  After each flush,
* we move to the next interval until we reach the largest.
*/
192int	repeatinterval[] = { 30, 120, 600 };	/* # of secs before flush */
193#define	MAXREPEAT((sizeof(repeatinterval) / sizeof(repeatinterval[0])) - 1) ((sizeof(repeatinterval) / sizeof(repeatinterval[0])) - 1)
194#define	REPEATTIME(f)((f)->f_time + repeatinterval[(f)->f_repeatcount])	((f)->f_time + repeatinterval[(f)->f_repeatcount])
195#define	BACKOFF(f){ if (++(f)->f_repeatcount > ((sizeof(repeatinterval) /
 sizeof(repeatinterval[0])) - 1)) (f)->f_repeatcount = ((sizeof
(repeatinterval) / sizeof(repeatinterval[0])) - 1); }	{ if (++(f)->f_repeatcount > MAXREPEAT((sizeof(repeatinterval) / sizeof(repeatinterval[0])) - 1)) \
		(f)->f_repeatcount = MAXREPEAT((sizeof(repeatinterval) / sizeof(repeatinterval[0])) - 1); \
	}

199/* values for f_type */
200#define F_UNUSED0	0		/* unused entry */
201#define F_FILE1		1		/* regular file */
202#define F_TTY2		2		/* terminal */
203#define F_CONSOLE3	3		/* console terminal */
204#define F_FORWUDP4	4		/* remote machine via UDP */
205#define F_USERS5		5		/* list of users */
206#define F_WALL6		6		/* everyone logged on */
207#define F_MEMBUF7	7		/* memory buffer */
208#define F_PIPE8		8		/* pipe to external program */
209#define F_FORWTCP9	9		/* remote machine via TCP */
210#define F_FORWTLS10	10		/* remote machine via TLS */

212char	*TypeNames[] = {
"UNUSED",	"FILE",		"TTY",		"CONSOLE",
"FORWUDP",	"USERS",	"WALL",		"MEMBUF",
"PIPE",		"FORWTCP",	"FORWTLS",
216};

218SIMPLEQ_HEAD(filed_list, filed)struct filed_list { struct filed *sqh_first; struct filed **sqh_last
; } Files;
219struct	filed consfile;

221int	Debug;			/* debug flag */
222int	Foreground;		/* run in foreground, instead of daemonizing */
223char	LocalHostName[HOST_NAME_MAX255+1];	/* our hostname */
224int	Started = 0;		/* set after privsep */
225int	Initialized = 0;	/* set when we have initialized ourselves */

227int	MarkInterval = 20 * 60;	/* interval between marks in seconds */
228int	MarkSeq = 0;		/* mark sequence number */
229int	PrivChild = 0;		/* Exec the privileged parent process */
230int	Repeat = 0;		/* 0 msg repeated, 1 in files only, 2 never */
231int	SecureMode = 1;		/* when true, speak only unix domain socks */
232int	NoDNS = 0;		/* when true, refrain from doing DNS lookups */
233int	ZuluTime = 0;		/* display date and time in UTC ISO format */
234int	IncludeHostname = 0;	/* include RFC 3164 hostnames when forwarding */
235int	Family = PF_UNSPEC0;	/* protocol family, may disable IPv4 or IPv6 */

237struct	tls *server_ctx;
238struct	tls_config *client_config, *server_config;
239const char *CAfile = "/etc/ssl/cert.pem"; /* file containing CA certificates */
240int	NoVerify = 0;		/* do not verify TLS server x509 certificate */
241const char *ClientCertfile = NULL((void *)0);
242const char *ClientKeyfile = NULL((void *)0);
243const char *ServerCAfile = NULL((void *)0);
244int	udpsend_dropped = 0;	/* messages dropped due to UDP not ready */
245int	tcpbuf_dropped = 0;	/* count messages dropped from TCP or TLS */
246int	file_dropped = 0;	/* messages dropped due to file system full */
247int	init_dropped = 0;	/* messages dropped during initialization */

249#define CTL_READING_CMD1		1
250#define CTL_WRITING_REPLY2	2
251#define CTL_WRITING_CONT_REPLY3	3
252int	ctl_state = 0;		/* What the control socket is up to */
253int	membuf_drop = 0;	/* logs dropped in continuous membuf read */

255/*
* Client protocol NB. all numeric fields in network byte order
*/
258#define CTL_VERSION2		2

260/* Request */
261struct	{
u_int32_t	version;
263#define CMD_READ1	1	/* Read out log */
264#define CMD_READ_CLEAR2	2	/* Read and clear log */
265#define CMD_CLEAR3	3	/* Clear log */
266#define CMD_LIST4	4	/* List available logs */
267#define CMD_FLAGS5	5	/* Query flags only */
268#define CMD_READ_CONT6	6	/* Read out log continuously */
u_int32_t	cmd;
u_int32_t	lines;
char		logname[MAX_MEMBUF_NAME64];
272}	ctl_cmd;

274size_t	ctl_cmd_bytes = 0;	/* number of bytes of ctl_cmd read */

276/* Reply */
277struct ctl_reply_hdr {
u_int32_t	version;
279#define CTL_HDR_FLAG_OVERFLOW0x01	0x01
u_int32_t	flags;
/* Reply text follows, up to MAX_MEMBUF long */
282};

284#define CTL_HDR_LEN(sizeof(struct ctl_reply_hdr))		(sizeof(struct ctl_reply_hdr))
285#define CTL_REPLY_MAXSIZE((sizeof(struct ctl_reply_hdr)) + (256 * 1024))	(CTL_HDR_LEN(sizeof(struct ctl_reply_hdr)) + MAX_MEMBUF(256 * 1024))
286#define CTL_REPLY_SIZE(strlen(reply_text) + (sizeof(struct ctl_reply_hdr)))		(strlen(reply_text) + CTL_HDR_LEN(sizeof(struct ctl_reply_hdr)))

288char	*ctl_reply = NULL((void *)0);	/* Buffer for control connection reply */
289char	*reply_text;		/* Start of reply text in buffer */
290size_t	ctl_reply_size = 0;	/* Number of bytes used in reply */
291size_t	ctl_reply_offset = 0;	/* Number of bytes of reply written so far */

293char	*linebuf;
294int	 linesize;

296int		 fd_ctlconn, fd_udp, fd_udp6, send_udp, send_udp6;
297struct event	*ev_ctlaccept, *ev_ctlread, *ev_ctlwrite;

299struct peer {
struct buffertls	 p_buftls;
struct bufferevent	*p_bufev;
struct tls		*p_ctx;
char			*p_peername;
char			*p_hostname;
int			 p_fd;
306};
307char hostname_unknown[] = "???";

309void	 klog_readcb(int, short, void *);
310void	 udp_readcb(int, short, void *);
311void	 unix_readcb(int, short, void *);
312int	 reserve_accept4(int, int, struct event *,
  void (*)(int, short, void *), struct sockaddr *, socklen_t *, int);
314void	 tcp_acceptcb(int, short, void *);
315void	 tls_acceptcb(int, short, void *);
316void	 acceptcb(int, short, void *, int);
317int	 octet_counting(struct evbuffer *, char **, int);
318int	 non_transparent_framing(struct evbuffer *, char **);
319void	 tcp_readcb(struct bufferevent *, void *);
320void	 tcp_closecb(struct bufferevent *, short, void *);
321int	 tcp_socket(struct filed *);
322void	 tcp_dropcb(struct bufferevent *, void *);
323void	 tcp_writecb(struct bufferevent *, void *);
324void	 tcp_errorcb(struct bufferevent *, short, void *);
325void	 tcp_connectcb(int, short, void *);
326int	 loghost_resolve(struct filed *);
327void	 loghost_retry(struct filed *);
328void	 udp_resolvecb(int, short, void *);
329int	 tcpbuf_countmsg(struct bufferevent *bufev);
330void	 die_signalcb(int, short, void *);
331void	 mark_timercb(int, short, void *);
332void	 init_signalcb(int, short, void *);
333void	 ctlsock_acceptcb(int, short, void *);
334void	 ctlconn_readcb(int, short, void *);
335void	 ctlconn_writecb(int, short, void *);
336void	 ctlconn_logto(char *);
337void	 ctlconn_cleanup(void);

339struct filed *cfline(char *, char *, char *);
340void	cvthname(struct sockaddr *, char *, size_t);
341int	decode(const char *, const CODE *);
342void	markit(void);
343void	fprintlog(struct filed *, int, char *);
344void	dropped_warn(int *, const char *);
345void	init(void);
346void	logevent(int, const char *);
347void	logmsg(struct msg *, int, char *);
348struct filed *find_dup(struct filed *);
349void	printline(char *, char *);
350void	printsys(char *);
351void	current_time(char *);
352void	usage(void);
353void	wallmsg(struct filed *, struct iovec *);
354int	loghost_parse(char *, char **, char **, char **);
355int	getmsgbufsize(void);
356void	address_alloc(const char *, const char *, char ***, char ***, int *);
357int	socket_bind(const char *, const char *, const char *, int,
  int *, int *);
359int	unix_socket(char *, int, mode_t);
360void	double_sockbuf(int, int, int);
361void	set_sockbuf(int);
362void	set_keepalive(int);
363void	tailify_replytext(char *, int);

365int
366main(int argc, char *argv[])
367{
struct timeval	 to;
struct event	*ev_klog, *ev_sendsys, *ev_udp, *ev_udp6,
	*ev_bind, *ev_listen, *ev_tls, *ev_unix,
	*ev_hup, *ev_int, *ev_quit, *ev_term, *ev_mark;
sigset_t	 sigmask;
const char	*errstr;
char		*p;
int		 ch, i;
int		 lockpipe[2] = { -1, -1}, pair[2], nullfd, fd;
int		 fd_ctlsock, fd_klog, fd_sendsys, *fd_bind, *fd_listen;
int		*fd_tls, *fd_unix, nunix, nbind, nlisten, ntls;
char		**path_unix, *path_ctlsock;
char		**bind_host, **bind_port, **listen_host, **listen_port;
char		*tls_hostport, **tls_host, **tls_port;

/* block signal until handler is set up */
sigemptyset(&sigmask);
sigaddset(&sigmask, SIGHUP1);
if (sigprocmask(SIG_SETMASK3, &sigmask, NULL((void *)0)) == -1)
1
Assuming the condition is false→
2
←
Taking false branch→
err(1, "sigprocmask block");

if ((path_unix = malloc(sizeof(*path_unix))) == NULL((void *)0))
3
←
Memory is allocated→
4
←
Assuming the condition is false→
5
←
Taking false branch→
err(1, "malloc %s", _PATH_LOG"/dev/log");
path_unix[0] = _PATH_LOG"/dev/log";
nunix = 1;
path_ctlsock = NULL((void *)0);

bind_host = listen_host = tls_host = NULL((void *)0);
bind_port = listen_port = tls_port = NULL((void *)0);
tls_hostport = NULL((void *)0);
nbind = nlisten = ntls = 0;

while ((ch = getopt(argc, argv,
6
←
Assuming the condition is false→
7
←
Loop condition is false. Execution continues on line 489→
   "46a:C:c:dFf:hK:k:m:nP:p:rS:s:T:U:uVZ")) != -1) {
switch (ch) {
case '4':		/* disable IPv6 */
	Family = PF_INET2;
	break;
case '6':		/* disable IPv4 */
	Family = PF_INET624;
	break;
case 'a':
	if ((path_unix = reallocarray(path_unix, nunix + 1,
	    sizeof(*path_unix))) == NULL((void *)0))
		err(1, "unix path %s", optarg);
	path_unix[nunix++] = optarg;
	break;
case 'C':		/* file containing CA certificates */
	CAfile = optarg;
	break;
case 'c':		/* file containing client certificate */
	ClientCertfile = optarg;
	break;
case 'd':		/* debug */
	Debug++;
	break;
case 'F':		/* foreground */
	Foreground = 1;
	break;
case 'f':		/* configuration file */
	ConfFile = optarg;
	break;
case 'h':		/* RFC 3164 hostnames */
	IncludeHostname = 1;
	break;
case 'K':		/* verify client with CA file */
	ServerCAfile = optarg;
	break;
case 'k':		/* file containing client key */
	ClientKeyfile = optarg;
	break;
case 'm':		/* mark interval */
	MarkInterval = strtonum(optarg, 0, 365*24*60, &errstr);
	if (errstr)
		errx(1, "mark_interval %s: %s", errstr, optarg);
	MarkInterval *= 60;
	break;
case 'n':		/* don't do DNS lookups */
	NoDNS = 1;
	break;
case 'P':		/* used internally, exec the parent */
	PrivChild = strtonum(optarg, 2, INT_MAX0x7fffffff, &errstr);
	if (errstr)
		errx(1, "priv child %s: %s", errstr, optarg);
	break;
case 'p':		/* path */
	path_unix[0] = optarg;
	break;
case 'r':
	Repeat++;
	break;
case 'S':		/* allow tls and listen on address */
	if (tls_hostport == NULL((void *)0))
		tls_hostport = optarg;
	address_alloc("tls", optarg, &tls_host, &tls_port,
	    &ntls);
	break;
case 's':
	path_ctlsock = optarg;
	break;
case 'T':		/* allow tcp and listen on address */
	address_alloc("listen", optarg, &listen_host,
	    &listen_port, &nlisten);
	break;
case 'U':		/* allow udp only from address */
	address_alloc("bind", optarg, &bind_host, &bind_port,
	    &nbind);
	break;
case 'u':		/* allow udp input port */
	SecureMode = 0;
	break;
case 'V':		/* do not verify certificates */
	NoVerify = 1;
	break;
case 'Z':		/* time stamps in UTC ISO format */
	ZuluTime = 1;
	break;
default:
	usage();
}
}
if (argc != optind)
8
←
Assuming 'argc' is equal to 'optind'→
9
←
Taking false branch→
usage();

log_init(Debug, LOG_SYSLOG(5<<3));
log_procinit("syslogd");
if (Debug)
10
←
Assuming 'Debug' is not equal to 0→
11
←
Taking true branch→
setvbuf(stdout(&__sF[1]), NULL((void *)0), _IOLBF1, 0);

if ((nullfd = open(_PATH_DEVNULL"/dev/null", O_RDWR0x0002)) == -1)
12
←
Assuming the condition is false→
13
←
Taking false branch→
fatal("open %s", _PATH_DEVNULL"/dev/null");
for (fd = nullfd + 1; fd <= STDERR_FILENO2; fd++) {
14
←
Assuming 'fd' is > STDERR_FILENO→
15
←
Loop condition is false. Execution continues on line 505→
if (fcntl(fd, F_GETFL3) == -1 && errno(*__errno()) == EBADF9)
	if (dup2(nullfd, fd) == -1)
		fatal("dup2 null");
}

if (PrivChild > 1)
16
←
Assuming 'PrivChild' is <= 1→
17
←
Taking false branch→
priv_exec(ConfFile, NoDNS, PrivChild, argc, argv);

consfile.f_type = F_CONSOLE3;
(void)strlcpy(consfile.f_un.f_fname, ctty,
   sizeof(consfile.f_un.f_fname));
consfile.f_file = open(consfile.f_un.f_fname, O_WRONLY0x0001|O_NONBLOCK0x0004);
if (consfile.f_file == -1)
18
←
Assuming the condition is false→
log_warn("open %s", consfile.f_un.f_fname);

if (gethostname(LocalHostName, sizeof(LocalHostName)) == -1 ||
19
←
Assuming the condition is true→
   LocalHostName[0] == '\0')
strlcpy(LocalHostName, "-", sizeof(LocalHostName));
else if ((p = strchr(LocalHostName, '.')) != NULL((void *)0))
*p = '\0';

/* Reserve space for kernel message buffer plus buffer full message. */
linesize = getmsgbufsize() + 64;
if (linesize < LOG_MAXLINE8192)
20
←
Assuming 'linesize' is < LOG_MAXLINE→
21
←
Taking true branch→
linesize = LOG_MAXLINE8192;
linesize++;
if ((linebuf = malloc(linesize)) == NULL((void *)0))
22
←
Assuming the condition is false→
23
←
Taking false branch→
fatal("allocate line buffer");

if (socket_bind("udp", NULL((void *)0), "syslog", SecureMode,
24
←
Assuming the condition is false→
25
←
Taking false branch→
   &fd_udp, &fd_udp6) == -1)
log_warnx("socket bind * failed");
if ((fd_bind = reallocarray(NULL((void *)0), nbind, sizeof(*fd_bind))) == NULL((void *)0))
26
←
Assuming the condition is false→
27
←
Taking false branch→
fatal("allocate bind fd");
for (i = 0; i < nbind; i++) {
28
←
Loop condition is false. Execution continues on line 539→
if (socket_bind("udp", bind_host[i], bind_port[i], 0,
    &fd_bind[i], &fd_bind[i]) == -1)
	log_warnx("socket bind udp failed");
}
if ((fd_listen = reallocarray(NULL((void *)0), nlisten, sizeof(*fd_listen)))
29
←
Assuming the condition is false→
30
←
Taking false branch→
   == NULL((void *)0))
fatal("allocate listen fd");
for (i = 0; i < nlisten; i++) {
31
←
Loop condition is false. Execution continues on line 547→
if (socket_bind("tcp", listen_host[i], listen_port[i], 0,
    &fd_listen[i], &fd_listen[i]) == -1)
	log_warnx("socket listen tcp failed");
}
if ((fd_tls = reallocarray(NULL((void *)0), ntls, sizeof(*fd_tls))) == NULL((void *)0))
32
←
Assuming the condition is false→
33
←
Taking false branch→
fatal("allocate tls fd");
for (i = 0; i < ntls; i++) {
34
←
Loop condition is false. Execution continues on line 555→
if (socket_bind("tls", tls_host[i], tls_port[i], 0,
    &fd_tls[i], &fd_tls[i]) == -1)
	log_warnx("socket listen tls failed");
}

if ((fd_unix = reallocarray(NULL((void *)0), nunix, sizeof(*fd_unix))) == NULL((void *)0))
35
←
Assuming the condition is false→
36
←
Taking false branch→
fatal("allocate unix fd");
for (i = 0; i < nunix; i++) {
37
←
Loop condition is true.  Entering loop body→
40
←
Loop condition is false. Execution continues on line 567→
fd_unix[i] = unix_socket(path_unix[i], SOCK_DGRAM2, 0666);
if (fd_unix[i] == -1) {
38
←
Assuming the condition is false→
39
←
Taking false branch→
	if (i == 0)
		log_warnx("log socket %s failed", path_unix[i]);
	continue;
}
double_sockbuf(fd_unix[i], SO_RCVBUF0x1002, 0);
}

if (socketpair(AF_UNIX1, SOCK_DGRAM2, PF_UNSPEC0, pair) == -1) {
41
←
Potential leak of memory pointed to by 'path_unix'
log_warn("socketpair sendsyslog");
fd_sendsys = -1;
} else {
/*
 * Avoid to lose messages from sendsyslog(2).  A larger
 * 1 MB socket buffer compensates bursts.
 */
double_sockbuf(pair[0], SO_RCVBUF0x1002, 1<<20);
double_sockbuf(pair[1], SO_SNDBUF0x1001, 1<<20);
fd_sendsys = pair[0];
}

fd_ctlsock = fd_ctlconn = -1;
if (path_ctlsock != NULL((void *)0)) {
fd_ctlsock = unix_socket(path_ctlsock, SOCK_STREAM1, 0600);
if (fd_ctlsock == -1) {
	log_warnx("control socket %s failed", path_ctlsock);
} else {
	if (listen(fd_ctlsock, 5) == -1) {
		log_warn("listen control socket");
		close(fd_ctlsock);
		fd_ctlsock = -1;
	}
}
}

if ((fd_klog = open(_PATH_KLOG"/dev/klog", O_RDONLY0x0000)) == -1) {
log_warn("open %s", _PATH_KLOG"/dev/klog");
} else if (fd_sendsys != -1) {
/* Use /dev/klog to register sendsyslog(2) receiver. */
if (ioctl(fd_klog, LIOCSFD((unsigned long)0x80000000 | ((sizeof(int) & 0x1fff) <<
 16) | ((('l')) << 8) | ((127))), &pair[1]) == -1)
	log_warn("ioctl klog LIOCSFD sendsyslog");
}
if (fd_sendsys != -1)
close(pair[1]);

if ((client_config = tls_config_new()) == NULL((void *)0))
log_warn("tls_config_new client");
if (tls_hostport) {
if ((server_config = tls_config_new()) == NULL((void *)0))
	log_warn("tls_config_new server");
if ((server_ctx = tls_server()) == NULL((void *)0)) {
	log_warn("tls_server");
	for (i = 0; i < ntls; i++)
		close(fd_tls[i]);
	free(fd_tls);
	fd_tls = NULL((void *)0);
	free(tls_host);
	free(tls_port);
	tls_host = tls_port = NULL((void *)0);
	ntls = 0;
}
}

if (client_config) {
if (NoVerify) {
	tls_config_insecure_noverifycert(client_config);
	tls_config_insecure_noverifyname(client_config);
} else {
	if (tls_config_set_ca_file(client_config,
	    CAfile) == -1) {
		log_warnx("load client TLS CA: %s",
		    tls_config_error(client_config));
		/* avoid reading default certs in chroot */
		tls_config_set_ca_mem(client_config, "", 0);
	} else
		log_debug("CAfile %s", CAfile);
}
if (ClientCertfile && ClientKeyfile) {
	if (tls_config_set_cert_file(client_config,
	    ClientCertfile) == -1)
		log_warnx("load client TLS cert: %s",
		    tls_config_error(client_config));
	else
		log_debug("ClientCertfile %s", ClientCertfile);

	if (tls_config_set_key_file(client_config,
	    ClientKeyfile) == -1)
		log_warnx("load client TLS key: %s",
		    tls_config_error(client_config));
	else
		log_debug("ClientKeyfile %s", ClientKeyfile);
} else if (ClientCertfile || ClientKeyfile) {
	log_warnx("options -c and -k must be used together");
}
if (tls_config_set_protocols(client_config,
    TLS_PROTOCOLS_ALL((1 << 3)|(1 << 4))) != 0)
	log_warnx("set client TLS protocols: %s",
	    tls_config_error(client_config));
if (tls_config_set_ciphers(client_config, "all") != 0)
	log_warnx("set client TLS ciphers: %s",
	    tls_config_error(client_config));
}
if (server_config && server_ctx) {
const char *names[2];

names[0] = tls_hostport;
names[1] = tls_host[0];

for (i = 0; i < 2; i++) {
	if (asprintf(&p, "/etc/ssl/private/%s.key", names[i])
	    == -1)
		continue;
	if (tls_config_set_key_file(server_config, p) == -1) {
		log_warnx("load server TLS key: %s",
		    tls_config_error(server_config));
		free(p);
		continue;
	}
	log_debug("Keyfile %s", p);
	free(p);
	if (asprintf(&p, "/etc/ssl/%s.crt", names[i]) == -1)
		continue;
	if (tls_config_set_cert_file(server_config, p) == -1) {
		log_warnx("load server TLS cert: %s",
		    tls_config_error(server_config));
		free(p);
		continue;
	}
	log_debug("Certfile %s", p);
	free(p);
	break;
}

if (ServerCAfile) {
	if (tls_config_set_ca_file(server_config,
	    ServerCAfile) == -1) {
		log_warnx("load server TLS CA: %s",
		    tls_config_error(server_config));
		/* avoid reading default certs in chroot */
		tls_config_set_ca_mem(server_config, "", 0);
	} else
		log_debug("Server CAfile %s", ServerCAfile);
	tls_config_verify_client(server_config);
}
if (tls_config_set_protocols(server_config,
    TLS_PROTOCOLS_ALL((1 << 3)|(1 << 4))) != 0)
	log_warnx("set server TLS protocols: %s",
	    tls_config_error(server_config));
if (tls_config_set_ciphers(server_config, "compat") != 0)
	log_warnx("Set server TLS ciphers: %s",
	    tls_config_error(server_config));
if (tls_configure(server_ctx, server_config) != 0) {
	log_warnx("tls_configure server: %s",
	    tls_error(server_ctx));
	tls_free(server_ctx);
	server_ctx = NULL((void *)0);
	for (i = 0; i < ntls; i++)
		close(fd_tls[i]);
	free(fd_tls);
	fd_tls = NULL((void *)0);
	free(tls_host);
	free(tls_port);
	tls_host = tls_port = NULL((void *)0);
	ntls = 0;
}
}

log_debug("off & running....");

if (!Debug && !Foreground) {
char c;

pipe(lockpipe);

switch(fork()) {
case -1:
	err(1, "fork");
case 0:
	setsid();
	close(lockpipe[0]);
	break;
default:
	close(lockpipe[1]);
	read(lockpipe[0], &c, 1);
	_exit(0);
}
}

/* tuck my process id away */
if (!Debug) {
FILE *fp;

fp = fopen(_PATH_LOGPID"/var/run/syslog.pid", "w");
if (fp != NULL((void *)0)) {
	fprintf(fp, "%ld\n", (long)getpid());
	(void) fclose(fp);
}
}

/* Privilege separation begins here */
priv_init(lockpipe[1], nullfd, argc, argv);

if (pledge("stdio unix inet recvfd", NULL((void *)0)) == -1)
err(1, "pledge");

Started = 1;

/* Process is now unprivileged and inside a chroot */
if (Debug)
event_set_log_callback(logevent);
event_init();

if ((ev_ctlaccept = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_ctlread = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_ctlwrite = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_klog = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_sendsys = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_udp = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_udp6 = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_bind = reallocarray(NULL((void *)0), nbind, sizeof(struct event)))
== NULL((void *)0) ||
   (ev_listen = reallocarray(NULL((void *)0), nlisten, sizeof(struct event)))
== NULL((void *)0) ||
   (ev_tls = reallocarray(NULL((void *)0), ntls, sizeof(struct event)))
== NULL((void *)0) ||
   (ev_unix = reallocarray(NULL((void *)0), nunix, sizeof(struct event)))
== NULL((void *)0) ||
   (ev_hup = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_int = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_quit = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_term = malloc(sizeof(struct event))) == NULL((void *)0) ||
   (ev_mark = malloc(sizeof(struct event))) == NULL((void *)0))
err(1, "malloc");

event_set(ev_ctlaccept, fd_ctlsock, EV_READ0x02|EV_PERSIST0x10,
   ctlsock_acceptcb, ev_ctlaccept);
event_set(ev_ctlread, fd_ctlconn, EV_READ0x02|EV_PERSIST0x10,
   ctlconn_readcb, ev_ctlread);
event_set(ev_ctlwrite, fd_ctlconn, EV_WRITE0x04|EV_PERSIST0x10,
   ctlconn_writecb, ev_ctlwrite);
event_set(ev_klog, fd_klog, EV_READ0x02|EV_PERSIST0x10, klog_readcb, ev_klog);
event_set(ev_sendsys, fd_sendsys, EV_READ0x02|EV_PERSIST0x10, unix_readcb,
   ev_sendsys);
event_set(ev_udp, fd_udp, EV_READ0x02|EV_PERSIST0x10, udp_readcb, ev_udp);
event_set(ev_udp6, fd_udp6, EV_READ0x02|EV_PERSIST0x10, udp_readcb, ev_udp6);
for (i = 0; i < nbind; i++)
event_set(&ev_bind[i], fd_bind[i], EV_READ0x02|EV_PERSIST0x10,
    udp_readcb, &ev_bind[i]);
for (i = 0; i < nlisten; i++)
event_set(&ev_listen[i], fd_listen[i], EV_READ0x02|EV_PERSIST0x10,
    tcp_acceptcb, &ev_listen[i]);
for (i = 0; i < ntls; i++)
event_set(&ev_tls[i], fd_tls[i], EV_READ0x02|EV_PERSIST0x10,
    tls_acceptcb, &ev_tls[i]);
for (i = 0; i < nunix; i++)
event_set(&ev_unix[i], fd_unix[i], EV_READ0x02|EV_PERSIST0x10,
    unix_readcb, &ev_unix[i]);

signal_set(ev_hup, SIGHUP, init_signalcb, ev_hup)event_set(ev_hup, 1, 0x08|0x10, init_signalcb, ev_hup);
signal_set(ev_int, SIGINT, die_signalcb, ev_int)event_set(ev_int, 2, 0x08|0x10, die_signalcb, ev_int);
signal_set(ev_quit, SIGQUIT, die_signalcb, ev_quit)event_set(ev_quit, 3, 0x08|0x10, die_signalcb, ev_quit);
signal_set(ev_term, SIGTERM, die_signalcb, ev_term)event_set(ev_term, 15, 0x08|0x10, die_signalcb, ev_term);

evtimer_set(ev_mark, mark_timercb, ev_mark)event_set(ev_mark, -1, 0, mark_timercb, ev_mark);

init();

/* Allocate ctl socket reply buffer if we have a ctl socket */
if (fd_ctlsock != -1 &&
   (ctl_reply = malloc(CTL_REPLY_MAXSIZE((sizeof(struct ctl_reply_hdr)) + (256 * 1024)))) == NULL((void *)0))
fatal("allocate control socket reply buffer");
reply_text = ctl_reply + CTL_HDR_LEN(sizeof(struct ctl_reply_hdr));

if (!Debug) {
close(lockpipe[1]);
dup2(nullfd, STDIN_FILENO0);
dup2(nullfd, STDOUT_FILENO1);
dup2(nullfd, STDERR_FILENO2);
}
if (nullfd > 2)
close(nullfd);

/*
* Signal to the priv process that the initial config parsing is done
* so that it will reject any future attempts to open more files
*/
priv_config_parse_done();

if (fd_ctlsock != -1)
event_add(ev_ctlaccept, NULL((void *)0));
if (fd_klog != -1)
event_add(ev_klog, NULL((void *)0));
if (fd_sendsys != -1)
event_add(ev_sendsys, NULL((void *)0));
if (!SecureMode) {
if (fd_udp != -1)
	event_add(ev_udp, NULL((void *)0));
if (fd_udp6 != -1)
	event_add(ev_udp6, NULL((void *)0));
}
for (i = 0; i < nbind; i++)
if (fd_bind[i] != -1)
	event_add(&ev_bind[i], NULL((void *)0));
for (i = 0; i < nlisten; i++)
if (fd_listen[i] != -1)
	event_add(&ev_listen[i], NULL((void *)0));
for (i = 0; i < ntls; i++)
if (fd_tls[i] != -1)
	event_add(&ev_tls[i], NULL((void *)0));
for (i = 0; i < nunix; i++)
if (fd_unix[i] != -1)
	event_add(&ev_unix[i], NULL((void *)0));

signal_add(ev_hup, NULL)event_add(ev_hup, ((void *)0));
signal_add(ev_term, NULL)event_add(ev_term, ((void *)0));
if (Debug || Foreground) {
signal_add(ev_int, NULL)event_add(ev_int, ((void *)0));
signal_add(ev_quit, NULL)event_add(ev_quit, ((void *)0));
} else {
(void)signal(SIGINT2, SIG_IGN(void (*)(int))1);
(void)signal(SIGQUIT3, SIG_IGN(void (*)(int))1);
}
(void)signal(SIGCHLD20, SIG_IGN(void (*)(int))1);
(void)signal(SIGPIPE13, SIG_IGN(void (*)(int))1);

to.tv_sec = TIMERINTVL30;
to.tv_usec = 0;
evtimer_add(ev_mark, &to)event_add(ev_mark, &to);

log_info(LOG_INFO6, "start");
log_debug("syslogd: started");

sigemptyset(&sigmask);
if (sigprocmask(SIG_SETMASK3, &sigmask, NULL((void *)0)) == -1)
err(1, "sigprocmask unblock");

/* Send message via libc, flushes log stash in kernel. */
openlog("syslogd", LOG_PID0x01, LOG_SYSLOG(5<<3));
syslog(LOG_DEBUG7, "running");

event_dispatch();
/* NOTREACHED */
return (0);
902}

904void
905address_alloc(const char *name, const char *address, char ***host,
  char ***port, int *num)
907{
char *p;

/* do not care about memory leak, argv has to be preserved */
if ((p = strdup(address)) == NULL((void *)0))
err(1, "%s address %s", name, address);
if ((*host = reallocarray(*host, *num + 1, sizeof(**host))) == NULL((void *)0))
err(1, "%s host %s", name, address);
if ((*port = reallocarray(*port, *num + 1, sizeof(**port))) == NULL((void *)0))
err(1, "%s port %s", name, address);
if (loghost_parse(p, NULL((void *)0), *host + *num, *port + *num) == -1)
errx(1, "bad %s address: %s", name, address);
(*num)++;
920}

922int
923socket_bind(const char *proto, const char *host, const char *port,
  int shutread, int *fd, int *fd6)
925{
struct addrinfo	 hints, *res, *res0;
char		 hostname[NI_MAXHOST256], servname[NI_MAXSERV32];
int		*fdp, error, reuseaddr;

*fd = *fd6 = -1;
if (proto == NULL((void *)0))
proto = "udp";
if (port == NULL((void *)0))
port = strcmp(proto, "tls") == 0 ? "syslog-tls" : "syslog";

memset(&hints, 0, sizeof(hints));
hints.ai_family = Family;
if (strcmp(proto, "udp") == 0) {
hints.ai_socktype = SOCK_DGRAM2;
hints.ai_protocol = IPPROTO_UDP17;
} else {
hints.ai_socktype = SOCK_STREAM1;
hints.ai_protocol = IPPROTO_TCP6;
}
hints.ai_flags = AI_PASSIVE1;

if ((error = getaddrinfo(host, port, &hints, &res0))) {
log_warnx("getaddrinfo proto %s, host %s, port %s: %s",
    proto, host ? host : "*", port, gai_strerror(error));
return (-1);
}

for (res = res0; res; res = res->ai_next) {
switch (res->ai_family) {
case AF_INET2:
	fdp = fd;
	break;
case AF_INET624:
	fdp = fd6;
	break;
default:
	continue;
}
if (*fdp >= 0)
	continue;

if ((*fdp = socket(res->ai_family,
    res->ai_socktype | SOCK_NONBLOCK0x4000, res->ai_protocol)) == -1)
	continue;

error = getnameinfo(res->ai_addr, res->ai_addrlen, hostname,
    sizeof(hostname), servname, sizeof(servname),
    NI_NUMERICHOST1 | NI_NUMERICSERV2 |
    (res->ai_socktype == SOCK_DGRAM2 ? NI_DGRAM16 : 0));
if (error) {
	log_warnx("malformed bind address host \"%s\": %s",
	    host, gai_strerror(error));
	strlcpy(hostname, hostname_unknown, sizeof(hostname));
	strlcpy(servname, hostname_unknown, sizeof(servname));
}
if (shutread && shutdown(*fdp, SHUT_RD0) == -1) {
	log_warn("shutdown SHUT_RD "
	    "protocol %d, address %s, portnum %s",
	    res->ai_protocol, hostname, servname);
	close(*fdp);
	*fdp = -1;
	continue;
}
if (!shutread && res->ai_protocol == IPPROTO_UDP17)
	double_sockbuf(*fdp, SO_RCVBUF0x1002, 0);
else if (res->ai_protocol == IPPROTO_TCP6) {
	set_sockbuf(*fdp);
	set_keepalive(*fdp);
}
reuseaddr = 1;
if (setsockopt(*fdp, SOL_SOCKET0xffff, SO_REUSEADDR0x0004, &reuseaddr,
    sizeof(reuseaddr)) == -1) {
	log_warn("setsockopt SO_REUSEADDR "
	    "protocol %d, address %s, portnum %s",
	    res->ai_protocol, hostname, servname);
	close(*fdp);
	*fdp = -1;
	continue;
}
if (bind(*fdp, res->ai_addr, res->ai_addrlen) == -1) {
	log_warn("bind protocol %d, address %s, portnum %s",
	    res->ai_protocol, hostname, servname);
	close(*fdp);
	*fdp = -1;
	continue;
}
if (!shutread && res->ai_protocol == IPPROTO_TCP6 &&
    listen(*fdp, 10) == -1) {
	log_warn("listen protocol %d, address %s, portnum %s",
	    res->ai_protocol, hostname, servname);
	close(*fdp);
	*fdp = -1;
	continue;
}
}

freeaddrinfo(res0);

if (*fd == -1 && *fd6 == -1)
return (-1);
return (0);
1027}

1029void
1030klog_readcb(int fd, short event, void *arg)
1031{
struct event		*ev = arg;
ssize_t			 n;

n = read(fd, linebuf, linesize - 1);
if (n > 0) {
linebuf[n] = '\0';
printsys(linebuf);
} else if (n == -1 && errno(*__errno()) != EINTR4) {
log_warn("read klog");
event_del(ev);
}
1043}

1045void
1046udp_readcb(int fd, short event, void *arg)
1047{
struct sockaddr_storage	 sa;
socklen_t		 salen;
ssize_t			 n;

salen = sizeof(sa);
n = recvfrom(fd, linebuf, LOG_MAXLINE8192, 0, (struct sockaddr *)&sa,
   &salen);
if (n > 0) {
char	 resolve[NI_MAXHOST256];

linebuf[n] = '\0';
cvthname((struct sockaddr *)&sa, resolve, sizeof(resolve));
log_debug("cvthname res: %s", resolve);
printline(resolve, linebuf);
} else if (n == -1 && errno(*__errno()) != EINTR4 && errno(*__errno()) != EWOULDBLOCK35)
log_warn("recvfrom udp");
1064}

1066void
1067unix_readcb(int fd, short event, void *arg)
1068{
struct sockaddr_un	 sa;
socklen_t		 salen;
ssize_t			 n;

salen = sizeof(sa);
n = recvfrom(fd, linebuf, LOG_MAXLINE8192, 0, (struct sockaddr *)&sa,
   &salen);
if (n > 0) {
linebuf[n] = '\0';
printline(LocalHostName, linebuf);
} else if (n == -1 && errno(*__errno()) != EINTR4 && errno(*__errno()) != EWOULDBLOCK35)
log_warn("recvfrom unix");
1081}

1083int
1084reserve_accept4(int lfd, int event, struct event *ev,
  void (*cb)(int, short, void *),
  struct sockaddr *sa, socklen_t *salen, int flags)
1087{
struct timeval	 to = { 1, 0 };
int		 afd;

if (event & EV_TIMEOUT0x01) {
log_debug("Listen again");
/* Enable the listen event, there is no timeout anymore. */
event_set(ev, lfd, EV_READ0x02|EV_PERSIST0x10, cb, ev);
event_add(ev, NULL((void *)0));
errno(*__errno()) = EWOULDBLOCK35;
return (-1);
}

if (getdtablecount() + FD_RESERVE5 >= getdtablesize()) {
afd = -1;
errno(*__errno()) = EMFILE24;
} else
afd = accept4(lfd, sa, salen, flags);

if (afd == -1 && (errno(*__errno()) == ENFILE23 || errno(*__errno()) == EMFILE24)) {
log_info(LOG_WARNING4, "accept deferred: %s", strerror(errno(*__errno())));
/*
 * Disable the listen event and convert it to a timeout.
 * Pass the listen file descriptor to the callback.
 */
event_del(ev);
event_set(ev, lfd, 0, cb, ev);
event_add(ev, &to);
return (-1);
}

return (afd);
1119}

1121void
1122tcp_acceptcb(int lfd, short event, void *arg)
1123{
acceptcb(lfd, event, arg, 0);
1125}

1127void
1128tls_acceptcb(int lfd, short event, void *arg)
1129{
acceptcb(lfd, event, arg, 1);
1131}

1133void
1134acceptcb(int lfd, short event, void *arg, int usetls)
1135{
struct event		*ev = arg;
struct peer		*p;
struct sockaddr_storage	 ss;
socklen_t		 sslen;
char			 hostname[NI_MAXHOST256], servname[NI_MAXSERV32];
char			*peername;
int			 fd, error;

sslen = sizeof(ss);
if ((fd = reserve_accept4(lfd, event, ev, tcp_acceptcb,
   (struct sockaddr *)&ss, &sslen, SOCK_NONBLOCK0x4000)) == -1) {
if (errno(*__errno()) != ENFILE23 && errno(*__errno()) != EMFILE24 &&
    errno(*__errno()) != EINTR4 && errno(*__errno()) != EWOULDBLOCK35 &&
    errno(*__errno()) != ECONNABORTED53)
	log_warn("accept tcp socket");
return;
}
log_debug("Accepting tcp connection");

error = getnameinfo((struct sockaddr *)&ss, sslen, hostname,
   sizeof(hostname), servname, sizeof(servname),
   NI_NUMERICHOST1 | NI_NUMERICSERV2);
if (error) {
log_warnx("malformed TCP accept address: %s",
    gai_strerror(error));
peername = hostname_unknown;
} else if (asprintf(&peername, ss.ss_family == AF_INET624 ?
   "[%s]:%s" : "%s:%s", hostname, servname) == -1) {
log_warn("allocate hostname \"%s\"", hostname);
peername = hostname_unknown;
}
log_debug("Peer address and port %s", peername);
if ((p = malloc(sizeof(*p))) == NULL((void *)0)) {
log_warn("allocate peername \"%s\"", peername);
close(fd);
return;
}
p->p_fd = fd;
if ((p->p_bufev = bufferevent_new(fd, tcp_readcb, NULL((void *)0), tcp_closecb,
   p)) == NULL((void *)0)) {
log_warn("bufferevent \"%s\"", peername);
free(p);
close(fd);
return;
}
p->p_ctx = NULL((void *)0);
if (usetls) {
if (tls_accept_socket(server_ctx, &p->p_ctx, fd) == -1) {
	log_warnx("tls_accept_socket \"%s\": %s",
	    peername, tls_error(server_ctx));
	bufferevent_free(p->p_bufev);
	free(p);
	close(fd);
	return;
}
buffertls_set(&p->p_buftls, p->p_bufev, p->p_ctx, fd);
buffertls_accept(&p->p_buftls, fd);
log_debug("tcp accept callback: tls context success");
}
if (!NoDNS && peername != hostname_unknown &&
   priv_getnameinfo((struct sockaddr *)&ss, ss.ss_len, hostname,
   sizeof(hostname)) != 0) {
log_debug("Host name for accept address (%s) unknown",
    hostname);
}
if (peername == hostname_unknown ||
   (p->p_hostname = strdup(hostname)) == NULL((void *)0))
p->p_hostname = hostname_unknown;
log_debug("Peer hostname %s", hostname);
p->p_peername = peername;
bufferevent_enable(p->p_bufev, EV_READ0x02);

log_info(LOG_DEBUG7, "%s logger \"%s\" accepted",
   p->p_ctx ? "tls" : "tcp", peername);
1210}

1212/*
* Syslog over TCP  RFC 6587  3.4.1. Octet Counting
*/
1215int
1216octet_counting(struct evbuffer *evbuf, char **msg, int drain)
1217{
char	*p, *buf, *end;
int	 len;

buf = EVBUFFER_DATA(evbuf)(evbuf)->buffer;
end = buf + EVBUFFER_LENGTH(evbuf)(evbuf)->off;
/*
* It can be assumed that octet-counting framing is used if a syslog
* frame starts with a digit.
*/
if (buf >= end || !isdigit((unsigned char)*buf))
return (-1);
/*
* SYSLOG-FRAME = MSG-LEN SP SYSLOG-MSG
* MSG-LEN is the octet count of the SYSLOG-MSG in the SYSLOG-FRAME.
* We support up to 5 digits in MSG-LEN, so the maximum is 99999.
*/
for (p = buf; p < end && p < buf + 5; p++) {
if (!isdigit((unsigned char)*p))
	break;
}
if (buf >= p || p >= end || *p != ' ')
return (-1);
p++;
/* Using atoi() is safe as buf starts with 1 to 5 digits and a space. */
len = atoi(buf);
if (drain)
log_debugadd(" octet counting %d", len);
if (p + len > end)
return (0);
if (drain)
evbuffer_drain(evbuf, p - buf);
if (msg)
*msg = p;
return (len);
1252}

1254/*
* Syslog over TCP  RFC 6587  3.4.2. Non-Transparent-Framing
*/
1257int
1258non_transparent_framing(struct evbuffer *evbuf, char **msg)
1259{
char	*p, *buf, *end;

buf = EVBUFFER_DATA(evbuf)(evbuf)->buffer;
end = buf + EVBUFFER_LENGTH(evbuf)(evbuf)->off;
/*
* The TRAILER has usually been a single character and most often
* is ASCII LF (%d10).  However, other characters have also been
* seen, with ASCII NUL (%d00) being a prominent example.
*/
for (p = buf; p < end; p++) {
if (*p == '\0' || *p == '\n')
	break;
}
if (p + 1 - buf >= INT_MAX0x7fffffff)
return (-1);
log_debugadd(" non transparent framing");
if (p >= end)
return (0);
/*
* Some devices have also been seen to emit a two-character
* TRAILER, which is usually CR and LF.
*/
if (buf < p && p[0] == '\n' && p[-1] == '\r')
p[-1] = '\0';
if (msg)
*msg = buf;
return (p + 1 - buf);
1287}

1289void
1290tcp_readcb(struct bufferevent *bufev, void *arg)
1291{
struct peer		*p = arg;
char			*msg;
int			 len;

while (EVBUFFER_LENGTH(bufev->input)(bufev->input)->off > 0) {
log_debugadd("%s logger \"%s\"", p->p_ctx ? "tls" : "tcp",
    p->p_peername);
msg = NULL((void *)0);
len = octet_counting(bufev->input, &msg, 1);
if (len < 0)
	len = non_transparent_framing(bufev->input, &msg);
if (len < 0)
	log_debugadd("unknown method");
if (msg == NULL((void *)0)) {
	log_debugadd(", incomplete frame");
	break;
}
log_debug(", use %d bytes", len);
if (len > 0 && msg[len-1] == '\n')
	msg[len-1] = '\0';
if (len == 0 || msg[len-1] != '\0') {
	memcpy(linebuf, msg, MINIMUM(len, LOG_MAXLINE)(((len) < (8192)) ? (len) : (8192)));
	linebuf[MINIMUM(len, LOG_MAXLINE)(((len) < (8192)) ? (len) : (8192))] = '\0';
	msg = linebuf;
}
printline(p->p_hostname, msg);
evbuffer_drain(bufev->input, len);
}
/* Maximum frame has 5 digits, 1 space, MAXLINE chars, 1 new line. */
if (EVBUFFER_LENGTH(bufev->input)(bufev->input)->off >= 5 + 1 + LOG_MAXLINE8192 + 1) {
log_debug(", use %zu bytes", EVBUFFER_LENGTH(bufev->input)(bufev->input)->off);
EVBUFFER_DATA(bufev->input)(bufev->input)->buffer[5 + 1 + LOG_MAXLINE8192] = '\0';
printline(p->p_hostname, EVBUFFER_DATA(bufev->input)(bufev->input)->buffer);
evbuffer_drain(bufev->input, -1);
} else if (EVBUFFER_LENGTH(bufev->input)(bufev->input)->off > 0)
log_debug(", buffer %zu bytes", EVBUFFER_LENGTH(bufev->input)(bufev->input)->off);
1328}

1330void
1331tcp_closecb(struct bufferevent *bufev, short event, void *arg)
1332{
struct peer		*p = arg;

if (event & EVBUFFER_EOF0x10) {
log_info(LOG_DEBUG7, "%s logger \"%s\" connection close",
    p->p_ctx ? "tls" : "tcp", p->p_peername);
} else {
log_info(LOG_NOTICE5, "%s logger \"%s\" connection error: %s",
    p->p_ctx ? "tls" : "tcp", p->p_peername,
    p->p_ctx ? tls_error(p->p_ctx) : strerror(errno(*__errno())));
}

if (p->p_peername != hostname_unknown)
free(p->p_peername);
if (p->p_hostname != hostname_unknown)
free(p->p_hostname);
bufferevent_free(p->p_bufev);
close(p->p_fd);
free(p);
1351}

1353int
1354tcp_socket(struct filed *f)
1355{
int	 s;

if ((s = socket(f->f_un.f_forw.f_addr.ss_family,
   SOCK_STREAM1 | SOCK_NONBLOCK0x4000, IPPROTO_TCP6)) == -1) {
log_warn("socket \"%s\"", f->f_un.f_forw.f_loghost);
return (-1);
}
set_sockbuf(s);
if (connect(s, (struct sockaddr *)&f->f_un.f_forw.f_addr,
   f->f_un.f_forw.f_addr.ss_len) == -1 && errno(*__errno()) != EINPROGRESS36) {
log_warn("connect \"%s\"", f->f_un.f_forw.f_loghost);
close(s);
return (-1);
}
return (s);
1371}

1373void
1374tcp_dropcb(struct bufferevent *bufev, void *arg)
1375{
struct filed	*f = arg;

/*
* Drop data received from the forward log server.
*/
log_debug("loghost \"%s\" did send %zu bytes back",
   f->f_un.f_forw.f_loghost, EVBUFFER_LENGTH(bufev->input)(bufev->input)->off);
evbuffer_drain(bufev->input, -1);
1384}

1386void
1387tcp_writecb(struct bufferevent *bufev, void *arg)
1388{
struct filed	*f = arg;
char		 ebuf[ERRBUFSIZE256];

/*
* Successful write, connection to server is good, reset wait time.
*/
log_debug("loghost \"%s\" successful write", f->f_un.f_forw.f_loghost);
f->f_un.f_forw.f_retrywait = 0;

if (f->f_dropped > 0 &&
   EVBUFFER_LENGTH(f->f_un.f_forw.f_bufev->output)(f->f_un.f_forw.f_bufev->output)->off < MAX_TCPBUF(256 * 1024)) {
snprintf(ebuf, sizeof(ebuf), "to loghost \"%s\"",
    f->f_un.f_forw.f_loghost);
dropped_warn(&f->f_dropped, ebuf);
}
1404}

1406void
1407tcp_errorcb(struct bufferevent *bufev, short event, void *arg)
1408{
struct filed	*f = arg;
char		*p, *buf, *end;
int		 l;
char		 ebuf[ERRBUFSIZE256];

if (event & EVBUFFER_EOF0x10)
snprintf(ebuf, sizeof(ebuf), "loghost \"%s\" connection close",
    f->f_un.f_forw.f_loghost);
else
snprintf(ebuf, sizeof(ebuf),
    "loghost \"%s\" connection error: %s",
    f->f_un.f_forw.f_loghost, f->f_un.f_forw.f_ctx ?
    tls_error(f->f_un.f_forw.f_ctx) : strerror(errno(*__errno())));
log_debug("%s", ebuf);

/* The SIGHUP handler may also close the socket, so invalidate it. */
if (f->f_un.f_forw.f_ctx) {
tls_close(f->f_un.f_forw.f_ctx);
tls_free(f->f_un.f_forw.f_ctx);
f->f_un.f_forw.f_ctx = NULL((void *)0);
}
bufferevent_disable(bufev, EV_READ0x02|EV_WRITE0x04);
close(f->f_file);
f->f_file = -1;

/*
* The messages in the output buffer may be out of sync.
* Check that the buffer starts with "1234 <1234 octets>\n".
* Otherwise remove the partial message from the beginning.
*/
buf = EVBUFFER_DATA(bufev->output)(bufev->output)->buffer;
end = buf + EVBUFFER_LENGTH(bufev->output)(bufev->output)->off;
if (buf < end && !((l = octet_counting(bufev->output, &p, 0)) > 0 &&
   p[l-1] == '\n')) {
for (p = buf; p < end; p++) {
	if (*p == '\n') {
		evbuffer_drain(bufev->output, p - buf + 1);
		break;
	}
}
/* Without '\n' discard everything. */
if (p == end)
	evbuffer_drain(bufev->output, -1);
log_debug("loghost \"%s\" dropped partial message",
    f->f_un.f_forw.f_loghost);
f->f_dropped++;
}

loghost_retry(f);

/* Log the connection error to the fresh buffer after reconnecting. */
log_info(LOG_WARNING4, "%s", ebuf);
1461}

1463void
1464tcp_connectcb(int fd, short event, void *arg)
1465{
struct filed		*f = arg;
struct bufferevent	*bufev = f->f_un.f_forw.f_bufev;
int			 s;

if (f->f_un.f_forw.f_addr.ss_family == AF_UNSPEC0) {
if (loghost_resolve(f) != 0) {
	loghost_retry(f);
	return;
}
}

if ((s = tcp_socket(f)) == -1) {
loghost_retry(f);
return;
}
log_debug("tcp connect callback: socket success, event %#x", event);
f->f_file = s;

bufferevent_setfd(bufev, s);
bufferevent_setcb(bufev, tcp_dropcb, tcp_writecb, tcp_errorcb, f);
/*
* Although syslog is a write only protocol, enable reading from
* the socket to detect connection close and errors.
*/
bufferevent_enable(bufev, EV_READ0x02|EV_WRITE0x04);

if (f->f_type == F_FORWTLS10) {
if ((f->f_un.f_forw.f_ctx = tls_client()) == NULL((void *)0)) {
	log_warn("tls_client \"%s\"", f->f_un.f_forw.f_loghost);
	goto error;
}
if (client_config &&
    tls_configure(f->f_un.f_forw.f_ctx, client_config) == -1) {
	log_warnx("tls_configure \"%s\": %s",
	    f->f_un.f_forw.f_loghost,
	    tls_error(f->f_un.f_forw.f_ctx));
	goto error;
}
if (tls_connect_socket(f->f_un.f_forw.f_ctx, s,
    f->f_un.f_forw.f_host) == -1) {
	log_warnx("tls_connect_socket \"%s\": %s",
	    f->f_un.f_forw.f_loghost,
	    tls_error(f->f_un.f_forw.f_ctx));
	goto error;
}
log_debug("tcp connect callback: tls context success");

buffertls_set(&f->f_un.f_forw.f_buftls, bufev,
    f->f_un.f_forw.f_ctx, s);
buffertls_connect(&f->f_un.f_forw.f_buftls, s);
}

return;

error:
if (f->f_un.f_forw.f_ctx) {
tls_free(f->f_un.f_forw.f_ctx);
f->f_un.f_forw.f_ctx = NULL((void *)0);
}
bufferevent_disable(bufev, EV_READ0x02|EV_WRITE0x04);
close(f->f_file);
f->f_file = -1;
loghost_retry(f);
1529}

1531int
1532loghost_resolve(struct filed *f)
1533{
char	hostname[NI_MAXHOST256];
int	error;

error = priv_getaddrinfo(f->f_un.f_forw.f_ipproto,
   f->f_un.f_forw.f_host, f->f_un.f_forw.f_port,
   (struct sockaddr *)&f->f_un.f_forw.f_addr,
   sizeof(f->f_un.f_forw.f_addr));
if (error) {
log_warnx("bad hostname \"%s\"", f->f_un.f_forw.f_loghost);
f->f_un.f_forw.f_addr.ss_family = AF_UNSPEC0;
return (error);
}

error = getnameinfo((struct sockaddr *)&f->f_un.f_forw.f_addr,
   f->f_un.f_forw.f_addr.ss_len, hostname, sizeof(hostname), NULL((void *)0), 0,
   NI_NUMERICHOST1 | NI_NUMERICSERV2 |
   (strncmp(f->f_un.f_forw.f_ipproto, "udp", 3) == 0 ? NI_DGRAM16 : 0));
if (error) {
log_warnx("malformed UDP address loghost \"%s\": %s",
    f->f_un.f_forw.f_loghost, gai_strerror(error));
strlcpy(hostname, hostname_unknown, sizeof(hostname));
}

log_debug("resolved loghost \"%s\" address %s",
   f->f_un.f_forw.f_loghost, hostname);
return (0);
1560}

1562void
1563loghost_retry(struct filed *f)
1564{
struct timeval		 to;

if (f->f_un.f_forw.f_retrywait == 0)
f->f_un.f_forw.f_retrywait = 1;
else
f->f_un.f_forw.f_retrywait <<= 1;
if (f->f_un.f_forw.f_retrywait > 600)
f->f_un.f_forw.f_retrywait = 600;
to.tv_sec = f->f_un.f_forw.f_retrywait;
to.tv_usec = 0;
evtimer_add(&f->f_un.f_forw.f_ev, &to)event_add(&f->f_un.f_forw.f_ev, &to);

log_debug("retry loghost \"%s\" wait %d",
   f->f_un.f_forw.f_loghost, f->f_un.f_forw.f_retrywait);
1579}

1581void
1582udp_resolvecb(int fd, short event, void *arg)
1583{
struct filed		*f = arg;
struct timeval		 to;

if (loghost_resolve(f) != 0) {
loghost_retry(f);
return;
}

switch (f->f_un.f_forw.f_addr.ss_family) {
case AF_INET2:
f->f_file = fd_udp;
break;
case AF_INET624:
f->f_file = fd_udp6;
break;
}
f->f_un.f_forw.f_retrywait = 0;

if (f->f_dropped > 0) {
char ebuf[ERRBUFSIZE256];

snprintf(ebuf, sizeof(ebuf), "to udp loghost \"%s\"",
    f->f_un.f_forw.f_loghost);
dropped_warn(&f->f_dropped, ebuf);
}
1609}

1611int
1612tcpbuf_countmsg(struct bufferevent *bufev)
1613{
char	*p, *buf, *end;
int	 i = 0;

buf = EVBUFFER_DATA(bufev->output)(bufev->output)->buffer;
end = buf + EVBUFFER_LENGTH(bufev->output)(bufev->output)->off;
for (p = buf; p < end; p++) {
if (*p == '\n')
	i++;
}
return (i);
1624}

1626void
1627usage(void)
1628{

(void)fprintf(stderr(&__sF[2]),
   "usage: syslogd [-46dFhnruVZ] [-a path] [-C CAfile]\n"
   "\t[-c cert_file] [-f config_file] [-K CAfile] [-k key_file]\n"
   "\t[-m mark_interval] [-p log_socket] [-S listen_address]\n"
   "\t[-s reporting_socket] [-T listen_address] [-U bind_address]\n");
exit(1);
1636}

1638/*
* Take a raw input line, decode the message, and print the message
* on the appropriate log files.
*/
1642void
1643printline(char *hname, char *msgstr)
1644{
struct msg msg;
char *p, *q, line[LOG_MAXLINE8192 + 4 + 1];  /* message, encoding, NUL */

p = msgstr;
for (q = line; *p && q < &line[LOG_MAXLINE8192]; p++) {
if (*p == '\n')
	*q++ = ' ';
else
	q = vis(q, *p, VIS_NOSLASH0x40, 0);
}
line[LOG_MAXLINE8192] = *q = '\0';

parsemsg(line, &msg);
if (msg.m_pri == -1)
msg.m_pri = DEFUPRI((1<<3)|5);
/*
* Don't allow users to log kernel messages.
* NOTE: since LOG_KERN == 0 this will also match
* messages with no facility specified.
*/
if (LOG_FAC(msg.m_pri)(((msg.m_pri) & 0x03f8) >> 3) == LOG_KERN(0<<3))
msg.m_pri = LOG_USER(1<<3) | LOG_PRI(msg.m_pri)((msg.m_pri) & 0x07);

if (msg.m_timestamp[0] == '\0')
current_time(msg.m_timestamp);

logmsg(&msg, 0, hname);
1672}

1674/*
* Take a raw input line from /dev/klog, split and format similar to syslog().
*/
1677void
1678printsys(char *msgstr)
1679{
struct msg msg;
int c, flags;
char *lp, *p, *q;
size_t prilen;
int l;

current_time(msg.m_timestamp);
strlcpy(msg.m_prog, _PATH_UNIX"/bsd", sizeof(msg.m_prog));
l = snprintf(msg.m_msg, sizeof(msg.m_msg), "%s: ", _PATH_UNIX"/bsd");
if (l < 0 || l >= sizeof(msg.m_msg)) {
msg.m_msg[0] = '\0';
l = 0;
}
lp = msg.m_msg + l;
for (p = msgstr; *p != '\0'; ) {
flags = SYNC_FILE0x002;	/* fsync file after write */
msg.m_pri = DEFSPRI((0<<3)|2);
prilen = parsemsg_priority(p, &msg.m_pri);
p += prilen;
if (prilen == 0) {
	/* kernel printf's come out on console */
	flags |= IGN_CONS0x001;
}
if (msg.m_pri &~ (LOG_FACMASK0x03f8|LOG_PRIMASK0x07))
	msg.m_pri = DEFSPRI((0<<3)|2);

q = lp;
while (*p && (c = *p++) != '\n' &&
    q < &msg.m_msg[sizeof(msg.m_msg) - 4])
	q = vis(q, c, VIS_NOSLASH0x40, 0);

logmsg(&msg, flags, LocalHostName);
}
1713}

1715void
1716vlogmsg(int pri, const char *prog, const char *fmt, va_list ap)
1717{
struct msg msg;
int	l;

msg.m_pri = pri;
current_time(msg.m_timestamp);
strlcpy(msg.m_prog, prog, sizeof(msg.m_prog));
l = snprintf(msg.m_msg, sizeof(msg.m_msg), "%s[%d]: ", prog, getpid());
if (l < 0 || l >= sizeof(msg.m_msg))
l = 0;
l = vsnprintf(msg.m_msg + l, sizeof(msg.m_msg) - l, fmt, ap);
if (l < 0)
strlcpy(msg.m_msg, fmt, sizeof(msg.m_msg));

if (!Started) {
fprintf(stderr(&__sF[2]), "%s\n", msg.m_msg);
init_dropped++;
return;
}
logmsg(&msg, 0, LocalHostName);
1737}

1739struct timeval	now;

1741void
1742current_time(char *timestamp)
1743{
(void)gettimeofday(&now, NULL((void *)0));

if (ZuluTime) {
struct tm *tm;
size_t l;

tm = gmtime(&now.tv_sec);
l = strftime(timestamp, 33, "%FT%T", tm);
/*
 * Use only millisecond precision as some time has
 * passed since syslog(3) was called.
 */
snprintf(timestamp + l, 33 - l, ".%03ldZ", now.tv_usec / 1000);
} else
strlcpy(timestamp, ctime(&now.tv_sec) + 4, 16);
1759}

1761/*
* Log a message to the appropriate log files, users, etc. based on
* the priority.
*/
1765void
1766logmsg(struct msg *msg, int flags, char *from)
1767{
struct filed *f;
int fac, msglen, prilev;

(void)gettimeofday(&now, NULL((void *)0));
log_debug("logmsg: pri 0%o, flags 0x%x, from %s, prog %s, msg %s",
   msg->m_pri, flags, from, msg->m_prog, msg->m_msg);

/* extract facility and priority level */
if (flags & MARK0x008)
fac = LOG_NFACILITIES24;
else
fac = LOG_FAC(msg->m_pri)(((msg->m_pri) & 0x03f8) >> 3);
prilev = LOG_PRI(msg->m_pri)((msg->m_pri) & 0x07);

/* log the message to the particular outputs */
if (!Initialized) {
f = &consfile;
if (f->f_type == F_CONSOLE3) {
	strlcpy(f->f_lasttime, msg->m_timestamp,
	    sizeof(f->f_lasttime));
	strlcpy(f->f_prevhost, from,
	    sizeof(f->f_prevhost));
	fprintlog(f, flags, msg->m_msg);
	/* May be set to F_UNUSED, try again next time. */
	f->f_type = F_CONSOLE3;
}
init_dropped++;
return;
}
/* log the message to the particular outputs */
msglen = strlen(msg->m_msg);
SIMPLEQ_FOREACH(f, &Files, f_next)for((f) = ((&Files)->sqh_first); (f) != ((void *)0); (
f) = ((f)->f_next.sqe_next)) {
/* skip messages that are incorrect priority */
if (f->f_pmask[fac] < prilev ||
    f->f_pmask[fac] == INTERNAL_NOPRI0x10)
	continue;

/* skip messages with the incorrect program or hostname */
if (f->f_program && fnmatch(f->f_program, msg->m_prog, 0) != 0)
	continue;
if (f->f_hostname && fnmatch(f->f_hostname, from, 0) != 0)
	continue;

if (f->f_type == F_CONSOLE3 && (flags & IGN_CONS0x001))
	continue;

/* don't output marks to recently written files */
if ((flags & MARK0x008) &&
    (now.tv_sec - f->f_time) < MarkInterval / 2)
	continue;

/*
 * suppress duplicate lines to this file
 */
if ((Repeat == 0 || (Repeat == 1 &&
    (f->f_type != F_PIPE8 && f->f_type != F_FORWUDP4 &&
    f->f_type != F_FORWTCP9 && f->f_type != F_FORWTLS10))) &&
    (flags & MARK0x008) == 0 && msglen == f->f_prevlen &&
    f->f_dropped == 0 &&
    !strcmp(msg->m_msg, f->f_prevline) &&
    !strcmp(from, f->f_prevhost)) {
	strlcpy(f->f_lasttime, msg->m_timestamp,
	    sizeof(f->f_lasttime));
	f->f_prevcount++;
	log_debug("msg repeated %d times, %ld sec of %d",
	    f->f_prevcount, (long)(now.tv_sec - f->f_time),
	    repeatinterval[f->f_repeatcount]);
	/*
	 * If domark would have logged this by now,
	 * flush it now (so we don't hold isolated messages),
	 * but back off so we'll flush less often
	 * in the future.
	 */
	if (now.tv_sec > REPEATTIME(f)((f)->f_time + repeatinterval[(f)->f_repeatcount])) {
		fprintlog(f, flags, (char *)NULL((void *)0));
		BACKOFF(f){ if (++(f)->f_repeatcount > ((sizeof(repeatinterval) /
 sizeof(repeatinterval[0])) - 1)) (f)->f_repeatcount = ((sizeof
(repeatinterval) / sizeof(repeatinterval[0])) - 1); };
	}
} else {
	/* new line, save it */
	if (f->f_prevcount)
		fprintlog(f, 0, (char *)NULL((void *)0));
	f->f_repeatcount = 0;
	f->f_prevpri = msg->m_pri;
	strlcpy(f->f_lasttime, msg->m_timestamp,
	    sizeof(f->f_lasttime));
	strlcpy(f->f_prevhost, from,
	    sizeof(f->f_prevhost));
	if (msglen < MAXSVLINE120) {
		f->f_prevlen = msglen;
		strlcpy(f->f_prevline, msg->m_msg,
		    sizeof(f->f_prevline));
		fprintlog(f, flags, (char *)NULL((void *)0));
	} else {
		f->f_prevline[0] = 0;
		f->f_prevlen = 0;
		fprintlog(f, flags, msg->m_msg);
	}
}

if (f->f_quick)
	break;
}
1870}

1872void
1873fprintlog(struct filed *f, int flags, char *msg)
1874{
struct iovec iov[IOVCNT7], *v;
struct msghdr msghdr;
int l, retryonce;
char line[LOG_MAXLINE8192 + 1], pribuf[13], greetings[500], repbuf[80];
char ebuf[ERRBUFSIZE256];

v = iov;
switch (f->f_type) {
case F_FORWUDP4:
case F_FORWTCP9:
case F_FORWTLS10:
l = snprintf(pribuf, sizeof(pribuf), "<%d>", f->f_prevpri);
if (l < 0)
	l = strlcpy(pribuf, "<13>", sizeof(pribuf));
if (l >= sizeof(pribuf))
	l = sizeof(pribuf) - 1;
v->iov_base = pribuf;
v->iov_len = l;
break;
case F_WALL6:
l = snprintf(greetings, sizeof(greetings),
    "\r\n\7Message from syslogd@%s at %.24s ...\r\n",
    f->f_prevhost, ctime(&now.tv_sec));
if (l < 0)
	l = strlcpy(greetings,
	    "\r\n\7Message from syslogd ...\r\n",
	    sizeof(greetings));
if (l >= sizeof(greetings))
	l = sizeof(greetings) - 1;
v->iov_base = greetings;
v->iov_len = l;
break;
default:
v->iov_base = "";
v->iov_len = 0;
break;
}
v++;

if (f->f_lasttime[0] != '\0') {
v->iov_base = f->f_lasttime;
v->iov_len = strlen(f->f_lasttime);
v++;
v->iov_base = " ";
v->iov_len = 1;
} else {
v->iov_base = "";
v->iov_len = 0;
v++;
v->iov_base = "";
v->iov_len = 0;
}
v++;

switch (f->f_type) {
case F_FORWUDP4:
case F_FORWTCP9:
case F_FORWTLS10:
if (IncludeHostname) {
	v->iov_base = LocalHostName;
	v->iov_len = strlen(LocalHostName);
	v++;
	v->iov_base = " ";
	v->iov_len = 1;
} else {
	/* XXX RFC requires to include host name */
	v->iov_base = "";
	v->iov_len = 0;
	v++;
	v->iov_base = "";
	v->iov_len = 0;
}
break;
default:
if (f->f_prevhost[0] != '\0') {
	v->iov_base = f->f_prevhost;
	v->iov_len = strlen(v->iov_base);
	v++;
	v->iov_base = " ";
	v->iov_len = 1;
} else {
	v->iov_base = "";
	v->iov_len = 0;
	v++;
	v->iov_base = "";
	v->iov_len = 0;
}
break;
}
v++;

if (msg) {
v->iov_base = msg;
v->iov_len = strlen(msg);
} else if (f->f_prevcount > 1) {
l = snprintf(repbuf, sizeof(repbuf),
    "last message repeated %d times", f->f_prevcount);
if (l < 0)
	l = strlcpy(repbuf, "last message repeated",
	    sizeof(repbuf));
if (l >= sizeof(repbuf))
	l = sizeof(repbuf) - 1;
v->iov_base = repbuf;
v->iov_len = l;
} else {
v->iov_base = f->f_prevline;
v->iov_len = f->f_prevlen;
}
v++;

switch (f->f_type) {
case F_CONSOLE3:
case F_TTY2:
case F_USERS5:
case F_WALL6:
v->iov_base = "\r\n";
v->iov_len = 2;
break;
case F_FILE1:
case F_PIPE8:
case F_FORWTCP9:
case F_FORWTLS10:
v->iov_base = "\n";
v->iov_len = 1;
break;
default:
v->iov_base = "";
v->iov_len = 0;
break;
}
v = NULL((void *)0);

log_debugadd("Logging to %s", TypeNames[f->f_type]);
f->f_time = now.tv_sec;

switch (f->f_type) {
case F_UNUSED0:
log_debug("");
break;

case F_FORWUDP4:
log_debugadd(" %s", f->f_un.f_forw.f_loghost);
if (f->f_un.f_forw.f_addr.ss_family == AF_UNSPEC0) {
	log_debug(" (dropped not resolved)");
	f->f_dropped++;
	break;
}
l = iov[0].iov_len + iov[1].iov_len + iov[2].iov_len +
    iov[3].iov_len + iov[4].iov_len + iov[5].iov_len +
    iov[6].iov_len;
if (l > MAX_UDPMSG1180) {
	l -= MAX_UDPMSG1180;
	if (iov[5].iov_len > l)
		iov[5].iov_len -= l;
	else
		iov[5].iov_len = 0;
}
memset(&msghdr, 0, sizeof(msghdr));
msghdr.msg_name = &f->f_un.f_forw.f_addr;
msghdr.msg_namelen = f->f_un.f_forw.f_addr.ss_len;
msghdr.msg_iov = iov;
msghdr.msg_iovlen = IOVCNT7;
if (sendmsg(f->f_file, &msghdr, 0) == -1) {
	switch (errno(*__errno())) {
	case EACCES13:
	case EADDRNOTAVAIL49:
	case EHOSTDOWN64:
	case EHOSTUNREACH65:
	case ENETDOWN50:
	case ENETUNREACH51:
	case ENOBUFS55:
	case EWOULDBLOCK35:
		log_debug(" (dropped send error)");
		f->f_dropped++;
		/* silently dropped */
		break;
	default:
		log_debug(" (dropped permanent send error)");
		f->f_dropped++;
		f->f_type = F_UNUSED0;
		snprintf(ebuf, sizeof(ebuf),
		    "to udp loghost \"%s\"",
		    f->f_un.f_forw.f_loghost);
		dropped_warn(&f->f_dropped, ebuf);
		log_warn("loghost \"%s\" disabled, sendmsg",
		    f->f_un.f_forw.f_loghost);
		break;
	}
} else {
	log_debug("");
	if (f->f_dropped > 0) {
		snprintf(ebuf, sizeof(ebuf),
		    "to udp loghost \"%s\"",
		    f->f_un.f_forw.f_loghost);
		dropped_warn(&f->f_dropped, ebuf);
	}
}
break;

case F_FORWTCP9:
case F_FORWTLS10:
log_debugadd(" %s", f->f_un.f_forw.f_loghost);
if (EVBUFFER_LENGTH(f->f_un.f_forw.f_bufev->output)(f->f_un.f_forw.f_bufev->output)->off >=
    MAX_TCPBUF(256 * 1024)) {
	log_debug(" (dropped tcpbuf full)");
	f->f_dropped++;
	break;
}
/*
 * Syslog over TLS  RFC 5425  4.3.  Sending Data
 * Syslog over TCP  RFC 6587  3.4.1.  Octet Counting
 * Use an additional '\n' to split messages.  This allows
 * buffer synchronisation, helps legacy implementations,
 * and makes line based testing easier.
 */
l = evbuffer_add_printf(f->f_un.f_forw.f_bufev->output,
    "%zu %s%s%s%s%s%s%s", iov[0].iov_len +
    iov[1].iov_len + iov[2].iov_len +
    iov[3].iov_len + iov[4].iov_len +
    iov[5].iov_len + iov[6].iov_len,
    (char *)iov[0].iov_base,
    (char *)iov[1].iov_base, (char *)iov[2].iov_base,
    (char *)iov[3].iov_base, (char *)iov[4].iov_base,
    (char *)iov[5].iov_base, (char *)iov[6].iov_base);
if (l < 0) {
	log_debug(" (dropped evbuffer add)");
	f->f_dropped++;
	break;
}
bufferevent_enable(f->f_un.f_forw.f_bufev, EV_WRITE0x04);
log_debug("");
break;

case F_CONSOLE3:
if (flags & IGN_CONS0x001) {
	log_debug(" (ignored)");
	break;
}
/* FALLTHROUGH */
case F_TTY2:
case F_FILE1:
case F_PIPE8:
log_debug(" %s", f->f_un.f_fname);
retryonce = 0;
again:
if (writev(f->f_file, iov, IOVCNT7) == -1) {
	int e = errno(*__errno());

	/* allow to recover from file system full */
	if (e == ENOSPC28 && f->f_type == F_FILE1) {
		if (f->f_dropped++ == 0) {
			f->f_type = F_UNUSED0;
			errno(*__errno()) = e;
			log_warn("write to file \"%s\"",
			    f->f_un.f_fname);
			f->f_type = F_FILE1;
		}
		break;
	}

	/* pipe is non-blocking. log and drop message if full */
	if (e == EAGAIN35 && f->f_type == F_PIPE8) {
		if (now.tv_sec - f->f_lasterrtime > 120) {
			f->f_lasterrtime = now.tv_sec;
			log_warn("write to pipe \"%s\"",
			    f->f_un.f_fname);
		}
		break;
	}

	/*
	 * Check for errors on TTY's or program pipes.
	 * Errors happen due to loss of tty or died programs.
	 */
	if (e == EAGAIN35) {
		/*
		 * Silently drop messages on blocked write.
		 * This can happen when logging to a locked tty.
		 */
		break;
	}

	(void)close(f->f_file);
	if ((e == EIO5 || e == EBADF9) &&
	    f->f_type != F_FILE1 && f->f_type != F_PIPE8 &&
	    !retryonce) {
		f->f_file = priv_open_tty(f->f_un.f_fname);
		retryonce = 1;
		if (f->f_file < 0) {
			f->f_type = F_UNUSED0;
			log_warn("priv_open_tty \"%s\"",
			    f->f_un.f_fname);
		} else
			goto again;
	} else if ((e == EPIPE32 || e == EBADF9) &&
	    f->f_type == F_PIPE8 && !retryonce) {
		f->f_file = priv_open_log(f->f_un.f_fname);
		retryonce = 1;
		if (f->f_file < 0) {
			f->f_type = F_UNUSED0;
			log_warn("priv_open_log \"%s\"",
			    f->f_un.f_fname);
		} else
			goto again;
	} else {
		f->f_type = F_UNUSED0;
		f->f_file = -1;
		errno(*__errno()) = e;
		log_warn("writev \"%s\"", f->f_un.f_fname);
	}
} else {
	if (flags & SYNC_FILE0x002)
		(void)fsync(f->f_file);
	if (f->f_dropped > 0 && f->f_type == F_FILE1) {
		snprintf(ebuf, sizeof(ebuf), "to file \"%s\"",
		    f->f_un.f_fname);
		dropped_warn(&f->f_dropped, ebuf);
	}
}
break;

case F_USERS5:
case F_WALL6:
log_debug("");
wallmsg(f, iov);
break;

case F_MEMBUF7:
log_debug("");
l = snprintf(line, sizeof(line),
    "%s%s%s%s%s%s%s", (char *)iov[0].iov_base,
    (char *)iov[1].iov_base, (char *)iov[2].iov_base,
    (char *)iov[3].iov_base, (char *)iov[4].iov_base,
    (char *)iov[5].iov_base, (char *)iov[6].iov_base);
if (l < 0)
	l = strlcpy(line, iov[5].iov_base, sizeof(line));
if (ringbuf_append_line(f->f_un.f_mb.f_rb, line) == 1)
	f->f_un.f_mb.f_overflow = 1;
if (f->f_un.f_mb.f_attached)
	ctlconn_logto(line);
break;
}
f->f_prevcount = 0;
2218}

2220/*
*  WALLMSG -- Write a message to the world at large
*
*	Write the specified message to either the entire
*	world, or a list of approved users.
*/
2226void
2227wallmsg(struct filed *f, struct iovec *iov)
2228{
struct utmp ut;
char utline[sizeof(ut.ut_line) + 1];
static int reenter;			/* avoid calling ourselves */
FILE *uf;
int i;

if (reenter++)
return;
if ((uf = priv_open_utmp()) == NULL((void *)0)) {
log_warn("priv_open_utmp");
reenter = 0;
return;
}
while (fread(&ut, sizeof(ut), 1, uf) == 1) {
if (ut.ut_name[0] == '\0')
	continue;
/* must use strncpy since ut_* may not be NUL terminated */
strncpy(utline, ut.ut_line, sizeof(utline) - 1);
utline[sizeof(utline) - 1] = '\0';
if (f->f_type == F_WALL6) {
	ttymsg(utline, iov);
	continue;
}
/* should we send the message to this user? */
for (i = 0; i < MAXUNAMES20; i++) {
	if (!f->f_un.f_uname[i][0])
		break;
	if (!strncmp(f->f_un.f_uname[i], ut.ut_name,
	    UT_NAMESIZE32)) {
		ttymsg(utline, iov);
		break;
	}
}
}
(void)fclose(uf);
reenter = 0;
2265}

2267/*
* Return a printable representation of a host address.
*/
2270void
2271cvthname(struct sockaddr *f, char *result, size_t res_len)
2272{
int error;

error = getnameinfo(f, f->sa_len, result, res_len, NULL((void *)0), 0,
   NI_NUMERICHOST1 | NI_NUMERICSERV2 | NI_DGRAM16);
if (error) {
log_warnx("malformed UDP from address: %s",
    gai_strerror(error));
strlcpy(result, hostname_unknown, res_len);
return;
}
log_debug("cvthname(%s)", result);
if (NoDNS)
return;

if (priv_getnameinfo(f, f->sa_len, result, res_len) != 0)
log_debug("Host name for from address (%s) unknown", result);
2289}

2291void
2292die_signalcb(int signum, short event, void *arg)
2293{
die(signum);
2295}

2297void
2298mark_timercb(int unused, short event, void *arg)
2299{
struct event		*ev = arg;
struct timeval		 to;

markit();

to.tv_sec = TIMERINTVL30;
to.tv_usec = 0;
evtimer_add(ev, &to)event_add(ev, &to);
2308}

2310void
2311init_signalcb(int signum, short event, void *arg)
2312{
init();
log_info(LOG_INFO6, "restart");

dropped_warn(&udpsend_dropped, "to udp loghost");
dropped_warn(&tcpbuf_dropped, "to remote loghost");
dropped_warn(&file_dropped, "to file");
log_debug("syslogd: restarted");
2320}

2322void
2323logevent(int severity, const char *msg)
2324{
log_debug("libevent: [%d] %s", severity, msg);
2326}

2328void
2329dropped_warn(int *count, const char *what)
2330{
int dropped;

if (*count == 0)
return;

dropped = *count;
*count = 0;
log_info(LOG_WARNING4, "dropped %d message%s %s",
   dropped, dropped == 1 ? "" : "s", what);
2340}

2342__dead__attribute__((__noreturn__)) void
2343die(int signo)
2344{
struct filed *f;

SIMPLEQ_FOREACH(f, &Files, f_next)for((f) = ((&Files)->sqh_first); (f) != ((void *)0); (
f) = ((f)->f_next.sqe_next)) {
/* flush any pending output */
if (f->f_prevcount)
	fprintlog(f, 0, (char *)NULL((void *)0));
if (f->f_type == F_FORWUDP4) {
	udpsend_dropped += f->f_dropped;
	f->f_dropped = 0;
}
if (f->f_type == F_FORWTLS10 || f->f_type == F_FORWTCP9) {
	tcpbuf_dropped += f->f_dropped +
	    tcpbuf_countmsg(f->f_un.f_forw.f_bufev);
	f->f_dropped = 0;
}
if (f->f_type == F_FILE1) {
	file_dropped += f->f_dropped;
	f->f_dropped = 0;
}
}
dropped_warn(&init_dropped, "during initialization");
dropped_warn(&udpsend_dropped, "to udp loghost");
dropped_warn(&tcpbuf_dropped, "to remote loghost");
dropped_warn(&file_dropped, "to file");

if (signo)
log_info(LOG_ERR3, "exiting on signal %d", signo);
log_debug("syslogd: exited");
exit(0);
2374}

2376/*
*  INIT -- Initialize syslogd from configuration table
*/
2379void
2380init(void)
2381{
char progblock[NAME_MAX255+1], hostblock[NAME_MAX255+1], *cline, *p, *q;
struct filed_list mb;
struct filed *f, *m;
FILE *cf;
int i;
size_t s;

log_debug("init");

/* If config file has been modified, then just die to restart */
if (priv_config_modified()) {
log_debug("config file changed: dying");
die(0);
}

/*
*  Close all open log files.
*/
Initialized = 0;
SIMPLEQ_INIT(&mb)do { (&mb)->sqh_first = ((void *)0); (&mb)->sqh_last
 = &(&mb)->sqh_first; } while (0);
while (!SIMPLEQ_EMPTY(&Files)(((&Files)->sqh_first) == ((void *)0))) {
f = SIMPLEQ_FIRST(&Files)((&Files)->sqh_first);
SIMPLEQ_REMOVE_HEAD(&Files, f_next)do { if (((&Files)->sqh_first = (&Files)->sqh_first
->f_next.sqe_next) == ((void *)0)) (&Files)->sqh_last
 = &(&Files)->sqh_first; } while (0);
/* flush any pending output */
if (f->f_prevcount)
	fprintlog(f, 0, (char *)NULL((void *)0));

switch (f->f_type) {
case F_FORWUDP4:
	evtimer_del(&f->f_un.f_forw.f_ev)event_del(&f->f_un.f_forw.f_ev);
	udpsend_dropped += f->f_dropped;
	f->f_dropped = 0;
	free(f->f_un.f_forw.f_ipproto);
	free(f->f_un.f_forw.f_host);
	free(f->f_un.f_forw.f_port);
	break;
case F_FORWTLS10:
	if (f->f_un.f_forw.f_ctx) {
		tls_close(f->f_un.f_forw.f_ctx);
		tls_free(f->f_un.f_forw.f_ctx);
	}
	/* FALLTHROUGH */
case F_FORWTCP9:
	evtimer_del(&f->f_un.f_forw.f_ev)event_del(&f->f_un.f_forw.f_ev);
	tcpbuf_dropped += f->f_dropped;
	if (f->f_un.f_forw.f_bufev) {
		bufferevent_disable(f->f_un.f_forw.f_bufev,
		    EV_READ0x02|EV_WRITE0x04);
		tcpbuf_dropped +=
		     tcpbuf_countmsg(f->f_un.f_forw.f_bufev);
		bufferevent_free(f->f_un.f_forw.f_bufev);
	}
	free(f->f_un.f_forw.f_ipproto);
	free(f->f_un.f_forw.f_host);
	free(f->f_un.f_forw.f_port);
	/* FALLTHROUGH */
case F_FILE1:
	if (f->f_type == F_FILE1)
		file_dropped += f->f_dropped;
	f->f_dropped = 0;
	/* FALLTHROUGH */
case F_TTY2:
case F_CONSOLE3:
case F_PIPE8:
	(void)close(f->f_file);
	break;
}
free(f->f_program);
free(f->f_hostname);
if (f->f_type == F_MEMBUF7) {
	f->f_program = NULL((void *)0);
	f->f_hostname = NULL((void *)0);
	log_debug("add %p to mb", f);
	SIMPLEQ_INSERT_HEAD(&mb, f, f_next)do { if (((f)->f_next.sqe_next = (&mb)->sqh_first) ==
 ((void *)0)) (&mb)->sqh_last = &(f)->f_next.sqe_next
; (&mb)->sqh_first = (f); } while (0);
} else
	free(f);
}
SIMPLEQ_INIT(&Files)do { (&Files)->sqh_first = ((void *)0); (&Files)->
sqh_last = &(&Files)->sqh_first; } while (0);

/* open the configuration file */
if ((cf = priv_open_config()) == NULL((void *)0)) {
log_debug("cannot open %s", ConfFile);
SIMPLEQ_INSERT_TAIL(&Files,do { (cfline("*.ERR\t/dev/console", "*", "*"))->f_next.sqe_next
 = ((void *)0); *(&Files)->sqh_last = (cfline("*.ERR\t/dev/console"
, "*", "*")); (&Files)->sqh_last = &(cfline("*.ERR\t/dev/console"
, "*", "*"))->f_next.sqe_next; } while (0)
    cfline("*.ERR\t/dev/console", "*", "*"), f_next)do { (cfline("*.ERR\t/dev/console", "*", "*"))->f_next.sqe_next
 = ((void *)0); *(&Files)->sqh_last = (cfline("*.ERR\t/dev/console"
, "*", "*")); (&Files)->sqh_last = &(cfline("*.ERR\t/dev/console"
, "*", "*"))->f_next.sqe_next; } while (0);
SIMPLEQ_INSERT_TAIL(&Files,do { (cfline("*.PANIC\t*", "*", "*"))->f_next.sqe_next = (
(void *)0); *(&Files)->sqh_last = (cfline("*.PANIC\t*"
, "*", "*")); (&Files)->sqh_last = &(cfline("*.PANIC\t*"
, "*", "*"))->f_next.sqe_next; } while (0)
    cfline("*.PANIC\t*", "*", "*"), f_next)do { (cfline("*.PANIC\t*", "*", "*"))->f_next.sqe_next = (
(void *)0); *(&Files)->sqh_last = (cfline("*.PANIC\t*"
, "*", "*")); (&Files)->sqh_last = &(cfline("*.PANIC\t*"
, "*", "*"))->f_next.sqe_next; } while (0);
Initialized = 1;
dropped_warn(&init_dropped, "during initialization");
return;
}

/*
*  Foreach line in the conf table, open that file.
*/
cline = NULL((void *)0);
s = 0;
strlcpy(progblock, "*", sizeof(progblock));
strlcpy(hostblock, "*", sizeof(hostblock));
send_udp = send_udp6 = 0;
while (getline(&cline, &s, cf) != -1) {
/*
 * check for end-of-section, comments, strip off trailing
 * spaces and newline character. !progblock and +hostblock
 * are treated specially: the following lines apply only to
 * that program.
 */
for (p = cline; isspace((unsigned char)*p); ++p)
	continue;
if (*p == '\0' || *p == '#')
	continue;
if (*p == '!' || *p == '+') {
	q = (*p == '!') ? progblock : hostblock;
	p++;
	while (isspace((unsigned char)*p))
		p++;
	if (*p == '\0' || (*p == '*' && (p[1] == '\0' ||
	    isspace((unsigned char)p[1])))) {
		strlcpy(q, "*", NAME_MAX255+1);
		continue;
	}
	for (i = 0; i < NAME_MAX255; i++) {
		if (*p == '\0' || isspace((unsigned char)*p))
			break;
		*q++ = *p++;
	}
	*q = '\0';
	continue;
}

p = cline + strlen(cline);
while (p > cline)
	if (!isspace((unsigned char)*--p)) {
		p++;
		break;
	}
*p = '\0';
f = cfline(cline, progblock, hostblock);
if (f != NULL((void *)0))
	SIMPLEQ_INSERT_TAIL(&Files, f, f_next)do { (f)->f_next.sqe_next = ((void *)0); *(&Files)->
sqh_last = (f); (&Files)->sqh_last = &(f)->f_next
.sqe_next; } while (0);
}
free(cline);
if (!feof(cf)(!__isthreaded ? (((cf)->_flags & 0x0020) != 0) : (feof
)(cf)))
fatal("read config file");

/* Match and initialize the memory buffers */
SIMPLEQ_FOREACH(f, &Files, f_next)for((f) = ((&Files)->sqh_first); (f) != ((void *)0); (
f) = ((f)->f_next.sqe_next)) {
if (f->f_type != F_MEMBUF7)
	continue;
log_debug("Initialize membuf %s at %p",
    f->f_un.f_mb.f_mname, f);

SIMPLEQ_FOREACH(m, &mb, f_next)for((m) = ((&mb)->sqh_first); (m) != ((void *)0); (m) =
 ((m)->f_next.sqe_next)) {
	if (m->f_un.f_mb.f_rb == NULL((void *)0))
		continue;
	if (strcmp(m->f_un.f_mb.f_mname,
	    f->f_un.f_mb.f_mname) == 0)
		break;
}
if (m == NULL((void *)0)) {
	log_debug("Membuf no match");
	f->f_un.f_mb.f_rb = ringbuf_init(f->f_un.f_mb.f_len);
	if (f->f_un.f_mb.f_rb == NULL((void *)0)) {
		f->f_type = F_UNUSED0;
		log_warn("allocate membuf");
	}
} else {
	log_debug("Membuf match f:%p, m:%p", f, m);
	f->f_un = m->f_un;
	m->f_un.f_mb.f_rb = NULL((void *)0);
}
}

/* make sure remaining buffers are freed */
while (!SIMPLEQ_EMPTY(&mb)(((&mb)->sqh_first) == ((void *)0))) {
m = SIMPLEQ_FIRST(&mb)((&mb)->sqh_first);
SIMPLEQ_REMOVE_HEAD(&mb, f_next)do { if (((&mb)->sqh_first = (&mb)->sqh_first->
f_next.sqe_next) == ((void *)0)) (&mb)->sqh_last = &
(&mb)->sqh_first; } while (0);
if (m->f_un.f_mb.f_rb != NULL((void *)0)) {
	log_warnx("mismatched membuf");
	ringbuf_free(m->f_un.f_mb.f_rb);
}
log_debug("Freeing membuf %p", m);

free(m);
}

/* close the configuration file */
(void)fclose(cf);

Initialized = 1;
dropped_warn(&init_dropped, "during initialization");

if (SecureMode) {
/*
 * If generic UDP file descriptors are used neither
 * for receiving nor for sending, close them.  Then
 * there is no useless *.514 in netstat.
 */
if (fd_udp != -1 && !send_udp) {
	close(fd_udp);
	fd_udp = -1;
}
if (fd_udp6 != -1 && !send_udp6) {
	close(fd_udp6);
	fd_udp6 = -1;
}
}

if (Debug) {
SIMPLEQ_FOREACH(f, &Files, f_next)for((f) = ((&Files)->sqh_first); (f) != ((void *)0); (
f) = ((f)->f_next.sqe_next)) {
	for (i = 0; i <= LOG_NFACILITIES24; i++)
		if (f->f_pmask[i] == INTERNAL_NOPRI0x10)
			printf("X ");
		else
			printf("%d ", f->f_pmask[i]);
	printf("%s: ", TypeNames[f->f_type]);
	switch (f->f_type) {
	case F_FILE1:
	case F_TTY2:
	case F_CONSOLE3:
	case F_PIPE8:
		printf("%s", f->f_un.f_fname);
		break;

	case F_FORWUDP4:
	case F_FORWTCP9:
	case F_FORWTLS10:
		printf("%s", f->f_un.f_forw.f_loghost);
		break;

	case F_USERS5:
		for (i = 0; i < MAXUNAMES20 &&
		    *f->f_un.f_uname[i]; i++)
			printf("%s, ", f->f_un.f_uname[i]);
		break;

	case F_MEMBUF7:
		printf("%s", f->f_un.f_mb.f_mname);
		break;

	}
	if (f->f_program || f->f_hostname)
		printf(" (%s, %s)",
		    f->f_program ? f->f_program : "*",
		    f->f_hostname ? f->f_hostname : "*");
	printf("\n");
}
}
2629}

2631#define progmatches(p1, p2)(p1 == p2 || (p1 != ((void *)0) && p2 != ((void *)0) &&
 strcmp(p1, p2) == 0)) \
(p1 == p2 || (p1 != NULL((void *)0) && p2 != NULL((void *)0) && strcmp(p1, p2) == 0))

2634/*
* Spot a line with a duplicate file, pipe, console, tty, or membuf target.
*/
2637struct filed *
2638find_dup(struct filed *f)
2639{
struct filed *list;

SIMPLEQ_FOREACH(list, &Files, f_next)for((list) = ((&Files)->sqh_first); (list) != ((void *
)0); (list) = ((list)->f_next.sqe_next)) {
if (list->f_quick || f->f_quick)
	continue;
switch (list->f_type) {
case F_FILE1:
case F_TTY2:
case F_CONSOLE3:
case F_PIPE8:
	if (strcmp(list->f_un.f_fname, f->f_un.f_fname) == 0 &&
	    progmatches(list->f_program, f->f_program)(list->f_program == f->f_program || (list->f_program
 != ((void *)0) && f->f_program != ((void *)0) &&
 strcmp(list->f_program, f->f_program) == 0)) &&
	    progmatches(list->f_hostname, f->f_hostname)(list->f_hostname == f->f_hostname || (list->f_hostname
 != ((void *)0) && f->f_hostname != ((void *)0) &&
 strcmp(list->f_hostname, f->f_hostname) == 0))) {
		log_debug("duplicate %s", f->f_un.f_fname);
		return (list);
	}
	break;
case F_MEMBUF7:
	if (strcmp(list->f_un.f_mb.f_mname,
	    f->f_un.f_mb.f_mname) == 0 &&
	    progmatches(list->f_program, f->f_program)(list->f_program == f->f_program || (list->f_program
 != ((void *)0) && f->f_program != ((void *)0) &&
 strcmp(list->f_program, f->f_program) == 0)) &&
	    progmatches(list->f_hostname, f->f_hostname)(list->f_hostname == f->f_hostname || (list->f_hostname
 != ((void *)0) && f->f_hostname != ((void *)0) &&
 strcmp(list->f_hostname, f->f_hostname) == 0))) {
		log_debug("duplicate membuf %s",
		    f->f_un.f_mb.f_mname);
		return (list);
	}
	break;
}
}
return (NULL((void *)0));
2670}

2672/*
* Crack a configuration file line
*/
2675struct filed *
2676cfline(char *line, char *progblock, char *hostblock)
2677{
int i, pri;
size_t rb_len;
char *bp, *p, *q, *proto, *host, *port, *ipproto;
char buf[LOG_MAXLINE8192];
struct filed *xf, *f, *d;
struct timeval to;

log_debug("cfline(\"%s\", f, \"%s\", \"%s\")",
   line, progblock, hostblock);

if ((f = calloc(1, sizeof(*f))) == NULL((void *)0))
fatal("allocate struct filed");
for (i = 0; i <= LOG_NFACILITIES24; i++)
f->f_pmask[i] = INTERNAL_NOPRI0x10;

/* save program name if any */
f->f_quick = 0;
if (*progblock == '!') {
progblock++;
f->f_quick = 1;
}
if (*hostblock == '+') {
hostblock++;
f->f_quick = 1;
}
if (strcmp(progblock, "*") != 0)
f->f_program = strdup(progblock);
if (strcmp(hostblock, "*") != 0)
f->f_hostname = strdup(hostblock);

/* scan through the list of selectors */
for (p = line; *p && *p != '\t' && *p != ' ';) {

/* find the end of this facility name list */
for (q = p; *q && *q != '\t' && *q != ' ' && *q++ != '.'; )
	continue;

/* collect priority name */
for (bp = buf; *q && !strchr("\t,; ", *q); )
	*bp++ = *q++;
*bp = '\0';

/* skip cruft */
while (*q && strchr(",;", *q))
	q++;

/* decode priority name */
if (*buf == '*')
	pri = LOG_PRIMASK0x07 + 1;
else {
	/* ignore trailing spaces */
	for (i=strlen(buf)-1; i >= 0 && buf[i] == ' '; i--) {
		buf[i]='\0';
	}

	pri = decode(buf, prioritynames);
	if (pri < 0) {
		log_warnx("unknown priority name \"%s\"", buf);
		free(f);
		return (NULL((void *)0));
	}
}

/* scan facilities */
while (*p && !strchr("\t.; ", *p)) {
	for (bp = buf; *p && !strchr("\t,;. ", *p); )
		*bp++ = *p++;
	*bp = '\0';
	if (*buf == '*')
		for (i = 0; i < LOG_NFACILITIES24; i++)
			f->f_pmask[i] = pri;
	else {
		i = decode(buf, facilitynames);
		if (i < 0) {
			log_warnx("unknown facility name "
			    "\"%s\"", buf);
			free(f);
			return (NULL((void *)0));
		}
		f->f_pmask[i >> 3] = pri;
	}
	while (*p == ',' || *p == ' ')
		p++;
}

p = q;
}

/* skip to action part */
while (*p == '\t' || *p == ' ')
p++;

switch (*p) {
case '@':
if ((strlcpy(f->f_un.f_forw.f_loghost, p,
    sizeof(f->f_un.f_forw.f_loghost)) >=
    sizeof(f->f_un.f_forw.f_loghost))) {
	log_warnx("loghost too long \"%s\"", p);
	break;
}
if (loghost_parse(++p, &proto, &host, &port) == -1) {
	log_warnx("bad loghost \"%s\"",
	    f->f_un.f_forw.f_loghost);
	break;
}
if (proto == NULL((void *)0))
	proto = "udp";
if (strcmp(proto, "udp") == 0) {
	if (fd_udp == -1)
		proto = "udp6";
	if (fd_udp6 == -1)
		proto = "udp4";
}
ipproto = proto;
if (strcmp(proto, "udp") == 0) {
	send_udp = send_udp6 = 1;
} else if (strcmp(proto, "udp4") == 0) {
	send_udp = 1;
	if (fd_udp == -1) {
		log_warnx("no udp4 \"%s\"",
		    f->f_un.f_forw.f_loghost);
		break;
	}
} else if (strcmp(proto, "udp6") == 0) {
	send_udp6 = 1;
	if (fd_udp6 == -1) {
		log_warnx("no udp6 \"%s\"",
		    f->f_un.f_forw.f_loghost);
		break;
	}
} else if (strcmp(proto, "tcp") == 0 ||
    strcmp(proto, "tcp4") == 0 || strcmp(proto, "tcp6") == 0) {
	;
} else if (strcmp(proto, "tls") == 0) {
	ipproto = "tcp";
} else if (strcmp(proto, "tls4") == 0) {
	ipproto = "tcp4";
} else if (strcmp(proto, "tls6") == 0) {
	ipproto = "tcp6";
} else {
	log_warnx("bad protocol \"%s\"",
	    f->f_un.f_forw.f_loghost);
	break;
}
if (strlen(host) >= NI_MAXHOST256) {
	log_warnx("host too long \"%s\"",
	    f->f_un.f_forw.f_loghost);
	break;
}
if (port == NULL((void *)0))
	port = strncmp(proto, "tls", 3) == 0 ?
	    "syslog-tls" : "syslog";
if (strlen(port) >= NI_MAXSERV32) {
	log_warnx("port too long \"%s\"",
	    f->f_un.f_forw.f_loghost);
	break;
}
f->f_un.f_forw.f_ipproto = strdup(ipproto);
f->f_un.f_forw.f_host = strdup(host);
f->f_un.f_forw.f_port = strdup(port);
if (f->f_un.f_forw.f_ipproto == NULL((void *)0) ||
    f->f_un.f_forw.f_host == NULL((void *)0) ||
    f->f_un.f_forw.f_port == NULL((void *)0)) {
	log_warnx("strdup ipproto host port \"%s\"",
	    f->f_un.f_forw.f_loghost);
	free(f->f_un.f_forw.f_ipproto);
	free(f->f_un.f_forw.f_host);
	free(f->f_un.f_forw.f_port);
	break;
}
f->f_file = -1;
loghost_resolve(f);
if (strncmp(proto, "udp", 3) == 0) {
	evtimer_set(&f->f_un.f_forw.f_ev, udp_resolvecb, f)event_set(&f->f_un.f_forw.f_ev, -1, 0, udp_resolvecb, f
);
	switch (f->f_un.f_forw.f_addr.ss_family) {
	case AF_UNSPEC0:
		log_debug("resolve \"%s\" delayed",
		    f->f_un.f_forw.f_loghost);
		to.tv_sec = 0;
		to.tv_usec = 1;
		evtimer_add(&f->f_un.f_forw.f_ev, &to)event_add(&f->f_un.f_forw.f_ev, &to);
		break;
	case AF_INET2:
		f->f_file = fd_udp;
		break;
	case AF_INET624:
		f->f_file = fd_udp6;
		break;
	}
	f->f_type = F_FORWUDP4;
} else if (strncmp(ipproto, "tcp", 3) == 0) {
	if ((f->f_un.f_forw.f_bufev = bufferevent_new(-1,
	    tcp_dropcb, tcp_writecb, tcp_errorcb, f)) == NULL((void *)0)) {
		log_warn("bufferevent \"%s\"",
		    f->f_un.f_forw.f_loghost);
		free(f->f_un.f_forw.f_ipproto);
		free(f->f_un.f_forw.f_host);
		free(f->f_un.f_forw.f_port);
		break;
	}
	/*
	 * If we try to connect to a TLS server immediately
	 * syslogd gets an SIGPIPE as the signal handlers have
	 * not been set up.  Delay the connection until the
	 * event loop is started.
	 */
	evtimer_set(&f->f_un.f_forw.f_ev, tcp_connectcb, f)event_set(&f->f_un.f_forw.f_ev, -1, 0, tcp_connectcb, f
);
	to.tv_sec = 0;
	to.tv_usec = 1;
	evtimer_add(&f->f_un.f_forw.f_ev, &to)event_add(&f->f_un.f_forw.f_ev, &to);
	f->f_type = (strncmp(proto, "tls", 3) == 0) ?
	    F_FORWTLS10 : F_FORWTCP9;
}
break;

case '/':
case '|':
(void)strlcpy(f->f_un.f_fname, p, sizeof(f->f_un.f_fname));
d = find_dup(f);
if (d != NULL((void *)0)) {
	for (i = 0; i <= LOG_NFACILITIES24; i++)
		if (f->f_pmask[i] != INTERNAL_NOPRI0x10)
			d->f_pmask[i] = f->f_pmask[i];
	free(f);
	return (NULL((void *)0));
}
if (strcmp(p, ctty) == 0) {
	f->f_file = priv_open_tty(p);
	if (f->f_file < 0)
		log_warn("priv_open_tty \"%s\"", p);
} else {
	f->f_file = priv_open_log(p);
	if (f->f_file < 0)
		log_warn("priv_open_log \"%s\"", p);
}
if (f->f_file < 0) {
	f->f_type = F_UNUSED0;
	break;
}
if (isatty(f->f_file)) {
	if (strcmp(p, ctty) == 0)
		f->f_type = F_CONSOLE3;
	else
		f->f_type = F_TTY2;
} else {
	if (*p == '|')
		f->f_type = F_PIPE8;
	else {
		f->f_type = F_FILE1;

		/* Clear O_NONBLOCK flag on f->f_file */
		if ((i = fcntl(f->f_file, F_GETFL3)) != -1) {
			i &= ~O_NONBLOCK0x0004;
			fcntl(f->f_file, F_SETFL4, i);
		}
	}
}
break;

case '*':
f->f_type = F_WALL6;
break;

case ':':
f->f_type = F_MEMBUF7;

/* Parse buffer size (in kb) */
errno(*__errno()) = 0;
rb_len = strtoul(++p, &q, 0);
if (*p == '\0' || (errno(*__errno()) == ERANGE34 && rb_len == ULONG_MAX0xffffffffffffffffUL) ||
    *q != ':' || rb_len == 0) {
	f->f_type = F_UNUSED0;
	log_warnx("strtoul \"%s\"", p);
	break;
}
q++;
rb_len *= 1024;

/* Copy buffer name */
for(i = 0; (size_t)i < sizeof(f->f_un.f_mb.f_mname) - 1; i++) {
	if (!isalnum((unsigned char)q[i]))
		break;
	f->f_un.f_mb.f_mname[i] = q[i];
}

/* Make sure buffer name is unique */
xf = find_dup(f);

/* Error on missing or non-unique name, or bad buffer length */
if (i == 0 || rb_len > MAX_MEMBUF(256 * 1024) || xf != NULL((void *)0)) {
	f->f_type = F_UNUSED0;
	log_warnx("find_dup \"%s\"", p);
	break;
}

/* Set buffer length */
rb_len = MAXIMUM(rb_len, MIN_MEMBUF)(((rb_len) > ((8192 * 4))) ? (rb_len) : ((8192 * 4)));
f->f_un.f_mb.f_len = rb_len;
f->f_un.f_mb.f_overflow = 0;
f->f_un.f_mb.f_attached = 0;
break;

default:
for (i = 0; i < MAXUNAMES20 && *p; i++) {
	for (q = p; *q && *q != ','; )
		q++;
	(void)strncpy(f->f_un.f_uname[i], p, UT_NAMESIZE32);
	if ((q - p) > UT_NAMESIZE32)
		f->f_un.f_uname[i][UT_NAMESIZE32] = '\0';
	else
		f->f_un.f_uname[i][q - p] = '\0';
	while (*q == ',' || *q == ' ')
		q++;
	p = q;
}
f->f_type = F_USERS5;
break;
}
return (f);
2997}

2999/*
* Parse the host and port parts from a loghost string.
*/
3002int
3003loghost_parse(char *str, char **proto, char **host, char **port)
3004{
char *prefix = NULL((void *)0);

if ((*host = strchr(str, ':')) &&
   (*host)[1] == '/' && (*host)[2] == '/') {
prefix = str;
**host = '\0';
str = *host + 3;
}
if (proto)
*proto = prefix;
else if (prefix)
return (-1);

*host = str;
if (**host == '[') {
(*host)++;
str = strchr(*host, ']');
if (str == NULL((void *)0))
	return (-1);
*str++ = '\0';
}
*port = strrchr(str, ':');
if (*port != NULL((void *)0))
*(*port)++ = '\0';

return (0);
3031}

3033/*
* Retrieve the size of the kernel message buffer, via sysctl.
*/
3036int
3037getmsgbufsize(void)
3038{
int msgbufsize, mib[2];
size_t size;

mib[0] = CTL_KERN1;
mib[1] = KERN_MSGBUFSIZE38;
size = sizeof msgbufsize;
if (sysctl(mib, 2, &msgbufsize, &size, NULL((void *)0), 0) == -1) {
log_debug("couldn't get kern.msgbufsize");
return (0);
}
return (msgbufsize);
3050}

3052/*
*  Decode a symbolic name to a numeric value
*/
3055int
3056decode(const char *name, const CODE *codetab)
3057{
const CODE *c;
char *p, buf[40];

for (p = buf; *name && p < &buf[sizeof(buf) - 1]; p++, name++) {
if (isupper((unsigned char)*name))
	*p = tolower((unsigned char)*name);
else
	*p = *name;
}
*p = '\0';
for (c = codetab; c->c_name; c++)
if (!strcmp(buf, c->c_name))
	return (c->c_val);

return (-1);
3073}

3075void
3076markit(void)
3077{
struct msg msg;
struct filed *f;

msg.m_pri = LOG_INFO6;
current_time(msg.m_timestamp);
msg.m_prog[0] = '\0';
strlcpy(msg.m_msg, "-- MARK --", sizeof(msg.m_msg));
MarkSeq += TIMERINTVL30;
if (MarkSeq >= MarkInterval) {
logmsg(&msg, MARK0x008, LocalHostName);
MarkSeq = 0;
}

SIMPLEQ_FOREACH(f, &Files, f_next)for((f) = ((&Files)->sqh_first); (f) != ((void *)0); (
f) = ((f)->f_next.sqe_next)) {
if (f->f_prevcount && now.tv_sec >= REPEATTIME(f)((f)->f_time + repeatinterval[(f)->f_repeatcount])) {
	log_debug("flush %s: repeated %d times, %d sec",
	    TypeNames[f->f_type], f->f_prevcount,
	    repeatinterval[f->f_repeatcount]);
	fprintlog(f, 0, (char *)NULL((void *)0));
	BACKOFF(f){ if (++(f)->f_repeatcount > ((sizeof(repeatinterval) /
 sizeof(repeatinterval[0])) - 1)) (f)->f_repeatcount = ((sizeof
(repeatinterval) / sizeof(repeatinterval[0])) - 1); };
}
}
3100}

3102int
3103unix_socket(char *path, int type, mode_t mode)
3104{
struct sockaddr_un s_un;
int fd, optval;
mode_t old_umask;

memset(&s_un, 0, sizeof(s_un));
s_un.sun_family = AF_UNIX1;
if (strlcpy(s_un.sun_path, path, sizeof(s_un.sun_path)) >=
   sizeof(s_un.sun_path)) {
log_warnx("socket path too long \"%s\"", path);
return (-1);
}

if ((fd = socket(AF_UNIX1, type, 0)) == -1) {
log_warn("socket unix \"%s\"", path);
return (-1);
}

if (Debug) {
if (connect(fd, (struct sockaddr *)&s_un, sizeof(s_un)) == 0 ||
    errno(*__errno()) == EPROTOTYPE41) {
	close(fd);
	errno(*__errno()) = EISCONN56;
	log_warn("connect unix \"%s\"", path);
	return (-1);
}
}

old_umask = umask(0177);

unlink(path);
if (bind(fd, (struct sockaddr *)&s_un, sizeof(s_un)) == -1) {
log_warn("bind unix \"%s\"", path);
umask(old_umask);
close(fd);
return (-1);
}

umask(old_umask);

if (chmod(path, mode) == -1) {
log_warn("chmod unix \"%s\"", path);
close(fd);
unlink(path);
return (-1);
}

optval = LOG_MAXLINE8192 + PATH_MAX1024;
if (setsockopt(fd, SOL_SOCKET0xffff, SO_RCVBUF0x1002, &optval, sizeof(optval))
   == -1)
log_warn("setsockopt unix \"%s\"", path);

return (fd);
3157}

3159/*
* Increase socket buffer size in small steps to get partial success
* if we hit a kernel limit.  Allow an optional final step.
*/
3163void
3164double_sockbuf(int fd, int optname, int bigsize)
3165{
socklen_t len;
int i, newsize, oldsize = 0;

len = sizeof(oldsize);
if (getsockopt(fd, SOL_SOCKET0xffff, optname, &oldsize, &len) == -1)
log_warn("getsockopt bufsize");
len = sizeof(newsize);
newsize =  LOG_MAXLINE8192 + 128;  /* data + control */
/* allow 8 full length messages, that is 66560 bytes */
for (i = 0; i < 4; i++, newsize *= 2) {
if (newsize <= oldsize)
	continue;
if (setsockopt(fd, SOL_SOCKET0xffff, optname, &newsize, len) == -1)
	log_warn("setsockopt bufsize %d", newsize);
else
	oldsize = newsize;
}
if (bigsize && bigsize > oldsize) {
if (setsockopt(fd, SOL_SOCKET0xffff, optname, &bigsize, len) == -1)
	log_warn("setsockopt bufsize %d", bigsize);
}
3187}

3189void
3190set_sockbuf(int fd)
3191{
int size = 65536;

if (setsockopt(fd, SOL_SOCKET0xffff, SO_SNDBUF0x1001, &size, sizeof(size)) == -1)
log_warn("setsockopt sndbufsize %d", size);
if (setsockopt(fd, SOL_SOCKET0xffff, SO_RCVBUF0x1002, &size, sizeof(size)) == -1)
log_warn("setsockopt rcvbufsize %d", size);
3198}

3200void
3201set_keepalive(int fd)
3202{
int val = 1;

if (setsockopt(fd, SOL_SOCKET0xffff, SO_KEEPALIVE0x0008, &val, sizeof(val)) == -1)
log_warn("setsockopt keepalive %d", val);
3207}

3209void
3210ctlconn_cleanup(void)
3211{
struct filed *f;

close(fd_ctlconn);
fd_ctlconn = -1;
event_del(ev_ctlread);
event_del(ev_ctlwrite);
event_add(ev_ctlaccept, NULL((void *)0));

if (ctl_state == CTL_WRITING_CONT_REPLY3)
SIMPLEQ_FOREACH(f, &Files, f_next)for((f) = ((&Files)->sqh_first); (f) != ((void *)0); (
f) = ((f)->f_next.sqe_next))
	if (f->f_type == F_MEMBUF7)
		f->f_un.f_mb.f_attached = 0;

ctl_state = ctl_cmd_bytes = ctl_reply_offset = ctl_reply_size = 0;
3226}

3228void
3229ctlsock_acceptcb(int fd, short event, void *arg)
3230{
struct event		*ev = arg;

if ((fd = reserve_accept4(fd, event, ev, ctlsock_acceptcb,
   NULL((void *)0), NULL((void *)0), SOCK_NONBLOCK0x4000)) == -1) {
if (errno(*__errno()) != ENFILE23 && errno(*__errno()) != EMFILE24 &&
    errno(*__errno()) != EINTR4 && errno(*__errno()) != EWOULDBLOCK35 &&
    errno(*__errno()) != ECONNABORTED53)
	log_warn("accept control socket");
return;
}
log_debug("Accepting control connection");

if (fd_ctlconn != -1)
ctlconn_cleanup();

/* Only one connection at a time */
event_del(ev);

fd_ctlconn = fd;
/* file descriptor has changed, reset event */
event_set(ev_ctlread, fd_ctlconn, EV_READ0x02|EV_PERSIST0x10,
   ctlconn_readcb, ev_ctlread);
event_set(ev_ctlwrite, fd_ctlconn, EV_WRITE0x04|EV_PERSIST0x10,
   ctlconn_writecb, ev_ctlwrite);
event_add(ev_ctlread, NULL((void *)0));
ctl_state = CTL_READING_CMD1;
ctl_cmd_bytes = 0;
3258}

3260static struct filed
3261*find_membuf_log(const char *name)
3262{
struct filed *f;

SIMPLEQ_FOREACH(f, &Files, f_next)for((f) = ((&Files)->sqh_first); (f) != ((void *)0); (
f) = ((f)->f_next.sqe_next)) {
if (f->f_type == F_MEMBUF7 &&
    strcmp(f->f_un.f_mb.f_mname, name) == 0)
	break;
}
return (f);
3271}

3273void
3274ctlconn_readcb(int fd, short event, void *arg)
3275{
struct filed		*f;
struct ctl_reply_hdr	*reply_hdr = (struct ctl_reply_hdr *)ctl_reply;
ssize_t			 n;
u_int32_t		 flags = 0;

if (ctl_state == CTL_WRITING_REPLY2 ||
   ctl_state == CTL_WRITING_CONT_REPLY3) {
/* client has closed the connection */
ctlconn_cleanup();
return;
}

retry:
n = read(fd, (char*)&ctl_cmd + ctl_cmd_bytes,
   sizeof(ctl_cmd) - ctl_cmd_bytes);
switch (n) {
case -1:
if (errno(*__errno()) == EINTR4)
	goto retry;
if (errno(*__errno()) == EWOULDBLOCK35)
	return;
log_warn("read control socket");
/* FALLTHROUGH */
case 0:
ctlconn_cleanup();
return;
default:
ctl_cmd_bytes += n;
}
if (ctl_cmd_bytes < sizeof(ctl_cmd))
return;

if (ntohl(ctl_cmd.version)(__uint32_t)(__builtin_constant_p(ctl_cmd.version) ? (__uint32_t
)(((__uint32_t)(ctl_cmd.version) & 0xff) << 24 | ((
__uint32_t)(ctl_cmd.version) & 0xff00) << 8 | ((__uint32_t
)(ctl_cmd.version) & 0xff0000) >> 8 | ((__uint32_t)
(ctl_cmd.version) & 0xff000000) >> 24) : __swap32md
(ctl_cmd.version)) != CTL_VERSION2) {
log_warnx("unknown client protocol version");
ctlconn_cleanup();
return;
}

/* Ensure that logname is \0 terminated */
if (memchr(ctl_cmd.logname, '\0', sizeof(ctl_cmd.logname)) == NULL((void *)0)) {
log_warnx("corrupt control socket command");
ctlconn_cleanup();
return;
}

*reply_text = '\0';

ctl_reply_size = ctl_reply_offset = 0;
memset(reply_hdr, '\0', sizeof(*reply_hdr));

ctl_cmd.cmd = ntohl(ctl_cmd.cmd)(__uint32_t)(__builtin_constant_p(ctl_cmd.cmd) ? (__uint32_t)
(((__uint32_t)(ctl_cmd.cmd) & 0xff) << 24 | ((__uint32_t
)(ctl_cmd.cmd) & 0xff00) << 8 | ((__uint32_t)(ctl_cmd
.cmd) & 0xff0000) >> 8 | ((__uint32_t)(ctl_cmd.cmd)
 & 0xff000000) >> 24) : __swap32md(ctl_cmd.cmd));
log_debug("ctlcmd %x logname \"%s\"", ctl_cmd.cmd, ctl_cmd.logname);

switch (ctl_cmd.cmd) {
case CMD_READ1:
case CMD_READ_CLEAR2:
case CMD_READ_CONT6:
case CMD_FLAGS5:
f = find_membuf_log(ctl_cmd.logname);
if (f == NULL((void *)0)) {
	strlcpy(reply_text, "No such log\n", MAX_MEMBUF(256 * 1024));
} else {
	if (ctl_cmd.cmd != CMD_FLAGS5) {
		ringbuf_to_string(reply_text, MAX_MEMBUF(256 * 1024),
		    f->f_un.f_mb.f_rb);
	}
	if (f->f_un.f_mb.f_overflow)
		flags |= CTL_HDR_FLAG_OVERFLOW0x01;
	if (ctl_cmd.cmd == CMD_READ_CLEAR2) {
		ringbuf_clear(f->f_un.f_mb.f_rb);
		f->f_un.f_mb.f_overflow = 0;
	}
	if (ctl_cmd.cmd == CMD_READ_CONT6) {
		f->f_un.f_mb.f_attached = 1;
		tailify_replytext(reply_text,
		    ctl_cmd.lines > 0 ? ctl_cmd.lines : 10);
	} else if (ctl_cmd.lines > 0) {
		tailify_replytext(reply_text, ctl_cmd.lines);
	}
}
break;
case CMD_CLEAR3:
f = find_membuf_log(ctl_cmd.logname);
if (f == NULL((void *)0)) {
	strlcpy(reply_text, "No such log\n", MAX_MEMBUF(256 * 1024));
} else {
	ringbuf_clear(f->f_un.f_mb.f_rb);
	if (f->f_un.f_mb.f_overflow)
		flags |= CTL_HDR_FLAG_OVERFLOW0x01;
	f->f_un.f_mb.f_overflow = 0;
	strlcpy(reply_text, "Log cleared\n", MAX_MEMBUF(256 * 1024));
}
break;
case CMD_LIST4:
SIMPLEQ_FOREACH(f, &Files, f_next)for((f) = ((&Files)->sqh_first); (f) != ((void *)0); (
f) = ((f)->f_next.sqe_next)) {
	if (f->f_type == F_MEMBUF7) {
		strlcat(reply_text, f->f_un.f_mb.f_mname,
		    MAX_MEMBUF(256 * 1024));
		if (f->f_un.f_mb.f_overflow) {
			strlcat(reply_text, "*", MAX_MEMBUF(256 * 1024));
			flags |= CTL_HDR_FLAG_OVERFLOW0x01;
		}
		strlcat(reply_text, " ", MAX_MEMBUF(256 * 1024));
	}
}
strlcat(reply_text, "\n", MAX_MEMBUF(256 * 1024));
break;
default:
log_warnx("unsupported control socket command");
ctlconn_cleanup();
return;
}
reply_hdr->version = htonl(CTL_VERSION)(__uint32_t)(__builtin_constant_p(2) ? (__uint32_t)(((__uint32_t
)(2) & 0xff) << 24 | ((__uint32_t)(2) & 0xff00)
 << 8 | ((__uint32_t)(2) & 0xff0000) >> 8 | (
(__uint32_t)(2) & 0xff000000) >> 24) : __swap32md(2
));
reply_hdr->flags = htonl(flags)(__uint32_t)(__builtin_constant_p(flags) ? (__uint32_t)(((__uint32_t
)(flags) & 0xff) << 24 | ((__uint32_t)(flags) &
 0xff00) << 8 | ((__uint32_t)(flags) & 0xff0000) >>
| ((__uint32_t)(flags) & 0xff000000) >> 24) : __swap32md
(flags));

ctl_reply_size = CTL_REPLY_SIZE(strlen(reply_text) + (sizeof(struct ctl_reply_hdr)));
log_debug("ctlcmd reply length %lu", (u_long)ctl_reply_size);

/* Otherwise, set up to write out reply */
ctl_state = (ctl_cmd.cmd == CMD_READ_CONT6) ?
   CTL_WRITING_CONT_REPLY3 : CTL_WRITING_REPLY2;

event_add(ev_ctlwrite, NULL((void *)0));

/* another syslogc can kick us out */
if (ctl_state == CTL_WRITING_CONT_REPLY3)
event_add(ev_ctlaccept, NULL((void *)0));
3403}

3405void
3406ctlconn_writecb(int fd, short event, void *arg)
3407{
struct event		*ev = arg;
ssize_t			 n;

if (!(ctl_state == CTL_WRITING_REPLY2 ||
   ctl_state == CTL_WRITING_CONT_REPLY3)) {
/* Shouldn't be here! */
log_warnx("control socket write with bad state");
ctlconn_cleanup();
return;
}

retry:
n = write(fd, ctl_reply + ctl_reply_offset,
   ctl_reply_size - ctl_reply_offset);
switch (n) {
case -1:
if (errno(*__errno()) == EINTR4)
	goto retry;
if (errno(*__errno()) == EWOULDBLOCK35)
	return;
if (errno(*__errno()) != EPIPE32)
	log_warn("write control socket");
/* FALLTHROUGH */
case 0:
ctlconn_cleanup();
return;
default:
ctl_reply_offset += n;
}
if (ctl_reply_offset < ctl_reply_size)
return;

if (ctl_state != CTL_WRITING_CONT_REPLY3) {
ctlconn_cleanup();
return;
}

/*
* Make space in the buffer for continuous writes.
* Set offset behind reply header to skip it
*/
*reply_text = '\0';
ctl_reply_offset = ctl_reply_size = CTL_REPLY_SIZE(strlen(reply_text) + (sizeof(struct ctl_reply_hdr)));

/* Now is a good time to report dropped lines */
if (membuf_drop) {
strlcat(reply_text, "<ENOBUFS>\n", MAX_MEMBUF(256 * 1024));
ctl_reply_size = CTL_REPLY_SIZE(strlen(reply_text) + (sizeof(struct ctl_reply_hdr)));
membuf_drop = 0;
} else {
/* Nothing left to write */
event_del(ev);
}
3461}

3463/* Shorten replytext to number of lines */
3464void
3465tailify_replytext(char *replytext, int lines)
3466{
char *start, *nl;
int count = 0;
start = nl = replytext;

while ((nl = strchr(nl, '\n')) != NULL((void *)0)) {
nl++;
if (++count > lines) {
	start = strchr(start, '\n');
	start++;
}
}
if (start != replytext) {
int len = strlen(start);
memmove(replytext, start, len);
*(replytext + len) = '\0';
}
3483}

3485void
3486ctlconn_logto(char *line)
3487{
size_t l;

if (membuf_drop)
return;

l = strlen(line);
if (l + 2 > (CTL_REPLY_MAXSIZE((sizeof(struct ctl_reply_hdr)) + (256 * 1024)) - ctl_reply_size)) {
/* remember line drops for later report */
membuf_drop = 1;
return;
}
memcpy(ctl_reply + ctl_reply_size, line, l);
memcpy(ctl_reply + ctl_reply_size + l, "\n", 2);
ctl_reply_size += l + 1;
event_add(ev_ctlwrite, NULL((void *)0));
3503}