1 /*-
2  * SPDX-License-Identifier: BSD-2-Clause
4  * Copyright (c) 2009-2010 The FreeBSD Foundation
117 	char addr[MAX(INET_ADDRSTRLEN, INET6_ADDRSTRLEN)];  in pjdlog_printf_render_sockaddr_ip()  local
121 	switch (ss->ss_family) {  in pjdlog_printf_render_sockaddr_ip()
127 		if (inet_ntop(ss->ss_family, &sin->sin_addr, addr,  in pjdlog_printf_render_sockaddr_ip()
128 		    sizeof(addr)) == NULL) {  in pjdlog_printf_render_sockaddr_ip()
139 		if (inet_ntop(ss->ss_family, &sin->sin6_addr, addr,  in pjdlog_printf_render_sockaddr_ip()
140 		    sizeof(addr)) == NULL) {  in pjdlog_printf_render_sockaddr_ip()
147 		snprintf(addr, sizeof(addr), "[unsupported family %hhu]",  in pjdlog_printf_render_sockaddr_ip()
148 		    ss->ss_family);  in pjdlog_printf_render_sockaddr_ip()
151 	ret = __printf_out(io, pi, addr, strlen(addr));  in pjdlog_printf_render_sockaddr_ip()
165 	switch (ss->ss_family) {  in pjdlog_printf_render_sockaddr()
171 		if (sun->sun_path[0] == '\0')  in pjdlog_printf_render_sockaddr()
174 			snprintf(buf, sizeof(buf), "%s", sun->sun_path);  in pjdlog_printf_render_sockaddr()
179 		char addr[INET_ADDRSTRLEN];  in pjdlog_printf_render_sockaddr()  local
184 		port = ntohs(sin->sin_port);  in pjdlog_printf_render_sockaddr()
185 		if (inet_ntop(ss->ss_family, &sin->sin_addr, addr,  in pjdlog_printf_render_sockaddr()
186 		    sizeof(addr)) == NULL) {  in pjdlog_printf_render_sockaddr()
190 		snprintf(buf, sizeof(buf), "%s:%u", addr, port);  in pjdlog_printf_render_sockaddr()
195 		char addr[INET6_ADDRSTRLEN];  in pjdlog_printf_render_sockaddr()  local
200 		port = ntohs(sin->sin6_port);  in pjdlog_printf_render_sockaddr()
201 		if (inet_ntop(ss->ss_family, &sin->sin6_addr, addr,  in pjdlog_printf_render_sockaddr()
202 		    sizeof(addr)) == NULL) {  in pjdlog_printf_render_sockaddr()
206 		snprintf(buf, sizeof(buf), "[%s]:%u", addr, port);  in pjdlog_printf_render_sockaddr()
211 		    ss->ss_family);  in pjdlog_printf_render_sockaddr()
220 pjdlog_init(int mode)  in pjdlog_init()  argument
227 	assert(mode == PJDLOG_MODE_STD || mode == PJDLOG_MODE_SYSLOG ||  in pjdlog_init()
228 	    mode == PJDLOG_MODE_SOCK);  in pjdlog_init()
230 	assert(mode == PJDLOG_MODE_STD || mode == PJDLOG_MODE_SYSLOG);  in pjdlog_init()
249 	if (mode == PJDLOG_MODE_SYSLOG)  in pjdlog_init()
251 	pjdlog_mode = mode;  in pjdlog_init()
257 	pjdlog_sock = -1;  in pjdlog_init()
275 	pjdlog_sock = -1;  in pjdlog_fini()
283  * (eg. by calling daemon(3)) application is responsible for changing mode to
287 pjdlog_mode_set(int mode)  in pjdlog_mode_set()  argument
293 	assert(mode == PJDLOG_MODE_STD || mode == PJDLOG_MODE_SYSLOG ||  in pjdlog_mode_set()
294 	    mode == PJDLOG_MODE_SOCK);  in pjdlog_mode_set()
296 	assert(mode == PJDLOG_MODE_STD || mode == PJDLOG_MODE_SYSLOG);  in pjdlog_mode_set()
299 	if (pjdlog_mode == mode)  in pjdlog_mode_set()
304 	if (mode == PJDLOG_MODE_SYSLOG)  in pjdlog_mode_set()
306 	else if (mode == PJDLOG_MODE_STD)  in pjdlog_mode_set()
309 	if (mode != PJDLOG_MODE_SOCK)  in pjdlog_mode_set()
310 		pjdlog_sock = -1;  in pjdlog_mode_set()
312 	pjdlog_mode = mode;  in pjdlog_mode_set()
319  * Return current mode.
332  * Sets socket number to use for PJDLOG_MODE_SOCK mode.
348  * Returns socket number used for PJDLOG_MODE_SOCK mode.
458 	assert(pjdlog_prefix_current < PJDLOG_PREFIX_STACK - 1);  in pjdlogv_prefix_push()
475 	pjdlog_prefix_current--;  in pjdlog_prefix_pop()
514 	return (vsnprintf(str + len, size - len, fmt, ap));  in vsnprlcat()
554 	assert(error >= -1);  in pjdlogv_common_single_line()
566 		logs = sizeof(log) - 4;  in pjdlogv_common_single_line()
569 		assert(!"Invalid mode.");  in pjdlogv_common_single_line()
604 	if (error != -1)  in pjdlogv_common_single_line()
625 		if (robust_send(pjdlog_sock, log, (size_t)dlen + 2) == -1)	/* +2 for size */  in pjdlogv_common_single_line()
627 		if (robust_recv(pjdlog_sock, ack, sizeof(ack)) == -1)  in pjdlogv_common_single_line()
633 		assert(!"Invalid mode.");  in pjdlogv_common_single_line()
661 	assert(error >= -1);  in _pjdlogv_common()
678 			    debuglevel, -1, prvline);  in _pjdlogv_common()
764 		_pjdlogv_common(func, file, line, LOG_CRIT, 0, -1, fmt, ap);  in _pjdlog_abort()
768 		_pjdlog_common(func, file, line, LOG_CRIT, 0, -1, "Aborted.");  in _pjdlog_abort()
770 		_pjdlog_common(func, file, line, LOG_CRIT, 0, -1,  in _pjdlog_abort()
773 	if (error != -1)  in _pjdlog_abort()
789 	if (robust_recv(sock, &dlen, sizeof(dlen)) == -1)  in pjdlog_receive()
790 		return (-1);  in pjdlog_receive()
793 	PJDLOG_ASSERT(dlen <= PJDLOG_MAX_MSGSIZE - 3);  in pjdlog_receive()
795 	if (robust_recv(sock, log, (size_t)dlen) == -1)  in pjdlog_receive()
796 		return (-1);  in pjdlog_receive()
798 	log[dlen - 1] = '\0';  in pjdlog_receive()
801 	_pjdlog_common(NULL, NULL, 0, loglevel, debuglevel, -1, "%s", log + 2);  in pjdlog_receive()
803 	if (robust_send(sock, "ok", 2) == -1)  in pjdlog_receive()
804 		return (-1);  in pjdlog_receive()