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/>.
22 #include <sys/socket.h>
24 #include <sys/types.h>
25 #include <sys/timerfd.h>
32 #include "shutdownd.h"
36 #include "sd-daemon.h"
37 #include "utmp-wtmp.h"
39 static int read_packet(int fd, struct shutdownd_command *_c) {
44 struct cmsghdr cmsghdr;
45 uint8_t buf[CMSG_SPACE(sizeof(struct ucred))];
47 struct shutdownd_command c;
55 iovec.iov_len = sizeof(c);
59 msghdr.msg_iov = &iovec;
60 msghdr.msg_iovlen = 1;
61 msghdr.msg_control = &control;
62 msghdr.msg_controllen = sizeof(control);
64 if ((n = recvmsg(fd, &msghdr, MSG_DONTWAIT)) <= 0) {
66 log_error("Short read");
70 if (errno == EAGAIN || errno == EINTR)
73 log_error("recvmsg(): %m");
77 if (msghdr.msg_controllen < CMSG_LEN(sizeof(struct ucred)) ||
78 control.cmsghdr.cmsg_level != SOL_SOCKET ||
79 control.cmsghdr.cmsg_type != SCM_CREDENTIALS ||
80 control.cmsghdr.cmsg_len != CMSG_LEN(sizeof(struct ucred))) {
81 log_warning("Received message without credentials. Ignoring.");
85 ucred = (struct ucred*) CMSG_DATA(&control.cmsghdr);
86 if (ucred->uid != 0) {
87 log_warning("Got request from unprivileged user. Ignoring.");
92 log_warning("Message has invalid size. Ignoring");
96 char_array_0(c.wall_message);
102 static void warn_wall(struct shutdownd_command *c) {
105 assert(c->warn_wall);
107 if (c->wall_message[0])
108 utmp_wall(c->wall_message);
110 char date[FORMAT_TIMESTAMP_MAX];
115 prefix = "The system is going down for system halt at";
116 else if (c->mode == 'P')
117 prefix = "The system is going down for power-off at";
118 else if (c->mode == 'r')
119 prefix = "The system is going down for reboot at";
121 assert_not_reached("Unknown mode!");
123 if (asprintf(&l, "%s %s!",
125 format_timestamp(date, sizeof(date), c->elapse)) < 0)
126 log_error("Failed to allocate wall message");
134 static usec_t when_wall(usec_t n, usec_t elapse) {
136 static const struct {
140 { 10 * USEC_PER_MINUTE, USEC_PER_MINUTE },
141 { USEC_PER_HOUR, 15 * USEC_PER_MINUTE },
142 { 3 * USEC_PER_HOUR, 30 * USEC_PER_MINUTE }
148 /* If the time is already passed, then don't announce */
153 for (i = 0; i < ELEMENTSOF(table); i++)
154 if (n + table[i].delay >= elapse)
155 sub = ((left / table[i].interval) * table[i].interval);
157 if (i >= ELEMENTSOF(table))
158 sub = ((left / USEC_PER_HOUR) * USEC_PER_HOUR);
160 return elapse > sub ? elapse - sub : 1;
163 static usec_t when_nologin(usec_t elapse) {
164 return elapse > 5*USEC_PER_MINUTE ? elapse - 5*USEC_PER_MINUTE : 1;
167 int main(int argc, char *argv[]) {
178 struct shutdownd_command c;
179 struct pollfd pollfd[_FD_MAX];
180 bool exec_shutdown = false, unlink_nologin = false, failed = false;
183 if (getppid() != 1) {
184 log_error("This program should be invoked by init only.");
189 log_error("This program does not take arguments.");
193 log_set_target(LOG_TARGET_SYSLOG_OR_KMSG);
194 log_parse_environment();
197 if ((n_fds = sd_listen_fds(true)) < 0) {
198 log_error("Failed to read listening file descriptors from environment: %s", strerror(-r));
203 log_error("Need exactly one file descriptor.");
207 if (setsockopt(SD_LISTEN_FDS_START, SOL_SOCKET, SO_PASSCRED, &one, sizeof(one)) < 0) {
208 log_error("SO_PASSCRED failed: %m");
215 pollfd[FD_SOCKET].fd = SD_LISTEN_FDS_START;
216 pollfd[FD_SOCKET].events = POLLIN;
218 for (i = 0; i < _FD_MAX; i++) {
223 pollfd[i].events = POLLIN;
225 if ((pollfd[i].fd = timerfd_create(CLOCK_REALTIME, TFD_NONBLOCK|TFD_CLOEXEC)) < 0) {
226 log_error("timerfd_create(): %m");
234 log_debug("systemd-shutdownd running as pid %lu", (unsigned long) getpid());
238 "STATUS=Processing requests...");
244 if (poll(pollfd, _FD_MAX, -1) < 0) {
246 if (errno == EAGAIN || errno == EINTR)
249 log_error("poll(): %m");
253 n = now(CLOCK_REALTIME);
255 if (pollfd[FD_SOCKET].revents) {
257 if ((k = read_packet(pollfd[FD_SOCKET].fd, &c)) < 0)
259 else if (k > 0 && c.elapse > 0) {
260 struct itimerspec its;
261 char date[FORMAT_TIMESTAMP_MAX];
264 /* Send wall messages every so often */
266 timespec_store(&its.it_value, when_wall(n, c.elapse));
267 if (timerfd_settime(pollfd[FD_WALL_TIMER].fd, TFD_TIMER_ABSTIME, &its, NULL) < 0) {
268 log_error("timerfd_settime(): %m");
272 /* Warn immediately if less than 15 minutes are left */
274 n + 15*USEC_PER_MINUTE >= c.elapse)
278 /* Disallow logins 5 minutes prior to shutdown */
280 timespec_store(&its.it_value, when_nologin(c.elapse));
281 if (timerfd_settime(pollfd[FD_NOLOGIN_TIMER].fd, TFD_TIMER_ABSTIME, &its, NULL) < 0) {
282 log_error("timerfd_settime(): %m");
286 /* Shutdown after the specified time is reached */
288 timespec_store(&its.it_value, c.elapse);
289 if (timerfd_settime(pollfd[FD_SHUTDOWN_TIMER].fd, TFD_TIMER_ABSTIME, &its, NULL) < 0) {
290 log_error("timerfd_settime(): %m");
295 "STATUS=Shutting down at %s...",
296 format_timestamp(date, sizeof(date), c.elapse));
300 if (pollfd[FD_WALL_TIMER].revents) {
301 struct itimerspec its;
304 flush_fd(pollfd[FD_WALL_TIMER].fd);
308 timespec_store(&its.it_value, when_wall(n, c.elapse));
309 if (timerfd_settime(pollfd[FD_WALL_TIMER].fd, TFD_TIMER_ABSTIME, &its, NULL) < 0) {
310 log_error("timerfd_settime(): %m");
315 if (pollfd[FD_NOLOGIN_TIMER].revents) {
318 if ((e = touch("/etc/nologin")) < 0)
319 log_error("Failed to create /etc/nologin: %s", strerror(-e));
321 unlink_nologin = true;
323 flush_fd(pollfd[FD_NOLOGIN_TIMER].fd);
326 if (pollfd[FD_SHUTDOWN_TIMER].revents) {
327 exec_shutdown = true;
331 } while (c.elapse > 0);
335 log_debug("systemd-shutdownd stopped as pid %lu", (unsigned long) getpid());
339 for (i = 0; i < _FD_MAX; i++)
340 if (pollfd[i].fd >= 0)
341 close_nointr_nofail(pollfd[i].fd);
350 execl(SYSTEMCTL_BINARY_PATH, "shutdown", sw, "now", NULL);
351 log_error("Failed to execute /sbin/shutdown: %m");
355 unlink("/etc/nologin");
358 "STATUS=Exiting...");