mirror of
git://git.gnupg.org/gnupg.git
synced 2024-11-01 20:18:44 +01:00
a9e0905342
* agent/cache.c: Fix typos. * agent/call-pinentry.c: Likewise. * agent/call-scd.c: Likewise. * agent/command-ssh.c: Likewise. * agent/command.c: Likewise. * agent/divert-scd.c: Likewise. * agent/findkey.c: Likewise. * agent/gpg-agent.c: Likewise. * agent/w32main.c: Likewise. * common/argparse.c: Likewise. * common/audit.c: Likewise. * common/audit.h: Likewise. * common/convert.c: Likewise. * common/dotlock.c: Likewise. * common/exechelp-posix.c: Likewise. * common/exechelp-w32.c: Likewise. * common/exechelp-w32ce.c: Likewise. * common/exechelp.h: Likewise. * common/helpfile.c: Likewise. * common/i18n.h: Likewise. * common/iobuf.c: Likewise. * common/iobuf.h: Likewise. * common/localename.c: Likewise. * common/logging.c: Likewise. * common/openpgp-oid.c: Likewise. * common/session-env.c: Likewise. * common/sexputil.c: Likewise. * common/sysutils.c: Likewise. * common/t-sexputil.c: Likewise. * common/ttyio.c: Likewise. * common/util.h: Likewise. * dirmngr/cdblib.c: Likewise. * dirmngr/certcache.c: Likewise. * dirmngr/crlcache.c: Likewise. * dirmngr/dirmngr-client.c: Likewise. * dirmngr/dirmngr.c: Likewise. * dirmngr/dirmngr_ldap.c: Likewise. * dirmngr/dns-stuff.c: Likewise. * dirmngr/http.c: Likewise. * dirmngr/ks-engine-hkp.c: Likewise. * dirmngr/ks-engine-ldap.c: Likewise. * dirmngr/ldap-wrapper.c: Likewise. * dirmngr/ldap.c: Likewise. * dirmngr/misc.c: Likewise. * dirmngr/ocsp.c: Likewise. * dirmngr/validate.c: Likewise. * g10/encrypt.c: Likewise. * g10/getkey.c: Likewise. * g10/gpg.c: Likewise. * g10/gpgv.c: Likewise. * g10/import.c: Likewise. * g10/keydb.c: Likewise. * g10/keydb.h: Likewise. * g10/keygen.c: Likewise. * g10/keyid.c: Likewise. * g10/keylist.c: Likewise. * g10/keyring.c: Likewise. * g10/mainproc.c: Likewise. * g10/misc.c: Likewise. * g10/options.h: Likewise. * g10/packet.h: Likewise. * g10/parse-packet.c: Likewise. * g10/pkclist.c: Likewise. * g10/pkglue.c: Likewise. * g10/plaintext.c: Likewise. * g10/server.c: Likewise. * g10/sig-check.c: Likewise. * g10/sqlite.c: Likewise. * g10/tdbio.c: Likewise. * g10/test-stubs.c: Likewise. * g10/tofu.c: Likewise. * g10/trust.c: Likewise. * g10/trustdb.c: Likewise. * g13/create.c: Likewise. * g13/mountinfo.c: Likewise. * kbx/keybox-blob.c: Likewise. * kbx/keybox-file.c: Likewise. * kbx/keybox-init.c: Likewise. * kbx/keybox-search-desc.h: Likewise. * kbx/keybox-search.c: Likewise. * kbx/keybox-update.c: Likewise. * scd/apdu.c: Likewise. * scd/app-openpgp.c: Likewise. * scd/app-p15.c: Likewise. * scd/app.c: Likewise. * scd/ccid-driver.c: Likewise. * scd/command.c: Likewise. * scd/iso7816.c: Likewise. * sm/base64.c: Likewise. * sm/call-agent.c: Likewise. * sm/call-dirmngr.c: Likewise. * sm/certchain.c: Likewise. * sm/gpgsm.c: Likewise. * sm/import.c: Likewise. * sm/keydb.c: Likewise. * sm/minip12.c: Likewise. * sm/qualified.c: Likewise. * sm/server.c: Likewise. * tools/gpg-check-pattern.c: Likewise. * tools/gpgconf-comp.c: Likewise. * tools/gpgkey2ssh.c: Likewise. * tools/gpgparsemail.c: Likewise. * tools/gpgtar.c: Likewise. * tools/rfc822parse.c: Likewise. * tools/symcryptrun.c: Likewise. Signed-off-by: Justus Winter <justus@g10code.com>
937 lines
23 KiB
C
937 lines
23 KiB
C
/* logging.c - Useful logging functions
|
|
* Copyright (C) 1998, 1999, 2000, 2001, 2003, 2004, 2005, 2006,
|
|
* 2009, 2010 Free Software Foundation, Inc.
|
|
*
|
|
* This file is part of GnuPG.
|
|
*
|
|
* GnuPG is free software; you can redistribute it and/or modify it
|
|
* under the terms of either
|
|
*
|
|
* - the GNU Lesser General Public License as published by the Free
|
|
* Software Foundation; either version 3 of the License, or (at
|
|
* your option) any later version.
|
|
*
|
|
* or
|
|
*
|
|
* - the GNU General Public License as published by the Free
|
|
* Software Foundation; either version 2 of the License, or (at
|
|
* your option) any later version.
|
|
*
|
|
* or both in parallel, as here.
|
|
*
|
|
* GnuPG is distributed in the hope that it will be useful, but
|
|
* WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* General Public License for more details.
|
|
*
|
|
* You should have received a copies of the GNU General Public License
|
|
* and the GNU Lesser General Public License along with this program;
|
|
* if not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
|
|
#include <config.h>
|
|
#include <stdlib.h>
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <stdarg.h>
|
|
#include <stddef.h>
|
|
#include <errno.h>
|
|
#include <time.h>
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#ifdef HAVE_W32_SYSTEM
|
|
# ifdef HAVE_WINSOCK2_H
|
|
# include <winsock2.h>
|
|
# endif
|
|
# include <windows.h>
|
|
#else /*!HAVE_W32_SYSTEM*/
|
|
# include <sys/socket.h>
|
|
# include <sys/un.h>
|
|
# include <netinet/in.h>
|
|
# include <arpa/inet.h>
|
|
#endif /*!HAVE_W32_SYSTEM*/
|
|
#include <unistd.h>
|
|
#include <fcntl.h>
|
|
#include <assert.h>
|
|
|
|
|
|
#define GNUPG_COMMON_NEED_AFLOCAL 1
|
|
#include "util.h"
|
|
#include "i18n.h"
|
|
#include "common-defs.h"
|
|
#include "logging.h"
|
|
|
|
#ifdef HAVE_W32_SYSTEM
|
|
# define S_IRGRP S_IRUSR
|
|
# define S_IROTH S_IRUSR
|
|
# define S_IWGRP S_IWUSR
|
|
# define S_IWOTH S_IWUSR
|
|
#endif
|
|
|
|
|
|
#ifdef HAVE_W32CE_SYSTEM
|
|
# define isatty(a) (0)
|
|
#endif
|
|
|
|
#undef WITH_IPV6
|
|
#if defined (AF_INET6) && defined(PF_INET) \
|
|
&& defined (INET6_ADDRSTRLEN) && defined(HAVE_INET_PTON)
|
|
# define WITH_IPV6 1
|
|
#endif
|
|
|
|
#ifndef EAFNOSUPPORT
|
|
# define EAFNOSUPPORT EINVAL
|
|
#endif
|
|
#ifndef INADDR_NONE /* Slowaris is missing that. */
|
|
#define INADDR_NONE ((unsigned long)(-1))
|
|
#endif /*INADDR_NONE*/
|
|
|
|
#ifdef HAVE_W32_SYSTEM
|
|
#define sock_close(a) closesocket(a)
|
|
#else
|
|
#define sock_close(a) close(a)
|
|
#endif
|
|
|
|
|
|
static estream_t logstream;
|
|
static int log_socket = -1;
|
|
static char prefix_buffer[80];
|
|
static int with_time;
|
|
static int with_prefix;
|
|
static int with_pid;
|
|
#ifdef HAVE_W32_SYSTEM
|
|
static int no_registry;
|
|
#endif
|
|
static int (*get_pid_suffix_cb)(unsigned long *r_value);
|
|
static int running_detached;
|
|
static int force_prefixes;
|
|
|
|
static int missing_lf;
|
|
static int errorcount;
|
|
|
|
|
|
int
|
|
log_get_errorcount (int clear)
|
|
{
|
|
int n = errorcount;
|
|
if( clear )
|
|
errorcount = 0;
|
|
return n;
|
|
}
|
|
|
|
void
|
|
log_inc_errorcount (void)
|
|
{
|
|
errorcount++;
|
|
}
|
|
|
|
|
|
/* The following 3 functions are used by es_fopencookie to write logs
|
|
to a socket. */
|
|
struct fun_cookie_s
|
|
{
|
|
int fd;
|
|
int quiet;
|
|
int want_socket;
|
|
int is_socket;
|
|
#ifdef HAVE_W32CE_SYSTEM
|
|
int use_writefile;
|
|
#endif
|
|
char name[1];
|
|
};
|
|
|
|
|
|
/* Write NBYTES of BUFFER to file descriptor FD. */
|
|
static int
|
|
writen (int fd, const void *buffer, size_t nbytes, int is_socket)
|
|
{
|
|
const char *buf = buffer;
|
|
size_t nleft = nbytes;
|
|
int nwritten;
|
|
#ifndef HAVE_W32_SYSTEM
|
|
(void)is_socket; /* Not required. */
|
|
#endif
|
|
|
|
while (nleft > 0)
|
|
{
|
|
#ifdef HAVE_W32_SYSTEM
|
|
if (is_socket)
|
|
nwritten = send (fd, buf, nleft, 0);
|
|
else
|
|
#endif
|
|
nwritten = write (fd, buf, nleft);
|
|
|
|
if (nwritten < 0 && errno == EINTR)
|
|
continue;
|
|
if (nwritten < 0)
|
|
return -1;
|
|
nleft -= nwritten;
|
|
buf = buf + nwritten;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
|
|
/* Returns true if STR represents a valid port number in decimal
|
|
notation and no garbage is following. */
|
|
static int
|
|
parse_portno (const char *str, unsigned short *r_port)
|
|
{
|
|
unsigned int value;
|
|
|
|
for (value=0; *str && (*str >= '0' && *str <= '9'); str++)
|
|
{
|
|
value = value * 10 + (*str - '0');
|
|
if (value > 65535)
|
|
return 0;
|
|
}
|
|
if (*str || !value)
|
|
return 0;
|
|
|
|
*r_port = value;
|
|
return 1;
|
|
}
|
|
|
|
|
|
static ssize_t
|
|
fun_writer (void *cookie_arg, const void *buffer, size_t size)
|
|
{
|
|
struct fun_cookie_s *cookie = cookie_arg;
|
|
|
|
/* FIXME: Use only estream with a callback for socket writing. This
|
|
avoids the ugly mix of fd and estream code. */
|
|
|
|
/* Note that we always try to reconnect to the socket but print
|
|
error messages only the first time an error occurred. If
|
|
RUNNING_DETACHED is set we don't fall back to stderr and even do
|
|
not print any error messages. This is needed because detached
|
|
processes often close stderr and by writing to file descriptor 2
|
|
we might send the log message to a file not intended for logging
|
|
(e.g. a pipe or network connection). */
|
|
if (cookie->want_socket && cookie->fd == -1)
|
|
{
|
|
#ifdef WITH_IPV6
|
|
struct sockaddr_in6 srvr_addr_in6;
|
|
#endif
|
|
struct sockaddr_in srvr_addr_in;
|
|
#ifndef HAVE_W32_SYSTEM
|
|
struct sockaddr_un srvr_addr_un;
|
|
#endif
|
|
size_t addrlen;
|
|
struct sockaddr *srvr_addr = NULL;
|
|
unsigned short port = 0;
|
|
int af = AF_LOCAL;
|
|
int pf = PF_LOCAL;
|
|
const char *name = cookie->name;
|
|
|
|
/* Not yet open or meanwhile closed due to an error. */
|
|
cookie->is_socket = 0;
|
|
|
|
/* Check whether this is a TCP socket or a local socket. */
|
|
if (!strncmp (name, "tcp://", 6) && name[6])
|
|
{
|
|
name += 6;
|
|
af = AF_INET;
|
|
pf = PF_INET;
|
|
}
|
|
#ifndef HAVE_W32_SYSTEM
|
|
else if (!strncmp (name, "socket://", 9) && name[9])
|
|
name += 9;
|
|
#endif
|
|
|
|
if (af == AF_LOCAL)
|
|
{
|
|
#ifdef HAVE_W32_SYSTEM
|
|
addrlen = 0;
|
|
#else
|
|
memset (&srvr_addr, 0, sizeof srvr_addr);
|
|
srvr_addr_un.sun_family = af;
|
|
strncpy (srvr_addr_un.sun_path,
|
|
name, sizeof (srvr_addr_un.sun_path)-1);
|
|
srvr_addr_un.sun_path[sizeof (srvr_addr_un.sun_path)-1] = 0;
|
|
srvr_addr = (struct sockaddr *)&srvr_addr_un;
|
|
addrlen = SUN_LEN (&srvr_addr_un);
|
|
#endif
|
|
}
|
|
else
|
|
{
|
|
char *addrstr, *p;
|
|
#ifdef HAVE_INET_PTON
|
|
void *addrbuf = NULL;
|
|
#endif /*HAVE_INET_PTON*/
|
|
|
|
addrstr = xtrymalloc (strlen (name) + 1);
|
|
if (!addrstr)
|
|
addrlen = 0; /* This indicates an error. */
|
|
else if (*name == '[')
|
|
{
|
|
/* Check for IPv6 literal address. */
|
|
strcpy (addrstr, name+1);
|
|
p = strchr (addrstr, ']');
|
|
if (!p || p[1] != ':' || !parse_portno (p+2, &port))
|
|
{
|
|
gpg_err_set_errno (EINVAL);
|
|
addrlen = 0;
|
|
}
|
|
else
|
|
{
|
|
*p = 0;
|
|
#ifdef WITH_IPV6
|
|
af = AF_INET6;
|
|
pf = PF_INET6;
|
|
memset (&srvr_addr_in6, 0, sizeof srvr_addr_in6);
|
|
srvr_addr_in6.sin6_family = af;
|
|
srvr_addr_in6.sin6_port = htons (port);
|
|
#ifdef HAVE_INET_PTON
|
|
addrbuf = &srvr_addr_in6.sin6_addr;
|
|
#endif /*HAVE_INET_PTON*/
|
|
srvr_addr = (struct sockaddr *)&srvr_addr_in6;
|
|
addrlen = sizeof srvr_addr_in6;
|
|
#else
|
|
gpg_err_set_errno (EAFNOSUPPORT);
|
|
addrlen = 0;
|
|
#endif
|
|
}
|
|
}
|
|
else
|
|
{
|
|
/* Check for IPv4 literal address. */
|
|
strcpy (addrstr, name);
|
|
p = strchr (addrstr, ':');
|
|
if (!p || !parse_portno (p+1, &port))
|
|
{
|
|
gpg_err_set_errno (EINVAL);
|
|
addrlen = 0;
|
|
}
|
|
else
|
|
{
|
|
*p = 0;
|
|
memset (&srvr_addr_in, 0, sizeof srvr_addr_in);
|
|
srvr_addr_in.sin_family = af;
|
|
srvr_addr_in.sin_port = htons (port);
|
|
#ifdef HAVE_INET_PTON
|
|
addrbuf = &srvr_addr_in.sin_addr;
|
|
#endif /*HAVE_INET_PTON*/
|
|
srvr_addr = (struct sockaddr *)&srvr_addr_in;
|
|
addrlen = sizeof srvr_addr_in;
|
|
}
|
|
}
|
|
|
|
if (addrlen)
|
|
{
|
|
#ifdef HAVE_INET_PTON
|
|
if (inet_pton (af, addrstr, addrbuf) != 1)
|
|
addrlen = 0;
|
|
#else /*!HAVE_INET_PTON*/
|
|
/* We need to use the old function. If we are here v6
|
|
support isn't enabled anyway and thus we can do fine
|
|
without. Note that Windows has a compatible inet_pton
|
|
function named inetPton, but only since Vista. */
|
|
srvr_addr_in.sin_addr.s_addr = inet_addr (addrstr);
|
|
if (srvr_addr_in.sin_addr.s_addr == INADDR_NONE)
|
|
addrlen = 0;
|
|
#endif /*!HAVE_INET_PTON*/
|
|
}
|
|
|
|
xfree (addrstr);
|
|
}
|
|
|
|
cookie->fd = addrlen? socket (pf, SOCK_STREAM, 0) : -1;
|
|
if (cookie->fd == -1)
|
|
{
|
|
if (!cookie->quiet && !running_detached
|
|
&& isatty (es_fileno (es_stderr)))
|
|
es_fprintf (es_stderr, "failed to create socket for logging: %s\n",
|
|
strerror(errno));
|
|
}
|
|
else
|
|
{
|
|
if (connect (cookie->fd, srvr_addr, addrlen) == -1)
|
|
{
|
|
if (!cookie->quiet && !running_detached
|
|
&& isatty (es_fileno (es_stderr)))
|
|
es_fprintf (es_stderr, "can't connect to '%s': %s\n",
|
|
cookie->name, strerror(errno));
|
|
sock_close (cookie->fd);
|
|
cookie->fd = -1;
|
|
}
|
|
}
|
|
|
|
if (cookie->fd == -1)
|
|
{
|
|
if (!running_detached)
|
|
{
|
|
/* Due to all the problems with apps not running
|
|
detached but being called with stderr closed or used
|
|
for a different purposes, it does not make sense to
|
|
switch to stderr. We therefore disable it. */
|
|
if (!cookie->quiet)
|
|
{
|
|
/* fputs ("switching logging to stderr\n", stderr);*/
|
|
cookie->quiet = 1;
|
|
}
|
|
cookie->fd = -1; /*fileno (stderr);*/
|
|
}
|
|
}
|
|
else /* Connection has been established. */
|
|
{
|
|
cookie->quiet = 0;
|
|
cookie->is_socket = 1;
|
|
}
|
|
}
|
|
|
|
log_socket = cookie->fd;
|
|
if (cookie->fd != -1)
|
|
{
|
|
#ifdef HAVE_W32CE_SYSTEM
|
|
if (cookie->use_writefile)
|
|
{
|
|
DWORD nwritten;
|
|
|
|
WriteFile ((HANDLE)cookie->fd, buffer, size, &nwritten, NULL);
|
|
return (ssize_t)size; /* Okay. */
|
|
}
|
|
#endif
|
|
if (!writen (cookie->fd, buffer, size, cookie->is_socket))
|
|
return (ssize_t)size; /* Okay. */
|
|
}
|
|
|
|
if (!running_detached && cookie->fd != -1
|
|
&& isatty (es_fileno (es_stderr)))
|
|
{
|
|
if (*cookie->name)
|
|
es_fprintf (es_stderr, "error writing to '%s': %s\n",
|
|
cookie->name, strerror(errno));
|
|
else
|
|
es_fprintf (es_stderr, "error writing to file descriptor %d: %s\n",
|
|
cookie->fd, strerror(errno));
|
|
}
|
|
if (cookie->is_socket && cookie->fd != -1)
|
|
{
|
|
sock_close (cookie->fd);
|
|
cookie->fd = -1;
|
|
log_socket = -1;
|
|
}
|
|
|
|
return (ssize_t)size;
|
|
}
|
|
|
|
|
|
static int
|
|
fun_closer (void *cookie_arg)
|
|
{
|
|
struct fun_cookie_s *cookie = cookie_arg;
|
|
|
|
if (cookie->fd != -1 && cookie->fd != 2)
|
|
sock_close (cookie->fd);
|
|
xfree (cookie);
|
|
log_socket = -1;
|
|
return 0;
|
|
}
|
|
|
|
|
|
/* Common function to either set the logging to a file or a file
|
|
descriptor. */
|
|
static void
|
|
set_file_fd (const char *name, int fd)
|
|
{
|
|
estream_t fp;
|
|
int want_socket;
|
|
#ifdef HAVE_W32CE_SYSTEM
|
|
int use_writefile = 0;
|
|
#endif
|
|
struct fun_cookie_s *cookie;
|
|
|
|
/* Close an open log stream. */
|
|
if (logstream)
|
|
{
|
|
es_fclose (logstream);
|
|
logstream = NULL;
|
|
}
|
|
|
|
/* Figure out what kind of logging we want. */
|
|
if (name && !strcmp (name, "-"))
|
|
{
|
|
name = NULL;
|
|
fd = es_fileno (es_stderr);
|
|
}
|
|
|
|
want_socket = 0;
|
|
if (name && !strncmp (name, "tcp://", 6) && name[6])
|
|
want_socket = 1;
|
|
#ifndef HAVE_W32_SYSTEM
|
|
else if (name && !strncmp (name, "socket://", 9) && name[9])
|
|
want_socket = 2;
|
|
#endif /*HAVE_W32_SYSTEM*/
|
|
#ifdef HAVE_W32CE_SYSTEM
|
|
else if (name && !strcmp (name, "GPG2:"))
|
|
{
|
|
HANDLE hd;
|
|
|
|
ActivateDevice (L"Drivers\\"GNUPG_NAME"_Log", 0);
|
|
/* Ignore a filename and write the debug output to the GPG2:
|
|
device. */
|
|
hd = CreateFile (L"GPG2:", GENERIC_WRITE,
|
|
FILE_SHARE_READ | FILE_SHARE_WRITE,
|
|
NULL, OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
|
|
fd = (hd == INVALID_HANDLE_VALUE)? -1 : (int)hd;
|
|
name = NULL;
|
|
force_prefixes = 1;
|
|
use_writefile = 1;
|
|
}
|
|
#endif /*HAVE_W32CE_SYSTEM*/
|
|
|
|
/* Setup a new stream. */
|
|
|
|
/* The xmalloc below is justified because we can expect that this
|
|
function is called only during initialization and there is no
|
|
easy way out of this error condition. */
|
|
cookie = xmalloc (sizeof *cookie + (name? strlen (name):0));
|
|
strcpy (cookie->name, name? name:"");
|
|
cookie->quiet = 0;
|
|
cookie->is_socket = 0;
|
|
cookie->want_socket = want_socket;
|
|
#ifdef HAVE_W32CE_SYSTEM
|
|
cookie->use_writefile = use_writefile;
|
|
#endif
|
|
if (!name)
|
|
cookie->fd = fd;
|
|
else if (want_socket)
|
|
cookie->fd = -1;
|
|
else
|
|
{
|
|
do
|
|
cookie->fd = open (name, O_WRONLY|O_APPEND|O_CREAT,
|
|
(S_IRUSR|S_IRGRP|S_IROTH|S_IWUSR|S_IWGRP|S_IWOTH));
|
|
while (cookie->fd == -1 && errno == EINTR);
|
|
}
|
|
log_socket = cookie->fd;
|
|
|
|
{
|
|
es_cookie_io_functions_t io = { NULL };
|
|
io.func_write = fun_writer;
|
|
io.func_close = fun_closer;
|
|
|
|
fp = es_fopencookie (cookie, "w", io);
|
|
}
|
|
|
|
/* On error default to a stderr based estream. */
|
|
if (!fp)
|
|
fp = es_stderr;
|
|
|
|
es_setvbuf (fp, NULL, _IOLBF, 0);
|
|
|
|
logstream = fp;
|
|
|
|
/* We always need to print the prefix and the pid for socket mode,
|
|
so that the server reading the socket can do something
|
|
meaningful. */
|
|
force_prefixes = want_socket;
|
|
|
|
missing_lf = 0;
|
|
}
|
|
|
|
|
|
/* Set the file to write log to. The special names NULL and "-" may
|
|
be used to select stderr and names formatted like
|
|
"socket:///home/foo/mylogs" may be used to write the logging to the
|
|
socket "/home/foo/mylogs". If the connection to the socket fails
|
|
or a write error is detected, the function writes to stderr and
|
|
tries the next time again to connect the socket.
|
|
*/
|
|
void
|
|
log_set_file (const char *name)
|
|
{
|
|
set_file_fd (name? name: "-", -1);
|
|
}
|
|
|
|
void
|
|
log_set_fd (int fd)
|
|
{
|
|
set_file_fd (NULL, fd);
|
|
}
|
|
|
|
|
|
void
|
|
log_set_pid_suffix_cb (int (*cb)(unsigned long *r_value))
|
|
{
|
|
get_pid_suffix_cb = cb;
|
|
}
|
|
|
|
|
|
void
|
|
log_set_prefix (const char *text, unsigned int flags)
|
|
{
|
|
if (text)
|
|
{
|
|
strncpy (prefix_buffer, text, sizeof (prefix_buffer)-1);
|
|
prefix_buffer[sizeof (prefix_buffer)-1] = 0;
|
|
}
|
|
|
|
with_prefix = (flags & GPGRT_LOG_WITH_PREFIX);
|
|
with_time = (flags & GPGRT_LOG_WITH_TIME);
|
|
with_pid = (flags & GPGRT_LOG_WITH_PID);
|
|
running_detached = (flags & GPGRT_LOG_RUN_DETACHED);
|
|
#ifdef HAVE_W32_SYSTEM
|
|
no_registry = (flags & GPGRT_LOG_NO_REGISTRY);
|
|
#endif
|
|
}
|
|
|
|
|
|
const char *
|
|
log_get_prefix (unsigned int *flags)
|
|
{
|
|
if (flags)
|
|
{
|
|
*flags = 0;
|
|
if (with_prefix)
|
|
*flags |= GPGRT_LOG_WITH_PREFIX;
|
|
if (with_time)
|
|
*flags |= GPGRT_LOG_WITH_TIME;
|
|
if (with_pid)
|
|
*flags |= GPGRT_LOG_WITH_PID;
|
|
if (running_detached)
|
|
*flags |= GPGRT_LOG_RUN_DETACHED;
|
|
#ifdef HAVE_W32_SYSTEM
|
|
if (no_registry)
|
|
*flags |= GPGRT_LOG_NO_REGISTRY;
|
|
#endif
|
|
}
|
|
return prefix_buffer;
|
|
}
|
|
|
|
/* This function returns true if the file descriptor FD is in use for
|
|
logging. This is preferable over a test using log_get_fd in that
|
|
it allows the logging code to use more then one file descriptor. */
|
|
int
|
|
log_test_fd (int fd)
|
|
{
|
|
if (logstream)
|
|
{
|
|
int tmp = es_fileno (logstream);
|
|
if ( tmp != -1 && tmp == fd)
|
|
return 1;
|
|
}
|
|
if (log_socket != -1 && log_socket == fd)
|
|
return 1;
|
|
return 0;
|
|
}
|
|
|
|
int
|
|
log_get_fd ()
|
|
{
|
|
return logstream? es_fileno(logstream) : -1;
|
|
}
|
|
|
|
estream_t
|
|
log_get_stream ()
|
|
{
|
|
if (!logstream)
|
|
{
|
|
log_set_file (NULL); /* Make sure a log stream has been set. */
|
|
assert (logstream);
|
|
}
|
|
return logstream;
|
|
}
|
|
|
|
static void
|
|
do_logv (int level, int ignore_arg_ptr, const char *fmt, va_list arg_ptr)
|
|
{
|
|
if (!logstream)
|
|
{
|
|
#ifdef HAVE_W32_SYSTEM
|
|
char *tmp;
|
|
|
|
tmp = (no_registry
|
|
? NULL
|
|
: read_w32_registry_string (NULL, GNUPG_REGISTRY_DIR,
|
|
"DefaultLogFile"));
|
|
log_set_file (tmp && *tmp? tmp : NULL);
|
|
xfree (tmp);
|
|
#else
|
|
log_set_file (NULL); /* Make sure a log stream has been set. */
|
|
#endif
|
|
assert (logstream);
|
|
}
|
|
|
|
es_flockfile (logstream);
|
|
if (missing_lf && level != GPGRT_LOG_CONT)
|
|
es_putc_unlocked ('\n', logstream );
|
|
missing_lf = 0;
|
|
|
|
if (level != GPGRT_LOG_CONT)
|
|
{ /* Note this does not work for multiple line logging as we would
|
|
* need to print to a buffer first */
|
|
if (with_time && !force_prefixes)
|
|
{
|
|
struct tm *tp;
|
|
time_t atime = time (NULL);
|
|
|
|
tp = localtime (&atime);
|
|
es_fprintf_unlocked (logstream, "%04d-%02d-%02d %02d:%02d:%02d ",
|
|
1900+tp->tm_year, tp->tm_mon+1, tp->tm_mday,
|
|
tp->tm_hour, tp->tm_min, tp->tm_sec );
|
|
}
|
|
if (with_prefix || force_prefixes)
|
|
es_fputs_unlocked (prefix_buffer, logstream);
|
|
if (with_pid || force_prefixes)
|
|
{
|
|
unsigned long pidsuf;
|
|
int pidfmt;
|
|
|
|
if (get_pid_suffix_cb && (pidfmt=get_pid_suffix_cb (&pidsuf)))
|
|
es_fprintf_unlocked (logstream, pidfmt == 1? "[%u.%lu]":"[%u.%lx]",
|
|
(unsigned int)getpid (), pidsuf);
|
|
else
|
|
es_fprintf_unlocked (logstream, "[%u]", (unsigned int)getpid ());
|
|
}
|
|
if (!with_time || force_prefixes)
|
|
es_putc_unlocked (':', logstream);
|
|
/* A leading backspace suppresses the extra space so that we can
|
|
correctly output, programname, filename and linenumber. */
|
|
if (fmt && *fmt == '\b')
|
|
fmt++;
|
|
else
|
|
es_putc_unlocked (' ', logstream);
|
|
}
|
|
|
|
switch (level)
|
|
{
|
|
case GPGRT_LOG_BEGIN: break;
|
|
case GPGRT_LOG_CONT: break;
|
|
case GPGRT_LOG_INFO: break;
|
|
case GPGRT_LOG_WARN: break;
|
|
case GPGRT_LOG_ERROR: break;
|
|
case GPGRT_LOG_FATAL: es_fputs_unlocked ("Fatal: ",logstream ); break;
|
|
case GPGRT_LOG_BUG: es_fputs_unlocked ("Ohhhh jeeee: ", logstream); break;
|
|
case GPGRT_LOG_DEBUG: es_fputs_unlocked ("DBG: ", logstream ); break;
|
|
default:
|
|
es_fprintf_unlocked (logstream,"[Unknown log level %d]: ", level);
|
|
break;
|
|
}
|
|
|
|
if (fmt)
|
|
{
|
|
if (ignore_arg_ptr)
|
|
es_fputs_unlocked (fmt, logstream);
|
|
else
|
|
es_vfprintf_unlocked (logstream, fmt, arg_ptr);
|
|
if (*fmt && fmt[strlen(fmt)-1] != '\n')
|
|
missing_lf = 1;
|
|
}
|
|
|
|
if (level == GPGRT_LOG_FATAL)
|
|
{
|
|
if (missing_lf)
|
|
es_putc_unlocked ('\n', logstream);
|
|
es_funlockfile (logstream);
|
|
exit (2);
|
|
}
|
|
else if (level == GPGRT_LOG_BUG)
|
|
{
|
|
if (missing_lf)
|
|
es_putc_unlocked ('\n', logstream );
|
|
es_funlockfile (logstream);
|
|
abort ();
|
|
}
|
|
else
|
|
es_funlockfile (logstream);
|
|
}
|
|
|
|
|
|
void
|
|
log_log (int level, const char *fmt, ...)
|
|
{
|
|
va_list arg_ptr ;
|
|
|
|
va_start (arg_ptr, fmt) ;
|
|
do_logv (level, 0, fmt, arg_ptr);
|
|
va_end (arg_ptr);
|
|
}
|
|
|
|
|
|
void
|
|
log_logv (int level, const char *fmt, va_list arg_ptr)
|
|
{
|
|
do_logv (level, 0, fmt, arg_ptr);
|
|
}
|
|
|
|
|
|
static void
|
|
do_log_ignore_arg (int level, const char *str, ...)
|
|
{
|
|
va_list arg_ptr;
|
|
va_start (arg_ptr, str);
|
|
do_logv (level, 1, str, arg_ptr);
|
|
va_end (arg_ptr);
|
|
}
|
|
|
|
|
|
void
|
|
log_string (int level, const char *string)
|
|
{
|
|
/* We need a dummy arg_ptr, but there is no portable way to create
|
|
one. So we call the do_logv function through a variadic wrapper.
|
|
MB: Why not just use "%s"? */
|
|
do_log_ignore_arg (level, string);
|
|
}
|
|
|
|
|
|
void
|
|
log_info (const char *fmt, ...)
|
|
{
|
|
va_list arg_ptr ;
|
|
|
|
va_start (arg_ptr, fmt);
|
|
do_logv (GPGRT_LOG_INFO, 0, fmt, arg_ptr);
|
|
va_end (arg_ptr);
|
|
}
|
|
|
|
|
|
void
|
|
log_error (const char *fmt, ...)
|
|
{
|
|
va_list arg_ptr ;
|
|
|
|
va_start (arg_ptr, fmt);
|
|
do_logv (GPGRT_LOG_ERROR, 0, fmt, arg_ptr);
|
|
va_end (arg_ptr);
|
|
/* Protect against counter overflow. */
|
|
if (errorcount < 30000)
|
|
errorcount++;
|
|
}
|
|
|
|
|
|
void
|
|
log_fatal (const char *fmt, ...)
|
|
{
|
|
va_list arg_ptr ;
|
|
|
|
va_start (arg_ptr, fmt);
|
|
do_logv (GPGRT_LOG_FATAL, 0, fmt, arg_ptr);
|
|
va_end (arg_ptr);
|
|
abort (); /* Never called; just to make the compiler happy. */
|
|
}
|
|
|
|
|
|
void
|
|
log_bug (const char *fmt, ...)
|
|
{
|
|
va_list arg_ptr ;
|
|
|
|
va_start (arg_ptr, fmt);
|
|
do_logv (GPGRT_LOG_BUG, 0, fmt, arg_ptr);
|
|
va_end (arg_ptr);
|
|
abort (); /* Never called; just to make the compiler happy. */
|
|
}
|
|
|
|
|
|
void
|
|
log_debug (const char *fmt, ...)
|
|
{
|
|
va_list arg_ptr ;
|
|
|
|
va_start (arg_ptr, fmt);
|
|
do_logv (GPGRT_LOG_DEBUG, 0, fmt, arg_ptr);
|
|
va_end (arg_ptr);
|
|
}
|
|
|
|
|
|
void
|
|
log_printf (const char *fmt, ...)
|
|
{
|
|
va_list arg_ptr;
|
|
|
|
va_start (arg_ptr, fmt);
|
|
do_logv (fmt ? GPGRT_LOG_CONT : GPGRT_LOG_BEGIN, 0, fmt, arg_ptr);
|
|
va_end (arg_ptr);
|
|
}
|
|
|
|
|
|
/* Flush the log - this is useful to make sure that the trailing
|
|
linefeed has been printed. */
|
|
void
|
|
log_flush (void)
|
|
{
|
|
do_log_ignore_arg (GPGRT_LOG_CONT, NULL);
|
|
}
|
|
|
|
|
|
/* Print a hexdump of BUFFER. With TEXT of NULL print just the raw
|
|
dump, with TEXT just an empty string, print a trailing linefeed,
|
|
otherwise print an entire debug line. */
|
|
void
|
|
log_printhex (const char *text, const void *buffer, size_t length)
|
|
{
|
|
if (text && *text)
|
|
log_debug ("%s ", text);
|
|
if (length)
|
|
{
|
|
const unsigned char *p = buffer;
|
|
log_printf ("%02X", *p);
|
|
for (length--, p++; length--; p++)
|
|
log_printf (" %02X", *p);
|
|
}
|
|
if (text)
|
|
log_printf ("\n");
|
|
}
|
|
|
|
|
|
/*
|
|
void
|
|
log_printcanon () {}
|
|
is found in sexputils.c
|
|
*/
|
|
|
|
/*
|
|
void
|
|
log_printsexp () {}
|
|
is found in sexputils.c
|
|
*/
|
|
|
|
|
|
void
|
|
log_clock (const char *string)
|
|
{
|
|
#if 0
|
|
static unsigned long long initial;
|
|
struct timespec tv;
|
|
unsigned long long now;
|
|
|
|
if (clock_gettime (CLOCK_REALTIME, &tv))
|
|
{
|
|
log_debug ("error getting the realtime clock value\n");
|
|
return;
|
|
}
|
|
now = tv.tv_sec * 1000000000ull;
|
|
now += tv.tv_nsec;
|
|
|
|
if (!initial)
|
|
initial = now;
|
|
|
|
log_debug ("[%6llu] %s", (now - initial)/1000, string);
|
|
#else
|
|
/* You need to link with -ltr to enable the above code. */
|
|
log_debug ("[not enabled in the source] %s", string);
|
|
#endif
|
|
}
|
|
|
|
|
|
#if __GNUC__ > 2 || (__GNUC__ == 2 && __GNUC_MINOR__ >= 5 )
|
|
void
|
|
bug_at( const char *file, int line, const char *func )
|
|
{
|
|
log_log (GPGRT_LOG_BUG, ("... this is a bug (%s:%d:%s)\n"), file, line, func);
|
|
abort (); /* Never called; just to make the compiler happy. */
|
|
}
|
|
#else
|
|
void
|
|
bug_at( const char *file, int line )
|
|
{
|
|
log_log (GPGRT_LOG_BUG, _("you found a bug ... (%s:%d)\n"), file, line);
|
|
abort (); /* Never called; just to make the compiler happy. */
|
|
}
|
|
#endif
|