File: | build-scan/../src/coredump/coredumpctl.c |
Warning: | line 380, column 24 Potential leak of memory pointed to by 'sgnl' |
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 < ident) | ||||||||
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 | } |