Scott James Remnant | 5074884 | 2006-05-16 21:02:31 +0100 | [diff] [blame] | 1 | /* upstart |
| 2 | * |
Scott James Remnant | b6270dd | 2006-07-13 02:16:38 +0100 | [diff] [blame] | 3 | * Copyright © 2006 Canonical Ltd. |
| 4 | * Author: Scott James Remnant <scott@ubuntu.com>. |
Scott James Remnant | 5074884 | 2006-05-16 21:02:31 +0100 | [diff] [blame] | 5 | * |
| 6 | * This program is free software; you can redistribute it and/or modify |
| 7 | * it under the terms of the GNU General Public License as published by |
| 8 | * the Free Software Foundation; either version 2 of the License, or |
| 9 | * (at your option) any later version. |
| 10 | * |
| 11 | * This program is distributed in the hope that it will be useful, |
| 12 | * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| 13 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| 14 | * GNU General Public License for more details. |
| 15 | * |
| 16 | * You should have received a copy of the GNU General Public License |
| 17 | * along with this program; if not, write to the Free Software |
| 18 | * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA |
| 19 | */ |
| 20 | |
| 21 | #ifdef HAVE_CONFIG_H |
| 22 | # include <config.h> |
| 23 | #endif /* HAVE_CONFIG_H */ |
| 24 | |
| 25 | |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 26 | #include <linux/kd.h> |
| 27 | |
| 28 | #include <sys/types.h> |
| 29 | #include <sys/wait.h> |
| 30 | #include <sys/ioctl.h> |
| 31 | #include <sys/reboot.h> |
| 32 | #include <sys/resource.h> |
| 33 | |
| 34 | #include <signal.h> |
Scott James Remnant | 94d0098 | 2006-08-25 15:38:22 +0200 | [diff] [blame] | 35 | #include <stdlib.h> |
Scott James Remnant | 12a330f | 2006-08-24 02:19:09 +0200 | [diff] [blame] | 36 | #include <syslog.h> |
Scott James Remnant | 027dd7b | 2006-08-21 09:01:25 +0200 | [diff] [blame] | 37 | #include <unistd.h> |
| 38 | |
Scott James Remnant | 77e8db3 | 2006-08-21 08:47:50 +0200 | [diff] [blame] | 39 | #include <nih/macros.h> |
| 40 | #include <nih/alloc.h> |
| 41 | #include <nih/list.h> |
| 42 | #include <nih/timer.h> |
| 43 | #include <nih/signal.h> |
| 44 | #include <nih/child.h> |
| 45 | #include <nih/main.h> |
| 46 | #include <nih/logging.h> |
| 47 | |
| 48 | #include "process.h" |
| 49 | #include "job.h" |
| 50 | #include "event.h" |
| 51 | #include "control.h" |
| 52 | #include "cfgfile.h" |
Scott James Remnant | 5074884 | 2006-05-16 21:02:31 +0100 | [diff] [blame] | 53 | |
| 54 | |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 55 | /* Prototypes for static functions */ |
| 56 | static void segv_handler (int signum); |
| 57 | static void cad_handler (void *data, NihSignal *signal); |
| 58 | static void kbd_handler (void *data, NihSignal *signal); |
Scott James Remnant | eabb780 | 2006-08-31 15:39:04 +0100 | [diff] [blame^] | 59 | static void stop_handler (void *data, NihSignal *signal); |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 60 | |
Scott James Remnant | 5074884 | 2006-05-16 21:02:31 +0100 | [diff] [blame] | 61 | int |
| 62 | main (int argc, |
| 63 | char *argv[]) |
| 64 | { |
Scott James Remnant | 77e8db3 | 2006-08-21 08:47:50 +0200 | [diff] [blame] | 65 | int ret, i; |
Scott James Remnant | 5074884 | 2006-05-16 21:02:31 +0100 | [diff] [blame] | 66 | |
Scott James Remnant | 77e8db3 | 2006-08-21 08:47:50 +0200 | [diff] [blame] | 67 | nih_main_init (argv[0]); |
| 68 | |
Scott James Remnant | 12a330f | 2006-08-24 02:19:09 +0200 | [diff] [blame] | 69 | openlog (program_name, LOG_CONS, LOG_DAEMON); |
| 70 | |
Scott James Remnant | 1cd8d86 | 2006-08-31 15:17:16 +0100 | [diff] [blame] | 71 | nih_log_set_priority (NIH_LOG_DEBUG); |
Scott James Remnant | 12a330f | 2006-08-24 02:19:09 +0200 | [diff] [blame] | 72 | nih_log_set_logger (nih_logger_syslog); |
Scott James Remnant | 77e8db3 | 2006-08-21 08:47:50 +0200 | [diff] [blame] | 73 | |
Scott James Remnant | 77e8db3 | 2006-08-21 08:47:50 +0200 | [diff] [blame] | 74 | /* Close any file descriptors we inherited, and open the console |
| 75 | * device instead |
| 76 | */ |
| 77 | for (i = 0; i < 3; i++) |
| 78 | close (i); |
| 79 | |
| 80 | process_setup_console (CONSOLE_OUTPUT); |
| 81 | |
Scott James Remnant | f497081 | 2006-08-27 18:27:19 +0100 | [diff] [blame] | 82 | /* Check we're root */ |
| 83 | if (getuid ()) { |
| 84 | nih_error (_("Need to be root")); |
| 85 | exit (1); |
| 86 | } |
| 87 | |
| 88 | /* Check we're process #1 */ |
| 89 | if (getpid () > 1) { |
| 90 | nih_error (_("Not being executed as init")); |
| 91 | exit (1); |
| 92 | } |
| 93 | |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 94 | |
| 95 | /* Reset the signal state and install the signal handler for those |
| 96 | * signals we actually want to catch; this also sets those that |
| 97 | * can be sent to us, because we're special |
| 98 | */ |
| 99 | nih_signal_reset (); |
| 100 | nih_signal_set_handler (SIGALRM, nih_signal_handler); |
| 101 | nih_signal_set_handler (SIGHUP, nih_signal_handler); |
Scott James Remnant | eabb780 | 2006-08-31 15:39:04 +0100 | [diff] [blame^] | 102 | nih_signal_set_handler (SIGSTOP, nih_signal_handler); |
| 103 | nih_signal_set_handler (SIGTSTP, nih_signal_handler); |
| 104 | nih_signal_set_handler (SIGCONT, nih_signal_handler); |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 105 | nih_signal_set_handler (SIGINT, nih_signal_handler); |
| 106 | nih_signal_set_handler (SIGWINCH, nih_signal_handler); |
| 107 | nih_signal_set_handler (SIGSEGV, segv_handler); |
| 108 | |
Scott James Remnant | eabb780 | 2006-08-31 15:39:04 +0100 | [diff] [blame^] | 109 | /* Ensure that we don't process events while paused */ |
| 110 | nih_signal_add_callback (NULL, SIGSTOP, stop_handler, NULL); |
| 111 | nih_signal_add_callback (NULL, SIGTSTP, stop_handler, NULL); |
| 112 | nih_signal_add_callback (NULL, SIGCONT, stop_handler, NULL); |
| 113 | |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 114 | /* Ask the kernel to send us SIGINT when control-alt-delete is |
| 115 | * pressed; generate an event with the same name. |
| 116 | */ |
| 117 | reboot (RB_DISABLE_CAD); |
| 118 | nih_signal_add_callback (NULL, SIGINT, cad_handler, NULL); |
| 119 | |
| 120 | /* Ask the kernel to send us SIGWINCH when alt-uparrow is pressed; |
| 121 | * generate a kbdrequest event. |
| 122 | */ |
| 123 | ioctl (0, KDSIGACCEPT, SIGWINCH); |
| 124 | nih_signal_add_callback (NULL, SIGWINCH, kbd_handler, NULL); |
| 125 | |
| 126 | |
| 127 | /* Reap all children that die */ |
| 128 | nih_child_add_watch (NULL, -1, job_child_reaper, NULL); |
| 129 | |
Scott James Remnant | dc8877d | 2006-08-29 16:56:48 +0100 | [diff] [blame] | 130 | /* Process the event queue and check the jobs for idleness |
| 131 | * every time through the main loop */ |
Scott James Remnant | 0c7e72a | 2006-08-27 22:22:53 +0100 | [diff] [blame] | 132 | nih_main_loop_add_func (NULL, (NihMainLoopCb)event_queue_run, NULL); |
Scott James Remnant | dc8877d | 2006-08-29 16:56:48 +0100 | [diff] [blame] | 133 | nih_main_loop_add_func (NULL, (NihMainLoopCb)job_detect_idle, NULL); |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 134 | |
Scott James Remnant | 94d0098 | 2006-08-25 15:38:22 +0200 | [diff] [blame] | 135 | |
Scott James Remnant | 77e8db3 | 2006-08-21 08:47:50 +0200 | [diff] [blame] | 136 | /* Become session and process group leader (should be already, |
| 137 | * but you never know what initramfs did |
| 138 | */ |
| 139 | setsid (); |
| 140 | |
| 141 | /* Open control socket */ |
| 142 | control_open (); |
| 143 | |
Scott James Remnant | ceaaf4d | 2006-08-24 01:40:10 +0200 | [diff] [blame] | 144 | /* Read configuration */ |
| 145 | cfg_watch_dir (NULL, CFG_DIR, NULL); |
| 146 | |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 147 | /* Set the PATH environment variable */ |
| 148 | setenv ("PATH", PATH, TRUE); |
| 149 | |
Scott James Remnant | 77e8db3 | 2006-08-21 08:47:50 +0200 | [diff] [blame] | 150 | |
| 151 | /* Generate and run the startup event */ |
Scott James Remnant | ff5efb9 | 2006-08-31 01:45:19 +0100 | [diff] [blame] | 152 | event_queue ("startup"); |
Scott James Remnant | 0c7e72a | 2006-08-27 22:22:53 +0100 | [diff] [blame] | 153 | event_queue_run (); |
Scott James Remnant | 32de922 | 2006-08-31 04:34:27 +0100 | [diff] [blame] | 154 | job_detect_idle (); |
Scott James Remnant | 77e8db3 | 2006-08-21 08:47:50 +0200 | [diff] [blame] | 155 | |
| 156 | /* Go! */ |
| 157 | ret = nih_main_loop (); |
| 158 | |
| 159 | return ret; |
Scott James Remnant | 5074884 | 2006-05-16 21:02:31 +0100 | [diff] [blame] | 160 | } |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 161 | |
| 162 | |
| 163 | /** |
| 164 | * segv_handler: |
| 165 | * @signum: |
| 166 | * |
| 167 | * Handle receiving the SEGV signal, usually caused by one of our own |
| 168 | * mistakes. We deal with it by dumping core in a child process and |
| 169 | * just carrying on in the parent. |
| 170 | **/ |
| 171 | static void |
| 172 | segv_handler (int signum) |
| 173 | { |
| 174 | pid_t pid; |
| 175 | |
| 176 | pid = fork (); |
| 177 | if (pid == 0) { |
| 178 | struct sigaction act; |
| 179 | struct rlimit limit; |
| 180 | sigset_t mask; |
| 181 | |
| 182 | /* Mask out all signals */ |
| 183 | sigfillset (&mask); |
| 184 | sigprocmask (SIG_SETMASK, &mask, NULL); |
| 185 | |
| 186 | /* Set the SEGV handler to the default so core is dumped */ |
| 187 | act.sa_handler = SIG_DFL; |
| 188 | act.sa_flags = 0; |
| 189 | sigemptyset (&act.sa_mask); |
| 190 | sigaction (SIGSEGV, &act, NULL); |
| 191 | |
| 192 | /* Dump in the root directory */ |
| 193 | chdir ("/"); |
| 194 | |
| 195 | /* Don't limit the core dump size */ |
| 196 | limit.rlim_cur = RLIM_INFINITY; |
| 197 | limit.rlim_max = RLIM_INFINITY; |
| 198 | setrlimit (RLIMIT_CORE, &limit); |
| 199 | |
| 200 | /* Raise the signal */ |
| 201 | raise (SIGSEGV); |
| 202 | |
| 203 | /* Unmask so that we receive it */ |
| 204 | sigdelset (&mask, SIGSEGV); |
| 205 | sigprocmask (SIG_SETMASK, &mask, NULL); |
| 206 | |
| 207 | /* Wait for death */ |
| 208 | pause (); |
| 209 | exit (0); |
| 210 | } else if (pid > 0) { |
| 211 | /* Wait for the core to be generated */ |
| 212 | waitpid (pid, NULL, 0); |
| 213 | |
| 214 | nih_error (_("Caught segmentation fault, core dumped")); |
| 215 | } else { |
| 216 | nih_error (_("Caught segmentation fault, unable to dump core")); |
| 217 | } |
| 218 | } |
| 219 | |
| 220 | /** |
| 221 | * cad_handler: |
| 222 | * @data: unused, |
| 223 | * @signal: signal that called this handler. |
| 224 | * |
| 225 | * Handle having recieved the SIGINT signal, sent to us when somebody |
| 226 | * presses Ctrl-Alt-Delete on the console. We just generate a |
| 227 | * control-alt-delete event. |
| 228 | **/ |
| 229 | static void |
| 230 | cad_handler (void *data, |
| 231 | NihSignal *signal) |
| 232 | { |
Scott James Remnant | ff5efb9 | 2006-08-31 01:45:19 +0100 | [diff] [blame] | 233 | event_queue ("control-alt-delete"); |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 234 | } |
| 235 | |
| 236 | /** |
| 237 | * kbd_handler: |
| 238 | * @data: unused, |
| 239 | * @signal: signal that called this handler. |
| 240 | * |
| 241 | * Handle having recieved the SIGWINCH signal, sent to us when somebody |
| 242 | * presses Alt-UpArrow on the console. We just generate a |
| 243 | * kbdrequest event. |
| 244 | **/ |
| 245 | static void |
| 246 | kbd_handler (void *data, |
| 247 | NihSignal *signal) |
| 248 | { |
Scott James Remnant | ff5efb9 | 2006-08-31 01:45:19 +0100 | [diff] [blame] | 249 | event_queue ("kbdrequest"); |
Scott James Remnant | f43bdf3 | 2006-08-27 18:20:29 +0100 | [diff] [blame] | 250 | } |
Scott James Remnant | eabb780 | 2006-08-31 15:39:04 +0100 | [diff] [blame^] | 251 | |
| 252 | /** |
| 253 | * stop_handler: |
| 254 | * @data: unused, |
| 255 | * @signal: signal caught. |
| 256 | * |
| 257 | * This is called when we receive the STOP, TSTP or CONT signals; we |
| 258 | * adjust the paused variable appropriately so that the event queue and |
| 259 | * job idle detection is not run. |
| 260 | **/ |
| 261 | static void |
| 262 | stop_handler (void *data, |
| 263 | NihSignal *signal) |
| 264 | { |
| 265 | nih_assert (signal != NULL); |
| 266 | |
| 267 | if (signal->signum == SIGCONT) { |
| 268 | nih_info (_("Event queue resumed")); |
| 269 | paused = FALSE; |
| 270 | } else { |
| 271 | nih_info (_("Event queue paused")); |
| 272 | paused = TRUE; |
| 273 | } |
| 274 | } |