init.c revision 1.103 1 1.103 matt /* $NetBSD: init.c,v 1.103 2012/03/20 18:50:31 matt Exp $ */
2 1.19 cgd
3 1.8 cgd /*-
4 1.15 pk * Copyright (c) 1991, 1993
5 1.15 pk * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.8 cgd * This code is derived from software contributed to Berkeley by
8 1.8 cgd * Donn Seeley at Berkeley Software Design, Inc.
9 1.8 cgd *
10 1.1 cgd * Redistribution and use in source and binary forms, with or without
11 1.1 cgd * modification, are permitted provided that the following conditions
12 1.1 cgd * are met:
13 1.1 cgd * 1. Redistributions of source code must retain the above copyright
14 1.1 cgd * notice, this list of conditions and the following disclaimer.
15 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 cgd * notice, this list of conditions and the following disclaimer in the
17 1.1 cgd * documentation and/or other materials provided with the distribution.
18 1.61 agc * 3. Neither the name of the University nor the names of its contributors
19 1.8 cgd * may be used to endorse or promote products derived from this software
20 1.1 cgd * without specific prior written permission.
21 1.1 cgd *
22 1.8 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
23 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25 1.8 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
26 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
28 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32 1.1 cgd * SUCH DAMAGE.
33 1.1 cgd */
34 1.3 cgd
35 1.26 perry #include <sys/cdefs.h>
36 1.8 cgd #ifndef lint
37 1.96 lukem __COPYRIGHT("@(#) Copyright (c) 1991, 1993\
38 1.96 lukem The Regents of the University of California. All rights reserved.");
39 1.8 cgd #endif /* not lint */
40 1.8 cgd
41 1.8 cgd #ifndef lint
42 1.19 cgd #if 0
43 1.25 perry static char sccsid[] = "@(#)init.c 8.2 (Berkeley) 4/28/95";
44 1.19 cgd #else
45 1.103 matt __RCSID("$NetBSD: init.c,v 1.103 2012/03/20 18:50:31 matt Exp $");
46 1.19 cgd #endif
47 1.8 cgd #endif /* not lint */
48 1.8 cgd
49 1.8 cgd #include <sys/param.h>
50 1.8 cgd #include <sys/sysctl.h>
51 1.1 cgd #include <sys/wait.h>
52 1.28 christos #include <sys/mman.h>
53 1.28 christos #include <sys/stat.h>
54 1.28 christos #include <sys/mount.h>
55 1.28 christos #include <machine/cpu.h>
56 1.8 cgd
57 1.8 cgd #include <db.h>
58 1.8 cgd #include <errno.h>
59 1.8 cgd #include <fcntl.h>
60 1.8 cgd #include <signal.h>
61 1.8 cgd #include <stdio.h>
62 1.8 cgd #include <stdlib.h>
63 1.8 cgd #include <string.h>
64 1.8 cgd #include <syslog.h>
65 1.8 cgd #include <time.h>
66 1.1 cgd #include <ttyent.h>
67 1.1 cgd #include <unistd.h>
68 1.22 jtc #include <util.h>
69 1.28 christos #include <paths.h>
70 1.28 christos #include <err.h>
71 1.1 cgd
72 1.8 cgd #include <stdarg.h>
73 1.8 cgd
74 1.8 cgd #ifdef SECURE
75 1.5 cgd #include <pwd.h>
76 1.5 cgd #endif
77 1.5 cgd
78 1.8 cgd #include "pathnames.h"
79 1.8 cgd
80 1.62 dsl #define XSTR(x) #x
81 1.62 dsl #define STR(x) XSTR(x)
82 1.62 dsl
83 1.8 cgd /*
84 1.8 cgd * Sleep times; used to prevent thrashing.
85 1.8 cgd */
86 1.8 cgd #define GETTY_SPACING 5 /* N secs minimum getty spacing */
87 1.8 cgd #define GETTY_SLEEP 30 /* sleep N secs after spacing problem */
88 1.8 cgd #define WINDOW_WAIT 3 /* wait N secs after starting window */
89 1.8 cgd #define STALL_TIMEOUT 30 /* wait N secs after warning */
90 1.8 cgd #define DEATH_WATCH 10 /* wait N secs for procs to die */
91 1.8 cgd
92 1.101 joerg static const struct timespec dtrtime = {.tv_sec = 0, .tv_nsec = 250000};
93 1.56 lukem
94 1.56 lukem #if defined(RESCUEDIR)
95 1.56 lukem #define INIT_BSHELL RESCUEDIR "/sh"
96 1.56 lukem #define INIT_MOUNT_MFS RESCUEDIR "/mount_mfs"
97 1.56 lukem #define INIT_PATH RESCUEDIR ":" _PATH_STDPATH
98 1.56 lukem #else
99 1.56 lukem #define INIT_BSHELL _PATH_BSHELL
100 1.56 lukem #define INIT_MOUNT_MFS "/sbin/mount_mfs"
101 1.56 lukem #define INIT_PATH _PATH_STDPATH
102 1.52 lukem #endif
103 1.52 lukem
104 1.101 joerg static void handle(sig_t, ...);
105 1.101 joerg static void delset(sigset_t *, ...);
106 1.27 perry
107 1.101 joerg static void stall(const char *, ...) __printflike(1, 2);
108 1.101 joerg static void warning(const char *, ...) __printflike(1, 2);
109 1.101 joerg static void emergency(const char *, ...) __printflike(1, 2);
110 1.101 joerg __dead static void disaster(int);
111 1.101 joerg static void badsys(int);
112 1.8 cgd
113 1.8 cgd /*
114 1.8 cgd * We really need a recursive typedef...
115 1.8 cgd * The following at least guarantees that the return type of (*state_t)()
116 1.8 cgd * is sufficiently wide to hold a function pointer.
117 1.8 cgd */
118 1.39 wiz typedef long (*state_func_t)(void);
119 1.39 wiz typedef state_func_t (*state_t)(void);
120 1.8 cgd
121 1.77 christos #define DEATH 'd'
122 1.77 christos #define SINGLE_USER 's'
123 1.77 christos #define RUNCOM 'r'
124 1.77 christos #define READ_TTYS 't'
125 1.77 christos #define MULTI_USER 'm'
126 1.77 christos #define CLEAN_TTYS 'T'
127 1.77 christos #define CATATONIA 'c'
128 1.77 christos
129 1.101 joerg static state_func_t single_user(void);
130 1.102 christos #ifndef LETS_GET_SMALL
131 1.101 joerg static state_func_t runcom(void);
132 1.101 joerg static state_func_t read_ttys(void);
133 1.101 joerg static state_func_t multi_user(void);
134 1.101 joerg static state_func_t clean_ttys(void);
135 1.101 joerg static state_func_t catatonia(void);
136 1.101 joerg static state_func_t death(void);
137 1.102 christos #endif
138 1.8 cgd
139 1.101 joerg static enum { AUTOBOOT, FASTBOOT } runcom_mode = AUTOBOOT;
140 1.8 cgd
141 1.101 joerg static void transition(state_t);
142 1.101 joerg static void setctty(const char *);
143 1.8 cgd
144 1.8 cgd typedef struct init_session {
145 1.8 cgd int se_index; /* index of entry in ttys file */
146 1.8 cgd pid_t se_process; /* controlling process */
147 1.77 christos struct timeval se_started; /* used to avoid thrashing */
148 1.8 cgd int se_flags; /* status of session */
149 1.8 cgd #define SE_SHUTDOWN 0x1 /* session won't be restarted */
150 1.21 mycroft #define SE_PRESENT 0x2 /* session is in /etc/ttys */
151 1.8 cgd char *se_device; /* filename of port */
152 1.8 cgd char *se_getty; /* what to run on that port */
153 1.8 cgd char **se_getty_argv; /* pre-parsed argument array */
154 1.8 cgd char *se_window; /* window system (started only once) */
155 1.8 cgd char **se_window_argv; /* pre-parsed argument array */
156 1.8 cgd struct init_session *se_prev;
157 1.8 cgd struct init_session *se_next;
158 1.8 cgd } session_t;
159 1.8 cgd
160 1.101 joerg static void collect_child(pid_t, int);
161 1.102 christos static int clang;
162 1.101 joerg static void transition_handler(int);
163 1.101 joerg static void alrm_handler(int);
164 1.101 joerg static int has_securelevel(void);
165 1.102 christos static int securelevel_present;
166 1.102 christos
167 1.102 christos #ifndef LETS_GET_SMALL
168 1.102 christos static int do_setttyent(void);
169 1.102 christos static void start_window_system(session_t *);
170 1.102 christos static char **construct_argv(char *);
171 1.102 christos static int setupargv(session_t *, struct ttyent *);
172 1.102 christos static pid_t start_getty(session_t *);
173 1.102 christos static void free_session(session_t *);
174 1.102 christos static session_t *new_session(session_t *, int, struct ttyent *);
175 1.102 christos static session_t *sessions;
176 1.101 joerg static void setsecuritylevel(int);
177 1.101 joerg static int getsecuritylevel(void);
178 1.101 joerg static int start_session_db(void);
179 1.101 joerg static void add_session(session_t *);
180 1.101 joerg static void del_session(session_t *);
181 1.101 joerg static session_t *find_session(pid_t);
182 1.101 joerg static DB *session_db;
183 1.101 joerg static state_t requested_transition = runcom;
184 1.73 salo
185 1.101 joerg static void clear_session_logs(session_t *, int);
186 1.101 joerg static state_func_t runetcrc(int);
187 1.77 christos #ifdef SUPPORT_UTMPX
188 1.77 christos static struct timeval boot_time;
189 1.101 joerg static state_t current_state = death;
190 1.77 christos static void session_utmpx(const session_t *, int);
191 1.77 christos static void make_utmpx(const char *, const char *, int, pid_t,
192 1.77 christos const struct timeval *, int);
193 1.77 christos static char get_runlevel(const state_t);
194 1.77 christos static void utmpx_set_runlevel(char, char);
195 1.77 christos #endif
196 1.73 salo
197 1.73 salo #ifdef CHROOT
198 1.101 joerg static int did_multiuser_chroot = 0;
199 1.101 joerg static char rootdir[PATH_MAX];
200 1.101 joerg static int shouldchroot(void);
201 1.101 joerg static int createsysctlnode(void);
202 1.73 salo #endif /* CHROOT */
203 1.73 salo
204 1.73 salo #else /* LETS_GET_SMALL */
205 1.101 joerg static state_t requested_transition = single_user;
206 1.73 salo #endif /* !LETS_GET_SMALL */
207 1.73 salo
208 1.45 abs #ifdef MFS_DEV_IF_NO_CONSOLE
209 1.58 christos
210 1.45 abs static int mfs_dev(void);
211 1.58 christos
212 1.28 christos #endif
213 1.28 christos
214 1.8 cgd /*
215 1.8 cgd * The mother of all processes.
216 1.8 cgd */
217 1.8 cgd int
218 1.43 lukem main(int argc, char **argv)
219 1.8 cgd {
220 1.8 cgd struct sigaction sa;
221 1.8 cgd sigset_t mask;
222 1.37 soren #ifndef LETS_GET_SMALL
223 1.37 soren int c;
224 1.8 cgd
225 1.77 christos #ifdef SUPPORT_UTMPX
226 1.77 christos (void)gettimeofday(&boot_time, NULL);
227 1.77 christos #endif /* SUPPORT_UTMPX */
228 1.77 christos
229 1.8 cgd /* Dispose of random users. */
230 1.8 cgd if (getuid() != 0) {
231 1.28 christos errno = EPERM;
232 1.87 cbiere err(1, NULL);
233 1.8 cgd }
234 1.8 cgd
235 1.8 cgd /* System V users like to reexec init. */
236 1.28 christos if (getpid() != 1)
237 1.87 cbiere errx(1, "already running");
238 1.28 christos #endif
239 1.8 cgd
240 1.8 cgd /*
241 1.8 cgd * Create an initial session.
242 1.8 cgd */
243 1.8 cgd if (setsid() < 0)
244 1.28 christos warn("initial setsid() failed");
245 1.12 cgd
246 1.12 cgd /*
247 1.12 cgd * Establish an initial user so that programs running
248 1.12 cgd * single user do not freak out and die (like passwd).
249 1.12 cgd */
250 1.12 cgd if (setlogin("root") < 0)
251 1.28 christos warn("setlogin() failed");
252 1.28 christos
253 1.28 christos
254 1.45 abs #ifdef MFS_DEV_IF_NO_CONSOLE
255 1.45 abs if (mfs_dev() == -1)
256 1.45 abs requested_transition = single_user;
257 1.28 christos #endif
258 1.28 christos
259 1.28 christos #ifndef LETS_GET_SMALL
260 1.28 christos /*
261 1.28 christos * Note that this does NOT open a file...
262 1.28 christos * Does 'init' deserve its own facility number?
263 1.28 christos */
264 1.42 lukem openlog("init", LOG_CONS, LOG_AUTH);
265 1.28 christos #endif /* LETS_GET_SMALL */
266 1.28 christos
267 1.8 cgd
268 1.13 cgd #ifndef LETS_GET_SMALL
269 1.8 cgd /*
270 1.8 cgd * This code assumes that we always get arguments through flags,
271 1.8 cgd * never through bits set in some random machine register.
272 1.8 cgd */
273 1.8 cgd while ((c = getopt(argc, argv, "sf")) != -1)
274 1.8 cgd switch (c) {
275 1.8 cgd case 's':
276 1.8 cgd requested_transition = single_user;
277 1.8 cgd break;
278 1.8 cgd case 'f':
279 1.8 cgd runcom_mode = FASTBOOT;
280 1.8 cgd break;
281 1.8 cgd default:
282 1.80 christos warning("unrecognized flag `%c'", c);
283 1.8 cgd break;
284 1.8 cgd }
285 1.8 cgd
286 1.8 cgd if (optind != argc)
287 1.8 cgd warning("ignoring excess arguments");
288 1.13 cgd #else /* LETS_GET_SMALL */
289 1.13 cgd requested_transition = single_user;
290 1.13 cgd #endif /* LETS_GET_SMALL */
291 1.8 cgd
292 1.8 cgd /*
293 1.8 cgd * We catch or block signals rather than ignore them,
294 1.8 cgd * so that they get reset on exec.
295 1.8 cgd */
296 1.8 cgd handle(badsys, SIGSYS, 0);
297 1.8 cgd handle(disaster, SIGABRT, SIGFPE, SIGILL, SIGSEGV,
298 1.8 cgd SIGBUS, SIGXCPU, SIGXFSZ, 0);
299 1.8 cgd handle(transition_handler, SIGHUP, SIGTERM, SIGTSTP, 0);
300 1.8 cgd handle(alrm_handler, SIGALRM, 0);
301 1.47 christos (void)sigfillset(&mask);
302 1.8 cgd delset(&mask, SIGABRT, SIGFPE, SIGILL, SIGSEGV, SIGBUS, SIGSYS,
303 1.47 christos SIGXCPU, SIGXFSZ, SIGHUP, SIGTERM, SIGTSTP, SIGALRM, 0);
304 1.47 christos (void)sigprocmask(SIG_SETMASK, &mask, NULL);
305 1.47 christos (void)sigemptyset(&sa.sa_mask);
306 1.8 cgd sa.sa_flags = 0;
307 1.8 cgd sa.sa_handler = SIG_IGN;
308 1.47 christos (void)sigaction(SIGTTIN, &sa, NULL);
309 1.47 christos (void)sigaction(SIGTTOU, &sa, NULL);
310 1.8 cgd
311 1.8 cgd /*
312 1.8 cgd * Paranoia.
313 1.8 cgd */
314 1.47 christos (void)close(0);
315 1.47 christos (void)close(1);
316 1.47 christos (void)close(2);
317 1.8 cgd
318 1.73 salo #if !defined(LETS_GET_SMALL) && defined(CHROOT)
319 1.73 salo /* Create "init.root" sysctl node. */
320 1.84 christos (void)createsysctlnode();
321 1.73 salo #endif /* !LETS_GET_SMALL && CHROOT*/
322 1.73 salo
323 1.8 cgd /*
324 1.100 elad * Securelevel might not be supported by the kernel. Query for it, and
325 1.100 elad * set a variable indicating whether we should attempt anything with it
326 1.100 elad * or not.
327 1.100 elad */
328 1.100 elad securelevel_present = has_securelevel();
329 1.100 elad
330 1.100 elad /*
331 1.8 cgd * Start the state machine.
332 1.8 cgd */
333 1.8 cgd transition(requested_transition);
334 1.8 cgd
335 1.8 cgd /*
336 1.8 cgd * Should never reach here.
337 1.8 cgd */
338 1.8 cgd return 1;
339 1.8 cgd }
340 1.8 cgd
341 1.8 cgd /*
342 1.8 cgd * Associate a function with a signal handler.
343 1.8 cgd */
344 1.101 joerg static void
345 1.8 cgd handle(sig_t handler, ...)
346 1.8 cgd {
347 1.8 cgd int sig;
348 1.8 cgd struct sigaction sa;
349 1.33 thorpej sigset_t mask_everything;
350 1.8 cgd va_list ap;
351 1.8 cgd
352 1.8 cgd va_start(ap, handler);
353 1.7 cgd
354 1.8 cgd sa.sa_handler = handler;
355 1.47 christos (void)sigfillset(&mask_everything);
356 1.1 cgd
357 1.27 perry while ((sig = va_arg(ap, int)) != 0) {
358 1.8 cgd sa.sa_mask = mask_everything;
359 1.8 cgd /* XXX SA_RESTART? */
360 1.8 cgd sa.sa_flags = sig == SIGCHLD ? SA_NOCLDSTOP : 0;
361 1.47 christos (void)sigaction(sig, &sa, NULL);
362 1.8 cgd }
363 1.8 cgd va_end(ap);
364 1.8 cgd }
365 1.1 cgd
366 1.8 cgd /*
367 1.8 cgd * Delete a set of signals from a mask.
368 1.8 cgd */
369 1.101 joerg static void
370 1.8 cgd delset(sigset_t *maskp, ...)
371 1.8 cgd {
372 1.8 cgd int sig;
373 1.8 cgd va_list ap;
374 1.8 cgd
375 1.8 cgd va_start(ap, maskp);
376 1.1 cgd
377 1.27 perry while ((sig = va_arg(ap, int)) != 0)
378 1.47 christos (void)sigdelset(maskp, sig);
379 1.8 cgd va_end(ap);
380 1.8 cgd }
381 1.8 cgd
382 1.91 dsl #if 0 /* Enable to get error messages from init ! */
383 1.91 dsl #define vsyslog(level, fmt, ap) print_console(level, fmt, ap)
384 1.91 dsl #define closelog()
385 1.91 dsl
386 1.91 dsl static void
387 1.91 dsl print_console(int level, const char *message, va_list ap)
388 1.91 dsl {
389 1.91 dsl /*
390 1.91 dsl * XXX: syslog seems to just plain not work in console-only
391 1.91 dsl * XXX: situation... that should be fixed. Let's leave this
392 1.91 dsl * XXX: note + code here in case someone gets in trouble and
393 1.91 dsl * XXX: wants to debug. -- Jachym Holecek <freza (at) liberouter.org>
394 1.91 dsl */
395 1.91 dsl char errbuf[1024];
396 1.91 dsl int fd, len;
397 1.91 dsl
398 1.91 dsl /* We can't do anything on errors, anyway... */
399 1.91 dsl fd = open(_PATH_CONSOLE, O_WRONLY);
400 1.91 dsl if (fd == -1)
401 1.91 dsl return ;
402 1.91 dsl
403 1.91 dsl /* %m will get lost... */
404 1.91 dsl len = vsnprintf(errbuf, sizeof(errbuf), message, ap);
405 1.91 dsl (void)write(fd, (void *)errbuf, len);
406 1.91 dsl (void)close(fd);
407 1.91 dsl }
408 1.91 dsl #endif
409 1.91 dsl
410 1.8 cgd /*
411 1.8 cgd * Log a message and sleep for a while (to give someone an opportunity
412 1.8 cgd * to read it and to save log or hardcopy output if the problem is chronic).
413 1.8 cgd * NB: should send a message to the session logger to avoid blocking.
414 1.8 cgd */
415 1.101 joerg static void
416 1.28 christos stall(const char *message, ...)
417 1.8 cgd {
418 1.8 cgd va_list ap;
419 1.8 cgd
420 1.8 cgd va_start(ap, message);
421 1.8 cgd vsyslog(LOG_ALERT, message, ap);
422 1.8 cgd va_end(ap);
423 1.24 mycroft closelog();
424 1.47 christos (void)sleep(STALL_TIMEOUT);
425 1.8 cgd }
426 1.8 cgd
427 1.8 cgd /*
428 1.8 cgd * Like stall(), but doesn't sleep.
429 1.8 cgd * If cpp had variadic macros, the two functions could be #defines for another.
430 1.8 cgd * NB: should send a message to the session logger to avoid blocking.
431 1.8 cgd */
432 1.101 joerg static void
433 1.28 christos warning(const char *message, ...)
434 1.8 cgd {
435 1.8 cgd va_list ap;
436 1.8 cgd
437 1.8 cgd va_start(ap, message);
438 1.8 cgd vsyslog(LOG_ALERT, message, ap);
439 1.8 cgd va_end(ap);
440 1.24 mycroft closelog();
441 1.8 cgd }
442 1.1 cgd
443 1.8 cgd /*
444 1.8 cgd * Log an emergency message.
445 1.8 cgd * NB: should send a message to the session logger to avoid blocking.
446 1.8 cgd */
447 1.101 joerg static void
448 1.28 christos emergency(const char *message, ...)
449 1.8 cgd {
450 1.8 cgd va_list ap;
451 1.8 cgd
452 1.8 cgd va_start(ap, message);
453 1.8 cgd vsyslog(LOG_EMERG, message, ap);
454 1.8 cgd va_end(ap);
455 1.24 mycroft closelog();
456 1.8 cgd }
457 1.1 cgd
458 1.8 cgd /*
459 1.8 cgd * Catch a SIGSYS signal.
460 1.8 cgd *
461 1.8 cgd * These may arise if a system does not support sysctl.
462 1.8 cgd * We tolerate up to 25 of these, then throw in the towel.
463 1.8 cgd */
464 1.101 joerg static void
465 1.39 wiz badsys(int sig)
466 1.1 cgd {
467 1.8 cgd static int badcount = 0;
468 1.8 cgd
469 1.8 cgd if (badcount++ < 25)
470 1.8 cgd return;
471 1.8 cgd disaster(sig);
472 1.1 cgd }
473 1.1 cgd
474 1.8 cgd /*
475 1.8 cgd * Catch an unexpected signal.
476 1.8 cgd */
477 1.101 joerg static void
478 1.39 wiz disaster(int sig)
479 1.8 cgd {
480 1.43 lukem
481 1.20 jtc emergency("fatal signal: %s", strsignal(sig));
482 1.47 christos (void)sleep(STALL_TIMEOUT);
483 1.8 cgd _exit(sig); /* reboot */
484 1.8 cgd }
485 1.8 cgd
486 1.8 cgd /*
487 1.100 elad * Check if securelevel is present.
488 1.100 elad */
489 1.101 joerg static int
490 1.100 elad has_securelevel(void)
491 1.100 elad {
492 1.100 elad #ifdef KERN_SECURELVL
493 1.100 elad int name[2], curlevel;
494 1.100 elad size_t len;
495 1.100 elad
496 1.100 elad name[0] = CTL_KERN;
497 1.100 elad name[1] = KERN_SECURELVL;
498 1.100 elad len = sizeof curlevel;
499 1.100 elad if (sysctl(name, 2, &curlevel, &len, NULL, 0) == -1) {
500 1.100 elad /* If it doesn't exist, it's okay. */
501 1.100 elad if (errno == ENOENT)
502 1.100 elad return 0;
503 1.100 elad }
504 1.100 elad return 1;
505 1.100 elad #else
506 1.100 elad return 0;
507 1.100 elad #endif
508 1.100 elad }
509 1.100 elad
510 1.100 elad /*
511 1.8 cgd * Get the security level of the kernel.
512 1.8 cgd */
513 1.101 joerg static int
514 1.39 wiz getsecuritylevel(void)
515 1.1 cgd {
516 1.8 cgd #ifdef KERN_SECURELVL
517 1.8 cgd int name[2], curlevel;
518 1.8 cgd size_t len;
519 1.8 cgd
520 1.100 elad if (!securelevel_present)
521 1.100 elad return -1;
522 1.100 elad
523 1.8 cgd name[0] = CTL_KERN;
524 1.8 cgd name[1] = KERN_SECURELVL;
525 1.8 cgd len = sizeof curlevel;
526 1.8 cgd if (sysctl(name, 2, &curlevel, &len, NULL, 0) == -1) {
527 1.47 christos emergency("cannot get kernel security level: %m");
528 1.93 dyoung return -1;
529 1.8 cgd }
530 1.93 dyoung return curlevel;
531 1.8 cgd #else
532 1.93 dyoung return -1;
533 1.8 cgd #endif
534 1.1 cgd }
535 1.1 cgd
536 1.8 cgd /*
537 1.8 cgd * Set the security level of the kernel.
538 1.8 cgd */
539 1.101 joerg static void
540 1.39 wiz setsecuritylevel(int newlevel)
541 1.1 cgd {
542 1.8 cgd #ifdef KERN_SECURELVL
543 1.8 cgd int name[2], curlevel;
544 1.1 cgd
545 1.100 elad if (!securelevel_present)
546 1.100 elad return;
547 1.100 elad
548 1.8 cgd curlevel = getsecuritylevel();
549 1.8 cgd if (newlevel == curlevel)
550 1.8 cgd return;
551 1.8 cgd name[0] = CTL_KERN;
552 1.8 cgd name[1] = KERN_SECURELVL;
553 1.8 cgd if (sysctl(name, 2, NULL, NULL, &newlevel, sizeof newlevel) == -1) {
554 1.80 christos emergency("cannot change kernel security level from"
555 1.47 christos " %d to %d: %m", curlevel, newlevel);
556 1.8 cgd return;
557 1.1 cgd }
558 1.8 cgd #ifdef SECURE
559 1.8 cgd warning("kernel security level changed from %d to %d",
560 1.8 cgd curlevel, newlevel);
561 1.8 cgd #endif
562 1.8 cgd #endif
563 1.1 cgd }
564 1.1 cgd
565 1.8 cgd /*
566 1.8 cgd * Change states in the finite state machine.
567 1.8 cgd * The initial state is passed as an argument.
568 1.8 cgd */
569 1.101 joerg static void
570 1.39 wiz transition(state_t s)
571 1.1 cgd {
572 1.43 lukem
573 1.55 christos if (s == NULL)
574 1.55 christos return;
575 1.77 christos for (;;) {
576 1.78 he #ifdef SUPPORT_UTMPX
577 1.77 christos #ifndef LETS_GET_SMALL
578 1.77 christos utmpx_set_runlevel(get_runlevel(current_state),
579 1.77 christos get_runlevel(s));
580 1.79 he current_state = s;
581 1.77 christos #endif
582 1.77 christos #endif
583 1.47 christos s = (state_t)(*s)();
584 1.77 christos }
585 1.1 cgd }
586 1.1 cgd
587 1.64 christos #ifndef LETS_GET_SMALL
588 1.8 cgd /*
589 1.8 cgd * Close out the accounting files for a login session.
590 1.8 cgd * NB: should send a message to the session logger to avoid blocking.
591 1.8 cgd */
592 1.101 joerg static void
593 1.50 christos clear_session_logs(session_t *sp, int status)
594 1.8 cgd {
595 1.83 isaki #if defined(SUPPORT_UTMP) || defined(SUPPORT_UTMPX)
596 1.8 cgd char *line = sp->se_device + sizeof(_PATH_DEV) - 1;
597 1.83 isaki #endif
598 1.55 christos
599 1.50 christos #ifdef SUPPORT_UTMPX
600 1.51 christos if (logoutx(line, status, DEAD_PROCESS))
601 1.50 christos logwtmpx(line, "", "", status, DEAD_PROCESS);
602 1.50 christos #endif
603 1.50 christos #ifdef SUPPORT_UTMP
604 1.8 cgd if (logout(line))
605 1.8 cgd logwtmp(line, "", "");
606 1.50 christos #endif
607 1.8 cgd }
608 1.64 christos #endif
609 1.1 cgd
610 1.8 cgd /*
611 1.8 cgd * Start a session and allocate a controlling terminal.
612 1.8 cgd * Only called by children of init after forking.
613 1.8 cgd */
614 1.101 joerg static void
615 1.40 wiz setctty(const char *name)
616 1.1 cgd {
617 1.8 cgd int fd;
618 1.1 cgd
619 1.84 christos (void)revoke(name);
620 1.84 christos (void)nanosleep(&dtrtime, NULL); /* leave DTR low for a bit */
621 1.8 cgd if ((fd = open(name, O_RDWR)) == -1) {
622 1.8 cgd stall("can't open %s: %m", name);
623 1.87 cbiere _exit(1);
624 1.7 cgd }
625 1.8 cgd if (login_tty(fd) == -1) {
626 1.8 cgd stall("can't get %s for controlling terminal: %m", name);
627 1.91 dsl _exit(2);
628 1.8 cgd }
629 1.8 cgd }
630 1.8 cgd
631 1.8 cgd /*
632 1.8 cgd * Bring the system up single user.
633 1.8 cgd */
634 1.101 joerg static state_func_t
635 1.39 wiz single_user(void)
636 1.8 cgd {
637 1.8 cgd pid_t pid, wpid;
638 1.8 cgd int status;
639 1.34 tls int from_securitylevel;
640 1.8 cgd sigset_t mask;
641 1.55 christos struct sigaction sa, satstp, sahup;
642 1.31 perry #ifdef ALTSHELL
643 1.56 lukem const char *shell = INIT_BSHELL;
644 1.31 perry #endif
645 1.70 christos const char *argv[2];
646 1.8 cgd #ifdef SECURE
647 1.8 cgd struct ttyent *typ;
648 1.10 cgd struct passwd *pp;
649 1.8 cgd char *clear, *password;
650 1.7 cgd #endif
651 1.26 perry #ifdef ALTSHELL
652 1.26 perry char altshell[128];
653 1.26 perry #endif /* ALTSHELL */
654 1.7 cgd
655 1.73 salo #if !defined(LETS_GET_SMALL) && defined(CHROOT)
656 1.73 salo /* Clear previous idea, just in case. */
657 1.73 salo did_multiuser_chroot = 0;
658 1.73 salo #endif /* !LETS_GET_SMALL && CHROOT */
659 1.73 salo
660 1.8 cgd /*
661 1.8 cgd * If the kernel is in secure mode, downgrade it to insecure mode.
662 1.8 cgd */
663 1.34 tls from_securitylevel = getsecuritylevel();
664 1.34 tls if (from_securitylevel > 0)
665 1.8 cgd setsecuritylevel(0);
666 1.8 cgd
667 1.55 christos (void)sigemptyset(&sa.sa_mask);
668 1.55 christos sa.sa_flags = 0;
669 1.55 christos sa.sa_handler = SIG_IGN;
670 1.55 christos (void)sigaction(SIGTSTP, &sa, &satstp);
671 1.55 christos (void)sigaction(SIGHUP, &sa, &sahup);
672 1.8 cgd if ((pid = fork()) == 0) {
673 1.8 cgd /*
674 1.8 cgd * Start the single user session.
675 1.8 cgd */
676 1.63 dsl if (access(_PATH_CONSTTY, F_OK) == 0)
677 1.63 dsl setctty(_PATH_CONSTTY);
678 1.63 dsl else
679 1.63 dsl setctty(_PATH_CONSOLE);
680 1.8 cgd
681 1.8 cgd #ifdef SECURE
682 1.8 cgd /*
683 1.8 cgd * Check the root password.
684 1.8 cgd * We don't care if the console is 'on' by default;
685 1.8 cgd * it's the only tty that can be 'off' and 'secure'.
686 1.8 cgd */
687 1.10 cgd typ = getttynam("console");
688 1.10 cgd pp = getpwnam("root");
689 1.34 tls if (typ && (from_securitylevel >=2 || (typ->ty_status
690 1.34 tls & TTY_SECURE) == 0) && pp && *pp->pw_passwd != '\0') {
691 1.47 christos (void)fprintf(stderr,
692 1.26 perry "Enter root password, or ^D to go multi-user\n");
693 1.8 cgd for (;;) {
694 1.8 cgd clear = getpass("Password:");
695 1.8 cgd if (clear == 0 || *clear == '\0')
696 1.87 cbiere _exit(0);
697 1.8 cgd password = crypt(clear, pp->pw_passwd);
698 1.47 christos (void)memset(clear, 0, _PASSWORD_LEN);
699 1.8 cgd if (strcmp(password, pp->pw_passwd) == 0)
700 1.8 cgd break;
701 1.80 christos warning("single-user login failed");
702 1.1 cgd }
703 1.8 cgd }
704 1.84 christos (void)endttyent();
705 1.10 cgd endpwent();
706 1.9 cgd #endif /* SECURE */
707 1.1 cgd
708 1.26 perry #ifdef ALTSHELL
709 1.47 christos (void)fprintf(stderr,
710 1.52 lukem "Enter pathname of shell or RETURN for %s: ", shell);
711 1.38 wiz if (fgets(altshell, sizeof(altshell), stdin) == NULL) {
712 1.38 wiz altshell[0] = '\0';
713 1.38 wiz } else {
714 1.38 wiz /* nuke \n */
715 1.38 wiz char *p;
716 1.38 wiz
717 1.41 wiz if ((p = strchr(altshell, '\n')) != NULL)
718 1.38 wiz *p = '\0';
719 1.38 wiz }
720 1.26 perry
721 1.26 perry if (altshell[0])
722 1.26 perry shell = altshell;
723 1.26 perry #endif /* ALTSHELL */
724 1.8 cgd
725 1.8 cgd /*
726 1.8 cgd * Unblock signals.
727 1.8 cgd * We catch all the interesting ones,
728 1.8 cgd * and those are reset to SIG_DFL on exec.
729 1.8 cgd */
730 1.47 christos (void)sigemptyset(&mask);
731 1.47 christos (void)sigprocmask(SIG_SETMASK, &mask, NULL);
732 1.8 cgd
733 1.8 cgd /*
734 1.8 cgd * Fire off a shell.
735 1.8 cgd * If the default one doesn't work, try the Bourne shell.
736 1.8 cgd */
737 1.8 cgd argv[0] = "-sh";
738 1.8 cgd argv[1] = 0;
739 1.84 christos (void)setenv("PATH", INIT_PATH, 1);
740 1.26 perry #ifdef ALTSHELL
741 1.26 perry if (altshell[0])
742 1.26 perry argv[0] = altshell;
743 1.70 christos (void)execv(shell, __UNCONST(argv));
744 1.80 christos emergency("can't exec `%s' for single user: %m", shell);
745 1.26 perry argv[0] = "-sh";
746 1.26 perry #endif /* ALTSHELL */
747 1.70 christos (void)execv(INIT_BSHELL, __UNCONST(argv));
748 1.80 christos emergency("can't exec `%s' for single user: %m", INIT_BSHELL);
749 1.67 mycroft (void)sleep(STALL_TIMEOUT);
750 1.91 dsl _exit(3);
751 1.8 cgd }
752 1.8 cgd
753 1.8 cgd if (pid == -1) {
754 1.8 cgd /*
755 1.8 cgd * We are seriously hosed. Do our best.
756 1.8 cgd */
757 1.80 christos emergency("can't fork single-user shell: %m, trying again");
758 1.47 christos while (waitpid(-1, NULL, WNOHANG) > 0)
759 1.8 cgd continue;
760 1.55 christos (void)sigaction(SIGTSTP, &satstp, NULL);
761 1.55 christos (void)sigaction(SIGHUP, &sahup, NULL);
762 1.93 dyoung return (state_func_t)single_user;
763 1.1 cgd }
764 1.8 cgd
765 1.8 cgd requested_transition = 0;
766 1.8 cgd do {
767 1.8 cgd if ((wpid = waitpid(-1, &status, WUNTRACED)) != -1)
768 1.50 christos collect_child(wpid, status);
769 1.8 cgd if (wpid == -1) {
770 1.8 cgd if (errno == EINTR)
771 1.8 cgd continue;
772 1.47 christos warning("wait for single-user shell failed: %m; "
773 1.47 christos "restarting");
774 1.47 christos return (state_func_t)single_user;
775 1.8 cgd }
776 1.8 cgd if (wpid == pid && WIFSTOPPED(status)) {
777 1.80 christos warning("shell stopped, restarting");
778 1.84 christos (void)kill(pid, SIGCONT);
779 1.8 cgd wpid = -1;
780 1.8 cgd }
781 1.8 cgd } while (wpid != pid && !requested_transition);
782 1.1 cgd
783 1.55 christos if (requested_transition) {
784 1.55 christos (void)sigaction(SIGTSTP, &satstp, NULL);
785 1.55 christos (void)sigaction(SIGHUP, &sahup, NULL);
786 1.47 christos return (state_func_t)requested_transition;
787 1.55 christos }
788 1.1 cgd
789 1.49 mycroft if (WIFSIGNALED(status)) {
790 1.49 mycroft if (WTERMSIG(status) == SIGKILL) {
791 1.49 mycroft /* executed /sbin/reboot; wait for the end quietly */
792 1.49 mycroft sigset_t s;
793 1.49 mycroft
794 1.49 mycroft (void)sigfillset(&s);
795 1.49 mycroft for (;;)
796 1.49 mycroft (void)sigsuspend(&s);
797 1.8 cgd } else {
798 1.91 dsl warning("single user shell terminated (%x), restarting",
799 1.91 dsl status);
800 1.55 christos (void)sigaction(SIGTSTP, &satstp, NULL);
801 1.55 christos (void)sigaction(SIGHUP, &sahup, NULL);
802 1.93 dyoung return (state_func_t)single_user;
803 1.1 cgd }
804 1.8 cgd }
805 1.8 cgd
806 1.8 cgd runcom_mode = FASTBOOT;
807 1.55 christos (void)sigaction(SIGTSTP, &satstp, NULL);
808 1.55 christos (void)sigaction(SIGHUP, &sahup, NULL);
809 1.13 cgd #ifndef LETS_GET_SMALL
810 1.93 dyoung return (state_func_t)runcom;
811 1.13 cgd #else /* LETS_GET_SMALL */
812 1.93 dyoung return (state_func_t)single_user;
813 1.13 cgd #endif /* LETS_GET_SMALL */
814 1.8 cgd }
815 1.8 cgd
816 1.13 cgd #ifndef LETS_GET_SMALL
817 1.73 salo
818 1.73 salo /* ARGSUSED */
819 1.101 joerg static state_func_t
820 1.73 salo runetcrc(int trychroot)
821 1.8 cgd {
822 1.8 cgd pid_t pid, wpid;
823 1.8 cgd int status;
824 1.70 christos const char *argv[4];
825 1.8 cgd struct sigaction sa;
826 1.8 cgd
827 1.47 christos switch ((pid = fork())) {
828 1.47 christos case 0:
829 1.47 christos (void)sigemptyset(&sa.sa_mask);
830 1.8 cgd sa.sa_flags = 0;
831 1.8 cgd sa.sa_handler = SIG_IGN;
832 1.47 christos (void)sigaction(SIGTSTP, &sa, NULL);
833 1.47 christos (void)sigaction(SIGHUP, &sa, NULL);
834 1.8 cgd
835 1.8 cgd setctty(_PATH_CONSOLE);
836 1.8 cgd
837 1.8 cgd argv[0] = "sh";
838 1.8 cgd argv[1] = _PATH_RUNCOM;
839 1.73 salo argv[2] = (runcom_mode == AUTOBOOT ? "autoboot" : 0);
840 1.8 cgd argv[3] = 0;
841 1.8 cgd
842 1.47 christos (void)sigprocmask(SIG_SETMASK, &sa.sa_mask, NULL);
843 1.8 cgd
844 1.73 salo #ifdef CHROOT
845 1.73 salo if (trychroot)
846 1.73 salo if (chroot(rootdir) != 0) {
847 1.80 christos warning("failed to chroot to `%s': %m",
848 1.73 salo rootdir);
849 1.91 dsl _exit(4); /* force single user mode */
850 1.73 salo }
851 1.73 salo #endif /* CHROOT */
852 1.73 salo
853 1.70 christos (void)execv(INIT_BSHELL, __UNCONST(argv));
854 1.80 christos stall("can't exec `%s' for `%s': %m", INIT_BSHELL, _PATH_RUNCOM);
855 1.91 dsl _exit(5); /* force single user mode */
856 1.47 christos /*NOTREACHED*/
857 1.47 christos case -1:
858 1.80 christos emergency("can't fork for `%s' on `%s': %m", INIT_BSHELL,
859 1.47 christos _PATH_RUNCOM);
860 1.47 christos while (waitpid(-1, NULL, WNOHANG) > 0)
861 1.1 cgd continue;
862 1.47 christos (void)sleep(STALL_TIMEOUT);
863 1.47 christos return (state_func_t)single_user;
864 1.47 christos default:
865 1.47 christos break;
866 1.8 cgd }
867 1.8 cgd
868 1.8 cgd /*
869 1.8 cgd * Copied from single_user(). This is a bit paranoid.
870 1.8 cgd */
871 1.8 cgd do {
872 1.8 cgd if ((wpid = waitpid(-1, &status, WUNTRACED)) != -1)
873 1.50 christos collect_child(wpid, status);
874 1.8 cgd if (wpid == -1) {
875 1.8 cgd if (errno == EINTR)
876 1.8 cgd continue;
877 1.80 christos warning("wait for `%s' on `%s' failed: %m; going to "
878 1.56 lukem "single user mode", INIT_BSHELL, _PATH_RUNCOM);
879 1.47 christos return (state_func_t)single_user;
880 1.8 cgd }
881 1.8 cgd if (wpid == pid && WIFSTOPPED(status)) {
882 1.80 christos warning("`%s' on `%s' stopped, restarting",
883 1.56 lukem INIT_BSHELL, _PATH_RUNCOM);
884 1.47 christos (void)kill(pid, SIGCONT);
885 1.8 cgd wpid = -1;
886 1.8 cgd }
887 1.8 cgd } while (wpid != pid);
888 1.8 cgd
889 1.8 cgd if (WIFSIGNALED(status) && WTERMSIG(status) == SIGTERM &&
890 1.8 cgd requested_transition == catatonia) {
891 1.8 cgd /* /etc/rc executed /sbin/reboot; wait for the end quietly */
892 1.8 cgd sigset_t s;
893 1.8 cgd
894 1.47 christos (void)sigfillset(&s);
895 1.8 cgd for (;;)
896 1.47 christos (void)sigsuspend(&s);
897 1.8 cgd }
898 1.8 cgd
899 1.8 cgd if (!WIFEXITED(status)) {
900 1.80 christos warning("`%s' on `%s' terminated abnormally, going to "
901 1.56 lukem "single user mode", INIT_BSHELL, _PATH_RUNCOM);
902 1.47 christos return (state_func_t)single_user;
903 1.8 cgd }
904 1.8 cgd
905 1.8 cgd if (WEXITSTATUS(status))
906 1.47 christos return (state_func_t)single_user;
907 1.8 cgd
908 1.93 dyoung return (state_func_t)read_ttys;
909 1.73 salo }
910 1.73 salo
911 1.73 salo /*
912 1.73 salo * Run the system startup script.
913 1.73 salo */
914 1.101 joerg static state_func_t
915 1.73 salo runcom(void)
916 1.73 salo {
917 1.73 salo state_func_t next_step;
918 1.73 salo
919 1.73 salo /* Run /etc/rc and choose next state depending on the result. */
920 1.73 salo next_step = runetcrc(0);
921 1.93 dyoung if (next_step != (state_func_t)read_ttys)
922 1.93 dyoung return (state_func_t)next_step;
923 1.73 salo
924 1.73 salo #ifdef CHROOT
925 1.73 salo /*
926 1.73 salo * If init.root sysctl does not point to "/", we'll chroot and run
927 1.73 salo * The Real(tm) /etc/rc now. Global variable rootdir will tell us
928 1.73 salo * where to go.
929 1.73 salo */
930 1.73 salo if (shouldchroot()) {
931 1.73 salo next_step = runetcrc(1);
932 1.93 dyoung if (next_step != (state_func_t)read_ttys)
933 1.93 dyoung return (state_func_t)next_step;
934 1.73 salo
935 1.73 salo did_multiuser_chroot = 1;
936 1.73 salo } else {
937 1.73 salo did_multiuser_chroot = 0;
938 1.73 salo }
939 1.73 salo #endif /* CHROOT */
940 1.73 salo
941 1.73 salo /*
942 1.73 salo * Regardless of whether in chroot or not, we booted successfuly.
943 1.73 salo * It's time to spawn gettys (ie. next_step's value at this point).
944 1.73 salo */
945 1.8 cgd runcom_mode = AUTOBOOT; /* the default */
946 1.8 cgd /* NB: should send a message to the session logger to avoid blocking. */
947 1.51 christos #ifdef SUPPORT_UTMPX
948 1.50 christos logwtmpx("~", "reboot", "", 0, INIT_PROCESS);
949 1.50 christos #endif
950 1.51 christos #ifdef SUPPORT_UTMP
951 1.8 cgd logwtmp("~", "reboot", "");
952 1.50 christos #endif
953 1.93 dyoung return (state_func_t)read_ttys;
954 1.8 cgd }
955 1.8 cgd
956 1.8 cgd /*
957 1.8 cgd * Open the session database.
958 1.8 cgd *
959 1.8 cgd * NB: We could pass in the size here; is it necessary?
960 1.8 cgd */
961 1.101 joerg static int
962 1.39 wiz start_session_db(void)
963 1.8 cgd {
964 1.43 lukem
965 1.8 cgd if (session_db && (*session_db->close)(session_db))
966 1.47 christos emergency("session database close: %m");
967 1.8 cgd if ((session_db = dbopen(NULL, O_RDWR, 0, DB_HASH, NULL)) == 0) {
968 1.47 christos emergency("session database open: %m");
969 1.93 dyoung return 1;
970 1.8 cgd }
971 1.93 dyoung return 0;
972 1.8 cgd
973 1.8 cgd }
974 1.8 cgd
975 1.8 cgd /*
976 1.8 cgd * Add a new login session.
977 1.8 cgd */
978 1.101 joerg static void
979 1.39 wiz add_session(session_t *sp)
980 1.8 cgd {
981 1.8 cgd DBT key;
982 1.8 cgd DBT data;
983 1.8 cgd
984 1.55 christos if (session_db == NULL)
985 1.55 christos return;
986 1.55 christos
987 1.8 cgd key.data = &sp->se_process;
988 1.8 cgd key.size = sizeof sp->se_process;
989 1.8 cgd data.data = &sp;
990 1.8 cgd data.size = sizeof sp;
991 1.8 cgd
992 1.8 cgd if ((*session_db->put)(session_db, &key, &data, 0))
993 1.47 christos emergency("insert %d: %m", sp->se_process);
994 1.77 christos #ifdef SUPPORT_UTMPX
995 1.77 christos session_utmpx(sp, 1);
996 1.77 christos #endif
997 1.8 cgd }
998 1.8 cgd
999 1.8 cgd /*
1000 1.8 cgd * Delete an old login session.
1001 1.8 cgd */
1002 1.101 joerg static void
1003 1.39 wiz del_session(session_t *sp)
1004 1.8 cgd {
1005 1.8 cgd DBT key;
1006 1.8 cgd
1007 1.8 cgd key.data = &sp->se_process;
1008 1.8 cgd key.size = sizeof sp->se_process;
1009 1.8 cgd
1010 1.8 cgd if ((*session_db->del)(session_db, &key, 0))
1011 1.47 christos emergency("delete %d: %m", sp->se_process);
1012 1.77 christos #ifdef SUPPORT_UTMPX
1013 1.77 christos session_utmpx(sp, 0);
1014 1.77 christos #endif
1015 1.8 cgd }
1016 1.8 cgd
1017 1.8 cgd /*
1018 1.8 cgd * Look up a login session by pid.
1019 1.8 cgd */
1020 1.101 joerg static session_t *
1021 1.8 cgd find_session(pid_t pid)
1022 1.8 cgd {
1023 1.8 cgd DBT key;
1024 1.8 cgd DBT data;
1025 1.8 cgd session_t *ret;
1026 1.8 cgd
1027 1.55 christos if (session_db == NULL)
1028 1.55 christos return NULL;
1029 1.55 christos
1030 1.8 cgd key.data = &pid;
1031 1.8 cgd key.size = sizeof pid;
1032 1.8 cgd if ((*session_db->get)(session_db, &key, &data, 0) != 0)
1033 1.8 cgd return 0;
1034 1.47 christos (void)memmove(&ret, data.data, sizeof(ret));
1035 1.8 cgd return ret;
1036 1.8 cgd }
1037 1.8 cgd
1038 1.8 cgd /*
1039 1.8 cgd * Construct an argument vector from a command line.
1040 1.8 cgd */
1041 1.101 joerg static char **
1042 1.39 wiz construct_argv(char *command)
1043 1.8 cgd {
1044 1.27 perry int argc = 0;
1045 1.47 christos char **argv = malloc(((strlen(command) + 1) / 2 + 1) * sizeof (char *));
1046 1.8 cgd static const char separators[] = " \t";
1047 1.8 cgd
1048 1.71 chris if (argv == NULL)
1049 1.93 dyoung return NULL;
1050 1.71 chris
1051 1.71 chris if ((argv[argc++] = strtok(command, separators)) == 0) {
1052 1.71 chris free(argv);
1053 1.93 dyoung return NULL;
1054 1.71 chris }
1055 1.47 christos while ((argv[argc++] = strtok(NULL, separators)) != NULL)
1056 1.8 cgd continue;
1057 1.93 dyoung return argv;
1058 1.8 cgd }
1059 1.8 cgd
1060 1.8 cgd /*
1061 1.8 cgd * Deallocate a session descriptor.
1062 1.8 cgd */
1063 1.101 joerg static void
1064 1.39 wiz free_session(session_t *sp)
1065 1.8 cgd {
1066 1.43 lukem
1067 1.8 cgd free(sp->se_device);
1068 1.8 cgd if (sp->se_getty) {
1069 1.8 cgd free(sp->se_getty);
1070 1.8 cgd free(sp->se_getty_argv);
1071 1.8 cgd }
1072 1.8 cgd if (sp->se_window) {
1073 1.8 cgd free(sp->se_window);
1074 1.8 cgd free(sp->se_window_argv);
1075 1.8 cgd }
1076 1.8 cgd free(sp);
1077 1.8 cgd }
1078 1.8 cgd
1079 1.8 cgd /*
1080 1.8 cgd * Allocate a new session descriptor.
1081 1.8 cgd */
1082 1.101 joerg static session_t *
1083 1.39 wiz new_session(session_t *sprev, int session_index, struct ttyent *typ)
1084 1.8 cgd {
1085 1.27 perry session_t *sp;
1086 1.8 cgd
1087 1.47 christos if ((typ->ty_status & TTY_ON) == 0 || typ->ty_name == NULL ||
1088 1.27 perry typ->ty_getty == NULL)
1089 1.93 dyoung return NULL;
1090 1.8 cgd
1091 1.47 christos sp = malloc(sizeof (session_t));
1092 1.55 christos if (sp == NULL)
1093 1.55 christos return NULL;
1094 1.84 christos (void)memset(sp, 0, sizeof *sp);
1095 1.8 cgd
1096 1.21 mycroft sp->se_flags = SE_PRESENT;
1097 1.8 cgd sp->se_index = session_index;
1098 1.8 cgd
1099 1.59 itojun (void)asprintf(&sp->se_device, "%s%s", _PATH_DEV, typ->ty_name);
1100 1.59 itojun if (!sp->se_device)
1101 1.59 itojun return NULL;
1102 1.8 cgd
1103 1.8 cgd if (setupargv(sp, typ) == 0) {
1104 1.8 cgd free_session(sp);
1105 1.93 dyoung return NULL;
1106 1.8 cgd }
1107 1.8 cgd
1108 1.27 perry sp->se_next = NULL;
1109 1.27 perry if (sprev == NULL) {
1110 1.8 cgd sessions = sp;
1111 1.27 perry sp->se_prev = NULL;
1112 1.8 cgd } else {
1113 1.8 cgd sprev->se_next = sp;
1114 1.8 cgd sp->se_prev = sprev;
1115 1.8 cgd }
1116 1.8 cgd
1117 1.93 dyoung return sp;
1118 1.8 cgd }
1119 1.8 cgd
1120 1.8 cgd /*
1121 1.8 cgd * Calculate getty and if useful window argv vectors.
1122 1.8 cgd */
1123 1.101 joerg static int
1124 1.39 wiz setupargv(session_t *sp, struct ttyent *typ)
1125 1.8 cgd {
1126 1.8 cgd
1127 1.8 cgd if (sp->se_getty) {
1128 1.8 cgd free(sp->se_getty);
1129 1.8 cgd free(sp->se_getty_argv);
1130 1.8 cgd }
1131 1.59 itojun (void)asprintf(&sp->se_getty, "%s %s", typ->ty_getty, typ->ty_name);
1132 1.59 itojun if (!sp->se_getty)
1133 1.93 dyoung return 0;
1134 1.8 cgd sp->se_getty_argv = construct_argv(sp->se_getty);
1135 1.27 perry if (sp->se_getty_argv == NULL) {
1136 1.80 christos warning("can't parse getty for port `%s'", sp->se_device);
1137 1.8 cgd free(sp->se_getty);
1138 1.27 perry sp->se_getty = NULL;
1139 1.93 dyoung return 0;
1140 1.8 cgd }
1141 1.8 cgd if (typ->ty_window) {
1142 1.8 cgd if (sp->se_window)
1143 1.8 cgd free(sp->se_window);
1144 1.8 cgd sp->se_window = strdup(typ->ty_window);
1145 1.8 cgd sp->se_window_argv = construct_argv(sp->se_window);
1146 1.27 perry if (sp->se_window_argv == NULL) {
1147 1.80 christos warning("can't parse window for port `%s'",
1148 1.47 christos sp->se_device);
1149 1.8 cgd free(sp->se_window);
1150 1.27 perry sp->se_window = NULL;
1151 1.93 dyoung return 0;
1152 1.1 cgd }
1153 1.8 cgd }
1154 1.93 dyoung return 1;
1155 1.8 cgd }
1156 1.8 cgd
1157 1.8 cgd /*
1158 1.8 cgd * Walk the list of ttys and create sessions for each active line.
1159 1.8 cgd */
1160 1.101 joerg static state_func_t
1161 1.39 wiz read_ttys(void)
1162 1.8 cgd {
1163 1.8 cgd int session_index = 0;
1164 1.27 perry session_t *sp, *snext;
1165 1.27 perry struct ttyent *typ;
1166 1.8 cgd
1167 1.77 christos #ifdef SUPPORT_UTMPX
1168 1.77 christos if (sessions == NULL) {
1169 1.77 christos struct stat st;
1170 1.77 christos
1171 1.77 christos make_utmpx("", BOOT_MSG, BOOT_TIME, 0, &boot_time, 0);
1172 1.77 christos
1173 1.77 christos /*
1174 1.99 mbalmer * If wtmpx is not empty, pick the down time from there
1175 1.77 christos */
1176 1.87 cbiere if (stat(_PATH_WTMPX, &st) != -1 && st.st_size != 0) {
1177 1.77 christos struct timeval down_time;
1178 1.77 christos
1179 1.77 christos TIMESPEC_TO_TIMEVAL(&down_time,
1180 1.77 christos st.st_atime > st.st_mtime ?
1181 1.77 christos &st.st_atimespec : &st.st_mtimespec);
1182 1.77 christos make_utmpx("", DOWN_MSG, DOWN_TIME, 0, &down_time, 0);
1183 1.77 christos }
1184 1.77 christos }
1185 1.77 christos #endif
1186 1.8 cgd /*
1187 1.8 cgd * Destroy any previous session state.
1188 1.8 cgd * There shouldn't be any, but just in case...
1189 1.8 cgd */
1190 1.8 cgd for (sp = sessions; sp; sp = snext) {
1191 1.64 christos #ifndef LETS_GET_SMALL
1192 1.8 cgd if (sp->se_process)
1193 1.50 christos clear_session_logs(sp, 0);
1194 1.64 christos #endif
1195 1.8 cgd snext = sp->se_next;
1196 1.8 cgd free_session(sp);
1197 1.8 cgd }
1198 1.27 perry sessions = NULL;
1199 1.73 salo
1200 1.73 salo if (start_session_db()) {
1201 1.80 christos warning("start_session_db failed, death");
1202 1.73 salo #ifdef CHROOT
1203 1.73 salo /* If /etc/rc ran in chroot, we want to kill any survivors. */
1204 1.73 salo if (did_multiuser_chroot)
1205 1.73 salo return (state_func_t)death;
1206 1.73 salo else
1207 1.73 salo #endif /* CHROOT */
1208 1.73 salo return (state_func_t)single_user;
1209 1.73 salo }
1210 1.73 salo
1211 1.84 christos (void)do_setttyent();
1212 1.8 cgd
1213 1.8 cgd /*
1214 1.8 cgd * Allocate a session entry for each active port.
1215 1.8 cgd * Note that sp starts at 0.
1216 1.8 cgd */
1217 1.27 perry while ((typ = getttyent()) != NULL)
1218 1.27 perry if ((snext = new_session(sp, ++session_index, typ)) != NULL)
1219 1.8 cgd sp = snext;
1220 1.84 christos (void)endttyent();
1221 1.8 cgd
1222 1.47 christos return (state_func_t)multi_user;
1223 1.8 cgd }
1224 1.8 cgd
1225 1.8 cgd /*
1226 1.8 cgd * Start a window system running.
1227 1.8 cgd */
1228 1.101 joerg static void
1229 1.39 wiz start_window_system(session_t *sp)
1230 1.8 cgd {
1231 1.8 cgd pid_t pid;
1232 1.8 cgd sigset_t mask;
1233 1.8 cgd
1234 1.8 cgd if ((pid = fork()) == -1) {
1235 1.80 christos emergency("can't fork for window system on port `%s': %m",
1236 1.47 christos sp->se_device);
1237 1.8 cgd /* hope that getty fails and we can try again */
1238 1.8 cgd return;
1239 1.8 cgd }
1240 1.8 cgd
1241 1.8 cgd if (pid)
1242 1.8 cgd return;
1243 1.8 cgd
1244 1.84 christos (void)sigemptyset(&mask);
1245 1.84 christos (void)sigprocmask(SIG_SETMASK, &mask, NULL);
1246 1.8 cgd
1247 1.8 cgd if (setsid() < 0)
1248 1.80 christos emergency("setsid failed (window): %m");
1249 1.8 cgd
1250 1.47 christos (void)execv(sp->se_window_argv[0], sp->se_window_argv);
1251 1.80 christos stall("can't exec window system `%s' for port `%s': %m",
1252 1.47 christos sp->se_window_argv[0], sp->se_device);
1253 1.91 dsl _exit(6);
1254 1.8 cgd }
1255 1.8 cgd
1256 1.8 cgd /*
1257 1.8 cgd * Start a login session running.
1258 1.8 cgd */
1259 1.101 joerg static pid_t
1260 1.39 wiz start_getty(session_t *sp)
1261 1.8 cgd {
1262 1.8 cgd pid_t pid;
1263 1.8 cgd sigset_t mask;
1264 1.47 christos time_t current_time = time(NULL);
1265 1.8 cgd
1266 1.8 cgd /*
1267 1.8 cgd * fork(), not vfork() -- we can't afford to block.
1268 1.8 cgd */
1269 1.8 cgd if ((pid = fork()) == -1) {
1270 1.80 christos emergency("can't fork for getty on port `%s': %m",
1271 1.80 christos sp->se_device);
1272 1.8 cgd return -1;
1273 1.8 cgd }
1274 1.8 cgd
1275 1.8 cgd if (pid)
1276 1.8 cgd return pid;
1277 1.8 cgd
1278 1.73 salo #ifdef CHROOT
1279 1.73 salo /* If /etc/rc did proceed inside chroot, we have to try as well. */
1280 1.73 salo if (did_multiuser_chroot)
1281 1.73 salo if (chroot(rootdir) != 0) {
1282 1.80 christos stall("can't chroot getty `%s' inside `%s': %m",
1283 1.73 salo sp->se_getty_argv[0], rootdir);
1284 1.91 dsl _exit(7);
1285 1.73 salo }
1286 1.73 salo #endif /* CHROOT */
1287 1.73 salo
1288 1.77 christos if (current_time > sp->se_started.tv_sec &&
1289 1.77 christos current_time - sp->se_started.tv_sec < GETTY_SPACING) {
1290 1.80 christos warning("getty repeating too quickly on port `%s', sleeping",
1291 1.47 christos sp->se_device);
1292 1.47 christos (void)sleep(GETTY_SLEEP);
1293 1.8 cgd }
1294 1.8 cgd
1295 1.8 cgd if (sp->se_window) {
1296 1.8 cgd start_window_system(sp);
1297 1.47 christos (void)sleep(WINDOW_WAIT);
1298 1.1 cgd }
1299 1.8 cgd
1300 1.47 christos (void)sigemptyset(&mask);
1301 1.47 christos (void)sigprocmask(SIG_SETMASK, &mask, (sigset_t *) 0);
1302 1.8 cgd
1303 1.47 christos (void)execv(sp->se_getty_argv[0], sp->se_getty_argv);
1304 1.80 christos stall("can't exec getty `%s' for port `%s': %m",
1305 1.47 christos sp->se_getty_argv[0], sp->se_device);
1306 1.91 dsl _exit(8);
1307 1.47 christos /*NOTREACHED*/
1308 1.1 cgd }
1309 1.77 christos #ifdef SUPPORT_UTMPX
1310 1.77 christos static void
1311 1.77 christos session_utmpx(const session_t *sp, int add)
1312 1.77 christos {
1313 1.77 christos const char *name = sp->se_getty ? sp->se_getty :
1314 1.77 christos (sp->se_window ? sp->se_window : "");
1315 1.77 christos const char *line = sp->se_device + sizeof(_PATH_DEV) - 1;
1316 1.77 christos
1317 1.77 christos make_utmpx(name, line, add ? LOGIN_PROCESS : DEAD_PROCESS,
1318 1.77 christos sp->se_process, &sp->se_started, sp->se_index);
1319 1.77 christos }
1320 1.77 christos
1321 1.77 christos static void
1322 1.77 christos make_utmpx(const char *name, const char *line, int type, pid_t pid,
1323 1.77 christos const struct timeval *tv, int session)
1324 1.77 christos {
1325 1.77 christos struct utmpx ut;
1326 1.87 cbiere const char *eline;
1327 1.77 christos
1328 1.77 christos (void)memset(&ut, 0, sizeof(ut));
1329 1.77 christos (void)strlcpy(ut.ut_name, name, sizeof(ut.ut_name));
1330 1.77 christos ut.ut_type = type;
1331 1.77 christos (void)strlcpy(ut.ut_line, line, sizeof(ut.ut_line));
1332 1.77 christos ut.ut_pid = pid;
1333 1.77 christos if (tv)
1334 1.77 christos ut.ut_tv = *tv;
1335 1.77 christos else
1336 1.77 christos (void)gettimeofday(&ut.ut_tv, NULL);
1337 1.77 christos ut.ut_session = session;
1338 1.77 christos
1339 1.87 cbiere eline = line + strlen(line);
1340 1.97 lukem if ((size_t)(eline - line) >= sizeof(ut.ut_id))
1341 1.87 cbiere line = eline - sizeof(ut.ut_id);
1342 1.77 christos (void)strncpy(ut.ut_id, line, sizeof(ut.ut_id));
1343 1.77 christos
1344 1.77 christos if (pututxline(&ut) == NULL)
1345 1.80 christos warning("can't add utmpx record for `%s': %m", ut.ut_line);
1346 1.84 christos endutxent();
1347 1.77 christos }
1348 1.77 christos
1349 1.77 christos static char
1350 1.77 christos get_runlevel(const state_t s)
1351 1.77 christos {
1352 1.77 christos if (s == (state_t)single_user)
1353 1.77 christos return SINGLE_USER;
1354 1.77 christos if (s == (state_t)runcom)
1355 1.77 christos return RUNCOM;
1356 1.77 christos if (s == (state_t)read_ttys)
1357 1.77 christos return READ_TTYS;
1358 1.77 christos if (s == (state_t)multi_user)
1359 1.77 christos return MULTI_USER;
1360 1.77 christos if (s == (state_t)clean_ttys)
1361 1.77 christos return CLEAN_TTYS;
1362 1.77 christos if (s == (state_t)catatonia)
1363 1.77 christos return CATATONIA;
1364 1.77 christos return DEATH;
1365 1.77 christos }
1366 1.77 christos
1367 1.77 christos static void
1368 1.77 christos utmpx_set_runlevel(char old, char new)
1369 1.77 christos {
1370 1.77 christos struct utmpx ut;
1371 1.77 christos
1372 1.81 christos /*
1373 1.81 christos * Don't record any transitions until we did the first transition
1374 1.81 christos * to read ttys, which is when we are guaranteed to have a read-write
1375 1.81 christos * /var. Perhaps use a different variable for this?
1376 1.81 christos */
1377 1.81 christos if (sessions == NULL)
1378 1.81 christos return;
1379 1.81 christos
1380 1.77 christos (void)memset(&ut, 0, sizeof(ut));
1381 1.77 christos (void)snprintf(ut.ut_line, sizeof(ut.ut_line), RUNLVL_MSG, new);
1382 1.77 christos ut.ut_type = RUN_LVL;
1383 1.77 christos (void)gettimeofday(&ut.ut_tv, NULL);
1384 1.77 christos ut.ut_exit.e_exit = old;
1385 1.77 christos ut.ut_exit.e_termination = new;
1386 1.77 christos if (pututxline(&ut) == NULL)
1387 1.80 christos warning("can't add utmpx record for `runlevel': %m");
1388 1.84 christos endutxent();
1389 1.77 christos }
1390 1.77 christos #endif /* SUPPORT_UTMPX */
1391 1.77 christos
1392 1.13 cgd #endif /* LETS_GET_SMALL */
1393 1.1 cgd
1394 1.8 cgd /*
1395 1.8 cgd * Collect exit status for a child.
1396 1.8 cgd * If an exiting login, start a new login running.
1397 1.8 cgd */
1398 1.101 joerg static void
1399 1.50 christos collect_child(pid_t pid, int status)
1400 1.1 cgd {
1401 1.13 cgd #ifndef LETS_GET_SMALL
1402 1.27 perry session_t *sp, *sprev, *snext;
1403 1.8 cgd
1404 1.8 cgd if (! sessions)
1405 1.8 cgd return;
1406 1.8 cgd
1407 1.47 christos if ((sp = find_session(pid)) == NULL)
1408 1.8 cgd return;
1409 1.1 cgd
1410 1.50 christos clear_session_logs(sp, status);
1411 1.8 cgd del_session(sp);
1412 1.8 cgd sp->se_process = 0;
1413 1.8 cgd
1414 1.8 cgd if (sp->se_flags & SE_SHUTDOWN) {
1415 1.27 perry if ((sprev = sp->se_prev) != NULL)
1416 1.8 cgd sprev->se_next = sp->se_next;
1417 1.8 cgd else
1418 1.8 cgd sessions = sp->se_next;
1419 1.27 perry if ((snext = sp->se_next) != NULL)
1420 1.8 cgd snext->se_prev = sp->se_prev;
1421 1.8 cgd free_session(sp);
1422 1.1 cgd return;
1423 1.1 cgd }
1424 1.8 cgd
1425 1.8 cgd if ((pid = start_getty(sp)) == -1) {
1426 1.8 cgd /* serious trouble */
1427 1.8 cgd requested_transition = clean_ttys;
1428 1.1 cgd return;
1429 1.1 cgd }
1430 1.8 cgd
1431 1.8 cgd sp->se_process = pid;
1432 1.77 christos (void)gettimeofday(&sp->se_started, NULL);
1433 1.8 cgd add_session(sp);
1434 1.13 cgd #endif /* LETS_GET_SMALL */
1435 1.8 cgd }
1436 1.8 cgd
1437 1.8 cgd /*
1438 1.8 cgd * Catch a signal and request a state transition.
1439 1.8 cgd */
1440 1.101 joerg static void
1441 1.39 wiz transition_handler(int sig)
1442 1.8 cgd {
1443 1.8 cgd
1444 1.8 cgd switch (sig) {
1445 1.13 cgd #ifndef LETS_GET_SMALL
1446 1.8 cgd case SIGHUP:
1447 1.8 cgd requested_transition = clean_ttys;
1448 1.8 cgd break;
1449 1.8 cgd case SIGTERM:
1450 1.8 cgd requested_transition = death;
1451 1.8 cgd break;
1452 1.8 cgd case SIGTSTP:
1453 1.8 cgd requested_transition = catatonia;
1454 1.8 cgd break;
1455 1.13 cgd #endif /* LETS_GET_SMALL */
1456 1.8 cgd default:
1457 1.8 cgd requested_transition = 0;
1458 1.8 cgd break;
1459 1.8 cgd }
1460 1.8 cgd }
1461 1.8 cgd
1462 1.13 cgd #ifndef LETS_GET_SMALL
1463 1.8 cgd /*
1464 1.8 cgd * Take the system multiuser.
1465 1.8 cgd */
1466 1.101 joerg static state_func_t
1467 1.39 wiz multi_user(void)
1468 1.8 cgd {
1469 1.8 cgd pid_t pid;
1470 1.50 christos int status;
1471 1.27 perry session_t *sp;
1472 1.8 cgd
1473 1.8 cgd requested_transition = 0;
1474 1.8 cgd
1475 1.8 cgd /*
1476 1.8 cgd * If the administrator has not set the security level to -1
1477 1.8 cgd * to indicate that the kernel should not run multiuser in secure
1478 1.8 cgd * mode, and the run script has not set a higher level of security
1479 1.8 cgd * than level 1, then put the kernel into secure mode.
1480 1.8 cgd */
1481 1.8 cgd if (getsecuritylevel() == 0)
1482 1.8 cgd setsecuritylevel(1);
1483 1.8 cgd
1484 1.8 cgd for (sp = sessions; sp; sp = sp->se_next) {
1485 1.8 cgd if (sp->se_process)
1486 1.8 cgd continue;
1487 1.8 cgd if ((pid = start_getty(sp)) == -1) {
1488 1.8 cgd /* serious trouble */
1489 1.8 cgd requested_transition = clean_ttys;
1490 1.1 cgd break;
1491 1.8 cgd }
1492 1.8 cgd sp->se_process = pid;
1493 1.77 christos (void)gettimeofday(&sp->se_started, NULL);
1494 1.8 cgd add_session(sp);
1495 1.1 cgd }
1496 1.8 cgd
1497 1.8 cgd while (!requested_transition)
1498 1.50 christos if ((pid = waitpid(-1, &status, 0)) != -1)
1499 1.50 christos collect_child(pid, status);
1500 1.8 cgd
1501 1.47 christos return (state_func_t)requested_transition;
1502 1.1 cgd }
1503 1.1 cgd
1504 1.8 cgd /*
1505 1.8 cgd * This is an n-squared algorithm. We hope it isn't run often...
1506 1.8 cgd */
1507 1.101 joerg static state_func_t
1508 1.39 wiz clean_ttys(void)
1509 1.1 cgd {
1510 1.27 perry session_t *sp, *sprev;
1511 1.27 perry struct ttyent *typ;
1512 1.27 perry int session_index = 0;
1513 1.27 perry int devlen;
1514 1.8 cgd
1515 1.21 mycroft for (sp = sessions; sp; sp = sp->se_next)
1516 1.21 mycroft sp->se_flags &= ~SE_PRESENT;
1517 1.21 mycroft
1518 1.84 christos (void)do_setttyent();
1519 1.73 salo
1520 1.8 cgd devlen = sizeof(_PATH_DEV) - 1;
1521 1.27 perry while ((typ = getttyent()) != NULL) {
1522 1.8 cgd ++session_index;
1523 1.8 cgd
1524 1.8 cgd for (sprev = 0, sp = sessions; sp; sprev = sp, sp = sp->se_next)
1525 1.8 cgd if (strcmp(typ->ty_name, sp->se_device + devlen) == 0)
1526 1.8 cgd break;
1527 1.8 cgd
1528 1.8 cgd if (sp) {
1529 1.21 mycroft sp->se_flags |= SE_PRESENT;
1530 1.8 cgd if (sp->se_index != session_index) {
1531 1.80 christos warning("port `%s' changed utmp index from "
1532 1.47 christos "%d to %d", sp->se_device, sp->se_index,
1533 1.47 christos session_index);
1534 1.8 cgd sp->se_index = session_index;
1535 1.8 cgd }
1536 1.8 cgd if ((typ->ty_status & TTY_ON) == 0 ||
1537 1.8 cgd typ->ty_getty == 0) {
1538 1.8 cgd sp->se_flags |= SE_SHUTDOWN;
1539 1.55 christos if (sp->se_process != 0)
1540 1.55 christos (void)kill(sp->se_process, SIGHUP);
1541 1.8 cgd continue;
1542 1.8 cgd }
1543 1.8 cgd sp->se_flags &= ~SE_SHUTDOWN;
1544 1.8 cgd if (setupargv(sp, typ) == 0) {
1545 1.80 christos warning("can't parse getty for port `%s'",
1546 1.47 christos sp->se_device);
1547 1.8 cgd sp->se_flags |= SE_SHUTDOWN;
1548 1.55 christos if (sp->se_process != 0)
1549 1.55 christos (void)kill(sp->se_process, SIGHUP);
1550 1.8 cgd }
1551 1.8 cgd continue;
1552 1.8 cgd }
1553 1.8 cgd
1554 1.84 christos (void)new_session(sprev, session_index, typ);
1555 1.8 cgd }
1556 1.8 cgd
1557 1.84 christos (void)endttyent();
1558 1.21 mycroft
1559 1.21 mycroft for (sp = sessions; sp; sp = sp->se_next)
1560 1.21 mycroft if ((sp->se_flags & SE_PRESENT) == 0) {
1561 1.21 mycroft sp->se_flags |= SE_SHUTDOWN;
1562 1.55 christos if (sp->se_process != 0)
1563 1.55 christos (void)kill(sp->se_process, SIGHUP);
1564 1.21 mycroft }
1565 1.1 cgd
1566 1.47 christos return (state_func_t)multi_user;
1567 1.1 cgd }
1568 1.1 cgd
1569 1.8 cgd /*
1570 1.8 cgd * Block further logins.
1571 1.8 cgd */
1572 1.101 joerg static state_func_t
1573 1.39 wiz catatonia(void)
1574 1.1 cgd {
1575 1.27 perry session_t *sp;
1576 1.8 cgd
1577 1.8 cgd for (sp = sessions; sp; sp = sp->se_next)
1578 1.8 cgd sp->se_flags |= SE_SHUTDOWN;
1579 1.1 cgd
1580 1.47 christos return (state_func_t)multi_user;
1581 1.1 cgd }
1582 1.13 cgd #endif /* LETS_GET_SMALL */
1583 1.1 cgd
1584 1.8 cgd /*
1585 1.8 cgd * Note SIGALRM.
1586 1.8 cgd */
1587 1.101 joerg static void
1588 1.47 christos /*ARGSUSED*/
1589 1.39 wiz alrm_handler(int sig)
1590 1.1 cgd {
1591 1.43 lukem
1592 1.8 cgd clang = 1;
1593 1.1 cgd }
1594 1.1 cgd
1595 1.13 cgd #ifndef LETS_GET_SMALL
1596 1.8 cgd /*
1597 1.8 cgd * Bring the system down to single user.
1598 1.8 cgd */
1599 1.101 joerg static state_func_t
1600 1.39 wiz death(void)
1601 1.1 cgd {
1602 1.27 perry session_t *sp;
1603 1.50 christos int i, status;
1604 1.8 cgd pid_t pid;
1605 1.8 cgd static const int death_sigs[3] = { SIGHUP, SIGTERM, SIGKILL };
1606 1.8 cgd
1607 1.8 cgd for (sp = sessions; sp; sp = sp->se_next)
1608 1.8 cgd sp->se_flags |= SE_SHUTDOWN;
1609 1.8 cgd
1610 1.8 cgd /* NB: should send a message to the session logger to avoid blocking. */
1611 1.50 christos #ifdef SUPPORT_UTMPX
1612 1.50 christos logwtmpx("~", "shutdown", "", 0, INIT_PROCESS);
1613 1.50 christos #endif
1614 1.50 christos #ifdef SUPPORT_UTMP
1615 1.8 cgd logwtmp("~", "shutdown", "");
1616 1.50 christos #endif
1617 1.8 cgd
1618 1.8 cgd for (i = 0; i < 3; ++i) {
1619 1.8 cgd if (kill(-1, death_sigs[i]) == -1 && errno == ESRCH)
1620 1.47 christos return (state_func_t)single_user;
1621 1.8 cgd
1622 1.8 cgd clang = 0;
1623 1.84 christos (void)alarm(DEATH_WATCH);
1624 1.8 cgd do
1625 1.50 christos if ((pid = waitpid(-1, &status, 0)) != -1)
1626 1.50 christos collect_child(pid, status);
1627 1.8 cgd while (clang == 0 && errno != ECHILD);
1628 1.8 cgd
1629 1.8 cgd if (errno == ECHILD)
1630 1.47 christos return (state_func_t)single_user;
1631 1.8 cgd }
1632 1.8 cgd
1633 1.8 cgd warning("some processes would not die; ps axl advised");
1634 1.8 cgd
1635 1.47 christos return (state_func_t)single_user;
1636 1.1 cgd }
1637 1.13 cgd #endif /* LETS_GET_SMALL */
1638 1.28 christos
1639 1.45 abs #ifdef MFS_DEV_IF_NO_CONSOLE
1640 1.28 christos
1641 1.45 abs static int
1642 1.45 abs mfs_dev(void)
1643 1.28 christos {
1644 1.28 christos /*
1645 1.28 christos * We cannot print errors so we bail out silently...
1646 1.28 christos */
1647 1.28 christos pid_t pid;
1648 1.30 drochner int status;
1649 1.46 lukem
1650 1.45 abs /* If we have /dev/console, assume all is OK */
1651 1.91 dsl if (access(_PATH_CONSOLE, F_OK) == 0)
1652 1.91 dsl return 0;
1653 1.28 christos
1654 1.91 dsl #if 0 /* Useful for testing MAKEDEV */
1655 1.91 dsl /* Mount an mfs over /mnt so we can create a console entry */
1656 1.28 christos switch ((pid = fork())) {
1657 1.28 christos case 0:
1658 1.62 dsl (void)execl(INIT_MOUNT_MFS, "mount_mfs",
1659 1.62 dsl "-b", "4096", "-f", "512",
1660 1.91 dsl "-s", 64, "-n", 10,
1661 1.68 dan "-p", "0755",
1662 1.91 dsl "swap", "/mnt", NULL);
1663 1.91 dsl _exit(9);
1664 1.47 christos /*NOTREACHED*/
1665 1.28 christos
1666 1.28 christos case -1:
1667 1.45 abs return(-1);
1668 1.28 christos
1669 1.28 christos default:
1670 1.28 christos if (waitpid(pid, &status, 0) == -1)
1671 1.45 abs return(-1);
1672 1.28 christos if (status != 0)
1673 1.45 abs return(-1);
1674 1.28 christos break;
1675 1.28 christos }
1676 1.28 christos
1677 1.91 dsl {
1678 1.95 christos dev_t dev;
1679 1.28 christos #ifdef CPU_CONSDEV
1680 1.91 dsl static int name[2] = { CTL_MACHDEP, CPU_CONSDEV };
1681 1.91 dsl size_t olen;
1682 1.91 dsl olen = sizeof(dev);
1683 1.91 dsl if (sysctl(name, sizeof(name) / sizeof(name[0]), &dev, &olen,
1684 1.91 dsl NULL, 0) == -1)
1685 1.46 lukem #endif
1686 1.91 dsl dev = makedev(0, 0);
1687 1.95 christos
1688 1.95 christos /* Make a console for us, so we can see things happening */
1689 1.95 christos if (mknod("/mnt/console", 0666 | S_IFCHR, dev) == -1)
1690 1.95 christos return(-1);
1691 1.95 christos (void)freopen("/mnt/console", "a", stderr);
1692 1.91 dsl }
1693 1.28 christos
1694 1.91 dsl #endif
1695 1.28 christos
1696 1.28 christos /* Run the makedev script to create devices */
1697 1.28 christos switch ((pid = fork())) {
1698 1.28 christos case 0:
1699 1.84 christos (void)dup2(2, 1); /* Give the script stdout */
1700 1.60 dsl if (chdir("/dev") == 0)
1701 1.62 dsl (void)execl(INIT_BSHELL, "sh",
1702 1.91 dsl access("./MAKEDEV", X_OK) == 0
1703 1.91 dsl ? "./MAKEDEV" : "/etc/MAKEDEV",
1704 1.94 apb "-MM", "init", NULL);
1705 1.91 dsl _exit(10);
1706 1.73 salo /* NOTREACHED */
1707 1.28 christos
1708 1.28 christos case -1:
1709 1.60 dsl break;
1710 1.28 christos
1711 1.28 christos default:
1712 1.28 christos if (waitpid(pid, &status, 0) == -1)
1713 1.60 dsl break;
1714 1.98 apb if (status != 0)
1715 1.98 apb warn("MAKEDEV exit status %d\n", status);
1716 1.98 apb /*
1717 1.98 apb * If /dev/console got created, then return 0
1718 1.98 apb * regardless of MAKEDEV exit status.
1719 1.98 apb */
1720 1.91 dsl if (access(_PATH_CONSOLE, F_OK) == 0)
1721 1.91 dsl return 0;
1722 1.91 dsl _exit(11);
1723 1.28 christos }
1724 1.47 christos warn("Unable to run MAKEDEV");
1725 1.91 dsl _exit(12);
1726 1.28 christos }
1727 1.28 christos #endif
1728 1.73 salo
1729 1.102 christos #ifndef LETS_GET_SMALL
1730 1.101 joerg static int
1731 1.73 salo do_setttyent(void)
1732 1.73 salo {
1733 1.84 christos (void)endttyent();
1734 1.73 salo #ifdef CHROOT
1735 1.73 salo if (did_multiuser_chroot) {
1736 1.73 salo char path[PATH_MAX];
1737 1.73 salo
1738 1.84 christos (void)snprintf(path, sizeof(path), "%s/%s", rootdir, _PATH_TTYS);
1739 1.73 salo
1740 1.73 salo return setttyentpath(path);
1741 1.73 salo } else
1742 1.73 salo #endif /* CHROOT */
1743 1.73 salo return setttyent();
1744 1.73 salo }
1745 1.102 christos #endif
1746 1.73 salo
1747 1.73 salo #if !defined(LETS_GET_SMALL) && defined(CHROOT)
1748 1.73 salo
1749 1.101 joerg static int
1750 1.103 matt createsysctlnode(void)
1751 1.73 salo {
1752 1.73 salo struct sysctlnode node;
1753 1.73 salo int mib[2];
1754 1.73 salo size_t len;
1755 1.73 salo
1756 1.73 salo /*
1757 1.73 salo * Create top-level dynamic sysctl node. Its child nodes will only
1758 1.73 salo * be readable by the superuser, since regular mortals should not
1759 1.76 elad * care ("Sssh, it's a secret!").
1760 1.73 salo */
1761 1.73 salo len = sizeof(struct sysctlnode);
1762 1.73 salo mib[0] = CTL_CREATE;
1763 1.73 salo
1764 1.84 christos (void)memset(&node, 0, len);
1765 1.73 salo node.sysctl_flags = SYSCTL_VERSION | CTLFLAG_READWRITE |
1766 1.74 elad CTLFLAG_PRIVATE | CTLTYPE_NODE;
1767 1.73 salo node.sysctl_num = CTL_CREATE;
1768 1.84 christos (void)snprintf(node.sysctl_name, SYSCTL_NAMELEN, "init");
1769 1.73 salo if (sysctl(&mib[0], 1, &node, &len, &node, len) == -1) {
1770 1.80 christos warning("could not create init node: %m");
1771 1.93 dyoung return -1;
1772 1.73 salo }
1773 1.73 salo
1774 1.73 salo /*
1775 1.73 salo * Create second level dynamic node capable of holding pathname.
1776 1.73 salo * Provide "/" as the default value.
1777 1.73 salo */
1778 1.73 salo len = sizeof(struct sysctlnode);
1779 1.73 salo mib[0] = node.sysctl_num;
1780 1.73 salo mib[1] = CTL_CREATE;
1781 1.73 salo
1782 1.84 christos (void)memset(&node, 0, len);
1783 1.73 salo node.sysctl_flags = SYSCTL_VERSION | CTLFLAG_READWRITE |
1784 1.75 elad CTLTYPE_STRING | CTLFLAG_OWNDATA;
1785 1.73 salo node.sysctl_size = _POSIX_PATH_MAX;
1786 1.73 salo node.sysctl_data = __UNCONST("/");
1787 1.73 salo node.sysctl_num = CTL_CREATE;
1788 1.84 christos (void)snprintf(node.sysctl_name, SYSCTL_NAMELEN, "root");
1789 1.73 salo if (sysctl(&mib[0], 2, NULL, NULL, &node, len) == -1) {
1790 1.80 christos warning("could not create init.root node: %m");
1791 1.93 dyoung return -1;
1792 1.73 salo }
1793 1.73 salo
1794 1.93 dyoung return 0;
1795 1.73 salo }
1796 1.73 salo
1797 1.101 joerg static int
1798 1.101 joerg shouldchroot(void)
1799 1.73 salo {
1800 1.73 salo struct sysctlnode node;
1801 1.73 salo size_t len, cnt;
1802 1.73 salo int mib;
1803 1.73 salo
1804 1.73 salo len = sizeof(struct sysctlnode);
1805 1.73 salo
1806 1.73 salo if (sysctlbyname("init.root", rootdir, &len, NULL, 0) == -1) {
1807 1.80 christos warning("could not read init.root: %m");
1808 1.73 salo
1809 1.73 salo /* Child killed our node. Recreate it. */
1810 1.73 salo if (errno == ENOENT) {
1811 1.73 salo /* Destroy whatever is left, recreate from scratch. */
1812 1.73 salo if (sysctlnametomib("init", &mib, &cnt) != -1) {
1813 1.84 christos (void)memset(&node, 0, sizeof(node));
1814 1.73 salo node.sysctl_flags = SYSCTL_VERSION;
1815 1.73 salo node.sysctl_num = mib;
1816 1.73 salo mib = CTL_DESTROY;
1817 1.73 salo
1818 1.73 salo (void)sysctl(&mib, 1, NULL, NULL, &node,
1819 1.73 salo sizeof(node));
1820 1.73 salo }
1821 1.73 salo
1822 1.84 christos (void)createsysctlnode();
1823 1.73 salo }
1824 1.73 salo
1825 1.73 salo /* We certainly won't chroot. */
1826 1.93 dyoung return 0;
1827 1.73 salo }
1828 1.73 salo
1829 1.73 salo if (rootdir[len] != '\0' || strlen(rootdir) != len - 1) {
1830 1.73 salo warning("init.root is not a string");
1831 1.93 dyoung return 0;
1832 1.73 salo }
1833 1.73 salo
1834 1.73 salo if (strcmp(rootdir, "/") == 0)
1835 1.93 dyoung return 0;
1836 1.73 salo
1837 1.93 dyoung return 1;
1838 1.73 salo }
1839 1.73 salo
1840 1.73 salo #endif /* !LETS_GET_SMALL && CHROOT */
1841