1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
4 This file is part of systemd.
6 Copyright 2010 Lennart Poettering
8 systemd is free software; you can redistribute it and/or modify it
9 under the terms of the GNU General Public License as published by
10 the Free Software Foundation; either version 2 of the License, or
11 (at your option) any later version.
13 systemd is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with systemd; If not, see <http://www.gnu.org/licenses/>.
31 #include <dbus/dbus.h>
34 #include "dbus-common.h"
36 #include "bus-errors.h"
38 static bool arg_skip
= false;
39 static bool arg_force
= false;
40 static bool arg_show_progress
= false;
42 static void start_target(const char *target
, bool isolate
) {
43 DBusMessage
*m
= NULL
, *reply
= NULL
;
45 const char *mode
, *basic_target
= "basic.target";
46 DBusConnection
*bus
= NULL
;
50 dbus_error_init(&error
);
52 if (bus_connect(DBUS_BUS_SYSTEM
, &bus
, NULL
, &error
) < 0) {
53 log_error("Failed to get D-Bus connection: %s", bus_error_message(&error
));
62 log_info("Running request %s/start/%s", target
, mode
);
64 if (!(m
= dbus_message_new_method_call("org.freedesktop.systemd1", "/org/freedesktop/systemd1", "org.freedesktop.systemd1.Manager", "StartUnitReplace"))) {
65 log_error("Could not allocate message.");
69 /* Start these units only if we can replace base.target with it */
71 if (!dbus_message_append_args(m
,
72 DBUS_TYPE_STRING
, &basic_target
,
73 DBUS_TYPE_STRING
, &target
,
74 DBUS_TYPE_STRING
, &mode
,
76 log_error("Could not attach target and flag information to message.");
80 if (!(reply
= dbus_connection_send_with_reply_and_block(bus
, m
, -1, &error
))) {
82 /* Don't print a waring if we aren't called during
84 if (!dbus_error_has_name(&error
, BUS_ERROR_NO_SUCH_JOB
))
85 log_error("Failed to start unit: %s", bus_error_message(&error
));
92 dbus_message_unref(m
);
95 dbus_message_unref(reply
);
98 dbus_connection_flush(bus
);
99 dbus_connection_close(bus
);
100 dbus_connection_unref(bus
);
103 dbus_error_free(&error
);
106 static int parse_proc_cmdline(void) {
107 char *line
, *w
, *state
;
111 if (detect_container(NULL
) > 0)
114 if ((r
= read_one_line_file("/proc/cmdline", &line
)) < 0) {
115 log_warning("Failed to read /proc/cmdline, ignoring: %s", strerror(-r
));
119 FOREACH_WORD_QUOTED(w
, l
, line
, state
) {
121 if (strneq(w
, "fsck.mode=auto", l
))
122 arg_force
= arg_skip
= false;
123 else if (strneq(w
, "fsck.mode=force", l
))
125 else if (strneq(w
, "fsck.mode=skip", l
))
127 else if (startswith(w
, "fsck.mode"))
128 log_warning("Invalid fsck.mode= parameter. Ignoring.");
129 #if defined(TARGET_FEDORA) || defined(TARGET_MANDRIVA)
130 else if (strneq(w
, "fastboot", l
))
132 else if (strneq(w
, "forcefsck", l
))
141 static void test_files(void) {
142 if (access("/fastboot", F_OK
) >= 0)
145 if (access("/forcefsck", F_OK
) >= 0)
148 if (access("/run/systemd/show-status", F_OK
) >= 0 || plymouth_running())
149 arg_show_progress
= true;
152 static double percent(int pass
, unsigned long cur
, unsigned long max
) {
153 /* Values stolen from e2fsck */
155 static const int pass_table
[] = {
156 0, 70, 90, 92, 95, 100
162 if ((unsigned) pass
>= ELEMENTSOF(pass_table
) || max
== 0)
165 return (double) pass_table
[pass
-1] +
166 ((double) pass_table
[pass
] - (double) pass_table
[pass
-1]) *
167 (double) cur
/ (double) max
;
170 static int process_progress(int fd
) {
178 close_nointr_nofail(fd
);
182 console
= fopen("/dev/console", "w");
190 unsigned long cur
, max
;
195 if (fscanf(f
, "%i %lu %lu %ms", &pass
, &cur
, &max
, &device
) != 4)
198 /* Only show one progress counter at max */
200 if (flock(fileno(console
), LOCK_EX
|LOCK_NB
) < 0) {
208 /* Only update once every 50ms */
209 t
= now(CLOCK_MONOTONIC
);
210 if (last
+ 50 * USEC_PER_MSEC
> t
) {
217 p
= percent(pass
, cur
, max
);
218 fprintf(console
, "\r%s: fsck %3.1f%% complete...\r%n", device
, p
, &m
);
230 fputc('\r', console
);
231 for (j
= 0; j
< (unsigned) clear
; j
++)
233 fputc('\r', console
);
242 int main(int argc
, char *argv
[]) {
243 const char *cmdline
[9];
244 int i
= 0, r
= EXIT_FAILURE
, q
;
247 struct udev
*udev
= NULL
;
248 struct udev_device
*udev_device
= NULL
;
251 int progress_pipe
[2] = { -1, -1 };
255 log_error("This program expects one or no arguments.");
259 log_set_target(LOG_TARGET_AUTO
);
260 log_parse_environment();
265 parse_proc_cmdline();
268 if (!arg_force
&& arg_skip
)
273 root_directory
= false;
276 struct timespec times
[2];
278 /* Find root device */
280 if (stat("/", &st
) < 0) {
281 log_error("Failed to stat() the root directory: %m");
285 /* Virtual root devices don't need an fsck */
286 if (major(st
.st_dev
) == 0)
289 /* check if we are already writable */
290 times
[0] = st
.st_atim
;
291 times
[1] = st
.st_mtim
;
292 if (utimensat(AT_FDCWD
, "/", times
, 0) == 0) {
293 log_info("Root directory is writable, skipping check.");
297 if (!(udev
= udev_new())) {
298 log_error("Out of memory");
302 if (!(udev_device
= udev_device_new_from_devnum(udev
, 'b', st
.st_dev
))) {
303 log_error("Failed to detect root device.");
307 if (!(device
= udev_device_get_devnode(udev_device
))) {
308 log_error("Failed to detect device node of root directory.");
312 root_directory
= true;
315 if (arg_show_progress
)
316 if (pipe(progress_pipe
) < 0) {
317 log_error("pipe(): %m");
321 cmdline
[i
++] = "/sbin/fsck";
332 if (progress_pipe
[1] >= 0) {
333 snprintf(dash_c
, sizeof(dash_c
), "-C%i", progress_pipe
[1]);
334 char_array_0(dash_c
);
335 cmdline
[i
++] = dash_c
;
338 cmdline
[i
++] = device
;
343 log_error("fork(): %m");
345 } else if (pid
== 0) {
347 if (progress_pipe
[0] >= 0)
348 close_nointr_nofail(progress_pipe
[0]);
349 execv(cmdline
[0], (char**) cmdline
);
350 _exit(8); /* Operational error */
353 if (progress_pipe
[1] >= 0) {
354 close_nointr_nofail(progress_pipe
[1]);
355 progress_pipe
[1] = -1;
358 if (progress_pipe
[0] >= 0) {
359 process_progress(progress_pipe
[0]);
360 progress_pipe
[0] = -1;
363 q
= wait_for_terminate(pid
, &status
);
365 log_error("waitid(): %s", strerror(-q
));
369 if (status
.si_code
!= CLD_EXITED
|| (status
.si_status
& ~1)) {
371 if (status
.si_code
== CLD_KILLED
|| status
.si_code
== CLD_DUMPED
)
372 log_error("fsck terminated by signal %s.", signal_to_string(status
.si_status
));
373 else if (status
.si_code
== CLD_EXITED
)
374 log_error("fsck failed with error code %i.", status
.si_status
);
376 log_error("fsck failed due to unknown reason.");
378 if (status
.si_code
== CLD_EXITED
&& (status
.si_status
& 2) && root_directory
)
379 /* System should be rebooted. */
380 start_target(SPECIAL_REBOOT_TARGET
, false);
381 else if (status
.si_code
== CLD_EXITED
&& (status
.si_status
& 6))
382 /* Some other problem */
383 start_target(SPECIAL_EMERGENCY_TARGET
, true);
386 log_warning("Ignoring error.");
392 if (status
.si_code
== CLD_EXITED
&& (status
.si_status
& 1))
393 touch("/run/systemd/quotacheck");
397 udev_device_unref(udev_device
);
402 close_pipe(progress_pipe
);