summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLennart Poettering <lennart@poettering.net>2014-06-27 19:32:14 +0200
committerLennart Poettering <lennart@poettering.net>2014-06-27 19:35:57 +0200
commitb59233e6a3b30c0529d1649c8f7e69790733787d (patch)
treeb35f98de62e758ebd41c9ac8108d8279d2dc66b1
parent8c9571d0ae50656f730a5e37378d5c3dcf3b9789 (diff)
coredump: simplify compression logic a bit
This also make sure we remove the original coredump temporary file if we successfully managed to compress the coredump.
-rw-r--r--src/journal/coredump.c147
1 files changed, 89 insertions, 58 deletions
diff --git a/src/journal/coredump.c b/src/journal/coredump.c
index 0dae0afe01..78e89d33cf 100644
--- a/src/journal/coredump.c
+++ b/src/journal/coredump.c
@@ -139,6 +139,8 @@ static int fix_acl(int fd, uid_t uid) {
acl_entry_t entry;
acl_permset_t permset;
+ assert(fd >= 0);
+
if (uid <= SYSTEM_UID_MAX)
return 0;
@@ -189,6 +191,8 @@ static int fix_xattr(int fd, const char *info[_INFO_LEN]) {
int r = 0;
unsigned i;
+ assert(fd >= 0);
+
/* Attach some metadata to coredumps via extended
* attributes. Just because we can. */
@@ -208,8 +212,17 @@ static int fix_xattr(int fd, const char *info[_INFO_LEN]) {
#define filename_escape(s) xescape((s), "./ ")
-static int fix_permissions(int fd, const char *filename, const char *target,
- const char *info[_INFO_LEN], uid_t uid) {
+static int fix_permissions(
+ int fd,
+ const char *filename,
+ const char *target,
+ const char *info[_INFO_LEN],
+ uid_t uid) {
+
+ assert(fd >= 0);
+ assert(filename);
+ assert(target);
+ assert(info);
/* Ignore errors on these */
fchmod(fd, 0640);
@@ -231,7 +244,7 @@ static int fix_permissions(int fd, const char *filename, const char *target,
static int maybe_remove_external_coredump(const char *filename, off_t size) {
- /* Returns 1 if might remove, 0 if will not remove, <0 on error. */
+ /* Returns 1 if might remove, 0 if will not remove, < 0 on error. */
if (IN_SET(arg_storage, COREDUMP_STORAGE_EXTERNAL, COREDUMP_STORAGE_BOTH) &&
size <= arg_external_size_max)
@@ -248,55 +261,67 @@ static int maybe_remove_external_coredump(const char *filename, off_t size) {
return 1;
}
-static int save_external_coredump(
- const char *info[_INFO_LEN],
- uid_t uid,
- char **ret_filename,
- int *ret_fd,
- off_t *ret_size) {
-
- _cleanup_free_ char *p = NULL, *t = NULL, *c = NULL, *fn = NULL, *tmp = NULL, *u = NULL;
- _cleanup_close_ int fd = -1;
+static int make_filename(const char *info[_INFO_LEN], char **ret) {
+ _cleanup_free_ char *c = NULL, *u = NULL, *p = NULL, *t = NULL;
sd_id128_t boot;
- struct stat st;
int r;
assert(info);
- assert(ret_filename);
- assert(ret_fd);
- assert(ret_size);
c = filename_escape(info[INFO_COMM]);
if (!c)
- return log_oom();
-
- p = filename_escape(info[INFO_PID]);
- if (!p)
- return log_oom();
+ return -ENOMEM;
u = filename_escape(info[INFO_UID]);
if (!u)
- return log_oom();
-
- t = filename_escape(info[INFO_TIMESTAMP]);
- if (!t)
- return log_oom();
+ return -ENOMEM;
r = sd_id128_get_boot(&boot);
- if (r < 0) {
- log_error("Failed to determine boot ID: %s", strerror(-r));
+ if (r < 0)
return r;
- }
- r = asprintf(&fn,
+ p = filename_escape(info[INFO_PID]);
+ if (!p)
+ return -ENOMEM;
+
+ t = filename_escape(info[INFO_TIMESTAMP]);
+ if (!t)
+ return -ENOMEM;
+
+ if (asprintf(ret,
"/var/lib/systemd/coredump/core.%s.%s." SD_ID128_FORMAT_STR ".%s.%s000000",
c,
u,
SD_ID128_FORMAT_VAL(boot),
p,
- t);
- if (r < 0)
- return log_oom();
+ t) < 0)
+ return -ENOMEM;
+
+ return 0;
+}
+
+static int save_external_coredump(
+ const char *info[_INFO_LEN],
+ uid_t uid,
+ char **ret_filename,
+ int *ret_fd,
+ off_t *ret_size) {
+
+ _cleanup_free_ char *fn = NULL, *tmp = NULL;
+ _cleanup_close_ int fd = -1;
+ struct stat st;
+ int r;
+
+ assert(info);
+ assert(ret_filename);
+ assert(ret_fd);
+ assert(ret_size);
+
+ r = make_filename(info, &fn);
+ if (r < 0) {
+ log_error("Failed to determine coredump file name: %s", strerror(-r));
+ return r;
+ }
tmp = tempfn_random(fn);
if (!tmp)
@@ -329,7 +354,7 @@ static int save_external_coredump(
if (lseek(fd, 0, SEEK_SET) == (off_t) -1) {
log_error("Failed to seek on %s: %m", tmp);
- goto uncompressed;
+ goto fail;
}
#ifdef HAVE_XZ
@@ -337,45 +362,51 @@ static int save_external_coredump(
if (maybe_remove_external_coredump(NULL, st.st_size) == 0
&& arg_compress) {
- _cleanup_free_ char *fn2 = NULL;
- char *tmp2;
- _cleanup_close_ int fd2 = -1;
+ _cleanup_free_ char *fn_compressed = NULL, *tmp_compressed = NULL;
+ _cleanup_close_ int fd_compressed = -1;
- tmp2 = strappenda(tmp, ".xz");
- fd2 = open(tmp2, O_CREAT|O_EXCL|O_RDWR|O_CLOEXEC|O_NOCTTY|O_NOFOLLOW, 0640);
- if (fd2 < 0) {
- log_error("Failed to create file %s: %m", tmp2);
+ fn_compressed = strappend(fn, ".xz");
+ if (!fn_compressed) {
+ r = log_oom();
goto uncompressed;
}
- r = compress_stream(fd, fd2, LZMA_PRESET_DEFAULT, -1);
- if (r < 0) {
- log_error("Failed to compress %s: %s", tmp2, strerror(-r));
- unlink_noerrno(tmp2);
- goto fail2;
+ tmp_compressed = tempfn_random(fn_compressed);
+ if (!tmp_compressed) {
+ r = log_oom();
+ goto uncompressed;
}
- fn2 = strappend(fn, ".xz");
- if (!fn2) {
- log_oom();
- goto fail2;
+ fd_compressed = open(tmp_compressed, O_CREAT|O_EXCL|O_RDWR|O_CLOEXEC|O_NOCTTY|O_NOFOLLOW, 0640);
+ if (fd_compressed < 0) {
+ log_error("Failed to create file %s: %m", tmp_compressed);
+ goto uncompressed;
}
- r = fix_permissions(fd2, tmp2, fn2, info, uid);
+ r = compress_stream(fd, fd_compressed, LZMA_PRESET_DEFAULT, -1);
+ if (r < 0) {
+ log_error("Failed to compress %s: %s", tmp_compressed, strerror(-r));
+ goto fail_compressed;
+ }
+
+ r = fix_permissions(fd_compressed, tmp_compressed, fn_compressed, info, uid);
if (r < 0)
- goto fail2;
+ goto fail_compressed;
+
+ /* OK, this worked, we can get rid of the uncompressed version now */
+ unlink_noerrno(tmp);
- *ret_filename = fn2; /* compressed */
- *ret_fd = fd; /* uncompressed */
- *ret_size = st.st_size; /* uncompressed */
+ *ret_filename = fn_compressed; /* compressed */
+ *ret_fd = fd; /* uncompressed */
+ *ret_size = st.st_size; /* uncompressed */
- fn2 = NULL;
+ fn_compressed = NULL;
fd = -1;
return 0;
- fail2:
- unlink_noerrno(tmp2);
+ fail_compressed:
+ unlink_noerrno(tmp_compressed);
}
#endif