Branch data Line data Source code
1 : : /* SPDX-License-Identifier: LGPL-2.1+ */
2 : : /***
3 : : Copyright © 2014 Holger Hans Peter Freyther
4 : : ***/
5 : :
6 : : #include <errno.h>
7 : : #include <fcntl.h>
8 : : #include <stdbool.h>
9 : : #include <stdio.h>
10 : : #include <sys/file.h>
11 : : #include <sys/prctl.h>
12 : : #include <sys/stat.h>
13 : : #include <unistd.h>
14 : :
15 : : #include "sd-bus.h"
16 : : #include "sd-device.h"
17 : :
18 : : #include "alloc-util.h"
19 : : #include "bus-common-errors.h"
20 : : #include "bus-error.h"
21 : : #include "bus-util.h"
22 : : #include "device-util.h"
23 : : #include "fd-util.h"
24 : : #include "fs-util.h"
25 : : #include "fsck-util.h"
26 : : #include "main-func.h"
27 : : #include "parse-util.h"
28 : : #include "path-util.h"
29 : : #include "proc-cmdline.h"
30 : : #include "process-util.h"
31 : : #include "rlimit-util.h"
32 : : #include "signal-util.h"
33 : : #include "socket-util.h"
34 : : #include "special.h"
35 : : #include "stdio-util.h"
36 : : #include "util.h"
37 : :
38 : : static bool arg_skip = false;
39 : : static bool arg_force = false;
40 : : static bool arg_show_progress = false;
41 : : static const char *arg_repair = "-a";
42 : :
43 : 0 : static void start_target(const char *target, const char *mode) {
44 [ # # ]: 0 : _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
45 [ # # ]: 0 : _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
46 : : int r;
47 : :
48 [ # # ]: 0 : assert(target);
49 : :
50 : 0 : r = bus_connect_system_systemd(&bus);
51 [ # # ]: 0 : if (r < 0) {
52 [ # # ]: 0 : log_error_errno(r, "Failed to get D-Bus connection: %m");
53 : 0 : return;
54 : : }
55 : :
56 [ # # ]: 0 : log_info("Running request %s/start/replace", target);
57 : :
58 : : /* Start these units only if we can replace base.target with it */
59 : 0 : r = sd_bus_call_method(bus,
60 : : "org.freedesktop.systemd1",
61 : : "/org/freedesktop/systemd1",
62 : : "org.freedesktop.systemd1.Manager",
63 : : "StartUnitReplace",
64 : : &error,
65 : : NULL,
66 : : "sss", "basic.target", target, mode);
67 : :
68 : : /* Don't print a warning if we aren't called during startup */
69 [ # # # # ]: 0 : if (r < 0 && !sd_bus_error_has_name(&error, BUS_ERROR_NO_SUCH_JOB))
70 [ # # ]: 0 : log_error("Failed to start unit: %s", bus_error_message(&error, r));
71 : : }
72 : :
73 : 0 : static int parse_proc_cmdline_item(const char *key, const char *value, void *data) {
74 : : int r;
75 : :
76 [ # # ]: 0 : assert(key);
77 : :
78 [ # # ]: 0 : if (streq(key, "fsck.mode")) {
79 : :
80 [ # # ]: 0 : if (proc_cmdline_value_missing(key, value))
81 : 0 : return 0;
82 : :
83 [ # # ]: 0 : if (streq(value, "auto"))
84 : 0 : arg_force = arg_skip = false;
85 [ # # ]: 0 : else if (streq(value, "force"))
86 : 0 : arg_force = true;
87 [ # # ]: 0 : else if (streq(value, "skip"))
88 : 0 : arg_skip = true;
89 : : else
90 [ # # ]: 0 : log_warning("Invalid fsck.mode= parameter '%s'. Ignoring.", value);
91 : :
92 [ # # ]: 0 : } else if (streq(key, "fsck.repair")) {
93 : :
94 [ # # ]: 0 : if (proc_cmdline_value_missing(key, value))
95 : 0 : return 0;
96 : :
97 [ # # ]: 0 : if (streq(value, "preen"))
98 : 0 : arg_repair = "-a";
99 : : else {
100 : 0 : r = parse_boolean(value);
101 [ # # ]: 0 : if (r > 0)
102 : 0 : arg_repair = "-y";
103 [ # # ]: 0 : else if (r == 0)
104 : 0 : arg_repair = "-n";
105 : : else
106 [ # # ]: 0 : log_warning("Invalid fsck.repair= parameter '%s'. Ignoring.", value);
107 : : }
108 : : }
109 : :
110 : : #if HAVE_SYSV_COMPAT
111 [ # # # # ]: 0 : else if (streq(key, "fastboot") && !value) {
112 [ # # ]: 0 : log_warning("Please pass 'fsck.mode=skip' rather than 'fastboot' on the kernel command line.");
113 : 0 : arg_skip = true;
114 : :
115 [ # # # # ]: 0 : } else if (streq(key, "forcefsck") && !value) {
116 [ # # ]: 0 : log_warning("Please pass 'fsck.mode=force' rather than 'forcefsck' on the kernel command line.");
117 : 0 : arg_force = true;
118 : : }
119 : : #endif
120 : :
121 : 0 : return 0;
122 : : }
123 : :
124 : 0 : static void test_files(void) {
125 : :
126 : : #if HAVE_SYSV_COMPAT
127 [ # # ]: 0 : if (access("/fastboot", F_OK) >= 0) {
128 [ # # ]: 0 : log_error("Please pass 'fsck.mode=skip' on the kernel command line rather than creating /fastboot on the root file system.");
129 : 0 : arg_skip = true;
130 : : }
131 : :
132 [ # # ]: 0 : if (access("/forcefsck", F_OK) >= 0) {
133 [ # # ]: 0 : log_error("Please pass 'fsck.mode=force' on the kernel command line rather than creating /forcefsck on the root file system.");
134 : 0 : arg_force = true;
135 : : }
136 : : #endif
137 : :
138 : 0 : arg_show_progress = access("/run/systemd/show-status", F_OK) >= 0;
139 : 0 : }
140 : :
141 : 0 : static double percent(int pass, unsigned long cur, unsigned long max) {
142 : : /* Values stolen from e2fsck */
143 : :
144 : : static const int pass_table[] = {
145 : : 0, 70, 90, 92, 95, 100
146 : : };
147 : :
148 [ # # ]: 0 : if (pass <= 0)
149 : 0 : return 0.0;
150 : :
151 [ # # # # ]: 0 : if ((unsigned) pass >= ELEMENTSOF(pass_table) || max == 0)
152 : 0 : return 100.0;
153 : :
154 : 0 : return (double) pass_table[pass-1] +
155 : 0 : ((double) pass_table[pass] - (double) pass_table[pass-1]) *
156 : 0 : (double) cur / (double) max;
157 : : }
158 : :
159 : 0 : static int process_progress(int fd) {
160 : 0 : _cleanup_fclose_ FILE *console = NULL, *f = NULL;
161 : 0 : usec_t last = 0;
162 : 0 : bool locked = false;
163 : 0 : int clear = 0, r;
164 : :
165 : : /* No progress pipe to process? Then we are a NOP. */
166 [ # # ]: 0 : if (fd < 0)
167 : 0 : return 0;
168 : :
169 : 0 : f = fdopen(fd, "r");
170 [ # # ]: 0 : if (!f) {
171 : 0 : safe_close(fd);
172 [ # # ]: 0 : return log_debug_errno(errno, "Failed to use pipe: %m");
173 : : }
174 : :
175 : 0 : console = fopen("/dev/console", "we");
176 [ # # ]: 0 : if (!console)
177 [ # # ]: 0 : return log_debug_errno(errno, "Failed to open /dev/console, can't print progress output: %m");
178 : :
179 : 0 : for (;;) {
180 : : int pass, m;
181 : : unsigned long cur, max;
182 [ # # # ]: 0 : _cleanup_free_ char *device = NULL;
183 : : double p;
184 : : usec_t t;
185 : :
186 [ # # ]: 0 : if (fscanf(f, "%i %lu %lu %ms", &pass, &cur, &max, &device) != 4) {
187 : :
188 [ # # ]: 0 : if (ferror(f))
189 [ # # ]: 0 : r = log_warning_errno(errno, "Failed to read from progress pipe: %m");
190 [ # # ]: 0 : else if (feof(f))
191 : 0 : r = 0;
192 : : else
193 [ # # ]: 0 : r = log_warning_errno(SYNTHETIC_ERRNO(errno), "Failed to parse progress pipe data");
194 : :
195 : 0 : break;
196 : : }
197 : :
198 : : /* Only show one progress counter at max */
199 [ # # ]: 0 : if (!locked) {
200 [ # # ]: 0 : if (flock(fileno(console), LOCK_EX|LOCK_NB) < 0)
201 : 0 : continue;
202 : :
203 : 0 : locked = true;
204 : : }
205 : :
206 : : /* Only update once every 50ms */
207 : 0 : t = now(CLOCK_MONOTONIC);
208 [ # # ]: 0 : if (last + 50 * USEC_PER_MSEC > t)
209 : 0 : continue;
210 : :
211 : 0 : last = t;
212 : :
213 : 0 : p = percent(pass, cur, max);
214 : 0 : fprintf(console, "\r%s: fsck %3.1f%% complete...\r%n", device, p, &m);
215 : 0 : fflush(console);
216 : :
217 [ # # ]: 0 : if (m > clear)
218 : 0 : clear = m;
219 : : }
220 : :
221 [ # # ]: 0 : if (clear > 0) {
222 : : unsigned j;
223 : :
224 : 0 : fputc('\r', console);
225 [ # # ]: 0 : for (j = 0; j < (unsigned) clear; j++)
226 : 0 : fputc(' ', console);
227 : 0 : fputc('\r', console);
228 : 0 : fflush(console);
229 : : }
230 : :
231 : 0 : return r;
232 : : }
233 : :
234 : 0 : static int fsck_progress_socket(void) {
235 : : static const union sockaddr_union sa = {
236 : : .un.sun_family = AF_UNIX,
237 : : .un.sun_path = "/run/systemd/fsck.progress",
238 : : };
239 : :
240 : 0 : _cleanup_close_ int fd = -1;
241 : :
242 : 0 : fd = socket(AF_UNIX, SOCK_STREAM, 0);
243 [ # # ]: 0 : if (fd < 0)
244 [ # # ]: 0 : return log_warning_errno(errno, "socket(): %m");
245 : :
246 [ # # # # : 0 : if (connect(fd, &sa.sa, SOCKADDR_UN_LEN(sa.un)) < 0)
# # ]
247 [ # # # # : 0 : return log_full_errno(IN_SET(errno, ECONNREFUSED, ENOENT) ? LOG_DEBUG : LOG_WARNING,
# # ]
248 : : errno, "Failed to connect to progress socket %s, ignoring: %m", sa.un.sun_path);
249 : :
250 : 0 : return TAKE_FD(fd);
251 : : }
252 : :
253 : 0 : static int run(int argc, char *argv[]) {
254 : 0 : _cleanup_close_pair_ int progress_pipe[2] = { -1, -1 };
255 : 0 : _cleanup_(sd_device_unrefp) sd_device *dev = NULL;
256 : 0 : _cleanup_free_ char *dpath = NULL;
257 : : const char *device, *type;
258 : : bool root_directory;
259 : : struct stat st;
260 : : int r, exit_status;
261 : : pid_t pid;
262 : :
263 : 0 : log_setup_service();
264 : :
265 [ # # ]: 0 : if (argc > 2) {
266 [ # # ]: 0 : log_error("This program expects one or no arguments.");
267 : 0 : return -EINVAL;
268 : : }
269 : :
270 : 0 : umask(0022);
271 : :
272 : 0 : r = proc_cmdline_parse(parse_proc_cmdline_item, NULL, PROC_CMDLINE_STRIP_RD_PREFIX);
273 [ # # ]: 0 : if (r < 0)
274 [ # # ]: 0 : log_warning_errno(r, "Failed to parse kernel command line, ignoring: %m");
275 : :
276 : 0 : test_files();
277 : :
278 [ # # # # ]: 0 : if (!arg_force && arg_skip)
279 : 0 : return 0;
280 : :
281 [ # # ]: 0 : if (argc > 1) {
282 : 0 : dpath = strdup(argv[1]);
283 [ # # ]: 0 : if (!dpath)
284 : 0 : return log_oom();
285 : :
286 : 0 : device = dpath;
287 : :
288 [ # # ]: 0 : if (stat(device, &st) < 0)
289 [ # # ]: 0 : return log_error_errno(errno, "Failed to stat %s: %m", device);
290 : :
291 [ # # ]: 0 : if (!S_ISBLK(st.st_mode)) {
292 [ # # ]: 0 : log_error("%s is not a block device.", device);
293 : 0 : return -EINVAL;
294 : : }
295 : :
296 : 0 : r = sd_device_new_from_devnum(&dev, 'b', st.st_rdev);
297 [ # # ]: 0 : if (r < 0)
298 [ # # ]: 0 : return log_error_errno(r, "Failed to detect device %s: %m", device);
299 : :
300 : 0 : root_directory = false;
301 : : } else {
302 : : struct timespec times[2];
303 : :
304 : : /* Find root device */
305 : :
306 [ # # ]: 0 : if (stat("/", &st) < 0)
307 [ # # ]: 0 : return log_error_errno(errno, "Failed to stat() the root directory: %m");
308 : :
309 : : /* Virtual root devices don't need an fsck */
310 [ # # ]: 0 : if (major(st.st_dev) == 0) {
311 [ # # ]: 0 : log_debug("Root directory is virtual or btrfs, skipping check.");
312 : 0 : return 0;
313 : : }
314 : :
315 : : /* check if we are already writable */
316 : 0 : times[0] = st.st_atim;
317 : 0 : times[1] = st.st_mtim;
318 : :
319 [ # # ]: 0 : if (utimensat(AT_FDCWD, "/", times, 0) == 0) {
320 [ # # ]: 0 : log_info("Root directory is writable, skipping check.");
321 : 0 : return 0;
322 : : }
323 : :
324 : 0 : r = sd_device_new_from_devnum(&dev, 'b', st.st_dev);
325 [ # # ]: 0 : if (r < 0)
326 [ # # ]: 0 : return log_error_errno(r, "Failed to detect root device: %m");
327 : :
328 : 0 : r = sd_device_get_devname(dev, &device);
329 [ # # ]: 0 : if (r < 0)
330 [ # # # # : 0 : return log_device_error_errno(dev, r, "Failed to detect device node of root directory: %m");
# # ]
331 : :
332 : 0 : root_directory = true;
333 : : }
334 : :
335 [ # # ]: 0 : if (sd_device_get_property_value(dev, "ID_FS_TYPE", &type) >= 0) {
336 : 0 : r = fsck_exists(type);
337 [ # # ]: 0 : if (r < 0)
338 [ # # # # : 0 : log_device_warning_errno(dev, r, "Couldn't detect if fsck.%s may be used, proceeding: %m", type);
# # ]
339 [ # # ]: 0 : else if (r == 0) {
340 [ # # # # : 0 : log_device_info(dev, "fsck.%s doesn't exist, not checking file system.", type);
# # ]
341 : 0 : return 0;
342 : : }
343 : : }
344 : :
345 [ # # # # ]: 0 : if (arg_show_progress &&
346 : 0 : pipe(progress_pipe) < 0)
347 [ # # ]: 0 : return log_error_errno(errno, "pipe(): %m");
348 : :
349 : 0 : r = safe_fork("(fsck)", FORK_RESET_SIGNALS|FORK_DEATHSIG|FORK_LOG, &pid);
350 [ # # ]: 0 : if (r < 0)
351 : 0 : return r;
352 [ # # ]: 0 : if (r == 0) {
353 : : char dash_c[STRLEN("-C") + DECIMAL_STR_MAX(int) + 1];
354 : 0 : int progress_socket = -1;
355 : : const char *cmdline[9];
356 : 0 : int i = 0;
357 : :
358 : : /* Child */
359 : :
360 : : /* Close the reading side of the progress pipe */
361 : 0 : progress_pipe[0] = safe_close(progress_pipe[0]);
362 : :
363 : : /* Try to connect to a progress management daemon, if there is one */
364 : 0 : progress_socket = fsck_progress_socket();
365 [ # # ]: 0 : if (progress_socket >= 0) {
366 : : /* If this worked we close the progress pipe early, and just use the socket */
367 : 0 : progress_pipe[1] = safe_close(progress_pipe[1]);
368 [ # # ]: 0 : xsprintf(dash_c, "-C%i", progress_socket);
369 [ # # ]: 0 : } else if (progress_pipe[1] >= 0) {
370 : : /* Otherwise if we have the progress pipe to our own local handle, we use it */
371 [ # # ]: 0 : xsprintf(dash_c, "-C%i", progress_pipe[1]);
372 : : } else
373 : 0 : dash_c[0] = 0;
374 : :
375 : 0 : cmdline[i++] = "/sbin/fsck";
376 : 0 : cmdline[i++] = arg_repair;
377 : 0 : cmdline[i++] = "-T";
378 : :
379 : : /*
380 : : * Since util-linux v2.25 fsck uses /run/fsck/<diskname>.lock files.
381 : : * The previous versions use flock for the device and conflict with
382 : : * udevd, see https://bugs.freedesktop.org/show_bug.cgi?id=79576#c5
383 : : */
384 : 0 : cmdline[i++] = "-l";
385 : :
386 [ # # ]: 0 : if (!root_directory)
387 : 0 : cmdline[i++] = "-M";
388 : :
389 [ # # ]: 0 : if (arg_force)
390 : 0 : cmdline[i++] = "-f";
391 : :
392 [ # # ]: 0 : if (!isempty(dash_c))
393 : 0 : cmdline[i++] = dash_c;
394 : :
395 : 0 : cmdline[i++] = device;
396 : 0 : cmdline[i++] = NULL;
397 : :
398 : 0 : (void) rlimit_nofile_safe();
399 : :
400 : 0 : execv(cmdline[0], (char**) cmdline);
401 : 0 : _exit(FSCK_OPERATIONAL_ERROR);
402 : : }
403 : :
404 : 0 : progress_pipe[1] = safe_close(progress_pipe[1]);
405 : 0 : (void) process_progress(TAKE_FD(progress_pipe[0]));
406 : :
407 : 0 : exit_status = wait_for_terminate_and_check("fsck", pid, WAIT_LOG_ABNORMAL);
408 [ # # ]: 0 : if (exit_status < 0)
409 : 0 : return exit_status;
410 [ # # ]: 0 : if ((exit_status & ~FSCK_ERROR_CORRECTED) != FSCK_SUCCESS) {
411 [ # # ]: 0 : log_error("fsck failed with exit status %i.", exit_status);
412 : :
413 [ # # # # ]: 0 : if ((exit_status & FSCK_SYSTEM_SHOULD_REBOOT) && root_directory) {
414 : : /* System should be rebooted. */
415 : 0 : start_target(SPECIAL_REBOOT_TARGET, "replace-irreversibly");
416 : 0 : return -EINVAL;
417 [ # # ]: 0 : } else if (exit_status & (FSCK_SYSTEM_SHOULD_REBOOT | FSCK_ERRORS_LEFT_UNCORRECTED))
418 : : /* Some other problem */
419 : 0 : start_target(SPECIAL_EMERGENCY_TARGET, "replace");
420 : : else
421 [ # # ]: 0 : log_warning("Ignoring error.");
422 : : }
423 : :
424 [ # # ]: 0 : if (exit_status & FSCK_ERROR_CORRECTED)
425 : 0 : (void) touch("/run/systemd/quotacheck");
426 : :
427 : 0 : return !!(exit_status & (FSCK_SYSTEM_SHOULD_REBOOT | FSCK_ERRORS_LEFT_UNCORRECTED));
428 : : }
429 : :
430 [ # # ]: 0 : DEFINE_MAIN_FUNCTION_WITH_POSITIVE_FAILURE(run);
|
