X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Fjournal%2Fcoredumpctl.c;h=9eaa8979a012995b25851d26bc0d3e8f74af0167;hb=8d4e028f1868c47864ec873d9f30c3ee961a8849;hp=70eaf0e64c98edbae83a16773c1709ce7eab36d0;hpb=9f6445e34a57c270f013c9416c123e56261553dd;p=elogind.git diff --git a/src/journal/coredumpctl.c b/src/journal/coredumpctl.c index 70eaf0e64..9eaa8979a 100644 --- a/src/journal/coredumpctl.c +++ b/src/journal/coredumpctl.c @@ -36,16 +36,18 @@ #include "pager.h" #include "macro.h" #include "journal-internal.h" +#include "copy.h" static enum { ACTION_NONE, + ACTION_INFO, ACTION_LIST, ACTION_DUMP, ACTION_GDB, } arg_action = ACTION_LIST; static FILE* output = NULL; -static char* field = NULL; +static const char* arg_field = NULL; static int arg_no_pager = false; static int arg_no_legend = false; @@ -79,21 +81,22 @@ static Set *new_matches(void) { } static int help(void) { - printf("%s [OPTIONS...] [MATCHES...]\n\n" + + printf("%s [OPTIONS...]\n\n" "List or retrieve coredumps from the journal.\n\n" "Flags:\n" - " -o --output=FILE Write output to FILE\n" - " --no-pager Do not pipe output into a pager\n" - " --no-legend Do not print the column headers.\n\n" + " -o --output=FILE Write output to FILE\n" + " --no-pager Do not pipe output into a pager\n" + " --no-legend Do not print the column headers.\n\n" "Commands:\n" - " -h --help Show this help\n" - " --version Print version string\n" - " -F --field=FIELD List all values a certain field takes\n" - " gdb Start gdb for the first matching coredump\n" - " list List available coredumps\n" - " dump PID Print coredump to stdout\n" - " dump PATH Print coredump to stdout\n" + " -h --help Show this help\n" + " --version Print version string\n" + " -F --field=FIELD List all values a certain field takes\n" + " list [MATCHES...] List available coredumps\n" + " info [MATCHES...] Show detailed information about one or more coredumps\n" + " dump [MATCHES...] Print first matching coredump to stdout\n" + " gdb [MATCHES...] Start gdb for the first matching coredump\n" , program_invocation_short_name); return 0; @@ -126,10 +129,11 @@ static int add_match(Set *set, const char *match) { goto fail; log_debug("Adding pattern: %s", pattern); - r = set_consume(set, pattern); + r = set_put(set, pattern); if (r < 0) { log_error("Failed to add pattern '%s': %s", pattern, strerror(-r)); + free(pattern); goto fail; } @@ -197,12 +201,11 @@ static int parse_argv(int argc, char *argv[], Set *matches) { break; case 'F': - if (field) { + if (arg_field) { log_error("cannot use --field/-F more than once"); return -EINVAL; } - - field = optarg; + arg_field = optarg; break; case '?': @@ -220,13 +223,15 @@ static int parse_argv(int argc, char *argv[], Set *matches) { arg_action = ACTION_DUMP; else if (streq(cmd, "gdb")) arg_action = ACTION_GDB; + else if (streq(cmd, "info")) + arg_action = ACTION_INFO; else { log_error("Unknown action '%s'", cmd); return -EINVAL; } } - if (field && arg_action != ACTION_LIST) { + if (arg_field && arg_action != ACTION_LIST) { log_error("Option --field/-F only makes sense with list"); return -EINVAL; } @@ -244,9 +249,10 @@ static int parse_argv(int argc, char *argv[], Set *matches) { static int retrieve(const void *data, size_t len, const char *name, - const char **var) { + char **var) { size_t ident; + char *v; ident = strlen(name) + 1; /* name + "=" */ @@ -259,50 +265,106 @@ static int retrieve(const void *data, if (((const char*) data)[ident - 1] != '=') return 0; - *var = strndup((const char*)data + ident, len - ident); - if (!*var) + v = strndup((const char*)data + ident, len - ident); + if (!v) return log_oom(); + free(*var); + *var = v; + + return 0; +} + +#define filename_escape(s) xescape((s), "./") + +static int make_coredump_path(sd_journal *j, char **ret) { + _cleanup_free_ char + *pid = NULL, *boot_id = NULL, *tstamp = NULL, *comm = NULL, + *p = NULL, *b = NULL, *t = NULL, *c = NULL; + const void *d; + size_t l; + char *fn; + + assert(j); + assert(ret); + + SD_JOURNAL_FOREACH_DATA(j, d, l) { + retrieve(d, l, "COREDUMP_COMM", &comm); + retrieve(d, l, "COREDUMP_PID", &pid); + retrieve(d, l, "COREDUMP_TIMESTAMP", &tstamp); + retrieve(d, l, "_BOOT_ID", &boot_id); + } + + if (!pid || !comm || !tstamp || !boot_id) { + log_error("Failed to retrieve necessary fields to find coredump on disk."); + return -ENOENT; + } + + p = filename_escape(pid); + if (!p) + return log_oom(); + + t = filename_escape(tstamp); + if (!t) + return log_oom(); + + c = filename_escape(comm); + if (!t) + return log_oom(); + + b = filename_escape(boot_id); + if (!b) + return log_oom(); + + fn = strjoin("/var/lib/systemd/coredump/core.", c, ".", b, ".", p, ".", t, NULL); + if (!fn) + return log_oom(); + + *ret = fn; return 0; } static void print_field(FILE* file, sd_journal *j) { - _cleanup_free_ const char *value = NULL; + _cleanup_free_ char *value = NULL; const void *d; size_t l; - assert(field); + assert(file); + assert(j); + + assert(arg_field); SD_JOURNAL_FOREACH_DATA(j, d, l) - retrieve(d, l, field, &value); + retrieve(d, l, arg_field, &value); + if (value) fprintf(file, "%s\n", value); } -static int print_entry(FILE* file, sd_journal *j, int had_legend) { - _cleanup_free_ const char +static int print_list(FILE* file, sd_journal *j, int had_legend) { + _cleanup_free_ char *pid = NULL, *uid = NULL, *gid = NULL, - *sgnl = NULL, *exe = NULL; + *sgnl = NULL, *exe = NULL, *comm = NULL, *cmdline = NULL; const void *d; size_t l; usec_t t; char buf[FORMAT_TIMESTAMP_MAX]; int r; + assert(file); + assert(j); + SD_JOURNAL_FOREACH_DATA(j, d, l) { - retrieve(d, l, "COREDUMP_PID", &pid); retrieve(d, l, "COREDUMP_PID", &pid); retrieve(d, l, "COREDUMP_UID", &uid); retrieve(d, l, "COREDUMP_GID", &gid); retrieve(d, l, "COREDUMP_SIGNAL", &sgnl); retrieve(d, l, "COREDUMP_EXE", &exe); - if (!exe) - retrieve(d, l, "COREDUMP_COMM", &exe); - if (!exe) - retrieve(d, l, "COREDUMP_CMDLINE", &exe); + retrieve(d, l, "COREDUMP_COMM", &comm); + retrieve(d, l, "COREDUMP_CMDLINE", &cmdline); } - if (!pid && !uid && !gid && !sgnl && !exe) { + if (!pid && !uid && !gid && !sgnl && !exe && !comm && !cmdline) { log_warning("Empty coredump log entry"); return -EINVAL; } @@ -326,11 +388,149 @@ static int print_entry(FILE* file, sd_journal *j, int had_legend) { fprintf(file, "%*s %*s %*s %*s %*s %s\n", FORMAT_TIMESTAMP_MAX-1, buf, - 6, pid, - 5, uid, - 5, gid, - 3, sgnl, - exe); + 6, strna(pid), + 5, strna(uid), + 5, strna(gid), + 3, strna(sgnl), + strna(exe ?: (comm ?: cmdline))); + + return 0; +} + +static int print_info(FILE *file, sd_journal *j, bool need_space) { + _cleanup_free_ char + *pid = NULL, *uid = NULL, *gid = NULL, + *sgnl = NULL, *exe = NULL, *comm = NULL, *cmdline = NULL, + *unit = NULL, *user_unit = NULL, *session = NULL, + *boot_id = NULL, *machine_id = NULL, *hostname = NULL, + *coredump = NULL, *slice = NULL, *cgroup = NULL, + *owner_uid = NULL, *message = NULL; + const void *d; + size_t l; + + assert(file); + assert(j); + + SD_JOURNAL_FOREACH_DATA(j, d, l) { + retrieve(d, l, "COREDUMP_PID", &pid); + retrieve(d, l, "COREDUMP_UID", &uid); + retrieve(d, l, "COREDUMP_GID", &gid); + retrieve(d, l, "COREDUMP_SIGNAL", &sgnl); + retrieve(d, l, "COREDUMP_EXE", &exe); + retrieve(d, l, "COREDUMP_COMM", &comm); + retrieve(d, l, "COREDUMP_CMDLINE", &cmdline); + retrieve(d, l, "COREDUMP_UNIT", &unit); + retrieve(d, l, "COREDUMP_USER_UNIT", &user_unit); + retrieve(d, l, "COREDUMP_SESSION", &session); + retrieve(d, l, "COREDUMP_OWNER_UID", &owner_uid); + retrieve(d, l, "COREDUMP_SLICE", &slice); + retrieve(d, l, "COREDUMP_CGROUP", &cgroup); + retrieve(d, l, "_BOOT_ID", &boot_id); + retrieve(d, l, "_MACHINE_ID", &machine_id); + retrieve(d, l, "_HOSTNAME", &hostname); + retrieve(d, l, "MESSAGE", &message); + } + + if (need_space) + fputs("\n", file); + + fprintf(file, + " PID: %s%s%s\n", + ansi_highlight(), strna(pid), ansi_highlight_off()); + + if (uid) { + uid_t n; + + if (parse_uid(uid, &n) >= 0) { + _cleanup_free_ char *u = NULL; + + u = uid_to_name(n); + fprintf(file, + " UID: %s (%s)\n", + uid, u); + } else { + fprintf(file, + " UID: %s\n", + uid); + } + } + + if (gid) { + gid_t n; + + if (parse_gid(gid, &n) >= 0) { + _cleanup_free_ char *g = NULL; + + g = gid_to_name(n); + fprintf(file, + " GID: %s (%s)\n", + gid, g); + } else { + fprintf(file, + " GID: %s\n", + gid); + } + } + + if (sgnl) { + int sig; + + if (safe_atoi(sgnl, &sig) >= 0) + fprintf(file, " Signal: %s (%s)\n", sgnl, signal_to_string(sig)); + else + fprintf(file, " Signal: %s\n", sgnl); + } + + if (exe) + fprintf(file, " Executable: %s%s%s\n", ansi_highlight(), exe, ansi_highlight_off()); + if (comm) + fprintf(file, " Comm: %s\n", comm); + if (cmdline) + fprintf(file, " Command Line: %s\n", cmdline); + if (cgroup) + fprintf(file, " Control Group: %s\n", cgroup); + if (unit) + fprintf(file, " Unit: %s\n", unit); + if (user_unit) + fprintf(file, " User Unit: %s\n", unit); + if (slice) + fprintf(file, " Slice: %s\n", slice); + if (session) + fprintf(file, " Session: %s\n", session); + if (owner_uid) { + uid_t n; + + if (parse_uid(owner_uid, &n) >= 0) { + _cleanup_free_ char *u = NULL; + + u = uid_to_name(n); + fprintf(file, + " Owner UID: %s (%s)\n", + owner_uid, u); + } else { + fprintf(file, + " Owner UID: %s\n", + owner_uid); + } + } + if (boot_id) + fprintf(file, " Boot ID: %s\n", boot_id); + if (machine_id) + fprintf(file, " Machine ID: %s\n", machine_id); + if (hostname) + fprintf(file, " Hostname: %s\n", hostname); + + if (make_coredump_path(j, &coredump) >= 0) + if (access(coredump, F_OK) >= 0) + fprintf(file, " Coredump: %s\n", coredump); + + if (message) { + _cleanup_free_ char *m = NULL; + + m = strreplace(message, "\n", "\n "); + + fprintf(file, " Message: %s\n", strstrip(m ?: message)); + } return 0; } @@ -346,13 +546,15 @@ static int dump_list(sd_journal *j) { sd_journal_set_data_threshold(j, 4096); SD_JOURNAL_FOREACH(j) { - if (field) + if (arg_action == ACTION_INFO) + print_info(stdout, j, found++); + else if (arg_field) print_field(stdout, j); else - print_entry(stdout, j, found++); + print_list(stdout, j, found++); } - if (!field && !found) { + if (!arg_field && !found) { log_notice("No coredumps found"); return -ESRCH; } @@ -391,27 +593,52 @@ static int dump_core(sd_journal* j) { if (r < 0) return r; - print_entry(output ? stdout : stderr, j, false); + print_info(output ? stdout : stderr, j, false); if (on_tty() && !output) { - log_error("Refusing to dump core to tty"); + log_error("Refusing to dump core to tty."); return -ENOTTY; } r = sd_journal_get_data(j, "COREDUMP", (const void**) &data, &len); - if (r < 0) { + if (r == ENOENT) { + _cleanup_free_ char *fn = NULL; + _cleanup_close_ int fd = -1; + + r = make_coredump_path(j, &fn); + if (r < 0) + return r; + + fd = open(fn, O_RDONLY|O_CLOEXEC|O_NOCTTY); + if (fd < 0) { + if (errno == ENOENT) + log_error("Coredump neither in journal file nor stored externally on disk."); + else + log_error("Failed to open coredump file: %s", strerror(-r)); + + return -errno; + } + + r = copy_bytes(fd, output ? fileno(output) : STDOUT_FILENO); + if (r < 0) { + log_error("Failed to stream coredump: %s", strerror(-r)); + return r; + } + + } else if (r < 0) { log_error("Failed to retrieve COREDUMP field: %s", strerror(-r)); return r; - } - assert(len >= 9); - data = (const uint8_t*) data + 9; - len -= 9; + } else { + assert(len >= 9); + data = (const uint8_t*) data + 9; + len -= 9; - ret = fwrite(data, len, 1, output ? output : stdout); - if (ret != 1) { - log_error("dumping coredump: %m (%zu)", ret); - return -errno; + ret = fwrite(data, len, 1, output ?: stdout); + if (ret != 1) { + log_error("Dumping coredump failed: %m (%zu)", ret); + return -errno; + } } r = sd_journal_previous(j); @@ -422,15 +649,16 @@ static int dump_core(sd_journal* j) { } static int run_gdb(sd_journal *j) { - char path[] = "/var/tmp/coredump-XXXXXX"; + + _cleanup_free_ char *exe = NULL, *coredump = NULL; + char temp[] = "/var/tmp/coredump-XXXXXX"; + bool unlink_temp = false; + const char *path; const void *data; + siginfo_t st; size_t len; - ssize_t sz; pid_t pid; - _cleanup_free_ char *exe = NULL; int r; - _cleanup_close_ int fd = -1; - siginfo_t st; assert(j); @@ -440,7 +668,8 @@ static int run_gdb(sd_journal *j) { if (r < 0) return r; - print_entry(stdout, j, false); + print_info(stdout, j, false); + fputs("\n", stdout); r = sd_journal_get_data(j, "COREDUMP_EXE", (const void**) &data, &len); if (r < 0) { @@ -461,36 +690,63 @@ static int run_gdb(sd_journal *j) { return -ENOENT; } + if (!path_is_absolute(exe)) { + log_error("Binary is not an absolute path."); + return -ENOENT; + } + r = sd_journal_get_data(j, "COREDUMP", (const void**) &data, &len); - if (r < 0) { + if (r == -ENOENT) { + + r = make_coredump_path(j, &coredump); + if (r < 0) + return r; + + if (access(coredump, R_OK) < 0) { + if (errno == ENOENT) + log_error("Coredump neither in journal file nor stored externally on disk."); + else + log_error("Failed to access coredump file: %m"); + + return -errno; + } + + path = coredump; + + } else if (r < 0) { log_error("Failed to retrieve COREDUMP field: %s", strerror(-r)); return r; - } - assert(len >= 9); - data = (const uint8_t*) data + 9; - len -= 9; + } else { + _cleanup_close_ int fd = -1; + ssize_t sz; - fd = mkostemp(path, O_WRONLY); - if (fd < 0) { - log_error("Failed to create temporary file: %m"); - return -errno; - } + assert(len >= 9); + data = (const uint8_t*) data + 9; + len -= 9; - sz = write(fd, data, len); - if (sz < 0) { - log_error("Failed to write temporary file: %m"); - r = -errno; - goto finish; - } - if (sz != (ssize_t) len) { - log_error("Short write to temporary file."); - r = -EIO; - goto finish; - } + fd = mkostemp_safe(temp, O_WRONLY|O_CLOEXEC); + if (fd < 0) { + log_error("Failed to create temporary file: %m"); + return -errno; + } - close_nointr_nofail(fd); - fd = -1; + unlink_temp = true; + + sz = write(fd, data, len); + if (sz < 0) { + log_error("Failed to write temporary file: %m"); + r = -errno; + goto finish; + } + if (sz != (ssize_t) len) { + log_error("Short write to temporary file."); + r = -EIO; + goto finish; + } + + path = temp; + } pid = fork(); if (pid < 0) { @@ -500,6 +756,7 @@ static int run_gdb(sd_journal *j) { } if (pid == 0) { execlp("gdb", "gdb", exe, path, NULL); + log_error("Failed to invoke gdb: %m"); _exit(1); } @@ -513,7 +770,9 @@ static int run_gdb(sd_journal *j) { r = st.si_code == CLD_EXITED ? st.si_status : 255; finish: - unlink(path); + if (unlink_temp) + unlink(temp); + return r; } @@ -566,6 +825,7 @@ int main(int argc, char *argv[]) { switch(arg_action) { case ACTION_LIST: + case ACTION_INFO: if (!arg_no_pager) pager_open(false);