diff options
Diffstat (limited to 'lib/dpkg/log.c')
-rw-r--r-- | lib/dpkg/log.c | 116 |
1 files changed, 116 insertions, 0 deletions
diff --git a/lib/dpkg/log.c b/lib/dpkg/log.c new file mode 100644 index 0000000..c2221c8 --- /dev/null +++ b/lib/dpkg/log.c @@ -0,0 +1,116 @@ +/* + * libdpkg - Debian packaging suite library routines + * log.c - logging related functions + * + * Copyright © 2005 Scott James Remnant <scott@netsplit.com> + * + * This is free software; you can redistribute it and/or modify + * it under the terms of 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. + * + * This 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 copy of the GNU General Public License + * along with this program. If not, see <https://www.gnu.org/licenses/>. + */ + +#include <config.h> +#include <compat.h> + +#include <errno.h> +#include <time.h> +#include <unistd.h> +#include <stdarg.h> +#include <stdio.h> + +#include <dpkg/i18n.h> +#include <dpkg/dpkg.h> +#include <dpkg/dpkg-db.h> +#include <dpkg/fdio.h> + +const char *log_file = NULL; + +void +log_message(const char *fmt, ...) +{ + static struct varbuf log; + static FILE *logfd = NULL; + char time_str[20]; + time_t now; + va_list args; + + if (!log_file) + return; + + if (!logfd) { + logfd = fopen(log_file, "a"); + if (!logfd) { + notice(_("could not open log '%s': %s"), + log_file, strerror(errno)); + log_file = NULL; + return; + } + setlinebuf(logfd); + setcloexec(fileno(logfd), log_file); + } + + va_start(args, fmt); + varbuf_reset(&log); + varbuf_vprintf(&log, fmt, args); + va_end(args); + + time(&now); + strftime(time_str, sizeof(time_str), "%Y-%m-%d %H:%M:%S", + localtime(&now)); + fprintf(logfd, "%s %s\n", time_str, log.buf); +} + +struct pipef { + struct pipef *next; + int fd; +}; + +static struct pipef *status_pipes = NULL; + +void +statusfd_add(int fd) +{ + struct pipef *pipe_new; + + setcloexec(fd, _("<package status and progress file descriptor>")); + + pipe_new = nfmalloc(sizeof(*pipe_new)); + pipe_new->fd = fd; + pipe_new->next = status_pipes; + status_pipes = pipe_new; +} + +void +statusfd_send(const char *fmt, ...) +{ + static struct varbuf vb; + struct pipef *pipef; + va_list args; + + if (!status_pipes) + return; + + va_start(args, fmt); + varbuf_reset(&vb); + varbuf_vprintf(&vb, fmt, args); + /* Sanitize string to not include new lines, as front-ends should be + * doing their own word-wrapping. */ + varbuf_map_char(&vb, '\n', ' '); + varbuf_add_char(&vb, '\n'); + va_end(args); + + for (pipef = status_pipes; pipef; pipef = pipef->next) { + if (fd_write(pipef->fd, vb.buf, vb.used) < 0) + ohshite(_("unable to write to status fd %d"), + pipef->fd); + } +} |