File: | build-scan/../src/coredump/coredumpctl.c |
Warning: | line 380, column 24 Potential leak of memory pointed to by 'exe' |
Press '?' to see keyboard shortcuts
Keyboard shortcuts:
1 | /* SPDX-License-Identifier: LGPL-2.1+ */ | ||||||||||
2 | |||||||||||
3 | #include <fcntl.h> | ||||||||||
4 | #include <getopt.h> | ||||||||||
5 | #include <locale.h> | ||||||||||
6 | #include <stdio.h> | ||||||||||
7 | #include <string.h> | ||||||||||
8 | #include <unistd.h> | ||||||||||
9 | |||||||||||
10 | #include "sd-bus.h" | ||||||||||
11 | #include "sd-journal.h" | ||||||||||
12 | #include "sd-messages.h" | ||||||||||
13 | |||||||||||
14 | #include "alloc-util.h" | ||||||||||
15 | #include "bus-error.h" | ||||||||||
16 | #include "bus-util.h" | ||||||||||
17 | #include "compress.h" | ||||||||||
18 | #include "fd-util.h" | ||||||||||
19 | #include "fileio.h" | ||||||||||
20 | #include "fs-util.h" | ||||||||||
21 | #include "journal-internal.h" | ||||||||||
22 | #include "journal-util.h" | ||||||||||
23 | #include "log.h" | ||||||||||
24 | #include "macro.h" | ||||||||||
25 | #include "pager.h" | ||||||||||
26 | #include "parse-util.h" | ||||||||||
27 | #include "path-util.h" | ||||||||||
28 | #include "process-util.h" | ||||||||||
29 | #include "sigbus.h" | ||||||||||
30 | #include "signal-util.h" | ||||||||||
31 | #include "string-util.h" | ||||||||||
32 | #include "strv.h" | ||||||||||
33 | #include "terminal-util.h" | ||||||||||
34 | #include "user-util.h" | ||||||||||
35 | #include "util.h" | ||||||||||
36 | #include "verbs.h" | ||||||||||
37 | |||||||||||
38 | #define SHORT_BUS_CALL_TIMEOUT_USEC(3 * ((usec_t) 1000000ULL)) (3 * USEC_PER_SEC((usec_t) 1000000ULL)) | ||||||||||
39 | |||||||||||
40 | static usec_t arg_since = USEC_INFINITY((usec_t) -1), arg_until = USEC_INFINITY((usec_t) -1); | ||||||||||
41 | static const char* arg_field = NULL((void*)0); | ||||||||||
42 | static const char *arg_debugger = NULL((void*)0); | ||||||||||
43 | static const char *arg_directory = NULL((void*)0); | ||||||||||
44 | static bool_Bool arg_no_pager = false0; | ||||||||||
45 | static int arg_no_legend = false0; | ||||||||||
46 | static int arg_one = false0; | ||||||||||
47 | static FILE* arg_output = NULL((void*)0); | ||||||||||
48 | static bool_Bool arg_reverse = false0; | ||||||||||
49 | static bool_Bool arg_quiet = false0; | ||||||||||
50 | |||||||||||
51 | static int add_match(sd_journal *j, const char *match) { | ||||||||||
52 | _cleanup_free___attribute__((cleanup(freep))) char *p = NULL((void*)0); | ||||||||||
53 | const char* prefix, *pattern; | ||||||||||
54 | pid_t pid; | ||||||||||
55 | int r; | ||||||||||
56 | |||||||||||
57 | if (strchr(match, '=')) | ||||||||||
58 | prefix = ""; | ||||||||||
59 | else if (strchr(match, '/')) { | ||||||||||
60 | r = path_make_absolute_cwd(match, &p); | ||||||||||
61 | if (r < 0) | ||||||||||
62 | return log_error_errno(r, "path_make_absolute_cwd(\"%s\"): %m", match)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 62, __func__, "path_make_absolute_cwd(\"%s\"): %m" , match) : -abs(_e); }); | ||||||||||
63 | |||||||||||
64 | match = p; | ||||||||||
65 | prefix = "COREDUMP_EXE="; | ||||||||||
66 | } else if (parse_pid(match, &pid) >= 0) | ||||||||||
67 | prefix = "COREDUMP_PID="; | ||||||||||
68 | else | ||||||||||
69 | prefix = "COREDUMP_COMM="; | ||||||||||
70 | |||||||||||
71 | pattern = strjoina(prefix, match)({ const char *_appendees_[] = { prefix, match }; char *_d_, * _p_; size_t _len_ = 0; size_t _i_; for (_i_ = 0; _i_ < __extension__ (__builtin_choose_expr( !__builtin_types_compatible_p(typeof (_appendees_), typeof(&*(_appendees_))), sizeof(_appendees_ )/sizeof((_appendees_)[0]), ((void)0))) && _appendees_ [_i_]; _i_++) _len_ += strlen(_appendees_[_i_]); _p_ = _d_ = __builtin_alloca (_len_ + 1); for (_i_ = 0; _i_ < __extension__ (__builtin_choose_expr ( !__builtin_types_compatible_p(typeof(_appendees_), typeof(& *(_appendees_))), sizeof(_appendees_)/sizeof((_appendees_)[0] ), ((void)0))) && _appendees_[_i_]; _i_++) _p_ = stpcpy (_p_, _appendees_[_i_]); *_p_ = 0; _d_; }); | ||||||||||
72 | log_debug("Adding match: %s", pattern)({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 72, __func__, "Adding match: %s" , pattern) : -abs(_e); }); | ||||||||||
73 | r = sd_journal_add_match(j, pattern, 0); | ||||||||||
74 | if (r < 0) | ||||||||||
75 | return log_error_errno(r, "Failed to add match \"%s\": %m", match)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 75, __func__, "Failed to add match \"%s\": %m" , match) : -abs(_e); }); | ||||||||||
76 | |||||||||||
77 | return 0; | ||||||||||
78 | } | ||||||||||
79 | |||||||||||
80 | static int add_matches(sd_journal *j, char **matches) { | ||||||||||
81 | char **match; | ||||||||||
82 | int r; | ||||||||||
83 | |||||||||||
84 | r = sd_journal_add_match(j, "MESSAGE_ID=" SD_MESSAGE_COREDUMP_STR"fc" "2e" "22" "bc" "6e" "e6" "47" "b6" "b9" "07" "29" "ab" "34" "a2" "50" "b1", 0); | ||||||||||
85 | if (r < 0) | ||||||||||
86 | return log_error_errno(r, "Failed to add match \"%s\": %m", "MESSAGE_ID=" SD_MESSAGE_COREDUMP_STR)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 86, __func__, "Failed to add match \"%s\": %m" , "MESSAGE_ID=" "fc" "2e" "22" "bc" "6e" "e6" "47" "b6" "b9" "07" "29" "ab" "34" "a2" "50" "b1") : -abs(_e); }); | ||||||||||
87 | |||||||||||
88 | r = sd_journal_add_match(j, "MESSAGE_ID=" SD_MESSAGE_BACKTRACE_STR"1f" "4e" "0a" "44" "a8" "86" "49" "93" "9a" "ae" "a3" "4f" "c6" "da" "8c" "95", 0); | ||||||||||
89 | if (r < 0) | ||||||||||
90 | return log_error_errno(r, "Failed to add match \"%s\": %m", "MESSAGE_ID=" SD_MESSAGE_BACKTRACE_STR)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 90, __func__, "Failed to add match \"%s\": %m" , "MESSAGE_ID=" "1f" "4e" "0a" "44" "a8" "86" "49" "93" "9a" "ae" "a3" "4f" "c6" "da" "8c" "95") : -abs(_e); }); | ||||||||||
91 | |||||||||||
92 | STRV_FOREACH(match, matches)for ((match) = (matches); (match) && *(match); (match )++) { | ||||||||||
93 | r = add_match(j, *match); | ||||||||||
94 | if (r < 0) | ||||||||||
95 | return r; | ||||||||||
96 | } | ||||||||||
97 | |||||||||||
98 | return 0; | ||||||||||
99 | } | ||||||||||
100 | |||||||||||
101 | static int acquire_journal(sd_journal **ret, char **matches) { | ||||||||||
102 | _cleanup_(sd_journal_closep)__attribute__((cleanup(sd_journal_closep))) sd_journal *j = NULL((void*)0); | ||||||||||
103 | int r; | ||||||||||
104 | |||||||||||
105 | assert(ret)do { if ((__builtin_expect(!!(!(ret)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("ret"), "../src/coredump/coredumpctl.c", 105, __PRETTY_FUNCTION__); } while (0); | ||||||||||
106 | |||||||||||
107 | if (arg_directory) { | ||||||||||
108 | r = sd_journal_open_directory(&j, arg_directory, 0); | ||||||||||
109 | if (r < 0) | ||||||||||
110 | return log_error_errno(r, "Failed to open journals in directory: %s: %m", arg_directory)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 110, __func__, "Failed to open journals in directory: %s: %m" , arg_directory) : -abs(_e); }); | ||||||||||
111 | } else { | ||||||||||
112 | r = sd_journal_open(&j, SD_JOURNAL_LOCAL_ONLY); | ||||||||||
113 | if (r < 0) | ||||||||||
114 | return log_error_errno(r, "Failed to open journal: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 114, __func__, "Failed to open journal: %m" ) : -abs(_e); }); | ||||||||||
115 | } | ||||||||||
116 | |||||||||||
117 | r = journal_access_check_and_warn(j, arg_quiet, true1); | ||||||||||
118 | if (r < 0) | ||||||||||
119 | return r; | ||||||||||
120 | |||||||||||
121 | r = add_matches(j, matches); | ||||||||||
122 | if (r < 0) | ||||||||||
123 | return r; | ||||||||||
124 | |||||||||||
125 | if (DEBUG_LOGGING(__builtin_expect(!!(log_get_max_level_realm(LOG_REALM_SYSTEMD ) >= 7),0))) { | ||||||||||
126 | _cleanup_free___attribute__((cleanup(freep))) char *filter; | ||||||||||
127 | |||||||||||
128 | filter = journal_make_match_string(j); | ||||||||||
129 | log_debug("Journal filter: %s", filter)({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 129, __func__, "Journal filter: %s" , filter) : -abs(_e); }); | ||||||||||
130 | } | ||||||||||
131 | |||||||||||
132 | *ret = TAKE_PTR(j)({ typeof(j) _ptr_ = (j); (j) = ((void*)0); _ptr_; }); | ||||||||||
133 | |||||||||||
134 | return 0; | ||||||||||
135 | } | ||||||||||
136 | |||||||||||
137 | static int help(void) { | ||||||||||
138 | printf("%s [OPTIONS...]\n\n" | ||||||||||
139 | "List or retrieve coredumps from the journal.\n\n" | ||||||||||
140 | "Flags:\n" | ||||||||||
141 | " -h --help Show this help\n" | ||||||||||
142 | " --version Print version string\n" | ||||||||||
143 | " --no-pager Do not pipe output into a pager\n" | ||||||||||
144 | " --no-legend Do not print the column headers\n" | ||||||||||
145 | " --debugger=DEBUGGER Use the given debugger\n" | ||||||||||
146 | " -1 Show information about most recent entry only\n" | ||||||||||
147 | " -S --since=DATE Only print coredumps since the date\n" | ||||||||||
148 | " -U --until=DATE Only print coredumps until the date\n" | ||||||||||
149 | " -r --reverse Show the newest entries first\n" | ||||||||||
150 | " -F --field=FIELD List all values a certain field takes\n" | ||||||||||
151 | " -o --output=FILE Write output to FILE\n" | ||||||||||
152 | " -D --directory=DIR Use journal files from directory\n\n" | ||||||||||
153 | " -q --quiet Do not show info messages and privilege warning\n" | ||||||||||
154 | "Commands:\n" | ||||||||||
155 | " list [MATCHES...] List available coredumps (default)\n" | ||||||||||
156 | " info [MATCHES...] Show detailed information about one or more coredumps\n" | ||||||||||
157 | " dump [MATCHES...] Print first matching coredump to stdout\n" | ||||||||||
158 | " debug [MATCHES...] Start a debugger for the first matching coredump\n" | ||||||||||
159 | , program_invocation_short_name); | ||||||||||
160 | |||||||||||
161 | return 0; | ||||||||||
162 | } | ||||||||||
163 | |||||||||||
164 | static int parse_argv(int argc, char *argv[]) { | ||||||||||
165 | enum { | ||||||||||
166 | ARG_VERSION = 0x100, | ||||||||||
167 | ARG_NO_PAGER, | ||||||||||
168 | ARG_NO_LEGEND, | ||||||||||
169 | ARG_DEBUGGER, | ||||||||||
170 | }; | ||||||||||
171 | |||||||||||
172 | int c, r; | ||||||||||
173 | |||||||||||
174 | static const struct option options[] = { | ||||||||||
175 | { "help", no_argument0, NULL((void*)0), 'h' }, | ||||||||||
176 | { "version" , no_argument0, NULL((void*)0), ARG_VERSION }, | ||||||||||
177 | { "no-pager", no_argument0, NULL((void*)0), ARG_NO_PAGER }, | ||||||||||
178 | { "no-legend", no_argument0, NULL((void*)0), ARG_NO_LEGEND }, | ||||||||||
179 | { "debugger", required_argument1, NULL((void*)0), ARG_DEBUGGER }, | ||||||||||
180 | { "output", required_argument1, NULL((void*)0), 'o' }, | ||||||||||
181 | { "field", required_argument1, NULL((void*)0), 'F' }, | ||||||||||
182 | { "directory", required_argument1, NULL((void*)0), 'D' }, | ||||||||||
183 | { "reverse", no_argument0, NULL((void*)0), 'r' }, | ||||||||||
184 | { "since", required_argument1, NULL((void*)0), 'S' }, | ||||||||||
185 | { "until", required_argument1, NULL((void*)0), 'U' }, | ||||||||||
186 | { "quiet", no_argument0, NULL((void*)0), 'q' }, | ||||||||||
187 | {} | ||||||||||
188 | }; | ||||||||||
189 | |||||||||||
190 | assert(argc >= 0)do { if ((__builtin_expect(!!(!(argc >= 0)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("argc >= 0"), "../src/coredump/coredumpctl.c" , 190, __PRETTY_FUNCTION__); } while (0); | ||||||||||
191 | assert(argv)do { if ((__builtin_expect(!!(!(argv)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("argv"), "../src/coredump/coredumpctl.c" , 191, __PRETTY_FUNCTION__); } while (0); | ||||||||||
192 | |||||||||||
193 | while ((c = getopt_long(argc, argv, "ho:F:1D:rS:U:q", options, NULL((void*)0))) >= 0) | ||||||||||
194 | switch(c) { | ||||||||||
195 | case 'h': | ||||||||||
196 | return help(); | ||||||||||
197 | |||||||||||
198 | case ARG_VERSION: | ||||||||||
199 | return version(); | ||||||||||
200 | |||||||||||
201 | case ARG_NO_PAGER: | ||||||||||
202 | arg_no_pager = true1; | ||||||||||
203 | break; | ||||||||||
204 | |||||||||||
205 | case ARG_NO_LEGEND: | ||||||||||
206 | arg_no_legend = true1; | ||||||||||
207 | break; | ||||||||||
208 | |||||||||||
209 | case ARG_DEBUGGER: | ||||||||||
210 | arg_debugger = optarg; | ||||||||||
211 | break; | ||||||||||
212 | |||||||||||
213 | case 'o': | ||||||||||
214 | if (arg_output) { | ||||||||||
215 | log_error("Cannot set output more than once.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 215, __func__, "Cannot set output more than once." ) : -abs(_e); }); | ||||||||||
216 | return -EINVAL22; | ||||||||||
217 | } | ||||||||||
218 | |||||||||||
219 | arg_output = fopen(optarg, "we"); | ||||||||||
220 | if (!arg_output) | ||||||||||
221 | return log_error_errno(errno, "writing to '%s': %m", optarg)({ int _level = ((3)), _e = (((*__errno_location ()))), _realm = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >= ((_level) & 0x07)) ? log_internal_realm(((_realm) << 10 | (_level)), _e, "../src/coredump/coredumpctl.c", 221, __func__ , "writing to '%s': %m", optarg) : -abs(_e); }); | ||||||||||
222 | |||||||||||
223 | break; | ||||||||||
224 | |||||||||||
225 | case 'S': | ||||||||||
226 | r = parse_timestamp(optarg, &arg_since); | ||||||||||
227 | if (r < 0) | ||||||||||
228 | return log_error_errno(r, "Failed to parse timestamp: %s", optarg)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 228, __func__, "Failed to parse timestamp: %s" , optarg) : -abs(_e); }); | ||||||||||
229 | break; | ||||||||||
230 | |||||||||||
231 | case 'U': | ||||||||||
232 | r = parse_timestamp(optarg, &arg_until); | ||||||||||
233 | if (r < 0) | ||||||||||
234 | return log_error_errno(r, "Failed to parse timestamp: %s", optarg)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 234, __func__, "Failed to parse timestamp: %s" , optarg) : -abs(_e); }); | ||||||||||
235 | break; | ||||||||||
236 | |||||||||||
237 | case 'F': | ||||||||||
238 | if (arg_field) { | ||||||||||
239 | log_error("Cannot use --field/-F more than once.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 239, __func__, "Cannot use --field/-F more than once." ) : -abs(_e); }); | ||||||||||
240 | return -EINVAL22; | ||||||||||
241 | } | ||||||||||
242 | arg_field = optarg; | ||||||||||
243 | break; | ||||||||||
244 | |||||||||||
245 | case '1': | ||||||||||
246 | arg_one = true1; | ||||||||||
247 | break; | ||||||||||
248 | |||||||||||
249 | case 'D': | ||||||||||
250 | arg_directory = optarg; | ||||||||||
251 | break; | ||||||||||
252 | |||||||||||
253 | case 'r': | ||||||||||
254 | arg_reverse = true1; | ||||||||||
255 | break; | ||||||||||
256 | |||||||||||
257 | case 'q': | ||||||||||
258 | arg_quiet = true1; | ||||||||||
259 | break; | ||||||||||
260 | |||||||||||
261 | case '?': | ||||||||||
262 | return -EINVAL22; | ||||||||||
263 | |||||||||||
264 | default: | ||||||||||
265 | assert_not_reached("Unhandled option")do { log_assert_failed_unreachable_realm(LOG_REALM_SYSTEMD, ( "Unhandled option"), "../src/coredump/coredumpctl.c", 265, __PRETTY_FUNCTION__ ); } while (0); | ||||||||||
266 | } | ||||||||||
267 | |||||||||||
268 | if (arg_since != USEC_INFINITY((usec_t) -1) && arg_until != USEC_INFINITY((usec_t) -1) && | ||||||||||
269 | arg_since > arg_until) { | ||||||||||
270 | log_error("--since= must be before --until=.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 270, __func__, "--since= must be before --until=." ) : -abs(_e); }); | ||||||||||
271 | return -EINVAL22; | ||||||||||
272 | } | ||||||||||
273 | |||||||||||
274 | return 1; | ||||||||||
275 | } | ||||||||||
276 | |||||||||||
277 | static int retrieve(const void *data, | ||||||||||
278 | size_t len, | ||||||||||
279 | const char *name, | ||||||||||
280 | char **var) { | ||||||||||
281 | |||||||||||
282 | size_t ident; | ||||||||||
283 | char *v; | ||||||||||
284 | |||||||||||
285 | ident = strlen(name) + 1; /* name + "=" */ | ||||||||||
286 | |||||||||||
287 | if (len
| ||||||||||
288 | return 0; | ||||||||||
289 | |||||||||||
290 | if (memcmp(data, name, ident - 1) != 0) | ||||||||||
291 | return 0; | ||||||||||
292 | |||||||||||
293 | if (((const char*) data)[ident - 1] != '=') | ||||||||||
294 | return 0; | ||||||||||
295 | |||||||||||
296 | v = strndup((const char*)data + ident, len - ident); | ||||||||||
297 | if (!v) | ||||||||||
298 | return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/coredump/coredumpctl.c" , 298, __func__); | ||||||||||
299 | |||||||||||
300 | free(*var); | ||||||||||
301 | *var = v; | ||||||||||
302 | |||||||||||
303 | return 1; | ||||||||||
304 | } | ||||||||||
305 | |||||||||||
306 | static int print_field(FILE* file, sd_journal *j) { | ||||||||||
307 | const void *d; | ||||||||||
308 | size_t l; | ||||||||||
309 | |||||||||||
310 | assert(file)do { if ((__builtin_expect(!!(!(file)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("file"), "../src/coredump/coredumpctl.c" , 310, __PRETTY_FUNCTION__); } while (0); | ||||||||||
311 | assert(j)do { if ((__builtin_expect(!!(!(j)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("j"), "../src/coredump/coredumpctl.c", 311 , __PRETTY_FUNCTION__); } while (0); | ||||||||||
312 | |||||||||||
313 | assert(arg_field)do { if ((__builtin_expect(!!(!(arg_field)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("arg_field"), "../src/coredump/coredumpctl.c" , 313, __PRETTY_FUNCTION__); } while (0); | ||||||||||
314 | |||||||||||
315 | /* A (user-specified) field may appear more than once for a given entry. | ||||||||||
316 | * We will print all of the occurences. | ||||||||||
317 | * This is different below for fields that systemd-coredump uses, | ||||||||||
318 | * because they cannot meaningfully appear more than once. | ||||||||||
319 | */ | ||||||||||
320 | SD_JOURNAL_FOREACH_DATA(j, d, l)for (sd_journal_restart_data(j); sd_journal_enumerate_data((j ), &(d), &(l)) > 0; ) { | ||||||||||
321 | _cleanup_free___attribute__((cleanup(freep))) char *value = NULL((void*)0); | ||||||||||
322 | int r; | ||||||||||
323 | |||||||||||
324 | r = retrieve(d, l, arg_field, &value); | ||||||||||
325 | if (r < 0) | ||||||||||
326 | return r; | ||||||||||
327 | if (r > 0) | ||||||||||
328 | fprintf(file, "%s\n", value); | ||||||||||
329 | } | ||||||||||
330 | |||||||||||
331 | return 0; | ||||||||||
332 | } | ||||||||||
333 | |||||||||||
334 | #define RETRIEVE(d, l, name, arg){ int _r = retrieve(d, l, name, &arg); if (_r < 0) return _r; if (_r > 0) continue; } \ | ||||||||||
335 | { \ | ||||||||||
336 | int _r = retrieve(d, l, name, &arg); \ | ||||||||||
337 | if (_r < 0) \ | ||||||||||
338 | return _r; \ | ||||||||||
339 | if (_r > 0) \ | ||||||||||
340 | continue; \ | ||||||||||
341 | } | ||||||||||
342 | |||||||||||
343 | static int print_list(FILE* file, sd_journal *j, int had_legend) { | ||||||||||
344 | _cleanup_free___attribute__((cleanup(freep))) char | ||||||||||
345 | *mid = NULL((void*)0), *pid = NULL((void*)0), *uid = NULL((void*)0), *gid = NULL((void*)0), | ||||||||||
346 | *sgnl = NULL((void*)0), *exe = NULL((void*)0), *comm = NULL((void*)0), *cmdline = NULL((void*)0), | ||||||||||
347 | *filename = NULL((void*)0), *truncated = NULL((void*)0), *coredump = NULL((void*)0); | ||||||||||
348 | const void *d; | ||||||||||
349 | size_t l; | ||||||||||
350 | usec_t t; | ||||||||||
351 | char buf[FORMAT_TIMESTAMP_MAX(3+1+10+1+8+1+6+1+6+1)]; | ||||||||||
352 | int r; | ||||||||||
353 | const char *present; | ||||||||||
354 | bool_Bool normal_coredump; | ||||||||||
355 | |||||||||||
356 | assert(file)do { if ((__builtin_expect(!!(!(file)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("file"), "../src/coredump/coredumpctl.c" , 356, __PRETTY_FUNCTION__); } while (0); | ||||||||||
| |||||||||||
357 | assert(j)do { if ((__builtin_expect(!!(!(j)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("j"), "../src/coredump/coredumpctl.c", 357 , __PRETTY_FUNCTION__); } while (0); | ||||||||||
358 | |||||||||||
359 | SD_JOURNAL_FOREACH_DATA(j, d, l)for (sd_journal_restart_data(j); sd_journal_enumerate_data((j ), &(d), &(l)) > 0; ) { | ||||||||||
360 | RETRIEVE(d, l, "MESSAGE_ID", mid){ int _r = retrieve(d, l, "MESSAGE_ID", &mid); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
361 | RETRIEVE(d, l, "COREDUMP_PID", pid){ int _r = retrieve(d, l, "COREDUMP_PID", &pid); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
362 | RETRIEVE(d, l, "COREDUMP_UID", uid){ int _r = retrieve(d, l, "COREDUMP_UID", &uid); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
363 | RETRIEVE(d, l, "COREDUMP_GID", gid){ int _r = retrieve(d, l, "COREDUMP_GID", &gid); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
364 | RETRIEVE(d, l, "COREDUMP_SIGNAL", sgnl){ int _r = retrieve(d, l, "COREDUMP_SIGNAL", &sgnl); if ( _r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
365 | RETRIEVE(d, l, "COREDUMP_EXE", exe){ int _r = retrieve(d, l, "COREDUMP_EXE", &exe); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
366 | RETRIEVE(d, l, "COREDUMP_COMM", comm){ int _r = retrieve(d, l, "COREDUMP_COMM", &comm); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
367 | RETRIEVE(d, l, "COREDUMP_CMDLINE", cmdline){ int _r = retrieve(d, l, "COREDUMP_CMDLINE", &cmdline); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
368 | RETRIEVE(d, l, "COREDUMP_FILENAME", filename){ int _r = retrieve(d, l, "COREDUMP_FILENAME", &filename) ; if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
369 | RETRIEVE(d, l, "COREDUMP_TRUNCATED", truncated){ int _r = retrieve(d, l, "COREDUMP_TRUNCATED", &truncated ); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
370 | RETRIEVE(d, l, "COREDUMP", coredump){ int _r = retrieve(d, l, "COREDUMP", &coredump); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
371 | } | ||||||||||
372 | |||||||||||
373 | if (!pid
| ||||||||||
374 | log_warning("Empty coredump log entry")({ int _level = (((4))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 374, __func__, "Empty coredump log entry" ) : -abs(_e); }); | ||||||||||
375 | return -EINVAL22; | ||||||||||
376 | } | ||||||||||
377 | |||||||||||
378 | r = sd_journal_get_realtime_usec(j, &t); | ||||||||||
379 | if (r < 0) | ||||||||||
380 | return log_error_errno(r, "Failed to get realtime timestamp: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 380, __func__, "Failed to get realtime timestamp: %m" ) : -abs(_e); }); | ||||||||||
| |||||||||||
381 | |||||||||||
382 | format_timestamp(buf, sizeof(buf), t); | ||||||||||
383 | |||||||||||
384 | if (!had_legend && !arg_no_legend) | ||||||||||
385 | fprintf(file, "%-*s %*s %*s %*s %*s %-*s %s\n", | ||||||||||
386 | FORMAT_TIMESTAMP_WIDTH28, "TIME", | ||||||||||
387 | 6, "PID", | ||||||||||
388 | 5, "UID", | ||||||||||
389 | 5, "GID", | ||||||||||
390 | 3, "SIG", | ||||||||||
391 | 9, "COREFILE", | ||||||||||
392 | "EXE"); | ||||||||||
393 | |||||||||||
394 | normal_coredump = streq_ptr(mid, SD_MESSAGE_COREDUMP_STR"fc" "2e" "22" "bc" "6e" "e6" "47" "b6" "b9" "07" "29" "ab" "34" "a2" "50" "b1"); | ||||||||||
395 | |||||||||||
396 | if (filename) | ||||||||||
397 | if (access(filename, R_OK4) == 0) | ||||||||||
398 | present = "present"; | ||||||||||
399 | else if (errno(*__errno_location ()) == ENOENT2) | ||||||||||
400 | present = "missing"; | ||||||||||
401 | else | ||||||||||
402 | present = "error"; | ||||||||||
403 | else if (coredump) | ||||||||||
404 | present = "journal"; | ||||||||||
405 | else if (normal_coredump) | ||||||||||
406 | present = "none"; | ||||||||||
407 | else | ||||||||||
408 | present = "-"; | ||||||||||
409 | |||||||||||
410 | if (STR_IN_SET(present, "present", "journal")(!!strv_find((((char**) ((const char*[]) { "present", "journal" , ((void*)0) }))), (present))) && truncated && parse_boolean(truncated) > 0) | ||||||||||
411 | present = "truncated"; | ||||||||||
412 | |||||||||||
413 | fprintf(file, "%-*s %*s %*s %*s %*s %-*s %s\n", | ||||||||||
414 | FORMAT_TIMESTAMP_WIDTH28, buf, | ||||||||||
415 | 6, strna(pid), | ||||||||||
416 | 5, strna(uid), | ||||||||||
417 | 5, strna(gid), | ||||||||||
418 | 3, normal_coredump ? strna(sgnl) : "-", | ||||||||||
419 | 9, present, | ||||||||||
420 | strna(exe ?: (comm ?: cmdline))); | ||||||||||
421 | |||||||||||
422 | return 0; | ||||||||||
423 | } | ||||||||||
424 | |||||||||||
425 | static int print_info(FILE *file, sd_journal *j, bool_Bool need_space) { | ||||||||||
426 | _cleanup_free___attribute__((cleanup(freep))) char | ||||||||||
427 | *mid = NULL((void*)0), *pid = NULL((void*)0), *uid = NULL((void*)0), *gid = NULL((void*)0), | ||||||||||
428 | *sgnl = NULL((void*)0), *exe = NULL((void*)0), *comm = NULL((void*)0), *cmdline = NULL((void*)0), | ||||||||||
429 | *unit = NULL((void*)0), *user_unit = NULL((void*)0), *session = NULL((void*)0), | ||||||||||
430 | *boot_id = NULL((void*)0), *machine_id = NULL((void*)0), *hostname = NULL((void*)0), | ||||||||||
431 | *slice = NULL((void*)0), *cgroup = NULL((void*)0), *owner_uid = NULL((void*)0), | ||||||||||
432 | *message = NULL((void*)0), *timestamp = NULL((void*)0), *filename = NULL((void*)0), | ||||||||||
433 | *truncated = NULL((void*)0), *coredump = NULL((void*)0); | ||||||||||
434 | const void *d; | ||||||||||
435 | size_t l; | ||||||||||
436 | bool_Bool normal_coredump; | ||||||||||
437 | int r; | ||||||||||
438 | |||||||||||
439 | assert(file)do { if ((__builtin_expect(!!(!(file)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("file"), "../src/coredump/coredumpctl.c" , 439, __PRETTY_FUNCTION__); } while (0); | ||||||||||
440 | assert(j)do { if ((__builtin_expect(!!(!(j)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("j"), "../src/coredump/coredumpctl.c", 440 , __PRETTY_FUNCTION__); } while (0); | ||||||||||
441 | |||||||||||
442 | SD_JOURNAL_FOREACH_DATA(j, d, l)for (sd_journal_restart_data(j); sd_journal_enumerate_data((j ), &(d), &(l)) > 0; ) { | ||||||||||
443 | RETRIEVE(d, l, "MESSAGE_ID", mid){ int _r = retrieve(d, l, "MESSAGE_ID", &mid); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
444 | RETRIEVE(d, l, "COREDUMP_PID", pid){ int _r = retrieve(d, l, "COREDUMP_PID", &pid); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
445 | RETRIEVE(d, l, "COREDUMP_UID", uid){ int _r = retrieve(d, l, "COREDUMP_UID", &uid); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
446 | RETRIEVE(d, l, "COREDUMP_GID", gid){ int _r = retrieve(d, l, "COREDUMP_GID", &gid); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
447 | RETRIEVE(d, l, "COREDUMP_SIGNAL", sgnl){ int _r = retrieve(d, l, "COREDUMP_SIGNAL", &sgnl); if ( _r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
448 | RETRIEVE(d, l, "COREDUMP_EXE", exe){ int _r = retrieve(d, l, "COREDUMP_EXE", &exe); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
449 | RETRIEVE(d, l, "COREDUMP_COMM", comm){ int _r = retrieve(d, l, "COREDUMP_COMM", &comm); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
450 | RETRIEVE(d, l, "COREDUMP_CMDLINE", cmdline){ int _r = retrieve(d, l, "COREDUMP_CMDLINE", &cmdline); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
451 | RETRIEVE(d, l, "COREDUMP_UNIT", unit){ int _r = retrieve(d, l, "COREDUMP_UNIT", &unit); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
452 | RETRIEVE(d, l, "COREDUMP_USER_UNIT", user_unit){ int _r = retrieve(d, l, "COREDUMP_USER_UNIT", &user_unit ); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
453 | RETRIEVE(d, l, "COREDUMP_SESSION", session){ int _r = retrieve(d, l, "COREDUMP_SESSION", &session); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
454 | RETRIEVE(d, l, "COREDUMP_OWNER_UID", owner_uid){ int _r = retrieve(d, l, "COREDUMP_OWNER_UID", &owner_uid ); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
455 | RETRIEVE(d, l, "COREDUMP_SLICE", slice){ int _r = retrieve(d, l, "COREDUMP_SLICE", &slice); if ( _r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
456 | RETRIEVE(d, l, "COREDUMP_CGROUP", cgroup){ int _r = retrieve(d, l, "COREDUMP_CGROUP", &cgroup); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
457 | RETRIEVE(d, l, "COREDUMP_TIMESTAMP", timestamp){ int _r = retrieve(d, l, "COREDUMP_TIMESTAMP", ×tamp ); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
458 | RETRIEVE(d, l, "COREDUMP_FILENAME", filename){ int _r = retrieve(d, l, "COREDUMP_FILENAME", &filename) ; if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
459 | RETRIEVE(d, l, "COREDUMP_TRUNCATED", truncated){ int _r = retrieve(d, l, "COREDUMP_TRUNCATED", &truncated ); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
460 | RETRIEVE(d, l, "COREDUMP", coredump){ int _r = retrieve(d, l, "COREDUMP", &coredump); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
461 | RETRIEVE(d, l, "_BOOT_ID", boot_id){ int _r = retrieve(d, l, "_BOOT_ID", &boot_id); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
462 | RETRIEVE(d, l, "_MACHINE_ID", machine_id){ int _r = retrieve(d, l, "_MACHINE_ID", &machine_id); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
463 | RETRIEVE(d, l, "_HOSTNAME", hostname){ int _r = retrieve(d, l, "_HOSTNAME", &hostname); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
464 | RETRIEVE(d, l, "MESSAGE", message){ int _r = retrieve(d, l, "MESSAGE", &message); if (_r < 0) return _r; if (_r > 0) continue; }; | ||||||||||
465 | } | ||||||||||
466 | |||||||||||
467 | if (need_space) | ||||||||||
468 | fputs("\n", file); | ||||||||||
469 | |||||||||||
470 | normal_coredump = streq_ptr(mid, SD_MESSAGE_COREDUMP_STR"fc" "2e" "22" "bc" "6e" "e6" "47" "b6" "b9" "07" "29" "ab" "34" "a2" "50" "b1"); | ||||||||||
471 | |||||||||||
472 | if (comm) | ||||||||||
473 | fprintf(file, | ||||||||||
474 | " PID: %s%s%s (%s)\n", | ||||||||||
475 | ansi_highlight(), strna(pid), ansi_normal(), comm); | ||||||||||
476 | else | ||||||||||
477 | fprintf(file, | ||||||||||
478 | " PID: %s%s%s\n", | ||||||||||
479 | ansi_highlight(), strna(pid), ansi_normal()); | ||||||||||
480 | |||||||||||
481 | if (uid) { | ||||||||||
482 | uid_t n; | ||||||||||
483 | |||||||||||
484 | if (parse_uid(uid, &n) >= 0) { | ||||||||||
485 | _cleanup_free___attribute__((cleanup(freep))) char *u = NULL((void*)0); | ||||||||||
486 | |||||||||||
487 | u = uid_to_name(n); | ||||||||||
488 | fprintf(file, | ||||||||||
489 | " UID: %s (%s)\n", | ||||||||||
490 | uid, u); | ||||||||||
491 | } else { | ||||||||||
492 | fprintf(file, | ||||||||||
493 | " UID: %s\n", | ||||||||||
494 | uid); | ||||||||||
495 | } | ||||||||||
496 | } | ||||||||||
497 | |||||||||||
498 | if (gid) { | ||||||||||
499 | gid_t n; | ||||||||||
500 | |||||||||||
501 | if (parse_gid(gid, &n) >= 0) { | ||||||||||
502 | _cleanup_free___attribute__((cleanup(freep))) char *g = NULL((void*)0); | ||||||||||
503 | |||||||||||
504 | g = gid_to_name(n); | ||||||||||
505 | fprintf(file, | ||||||||||
506 | " GID: %s (%s)\n", | ||||||||||
507 | gid, g); | ||||||||||
508 | } else { | ||||||||||
509 | fprintf(file, | ||||||||||
510 | " GID: %s\n", | ||||||||||
511 | gid); | ||||||||||
512 | } | ||||||||||
513 | } | ||||||||||
514 | |||||||||||
515 | if (sgnl) { | ||||||||||
516 | int sig; | ||||||||||
517 | const char *name = normal_coredump ? "Signal" : "Reason"; | ||||||||||
518 | |||||||||||
519 | if (normal_coredump && safe_atoi(sgnl, &sig) >= 0) | ||||||||||
520 | fprintf(file, " %s: %s (%s)\n", name, sgnl, signal_to_string(sig)); | ||||||||||
521 | else | ||||||||||
522 | fprintf(file, " %s: %s\n", name, sgnl); | ||||||||||
523 | } | ||||||||||
524 | |||||||||||
525 | if (timestamp) { | ||||||||||
526 | usec_t u; | ||||||||||
527 | |||||||||||
528 | r = safe_atou64(timestamp, &u); | ||||||||||
529 | if (r >= 0) { | ||||||||||
530 | char absolute[FORMAT_TIMESTAMP_MAX(3+1+10+1+8+1+6+1+6+1)], relative[FORMAT_TIMESPAN_MAX64]; | ||||||||||
531 | |||||||||||
532 | fprintf(file, | ||||||||||
533 | " Timestamp: %s (%s)\n", | ||||||||||
534 | format_timestamp(absolute, sizeof(absolute), u), | ||||||||||
535 | format_timestamp_relative(relative, sizeof(relative), u)); | ||||||||||
536 | |||||||||||
537 | } else | ||||||||||
538 | fprintf(file, " Timestamp: %s\n", timestamp); | ||||||||||
539 | } | ||||||||||
540 | |||||||||||
541 | if (cmdline) | ||||||||||
542 | fprintf(file, " Command Line: %s\n", cmdline); | ||||||||||
543 | if (exe) | ||||||||||
544 | fprintf(file, " Executable: %s%s%s\n", ansi_highlight(), exe, ansi_normal()); | ||||||||||
545 | if (cgroup) | ||||||||||
546 | fprintf(file, " Control Group: %s\n", cgroup); | ||||||||||
547 | if (unit) | ||||||||||
548 | fprintf(file, " Unit: %s\n", unit); | ||||||||||
549 | if (user_unit) | ||||||||||
550 | fprintf(file, " User Unit: %s\n", user_unit); | ||||||||||
551 | if (slice) | ||||||||||
552 | fprintf(file, " Slice: %s\n", slice); | ||||||||||
553 | if (session) | ||||||||||
554 | fprintf(file, " Session: %s\n", session); | ||||||||||
555 | if (owner_uid) { | ||||||||||
556 | uid_t n; | ||||||||||
557 | |||||||||||
558 | if (parse_uid(owner_uid, &n) >= 0) { | ||||||||||
559 | _cleanup_free___attribute__((cleanup(freep))) char *u = NULL((void*)0); | ||||||||||
560 | |||||||||||
561 | u = uid_to_name(n); | ||||||||||
562 | fprintf(file, | ||||||||||
563 | " Owner UID: %s (%s)\n", | ||||||||||
564 | owner_uid, u); | ||||||||||
565 | } else { | ||||||||||
566 | fprintf(file, | ||||||||||
567 | " Owner UID: %s\n", | ||||||||||
568 | owner_uid); | ||||||||||
569 | } | ||||||||||
570 | } | ||||||||||
571 | if (boot_id) | ||||||||||
572 | fprintf(file, " Boot ID: %s\n", boot_id); | ||||||||||
573 | if (machine_id) | ||||||||||
574 | fprintf(file, " Machine ID: %s\n", machine_id); | ||||||||||
575 | if (hostname) | ||||||||||
576 | fprintf(file, " Hostname: %s\n", hostname); | ||||||||||
577 | |||||||||||
578 | if (filename) { | ||||||||||
579 | bool_Bool inacc, trunc; | ||||||||||
580 | |||||||||||
581 | inacc = access(filename, R_OK4) < 0; | ||||||||||
582 | trunc = truncated && parse_boolean(truncated) > 0; | ||||||||||
583 | |||||||||||
584 | if (inacc || trunc) | ||||||||||
585 | fprintf(file, " Storage: %s%s (%s%s%s)%s\n", | ||||||||||
586 | ansi_highlight_red(), | ||||||||||
587 | filename, | ||||||||||
588 | inacc ? "inaccessible" : "", | ||||||||||
589 | inacc && trunc ? ", " : "", | ||||||||||
590 | trunc ? "truncated" : "", | ||||||||||
591 | ansi_normal()); | ||||||||||
592 | else | ||||||||||
593 | fprintf(file, " Storage: %s\n", filename); | ||||||||||
594 | } | ||||||||||
595 | |||||||||||
596 | else if (coredump) | ||||||||||
597 | fprintf(file, " Storage: journal\n"); | ||||||||||
598 | else | ||||||||||
599 | fprintf(file, " Storage: none\n"); | ||||||||||
600 | |||||||||||
601 | if (message) { | ||||||||||
602 | _cleanup_free___attribute__((cleanup(freep))) char *m = NULL((void*)0); | ||||||||||
603 | |||||||||||
604 | m = strreplace(message, "\n", "\n "); | ||||||||||
605 | |||||||||||
606 | fprintf(file, " Message: %s\n", strstrip(m ?: message)); | ||||||||||
607 | } | ||||||||||
608 | |||||||||||
609 | return 0; | ||||||||||
610 | } | ||||||||||
611 | |||||||||||
612 | static int focus(sd_journal *j) { | ||||||||||
613 | int r; | ||||||||||
614 | |||||||||||
615 | r = sd_journal_seek_tail(j); | ||||||||||
616 | if (r == 0) | ||||||||||
617 | r = sd_journal_previous(j); | ||||||||||
618 | if (r < 0) | ||||||||||
619 | return log_error_errno(r, "Failed to search journal: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 619, __func__, "Failed to search journal: %m" ) : -abs(_e); }); | ||||||||||
620 | if (r == 0) { | ||||||||||
621 | log_error("No match found.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 621, __func__, "No match found." ) : -abs(_e); }); | ||||||||||
622 | return -ESRCH3; | ||||||||||
623 | } | ||||||||||
624 | return r; | ||||||||||
625 | } | ||||||||||
626 | |||||||||||
627 | static int print_entry(sd_journal *j, unsigned n_found, bool_Bool verb_is_info) { | ||||||||||
628 | assert(j)do { if ((__builtin_expect(!!(!(j)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("j"), "../src/coredump/coredumpctl.c", 628 , __PRETTY_FUNCTION__); } while (0); | ||||||||||
629 | |||||||||||
630 | if (verb_is_info) | ||||||||||
631 | return print_info(stdoutstdout, j, n_found); | ||||||||||
632 | else if (arg_field) | ||||||||||
633 | return print_field(stdoutstdout, j); | ||||||||||
634 | else | ||||||||||
635 | return print_list(stdoutstdout, j, n_found); | ||||||||||
636 | } | ||||||||||
637 | |||||||||||
638 | static int dump_list(int argc, char **argv, void *userdata) { | ||||||||||
639 | _cleanup_(sd_journal_closep)__attribute__((cleanup(sd_journal_closep))) sd_journal *j = NULL((void*)0); | ||||||||||
640 | unsigned n_found = 0; | ||||||||||
641 | bool_Bool verb_is_info; | ||||||||||
642 | int r; | ||||||||||
643 | |||||||||||
644 | verb_is_info = (argc >= 1 && streq(argv[0], "info")(strcmp((argv[0]),("info")) == 0)); | ||||||||||
645 | |||||||||||
646 | r = acquire_journal(&j, argv + 1); | ||||||||||
647 | if (r < 0) | ||||||||||
648 | return r; | ||||||||||
649 | |||||||||||
650 | (void) pager_open(arg_no_pager, false0); | ||||||||||
651 | |||||||||||
652 | /* The coredumps are likely to compressed, and for just | ||||||||||
653 | * listing them we don't need to decompress them, so let's | ||||||||||
654 | * pick a fairly low data threshold here */ | ||||||||||
655 | sd_journal_set_data_threshold(j, 4096); | ||||||||||
656 | |||||||||||
657 | if (arg_one) { | ||||||||||
658 | r = focus(j); | ||||||||||
659 | if (r < 0) | ||||||||||
660 | return r; | ||||||||||
661 | |||||||||||
662 | return print_entry(j, 0, verb_is_info); | ||||||||||
663 | } else { | ||||||||||
664 | if (arg_since != USEC_INFINITY((usec_t) -1) && !arg_reverse) | ||||||||||
665 | r = sd_journal_seek_realtime_usec(j, arg_since); | ||||||||||
666 | else if (arg_until != USEC_INFINITY((usec_t) -1) && arg_reverse) | ||||||||||
667 | r = sd_journal_seek_realtime_usec(j, arg_until); | ||||||||||
668 | else if (arg_reverse) | ||||||||||
669 | r = sd_journal_seek_tail(j); | ||||||||||
670 | else | ||||||||||
671 | r = sd_journal_seek_head(j); | ||||||||||
672 | if (r < 0) | ||||||||||
673 | return log_error_errno(r, "Failed to seek to date: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 673, __func__, "Failed to seek to date: %m" ) : -abs(_e); }); | ||||||||||
674 | |||||||||||
675 | for (;;) { | ||||||||||
676 | if (!arg_reverse) | ||||||||||
677 | r = sd_journal_next(j); | ||||||||||
678 | else | ||||||||||
679 | r = sd_journal_previous(j); | ||||||||||
680 | |||||||||||
681 | if (r < 0) | ||||||||||
682 | return log_error_errno(r, "Failed to iterate through journal: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 682, __func__, "Failed to iterate through journal: %m" ) : -abs(_e); }); | ||||||||||
683 | |||||||||||
684 | if (r == 0) | ||||||||||
685 | break; | ||||||||||
686 | |||||||||||
687 | if (arg_until != USEC_INFINITY((usec_t) -1) && !arg_reverse) { | ||||||||||
688 | usec_t usec; | ||||||||||
689 | |||||||||||
690 | r = sd_journal_get_realtime_usec(j, &usec); | ||||||||||
691 | if (r < 0) | ||||||||||
692 | return log_error_errno(r, "Failed to determine timestamp: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 692, __func__, "Failed to determine timestamp: %m" ) : -abs(_e); }); | ||||||||||
693 | if (usec > arg_until) | ||||||||||
694 | continue; | ||||||||||
695 | } | ||||||||||
696 | |||||||||||
697 | if (arg_since != USEC_INFINITY((usec_t) -1) && arg_reverse) { | ||||||||||
698 | usec_t usec; | ||||||||||
699 | |||||||||||
700 | r = sd_journal_get_realtime_usec(j, &usec); | ||||||||||
701 | if (r < 0) | ||||||||||
702 | return log_error_errno(r, "Failed to determine timestamp: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 702, __func__, "Failed to determine timestamp: %m" ) : -abs(_e); }); | ||||||||||
703 | if (usec < arg_since) | ||||||||||
704 | continue; | ||||||||||
705 | } | ||||||||||
706 | |||||||||||
707 | r = print_entry(j, n_found++, verb_is_info); | ||||||||||
708 | if (r < 0) | ||||||||||
709 | return r; | ||||||||||
710 | } | ||||||||||
711 | |||||||||||
712 | if (!arg_field && n_found <= 0) { | ||||||||||
713 | if (!arg_quiet) | ||||||||||
714 | log_notice("No coredumps found.")({ int _level = (((5))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 714, __func__, "No coredumps found." ) : -abs(_e); }); | ||||||||||
715 | return -ESRCH3; | ||||||||||
716 | } | ||||||||||
717 | } | ||||||||||
718 | |||||||||||
719 | return 0; | ||||||||||
720 | } | ||||||||||
721 | |||||||||||
722 | static int save_core(sd_journal *j, FILE *file, char **path, bool_Bool *unlink_temp) { | ||||||||||
723 | const char *data; | ||||||||||
724 | _cleanup_free___attribute__((cleanup(freep))) char *filename = NULL((void*)0); | ||||||||||
725 | size_t len; | ||||||||||
726 | int r, fd; | ||||||||||
727 | _cleanup_close___attribute__((cleanup(closep))) int fdt = -1; | ||||||||||
728 | char *temp = NULL((void*)0); | ||||||||||
729 | |||||||||||
730 | assert(!(file && path))do { if ((__builtin_expect(!!(!(!(file && path))),0)) ) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("!(file && path)" ), "../src/coredump/coredumpctl.c", 730, __PRETTY_FUNCTION__) ; } while (0); /* At most one can be specified */ | ||||||||||
731 | assert(!!path == !!unlink_temp)do { if ((__builtin_expect(!!(!(!!path == !!unlink_temp)),0)) ) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("!!path == !!unlink_temp" ), "../src/coredump/coredumpctl.c", 731, __PRETTY_FUNCTION__) ; } while (0); /* Those must be specified together */ | ||||||||||
732 | |||||||||||
733 | /* Look for a coredump on disk first. */ | ||||||||||
734 | r = sd_journal_get_data(j, "COREDUMP_FILENAME", (const void**) &data, &len); | ||||||||||
735 | if (r == 0) | ||||||||||
736 | retrieve(data, len, "COREDUMP_FILENAME", &filename); | ||||||||||
737 | else { | ||||||||||
738 | if (r != -ENOENT2) | ||||||||||
739 | return log_error_errno(r, "Failed to retrieve COREDUMP_FILENAME field: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 739, __func__, "Failed to retrieve COREDUMP_FILENAME field: %m" ) : -abs(_e); }); | ||||||||||
740 | /* Check that we can have a COREDUMP field. We still haven't set a high | ||||||||||
741 | * data threshold, so we'll get a few kilobytes at most. | ||||||||||
742 | */ | ||||||||||
743 | |||||||||||
744 | r = sd_journal_get_data(j, "COREDUMP", (const void**) &data, &len); | ||||||||||
745 | if (r == -ENOENT2) | ||||||||||
746 | return log_error_errno(r, "Coredump entry has no core attached (neither internally in the journal nor externally on disk).")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 746, __func__, "Coredump entry has no core attached (neither internally in the journal nor externally on disk)." ) : -abs(_e); }); | ||||||||||
747 | if (r < 0) | ||||||||||
748 | return log_error_errno(r, "Failed to retrieve COREDUMP field: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 748, __func__, "Failed to retrieve COREDUMP field: %m" ) : -abs(_e); }); | ||||||||||
749 | } | ||||||||||
750 | |||||||||||
751 | if (filename) { | ||||||||||
752 | if (access(filename, R_OK4) < 0) | ||||||||||
753 | return log_error_errno(errno, "File \"%s\" is not readable: %m", filename)({ int _level = ((3)), _e = (((*__errno_location ()))), _realm = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >= ((_level) & 0x07)) ? log_internal_realm(((_realm) << 10 | (_level)), _e, "../src/coredump/coredumpctl.c", 753, __func__ , "File \"%s\" is not readable: %m", filename) : -abs(_e); }); | ||||||||||
754 | |||||||||||
755 | if (path && !endswith(filename, ".xz") && !endswith(filename, ".lz4")) { | ||||||||||
756 | *path = TAKE_PTR(filename)({ typeof(filename) _ptr_ = (filename); (filename) = ((void*) 0); _ptr_; }); | ||||||||||
757 | |||||||||||
758 | return 0; | ||||||||||
759 | } | ||||||||||
760 | } | ||||||||||
761 | |||||||||||
762 | if (path) { | ||||||||||
763 | const char *vt; | ||||||||||
764 | |||||||||||
765 | /* Create a temporary file to write the uncompressed core to. */ | ||||||||||
766 | |||||||||||
767 | r = var_tmp_dir(&vt); | ||||||||||
768 | if (r < 0) | ||||||||||
769 | return log_error_errno(r, "Failed to acquire temporary directory path: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 769, __func__, "Failed to acquire temporary directory path: %m" ) : -abs(_e); }); | ||||||||||
770 | |||||||||||
771 | temp = strjoin(vt, "/coredump-XXXXXX")strjoin_real((vt), "/coredump-XXXXXX", ((void*)0)); | ||||||||||
772 | if (!temp) | ||||||||||
773 | return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/coredump/coredumpctl.c" , 773, __func__); | ||||||||||
774 | |||||||||||
775 | fdt = mkostemp_safe(temp); | ||||||||||
776 | if (fdt < 0) | ||||||||||
777 | return log_error_errno(fdt, "Failed to create temporary file: %m")({ int _level = ((3)), _e = ((fdt)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 777, __func__, "Failed to create temporary file: %m" ) : -abs(_e); }); | ||||||||||
778 | log_debug("Created temporary file %s", temp)({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 778, __func__, "Created temporary file %s" , temp) : -abs(_e); }); | ||||||||||
779 | |||||||||||
780 | fd = fdt; | ||||||||||
781 | } else { | ||||||||||
782 | /* If neither path or file are specified, we will write to stdout. Let's now check | ||||||||||
783 | * if stdout is connected to a tty. We checked that the file exists, or that the | ||||||||||
784 | * core might be stored in the journal. In this second case, if we found the entry, | ||||||||||
785 | * in all likelyhood we will be able to access the COREDUMP= field. In either case, | ||||||||||
786 | * we stop before doing any "real" work, i.e. before starting decompression or | ||||||||||
787 | * reading from the file or creating temporary files. | ||||||||||
788 | */ | ||||||||||
789 | if (!file) { | ||||||||||
790 | if (on_tty()) | ||||||||||
791 | return log_error_errno(ENOTTY, "Refusing to dump core to tty"({ int _level = ((3)), _e = ((25)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 792, __func__, "Refusing to dump core to tty" " (use shell redirection or specify --output).") : -abs(_e); }) | ||||||||||
792 | " (use shell redirection or specify --output).")({ int _level = ((3)), _e = ((25)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 792, __func__, "Refusing to dump core to tty" " (use shell redirection or specify --output).") : -abs(_e); }); | ||||||||||
793 | file = stdoutstdout; | ||||||||||
794 | } | ||||||||||
795 | |||||||||||
796 | fd = fileno(file); | ||||||||||
797 | } | ||||||||||
798 | |||||||||||
799 | if (filename) { | ||||||||||
800 | #if HAVE_XZ1 || HAVE_LZ41 | ||||||||||
801 | _cleanup_close___attribute__((cleanup(closep))) int fdf; | ||||||||||
802 | |||||||||||
803 | fdf = open(filename, O_RDONLY00 | O_CLOEXEC02000000); | ||||||||||
804 | if (fdf < 0) { | ||||||||||
805 | r = log_error_errno(errno, "Failed to open %s: %m", filename)({ int _level = ((3)), _e = (((*__errno_location ()))), _realm = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >= ((_level) & 0x07)) ? log_internal_realm(((_realm) << 10 | (_level)), _e, "../src/coredump/coredumpctl.c", 805, __func__ , "Failed to open %s: %m", filename) : -abs(_e); }); | ||||||||||
806 | goto error; | ||||||||||
807 | } | ||||||||||
808 | |||||||||||
809 | r = decompress_stream(filename, fdf, fd, -1); | ||||||||||
810 | if (r < 0) { | ||||||||||
811 | log_error_errno(r, "Failed to decompress %s: %m", filename)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 811, __func__, "Failed to decompress %s: %m" , filename) : -abs(_e); }); | ||||||||||
812 | goto error; | ||||||||||
813 | } | ||||||||||
814 | #else | ||||||||||
815 | log_error("Cannot decompress file. Compiled without compression support.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 815, __func__, "Cannot decompress file. Compiled without compression support." ) : -abs(_e); }); | ||||||||||
816 | r = -EOPNOTSUPP95; | ||||||||||
817 | goto error; | ||||||||||
818 | #endif | ||||||||||
819 | } else { | ||||||||||
820 | ssize_t sz; | ||||||||||
821 | |||||||||||
822 | /* We want full data, nothing truncated. */ | ||||||||||
823 | sd_journal_set_data_threshold(j, 0); | ||||||||||
824 | |||||||||||
825 | r = sd_journal_get_data(j, "COREDUMP", (const void**) &data, &len); | ||||||||||
826 | if (r < 0) | ||||||||||
827 | return log_error_errno(r, "Failed to retrieve COREDUMP field: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 827, __func__, "Failed to retrieve COREDUMP field: %m" ) : -abs(_e); }); | ||||||||||
828 | |||||||||||
829 | assert(len >= 9)do { if ((__builtin_expect(!!(!(len >= 9)),0))) log_assert_failed_realm (LOG_REALM_SYSTEMD, ("len >= 9"), "../src/coredump/coredumpctl.c" , 829, __PRETTY_FUNCTION__); } while (0); | ||||||||||
830 | data += 9; | ||||||||||
831 | len -= 9; | ||||||||||
832 | |||||||||||
833 | sz = write(fd, data, len); | ||||||||||
834 | if (sz < 0) { | ||||||||||
835 | r = log_error_errno(errno, "Failed to write output: %m")({ int _level = ((3)), _e = (((*__errno_location ()))), _realm = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >= ((_level) & 0x07)) ? log_internal_realm(((_realm) << 10 | (_level)), _e, "../src/coredump/coredumpctl.c", 835, __func__ , "Failed to write output: %m") : -abs(_e); }); | ||||||||||
836 | goto error; | ||||||||||
837 | } | ||||||||||
838 | if (sz != (ssize_t) len) { | ||||||||||
839 | log_error("Short write to output.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 839, __func__, "Short write to output." ) : -abs(_e); }); | ||||||||||
840 | r = -EIO5; | ||||||||||
841 | goto error; | ||||||||||
842 | } | ||||||||||
843 | } | ||||||||||
844 | |||||||||||
845 | if (temp) { | ||||||||||
846 | *path = temp; | ||||||||||
847 | *unlink_temp = true1; | ||||||||||
848 | } | ||||||||||
849 | return 0; | ||||||||||
850 | |||||||||||
851 | error: | ||||||||||
852 | if (temp) { | ||||||||||
853 | unlink(temp); | ||||||||||
854 | log_debug("Removed temporary file %s", temp)({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 854, __func__, "Removed temporary file %s" , temp) : -abs(_e); }); | ||||||||||
855 | } | ||||||||||
856 | return r; | ||||||||||
857 | } | ||||||||||
858 | |||||||||||
859 | static int dump_core(int argc, char **argv, void *userdata) { | ||||||||||
860 | _cleanup_(sd_journal_closep)__attribute__((cleanup(sd_journal_closep))) sd_journal *j = NULL((void*)0); | ||||||||||
861 | int r; | ||||||||||
862 | |||||||||||
863 | if (arg_field) { | ||||||||||
864 | log_error("Option --field/-F only makes sense with list")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 864, __func__, "Option --field/-F only makes sense with list" ) : -abs(_e); }); | ||||||||||
865 | return -EINVAL22; | ||||||||||
866 | } | ||||||||||
867 | |||||||||||
868 | r = acquire_journal(&j, argv + 1); | ||||||||||
869 | if (r < 0) | ||||||||||
870 | return r; | ||||||||||
871 | |||||||||||
872 | r = focus(j); | ||||||||||
873 | if (r < 0) | ||||||||||
874 | return r; | ||||||||||
875 | |||||||||||
876 | print_info(arg_output ? stdoutstdout : stderrstderr, j, false0); | ||||||||||
877 | |||||||||||
878 | r = save_core(j, arg_output, NULL((void*)0), NULL((void*)0)); | ||||||||||
879 | if (r < 0) | ||||||||||
880 | return r; | ||||||||||
881 | |||||||||||
882 | r = sd_journal_previous(j); | ||||||||||
883 | if (r > 0 && !arg_quiet) | ||||||||||
884 | log_notice("More than one entry matches, ignoring rest.")({ int _level = (((5))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 884, __func__, "More than one entry matches, ignoring rest." ) : -abs(_e); }); | ||||||||||
885 | |||||||||||
886 | return 0; | ||||||||||
887 | } | ||||||||||
888 | |||||||||||
889 | static int run_debug(int argc, char **argv, void *userdata) { | ||||||||||
890 | _cleanup_(sd_journal_closep)__attribute__((cleanup(sd_journal_closep))) sd_journal *j = NULL((void*)0); | ||||||||||
891 | _cleanup_free___attribute__((cleanup(freep))) char *exe = NULL((void*)0), *path = NULL((void*)0); | ||||||||||
892 | bool_Bool unlink_path = false0; | ||||||||||
893 | const char *data, *fork_name; | ||||||||||
894 | size_t len; | ||||||||||
895 | pid_t pid; | ||||||||||
896 | int r; | ||||||||||
897 | |||||||||||
898 | if (!arg_debugger) { | ||||||||||
899 | char *env_debugger; | ||||||||||
900 | |||||||||||
901 | env_debugger = getenv("SYSTEMD_DEBUGGER"); | ||||||||||
902 | if (env_debugger) | ||||||||||
903 | arg_debugger = env_debugger; | ||||||||||
904 | else | ||||||||||
905 | arg_debugger = "gdb"; | ||||||||||
906 | } | ||||||||||
907 | |||||||||||
908 | if (arg_field) { | ||||||||||
909 | log_error("Option --field/-F only makes sense with list")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 909, __func__, "Option --field/-F only makes sense with list" ) : -abs(_e); }); | ||||||||||
910 | return -EINVAL22; | ||||||||||
911 | } | ||||||||||
912 | |||||||||||
913 | r = acquire_journal(&j, argv + 1); | ||||||||||
914 | if (r < 0) | ||||||||||
915 | return r; | ||||||||||
916 | |||||||||||
917 | r = focus(j); | ||||||||||
918 | if (r < 0) | ||||||||||
919 | return r; | ||||||||||
920 | |||||||||||
921 | print_info(stdoutstdout, j, false0); | ||||||||||
922 | fputs("\n", stdoutstdout); | ||||||||||
923 | |||||||||||
924 | r = sd_journal_get_data(j, "COREDUMP_EXE", (const void**) &data, &len); | ||||||||||
925 | if (r < 0) | ||||||||||
926 | return log_error_errno(r, "Failed to retrieve COREDUMP_EXE field: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 926, __func__, "Failed to retrieve COREDUMP_EXE field: %m" ) : -abs(_e); }); | ||||||||||
927 | |||||||||||
928 | assert(len > STRLEN("COREDUMP_EXE="))do { if ((__builtin_expect(!!(!(len > (sizeof("""COREDUMP_EXE=" "") - 1))),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("len > STRLEN(\"COREDUMP_EXE=\")" ), "../src/coredump/coredumpctl.c", 928, __PRETTY_FUNCTION__) ; } while (0); | ||||||||||
929 | data += STRLEN("COREDUMP_EXE=")(sizeof("""COREDUMP_EXE=""") - 1); | ||||||||||
930 | len -= STRLEN("COREDUMP_EXE=")(sizeof("""COREDUMP_EXE=""") - 1); | ||||||||||
931 | |||||||||||
932 | exe = strndup(data, len); | ||||||||||
933 | if (!exe) | ||||||||||
934 | return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/coredump/coredumpctl.c" , 934, __func__); | ||||||||||
935 | |||||||||||
936 | if (endswith(exe, " (deleted)")) { | ||||||||||
937 | log_error("Binary already deleted.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 937, __func__, "Binary already deleted." ) : -abs(_e); }); | ||||||||||
938 | return -ENOENT2; | ||||||||||
939 | } | ||||||||||
940 | |||||||||||
941 | if (!path_is_absolute(exe)) { | ||||||||||
942 | log_error("Binary is not an absolute path.")({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 942, __func__, "Binary is not an absolute path." ) : -abs(_e); }); | ||||||||||
943 | return -ENOENT2; | ||||||||||
944 | } | ||||||||||
945 | |||||||||||
946 | r = save_core(j, NULL((void*)0), &path, &unlink_path); | ||||||||||
947 | if (r < 0) | ||||||||||
948 | return r; | ||||||||||
949 | |||||||||||
950 | /* Don't interfere with gdb and its handling of SIGINT. */ | ||||||||||
951 | (void) ignore_signals(SIGINT2, -1); | ||||||||||
952 | |||||||||||
953 | fork_name = strjoina("(", arg_debugger, ")")({ const char *_appendees_[] = { "(", arg_debugger, ")" }; char *_d_, *_p_; size_t _len_ = 0; size_t _i_; for (_i_ = 0; _i_ < __extension__ (__builtin_choose_expr( !__builtin_types_compatible_p (typeof(_appendees_), typeof(&*(_appendees_))), sizeof(_appendees_ )/sizeof((_appendees_)[0]), ((void)0))) && _appendees_ [_i_]; _i_++) _len_ += strlen(_appendees_[_i_]); _p_ = _d_ = __builtin_alloca (_len_ + 1); for (_i_ = 0; _i_ < __extension__ (__builtin_choose_expr ( !__builtin_types_compatible_p(typeof(_appendees_), typeof(& *(_appendees_))), sizeof(_appendees_)/sizeof((_appendees_)[0] ), ((void)0))) && _appendees_[_i_]; _i_++) _p_ = stpcpy (_p_, _appendees_[_i_]); *_p_ = 0; _d_; }); | ||||||||||
954 | |||||||||||
955 | r = safe_fork(fork_name, FORK_RESET_SIGNALS|FORK_DEATHSIG|FORK_CLOSE_ALL_FDS|FORK_LOG, &pid); | ||||||||||
956 | if (r < 0) | ||||||||||
957 | goto finish; | ||||||||||
958 | if (r == 0) { | ||||||||||
959 | execlp(arg_debugger, arg_debugger, exe, "-c", path, NULL((void*)0)); | ||||||||||
960 | log_open(); | ||||||||||
961 | log_error_errno(errno, "Failed to invoke %s: %m", arg_debugger)({ int _level = ((3)), _e = (((*__errno_location ()))), _realm = (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >= ((_level) & 0x07)) ? log_internal_realm(((_realm) << 10 | (_level)), _e, "../src/coredump/coredumpctl.c", 961, __func__ , "Failed to invoke %s: %m", arg_debugger) : -abs(_e); }); | ||||||||||
962 | _exit(EXIT_FAILURE1); | ||||||||||
963 | } | ||||||||||
964 | |||||||||||
965 | r = wait_for_terminate_and_check(arg_debugger, pid, WAIT_LOG_ABNORMAL); | ||||||||||
966 | |||||||||||
967 | finish: | ||||||||||
968 | (void) default_signals(SIGINT2, -1); | ||||||||||
969 | |||||||||||
970 | if (unlink_path) { | ||||||||||
971 | log_debug("Removed temporary file %s", path)({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 971, __func__, "Removed temporary file %s" , path) : -abs(_e); }); | ||||||||||
972 | unlink(path); | ||||||||||
973 | } | ||||||||||
974 | |||||||||||
975 | return r; | ||||||||||
976 | } | ||||||||||
977 | |||||||||||
978 | static int check_units_active(void) { | ||||||||||
979 | _cleanup_(sd_bus_unrefp)__attribute__((cleanup(sd_bus_unrefp))) sd_bus *bus = NULL((void*)0); | ||||||||||
980 | _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = NULL((void*)0); | ||||||||||
981 | _cleanup_(sd_bus_error_free)__attribute__((cleanup(sd_bus_error_free))) sd_bus_error error = SD_BUS_ERROR_NULL((const sd_bus_error) {(((void*)0)), (((void*)0)), 0}); | ||||||||||
982 | _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *reply = NULL((void*)0); | ||||||||||
983 | int c = 0, r; | ||||||||||
984 | const char *id, *state, *substate; | ||||||||||
985 | |||||||||||
986 | if (arg_quiet) | ||||||||||
987 | return false0; | ||||||||||
988 | |||||||||||
989 | r = sd_bus_default_system(&bus); | ||||||||||
990 | if (r < 0) | ||||||||||
991 | return log_error_errno(r, "Failed to acquire bus: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 991, __func__, "Failed to acquire bus: %m" ) : -abs(_e); }); | ||||||||||
992 | |||||||||||
993 | r = sd_bus_message_new_method_call( | ||||||||||
994 | bus, | ||||||||||
995 | &m, | ||||||||||
996 | "org.freedesktop.systemd1", | ||||||||||
997 | "/org/freedesktop/systemd1", | ||||||||||
998 | "org.freedesktop.systemd1.Manager", | ||||||||||
999 | "ListUnitsByPatterns"); | ||||||||||
1000 | if (r < 0) | ||||||||||
1001 | return bus_log_create_error(r); | ||||||||||
1002 | |||||||||||
1003 | r = sd_bus_message_append_strv(m, NULL((void*)0)); | ||||||||||
1004 | if (r < 0) | ||||||||||
1005 | return bus_log_create_error(r); | ||||||||||
1006 | |||||||||||
1007 | r = sd_bus_message_append_strv(m, STRV_MAKE("systemd-coredump@*.service")((char**) ((const char*[]) { "systemd-coredump@*.service", (( void*)0) }))); | ||||||||||
1008 | if (r < 0) | ||||||||||
1009 | return bus_log_create_error(r); | ||||||||||
1010 | |||||||||||
1011 | r = sd_bus_call(bus, m, SHORT_BUS_CALL_TIMEOUT_USEC(3 * ((usec_t) 1000000ULL)), &error, &reply); | ||||||||||
1012 | if (r < 0) | ||||||||||
1013 | return log_error_errno(r, "Failed to check if any systemd-coredump@.service units are running: %s",({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 1014, __func__, "Failed to check if any systemd-coredump@.service units are running: %s" , bus_error_message(&error, r)) : -abs(_e); }) | ||||||||||
1014 | bus_error_message(&error, r))({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 1014, __func__, "Failed to check if any systemd-coredump@.service units are running: %s" , bus_error_message(&error, r)) : -abs(_e); }); | ||||||||||
1015 | |||||||||||
1016 | r = sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "(ssssssouso)"); | ||||||||||
1017 | if (r < 0) | ||||||||||
1018 | return bus_log_parse_error(r); | ||||||||||
1019 | |||||||||||
1020 | while ((r = sd_bus_message_read( | ||||||||||
1021 | reply, "(ssssssouso)", | ||||||||||
1022 | &id, NULL((void*)0), NULL((void*)0), &state, &substate, | ||||||||||
1023 | NULL((void*)0), NULL((void*)0), NULL((void*)0), NULL((void*)0), NULL((void*)0))) > 0) { | ||||||||||
1024 | bool_Bool found = !STR_IN_SET(state, "inactive", "dead", "failed")(!!strv_find((((char**) ((const char*[]) { "inactive", "dead" , "failed", ((void*)0) }))), (state))); | ||||||||||
1025 | log_debug("Unit %s is %s/%s, %scounting it.", id, state, substate, found ? "" : "not ")({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD ); (log_get_max_level_realm(_realm) >= ((_level) & 0x07 )) ? log_internal_realm(((_realm) << 10 | (_level)), _e , "../src/coredump/coredumpctl.c", 1025, __func__, "Unit %s is %s/%s, %scounting it." , id, state, substate, found ? "" : "not ") : -abs(_e); }); | ||||||||||
1026 | c += found; | ||||||||||
1027 | } | ||||||||||
1028 | if (r < 0) | ||||||||||
1029 | return bus_log_parse_error(r); | ||||||||||
1030 | |||||||||||
1031 | r = sd_bus_message_exit_container(reply); | ||||||||||
1032 | if (r < 0) | ||||||||||
1033 | return bus_log_parse_error(r); | ||||||||||
1034 | |||||||||||
1035 | return c; | ||||||||||
1036 | } | ||||||||||
1037 | |||||||||||
1038 | static int coredumpctl_main(int argc, char *argv[]) { | ||||||||||
1039 | |||||||||||
1040 | static const Verb verbs[] = { | ||||||||||
1041 | { "list", VERB_ANY((unsigned) -1), VERB_ANY((unsigned) -1), VERB_DEFAULT, dump_list }, | ||||||||||
1042 | { "info", VERB_ANY((unsigned) -1), VERB_ANY((unsigned) -1), 0, dump_list }, | ||||||||||
1043 | { "dump", VERB_ANY((unsigned) -1), VERB_ANY((unsigned) -1), 0, dump_core }, | ||||||||||
1044 | { "debug", VERB_ANY((unsigned) -1), VERB_ANY((unsigned) -1), 0, run_debug }, | ||||||||||
1045 | { "gdb", VERB_ANY((unsigned) -1), VERB_ANY((unsigned) -1), 0, run_debug }, | ||||||||||
1046 | {} | ||||||||||
1047 | }; | ||||||||||
1048 | |||||||||||
1049 | return dispatch_verb(argc, argv, verbs, NULL((void*)0)); | ||||||||||
1050 | } | ||||||||||
1051 | |||||||||||
1052 | int main(int argc, char *argv[]) { | ||||||||||
1053 | int r, units_active; | ||||||||||
1054 | |||||||||||
1055 | setlocale(LC_ALL6, ""); | ||||||||||
1056 | log_parse_environment()log_parse_environment_realm(LOG_REALM_SYSTEMD); | ||||||||||
1057 | log_open(); | ||||||||||
1058 | |||||||||||
1059 | r = parse_argv(argc, argv); | ||||||||||
1060 | if (r <= 0) | ||||||||||
1061 | goto end; | ||||||||||
1062 | |||||||||||
1063 | sigbus_install(); | ||||||||||
1064 | |||||||||||
1065 | units_active = check_units_active(); /* error is treated the same as 0 */ | ||||||||||
1066 | |||||||||||
1067 | r = coredumpctl_main(argc, argv); | ||||||||||
1068 | |||||||||||
1069 | if (units_active > 0) | ||||||||||
1070 | printf("%s-- Notice: %d systemd-coredump@.service %s, output may be incomplete.%s\n", | ||||||||||
1071 | ansi_highlight_red(), | ||||||||||
1072 | units_active, units_active == 1 ? "unit is running" : "units are running", | ||||||||||
1073 | ansi_normal()); | ||||||||||
1074 | end: | ||||||||||
1075 | pager_close(); | ||||||||||
1076 | |||||||||||
1077 | safe_fclose(arg_output); | ||||||||||
1078 | |||||||||||
1079 | return r >= 0 ? r : EXIT_FAILURE1; | ||||||||||
1080 | } |