1 /* SPDX-License-Identifier: LGPL-2.1+ */
3 Copyright © 2014 Holger Hans Peter Freyther
10 #include <sys/prctl.h>
15 #include "sd-device.h"
17 #include "alloc-util.h"
18 #include "bus-common-errors.h"
19 #include "bus-error.h"
21 #include "device-util.h"
24 #include "fsck-util.h"
25 #include "main-func.h"
26 #include "parse-util.h"
27 #include "path-util.h"
28 #include "proc-cmdline.h"
29 #include "process-util.h"
30 #include "rlimit-util.h"
31 #include "signal-util.h"
32 #include "socket-util.h"
34 #include "stdio-util.h"
37 static bool arg_skip
= false;
38 static bool arg_force
= false;
39 static bool arg_show_progress
= false;
40 static const char *arg_repair
= "-a";
42 static void start_target(const char *target
, const char *mode
) {
43 _cleanup_(sd_bus_error_free
) sd_bus_error error
= SD_BUS_ERROR_NULL
;
44 _cleanup_(sd_bus_flush_close_unrefp
) sd_bus
*bus
= NULL
;
49 r
= bus_connect_system_systemd(&bus
);
51 log_error_errno(r
, "Failed to get D-Bus connection: %m");
55 log_info("Running request %s/start/replace", target
);
57 /* Start these units only if we can replace base.target with it */
58 r
= sd_bus_call_method(bus
,
59 "org.freedesktop.systemd1",
60 "/org/freedesktop/systemd1",
61 "org.freedesktop.systemd1.Manager",
65 "sss", "basic.target", target
, mode
);
67 /* Don't print a warning if we aren't called during startup */
68 if (r
< 0 && !sd_bus_error_has_name(&error
, BUS_ERROR_NO_SUCH_JOB
))
69 log_error("Failed to start unit: %s", bus_error_message(&error
, r
));
72 static int parse_proc_cmdline_item(const char *key
, const char *value
, void *data
) {
77 if (streq(key
, "fsck.mode")) {
79 if (proc_cmdline_value_missing(key
, value
))
82 if (streq(value
, "auto"))
83 arg_force
= arg_skip
= false;
84 else if (streq(value
, "force"))
86 else if (streq(value
, "skip"))
89 log_warning("Invalid fsck.mode= parameter '%s'. Ignoring.", value
);
91 } else if (streq(key
, "fsck.repair")) {
93 if (proc_cmdline_value_missing(key
, value
))
96 if (streq(value
, "preen"))
99 r
= parse_boolean(value
);
105 log_warning("Invalid fsck.repair= parameter '%s'. Ignoring.", value
);
110 else if (streq(key
, "fastboot") && !value
) {
111 log_warning("Please pass 'fsck.mode=skip' rather than 'fastboot' on the kernel command line.");
114 } else if (streq(key
, "forcefsck") && !value
) {
115 log_warning("Please pass 'fsck.mode=force' rather than 'forcefsck' on the kernel command line.");
123 static void test_files(void) {
126 if (access("/fastboot", F_OK
) >= 0) {
127 log_error("Please pass 'fsck.mode=skip' on the kernel command line rather than creating /fastboot on the root file system.");
131 if (access("/forcefsck", F_OK
) >= 0) {
132 log_error("Please pass 'fsck.mode=force' on the kernel command line rather than creating /forcefsck on the root file system.");
137 arg_show_progress
= access("/run/systemd/show-status", F_OK
) >= 0;
140 static double percent(int pass
, unsigned long cur
, unsigned long max
) {
141 /* Values stolen from e2fsck */
143 static const int pass_table
[] = {
144 0, 70, 90, 92, 95, 100
150 if ((unsigned) pass
>= ELEMENTSOF(pass_table
) || max
== 0)
153 return (double) pass_table
[pass
-1] +
154 ((double) pass_table
[pass
] - (double) pass_table
[pass
-1]) *
155 (double) cur
/ (double) max
;
158 static int process_progress(int fd
, FILE* console
) {
159 _cleanup_fclose_
FILE *f
= NULL
;
164 /* No progress pipe to process? Then we are a NOP. */
171 return log_debug_errno(errno
, "Failed to use pipe: %m");
176 unsigned long cur
, max
;
177 _cleanup_free_
char *device
= NULL
;
181 if (fscanf(f
, "%i %lu %lu %ms", &pass
, &cur
, &max
, &device
) != 4) {
184 r
= log_warning_errno(errno
, "Failed to read from progress pipe: %m");
188 r
= log_warning_errno(SYNTHETIC_ERRNO(errno
), "Failed to parse progress pipe data");
193 /* Only show one progress counter at max */
195 if (flock(fileno(console
), LOCK_EX
|LOCK_NB
) < 0)
201 /* Only update once every 50ms */
202 t
= now(CLOCK_MONOTONIC
);
203 if (last
+ 50 * USEC_PER_MSEC
> t
)
208 p
= percent(pass
, cur
, max
);
209 fprintf(console
, "\r%s: fsck %3.1f%% complete...\r%n", device
, p
, &m
);
219 fputc('\r', console
);
220 for (j
= 0; j
< (unsigned) clear
; j
++)
222 fputc('\r', console
);
229 static int fsck_progress_socket(void) {
230 static const union sockaddr_union sa
= {
231 .un
.sun_family
= AF_UNIX
,
232 .un
.sun_path
= "/run/systemd/fsck.progress",
235 _cleanup_close_
int fd
= -1;
237 fd
= socket(AF_UNIX
, SOCK_STREAM
, 0);
239 return log_warning_errno(errno
, "socket(): %m");
241 if (connect(fd
, &sa
.sa
, SOCKADDR_UN_LEN(sa
.un
)) < 0)
242 return log_full_errno(IN_SET(errno
, ECONNREFUSED
, ENOENT
) ? LOG_DEBUG
: LOG_WARNING
,
243 errno
, "Failed to connect to progress socket %s, ignoring: %m", sa
.un
.sun_path
);
248 static int run(int argc
, char *argv
[]) {
249 _cleanup_close_pair_
int progress_pipe
[2] = { -1, -1 };
250 _cleanup_(sd_device_unrefp
) sd_device
*dev
= NULL
;
251 _cleanup_free_
char *dpath
= NULL
;
252 _cleanup_fclose_
FILE *console
= NULL
;
253 const char *device
, *type
;
262 return log_error_errno(SYNTHETIC_ERRNO(EINVAL
),
263 "This program expects one or no arguments.");
267 r
= proc_cmdline_parse(parse_proc_cmdline_item
, NULL
, PROC_CMDLINE_STRIP_RD_PREFIX
);
269 log_warning_errno(r
, "Failed to parse kernel command line, ignoring: %m");
273 if (!arg_force
&& arg_skip
)
277 dpath
= strdup(argv
[1]);
283 if (stat(device
, &st
) < 0)
284 return log_error_errno(errno
, "Failed to stat %s: %m", device
);
286 if (!S_ISBLK(st
.st_mode
))
287 return log_error_errno(SYNTHETIC_ERRNO(EINVAL
),
288 "%s is not a block device.",
291 r
= sd_device_new_from_devnum(&dev
, 'b', st
.st_rdev
);
293 return log_error_errno(r
, "Failed to detect device %s: %m", device
);
295 root_directory
= false;
297 struct timespec times
[2];
299 /* Find root device */
301 if (stat("/", &st
) < 0)
302 return log_error_errno(errno
, "Failed to stat() the root directory: %m");
304 /* Virtual root devices don't need an fsck */
305 if (major(st
.st_dev
) == 0) {
306 log_debug("Root directory is virtual or btrfs, skipping check.");
310 /* check if we are already writable */
311 times
[0] = st
.st_atim
;
312 times
[1] = st
.st_mtim
;
314 if (utimensat(AT_FDCWD
, "/", times
, 0) == 0) {
315 log_info("Root directory is writable, skipping check.");
319 r
= sd_device_new_from_devnum(&dev
, 'b', st
.st_dev
);
321 return log_error_errno(r
, "Failed to detect root device: %m");
323 r
= sd_device_get_devname(dev
, &device
);
325 return log_device_error_errno(dev
, r
, "Failed to detect device node of root directory: %m");
327 root_directory
= true;
330 if (sd_device_get_property_value(dev
, "ID_FS_TYPE", &type
) >= 0) {
331 r
= fsck_exists(type
);
333 log_device_warning_errno(dev
, r
, "Couldn't detect if fsck.%s may be used, proceeding: %m", type
);
335 log_device_info(dev
, "fsck.%s doesn't exist, not checking file system.", type
);
340 console
= fopen("/dev/console", "we");
343 pipe(progress_pipe
) < 0)
344 return log_error_errno(errno
, "pipe(): %m");
346 r
= safe_fork("(fsck)", FORK_RESET_SIGNALS
|FORK_DEATHSIG
|FORK_LOG
, &pid
);
350 char dash_c
[STRLEN("-C") + DECIMAL_STR_MAX(int) + 1];
351 int progress_socket
= -1;
352 const char *cmdline
[9];
357 /* Close the reading side of the progress pipe */
358 progress_pipe
[0] = safe_close(progress_pipe
[0]);
360 /* Try to connect to a progress management daemon, if there is one */
361 progress_socket
= fsck_progress_socket();
362 if (progress_socket
>= 0) {
363 /* If this worked we close the progress pipe early, and just use the socket */
364 progress_pipe
[1] = safe_close(progress_pipe
[1]);
365 xsprintf(dash_c
, "-C%i", progress_socket
);
366 } else if (progress_pipe
[1] >= 0) {
367 /* Otherwise if we have the progress pipe to our own local handle, we use it */
368 xsprintf(dash_c
, "-C%i", progress_pipe
[1]);
372 cmdline
[i
++] = "/sbin/fsck";
373 cmdline
[i
++] = arg_repair
;
377 * Since util-linux v2.25 fsck uses /run/fsck/<diskname>.lock files.
378 * The previous versions use flock for the device and conflict with
379 * udevd, see https://bugs.freedesktop.org/show_bug.cgi?id=79576#c5
389 if (!isempty(dash_c
))
390 cmdline
[i
++] = dash_c
;
392 cmdline
[i
++] = device
;
395 (void) rlimit_nofile_safe();
397 execv(cmdline
[0], (char**) cmdline
);
398 _exit(FSCK_OPERATIONAL_ERROR
);
402 progress_pipe
[1] = safe_close(progress_pipe
[1]);
403 (void) process_progress(TAKE_FD(progress_pipe
[0]), console
);
406 exit_status
= wait_for_terminate_and_check("fsck", pid
, WAIT_LOG_ABNORMAL
);
409 if ((exit_status
& ~FSCK_ERROR_CORRECTED
) != FSCK_SUCCESS
) {
410 log_error("fsck failed with exit status %i.", exit_status
);
412 if ((exit_status
& FSCK_SYSTEM_SHOULD_REBOOT
) && root_directory
) {
413 /* System should be rebooted. */
414 start_target(SPECIAL_REBOOT_TARGET
, "replace-irreversibly");
416 } else if (exit_status
& (FSCK_SYSTEM_SHOULD_REBOOT
| FSCK_ERRORS_LEFT_UNCORRECTED
))
417 /* Some other problem */
418 start_target(SPECIAL_EMERGENCY_TARGET
, "replace");
420 log_warning("Ignoring error.");
423 if (exit_status
& FSCK_ERROR_CORRECTED
)
424 (void) touch("/run/systemd/quotacheck");
426 return !!(exit_status
& (FSCK_SYSTEM_SHOULD_REBOOT
| FSCK_ERRORS_LEFT_UNCORRECTED
));
429 DEFINE_MAIN_FUNCTION_WITH_POSITIVE_FAILURE(run
);