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