blob: e6f7bb2becb9387a4b8a5e73acc709b8ea9c5a69 [file] [log] [blame]
Scott James Remnant50748842006-05-16 21:02:31 +01001/* upstart
2 *
Scott James Remnantb6270dd2006-07-13 02:16:38 +01003 * Copyright © 2006 Canonical Ltd.
4 * Author: Scott James Remnant <scott@ubuntu.com>.
Scott James Remnant50748842006-05-16 21:02:31 +01005 *
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
19 */
20
21#ifdef HAVE_CONFIG_H
22# include <config.h>
23#endif /* HAVE_CONFIG_H */
24
25
Scott James Remnantf43bdf32006-08-27 18:20:29 +010026#include <sys/types.h>
27#include <sys/wait.h>
28#include <sys/ioctl.h>
29#include <sys/reboot.h>
30#include <sys/resource.h>
31
Scott James Remnant3401ab72006-09-01 02:14:47 +010032#include <errno.h>
33#include <stdio.h>
Scott James Remnantf43bdf32006-08-27 18:20:29 +010034#include <signal.h>
Scott James Remnant94d00982006-08-25 15:38:22 +020035#include <stdlib.h>
Scott James Remnant3401ab72006-09-01 02:14:47 +010036#include <string.h>
Scott James Remnant12a330f2006-08-24 02:19:09 +020037#include <syslog.h>
Scott James Remnant027dd7b2006-08-21 09:01:25 +020038#include <unistd.h>
Scott James Remnantff0d26a2006-08-31 20:49:43 +010039#include <termios.h>
Scott James Remnant027dd7b2006-08-21 09:01:25 +020040
Scott James Remnant097b2a92006-09-01 19:30:37 +010041#include <linux/kd.h>
42
Scott James Remnant77e8db32006-08-21 08:47:50 +020043#include <nih/macros.h>
44#include <nih/alloc.h>
45#include <nih/list.h>
46#include <nih/timer.h>
47#include <nih/signal.h>
48#include <nih/child.h>
Scott James Remnant3401ab72006-09-01 02:14:47 +010049#include <nih/option.h>
Scott James Remnant77e8db32006-08-21 08:47:50 +020050#include <nih/main.h>
Scott James Remnant28fcc922006-09-01 04:15:57 +010051#include <nih/error.h>
Scott James Remnant77e8db32006-08-21 08:47:50 +020052#include <nih/logging.h>
53
54#include "process.h"
55#include "job.h"
56#include "event.h"
57#include "control.h"
58#include "cfgfile.h"
Scott James Remnant50748842006-05-16 21:02:31 +010059
60
Scott James Remnant1db88042006-09-01 03:14:19 +010061/**
62 * STATE_FD:
63 *
64 * File descriptor we read our state from.
65 **/
66#define STATE_FD 101
67
68
Scott James Remnantf43bdf32006-08-27 18:20:29 +010069/* Prototypes for static functions */
Scott James Remnant3401ab72006-09-01 02:14:47 +010070static void reset_console (void);
71static void segv_handler (int signum);
72static void cad_handler (void *data, NihSignal *signal);
73static void kbd_handler (void *data, NihSignal *signal);
74static void stop_handler (void *data, NihSignal *signal);
Scott James Remnant1db88042006-09-01 03:14:19 +010075static void term_handler (const char *prog, NihSignal *signal);
Scott James Remnant3401ab72006-09-01 02:14:47 +010076static void read_state (int fd);
77static void write_state (int fd);
78
Scott James Remnant1db88042006-09-01 03:14:19 +010079
Scott James Remnant3401ab72006-09-01 02:14:47 +010080/**
Scott James Remnant1db88042006-09-01 03:14:19 +010081 * restart:
Scott James Remnant3401ab72006-09-01 02:14:47 +010082 *
Scott James Remnant1db88042006-09-01 03:14:19 +010083 * This is set to %TRUE if we're being re-exec'd by an existing init
84 * process.
Scott James Remnant3401ab72006-09-01 02:14:47 +010085 **/
Scott James Remnant1db88042006-09-01 03:14:19 +010086static int restart = FALSE;
Scott James Remnant3401ab72006-09-01 02:14:47 +010087
88
89/**
90 * options:
91 *
92 * Command-line options we accept.
93 **/
94static NihOption options[] = {
Scott James Remnant1db88042006-09-01 03:14:19 +010095 { 0, "restart", NULL, NULL, NULL, &restart, NULL },
Scott James Remnant3401ab72006-09-01 02:14:47 +010096
97 /* Ignore invalid options */
98 { '-', "--", NULL, NULL, NULL, NULL, NULL },
99
100 NIH_OPTION_LAST
101};
Scott James Remnantff0d26a2006-08-31 20:49:43 +0100102
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100103
Scott James Remnant50748842006-05-16 21:02:31 +0100104int
105main (int argc,
106 char *argv[])
107{
Scott James Remnant3401ab72006-09-01 02:14:47 +0100108 char **args;
109 int ret, i;
Scott James Remnant50748842006-05-16 21:02:31 +0100110
Scott James Remnant77e8db32006-08-21 08:47:50 +0200111 nih_main_init (argv[0]);
112
Scott James Remnant3401ab72006-09-01 02:14:47 +0100113 args = nih_option_parser (NULL, argc, argv, options, FALSE);
114 if (! args)
115 exit (1);
Scott James Remnant12a330f2006-08-24 02:19:09 +0200116
Scott James Remnanta17917d2006-09-07 00:18:28 +0100117 /* Check we're root */
118 if (getuid ()) {
119 nih_error (_("Need to be root"));
120 exit (1);
121 }
122
123 /* Check we're process #1 */
124 if (getpid () > 1) {
125 execv ("/sbin/telinit", argv);
126 /* Ignore failure, probably just that telinit doesn't exist */
127
128 nih_error (_("Not being executed as init"));
129 exit (1);
130 }
131
132
Scott James Remnant3401ab72006-09-01 02:14:47 +0100133 /* Send all logging output to syslog */
134 openlog (program_name, LOG_CONS, LOG_DAEMON);
Scott James Remnant12a330f2006-08-24 02:19:09 +0200135 nih_log_set_logger (nih_logger_syslog);
Scott James Remnant77e8db32006-08-21 08:47:50 +0200136
Scott James Remnant77e8db32006-08-21 08:47:50 +0200137 /* Close any file descriptors we inherited, and open the console
Scott James Remnant3401ab72006-09-01 02:14:47 +0100138 * device instead. Normally we reset the console, unless we're
139 * inheriting one from another init process.
Scott James Remnant77e8db32006-08-21 08:47:50 +0200140 */
141 for (i = 0; i < 3; i++)
142 close (i);
143
144 process_setup_console (CONSOLE_OUTPUT);
Scott James Remnant1db88042006-09-01 03:14:19 +0100145 if (! restart)
Scott James Remnant3401ab72006-09-01 02:14:47 +0100146 reset_console ();
Scott James Remnant77e8db32006-08-21 08:47:50 +0200147
Scott James Remnantf4970812006-08-27 18:27:19 +0100148
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100149 /* Reset the signal state and install the signal handler for those
150 * signals we actually want to catch; this also sets those that
151 * can be sent to us, because we're special
152 */
153 nih_signal_reset ();
154 nih_signal_set_handler (SIGALRM, nih_signal_handler);
155 nih_signal_set_handler (SIGHUP, nih_signal_handler);
Scott James Remnanteabb7802006-08-31 15:39:04 +0100156 nih_signal_set_handler (SIGTSTP, nih_signal_handler);
157 nih_signal_set_handler (SIGCONT, nih_signal_handler);
Scott James Remnant1db88042006-09-01 03:14:19 +0100158 nih_signal_set_handler (SIGTERM, nih_signal_handler);
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100159 nih_signal_set_handler (SIGINT, nih_signal_handler);
160 nih_signal_set_handler (SIGWINCH, nih_signal_handler);
161 nih_signal_set_handler (SIGSEGV, segv_handler);
162
Scott James Remnanteabb7802006-08-31 15:39:04 +0100163 /* Ensure that we don't process events while paused */
Scott James Remnanteabb7802006-08-31 15:39:04 +0100164 nih_signal_add_callback (NULL, SIGTSTP, stop_handler, NULL);
165 nih_signal_add_callback (NULL, SIGCONT, stop_handler, NULL);
166
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100167 /* Ask the kernel to send us SIGINT when control-alt-delete is
168 * pressed; generate an event with the same name.
169 */
170 reboot (RB_DISABLE_CAD);
171 nih_signal_add_callback (NULL, SIGINT, cad_handler, NULL);
172
173 /* Ask the kernel to send us SIGWINCH when alt-uparrow is pressed;
174 * generate a kbdrequest event.
175 */
176 ioctl (0, KDSIGACCEPT, SIGWINCH);
177 nih_signal_add_callback (NULL, SIGWINCH, kbd_handler, NULL);
178
Scott James Remnant1db88042006-09-01 03:14:19 +0100179 /* SIGTERM instructs us to re-exec ourselves */
180 nih_signal_add_callback (NULL, SIGTERM,
181 (NihSignalCb)term_handler, argv[0]);
182
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100183
184 /* Reap all children that die */
185 nih_child_add_watch (NULL, -1, job_child_reaper, NULL);
186
Scott James Remnantdc8877d2006-08-29 16:56:48 +0100187 /* Process the event queue and check the jobs for idleness
188 * every time through the main loop */
Scott James Remnant0c7e72a2006-08-27 22:22:53 +0100189 nih_main_loop_add_func (NULL, (NihMainLoopCb)event_queue_run, NULL);
Scott James Remnantdc8877d2006-08-29 16:56:48 +0100190 nih_main_loop_add_func (NULL, (NihMainLoopCb)job_detect_idle, NULL);
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100191
Scott James Remnant94d00982006-08-25 15:38:22 +0200192
Scott James Remnant77e8db32006-08-21 08:47:50 +0200193 /* Become session and process group leader (should be already,
194 * but you never know what initramfs did
195 */
196 setsid ();
197
198 /* Open control socket */
199 control_open ();
200
Scott James Remnantceaaf4d2006-08-24 01:40:10 +0200201 /* Read configuration */
Scott James Remnant987bcc42006-09-07 00:38:24 +0100202 cfg_watch_dir (NULL, CFG_DIR, NULL);
Scott James Remnantceaaf4d2006-08-24 01:40:10 +0200203
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100204 /* Set the PATH environment variable */
205 setenv ("PATH", PATH, TRUE);
206
Scott James Remnant77e8db32006-08-21 08:47:50 +0200207
Scott James Remnant3401ab72006-09-01 02:14:47 +0100208 /* Generate and run the startup event or read the state from the
209 * init daemon that exec'd us
210 */
Scott James Remnant1db88042006-09-01 03:14:19 +0100211 if (! restart) {
Scott James Remnantea204d42006-09-07 00:30:53 +0100212 event_queue (STARTUP_EVENT);
Scott James Remnant3401ab72006-09-01 02:14:47 +0100213 } else {
Scott James Remnant1db88042006-09-01 03:14:19 +0100214 sigset_t mask;
215
216 /* State file descriptor is fixed */
217 read_state (STATE_FD);
218
219 /* We're ok to receive signals again */
220 sigemptyset (&mask);
221 sigprocmask (SIG_SETMASK, &mask, NULL);
Scott James Remnant3401ab72006-09-01 02:14:47 +0100222 }
223
224 /* Run the event queue once, and detect anything idle */
Scott James Remnant0c7e72a2006-08-27 22:22:53 +0100225 event_queue_run ();
Scott James Remnant32de9222006-08-31 04:34:27 +0100226 job_detect_idle ();
Scott James Remnant77e8db32006-08-21 08:47:50 +0200227
228 /* Go! */
229 ret = nih_main_loop ();
230
231 return ret;
Scott James Remnant50748842006-05-16 21:02:31 +0100232}
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100233
234
235/**
Scott James Remnantff0d26a2006-08-31 20:49:43 +0100236 * reset_console:
237 *
238 * Set up the console flags to something sensible. Cribbed from sysvinit,
239 * initng, etc.
240 **/
241static void
242reset_console (void)
243{
Scott James Remnant4bc5fe32006-08-31 21:48:33 +0100244 struct termios tty;
245
Scott James Remnantff0d26a2006-08-31 20:49:43 +0100246 tcgetattr (0, &tty);
247
248 tty.c_cflag &= (CBAUD | CBAUDEX | CSIZE | CSTOPB | PARENB | PARODD);
249 tty.c_cflag |= (HUPCL | CLOCAL | CREAD);
250
251 /* Set up usual keys */
252 tty.c_cc[VINTR] = 3; /* ^C */
253 tty.c_cc[VQUIT] = 28; /* ^\ */
254 tty.c_cc[VERASE] = 127;
255 tty.c_cc[VKILL] = 24; /* ^X */
256 tty.c_cc[VEOF] = 4; /* ^D */
257 tty.c_cc[VTIME] = 0;
258 tty.c_cc[VMIN] = 1;
259 tty.c_cc[VSTART] = 17; /* ^Q */
260 tty.c_cc[VSTOP] = 19; /* ^S */
261 tty.c_cc[VSUSP] = 26; /* ^Z */
262
263 /* Pre and post processing */
264 tty.c_iflag = (IGNPAR | ICRNL | IXON | IXANY);
265 tty.c_oflag = (OPOST | ONLCR);
266 tty.c_lflag = (ISIG | ICANON | ECHO | ECHOCTL | ECHOPRT | ECHOKE);
267
268 /* Set the terminal line and flush it */
269 tcsetattr (0, TCSANOW, &tty);
270 tcflush (0, TCIOFLUSH);
271}
272
273
274/**
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100275 * segv_handler:
276 * @signum:
277 *
278 * Handle receiving the SEGV signal, usually caused by one of our own
279 * mistakes. We deal with it by dumping core in a child process and
280 * just carrying on in the parent.
281 **/
282static void
283segv_handler (int signum)
284{
285 pid_t pid;
286
287 pid = fork ();
288 if (pid == 0) {
289 struct sigaction act;
290 struct rlimit limit;
291 sigset_t mask;
292
293 /* Mask out all signals */
294 sigfillset (&mask);
295 sigprocmask (SIG_SETMASK, &mask, NULL);
296
297 /* Set the SEGV handler to the default so core is dumped */
298 act.sa_handler = SIG_DFL;
299 act.sa_flags = 0;
300 sigemptyset (&act.sa_mask);
301 sigaction (SIGSEGV, &act, NULL);
302
303 /* Dump in the root directory */
304 chdir ("/");
305
306 /* Don't limit the core dump size */
307 limit.rlim_cur = RLIM_INFINITY;
308 limit.rlim_max = RLIM_INFINITY;
309 setrlimit (RLIMIT_CORE, &limit);
310
311 /* Raise the signal */
312 raise (SIGSEGV);
313
314 /* Unmask so that we receive it */
315 sigdelset (&mask, SIGSEGV);
316 sigprocmask (SIG_SETMASK, &mask, NULL);
317
318 /* Wait for death */
319 pause ();
320 exit (0);
321 } else if (pid > 0) {
322 /* Wait for the core to be generated */
323 waitpid (pid, NULL, 0);
324
325 nih_error (_("Caught segmentation fault, core dumped"));
326 } else {
327 nih_error (_("Caught segmentation fault, unable to dump core"));
328 }
329}
330
331/**
332 * cad_handler:
333 * @data: unused,
334 * @signal: signal that called this handler.
335 *
336 * Handle having recieved the SIGINT signal, sent to us when somebody
337 * presses Ctrl-Alt-Delete on the console. We just generate a
Scott James Remnantbb3cc3f2006-09-08 17:17:47 +0100338 * ctrlaltdel event.
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100339 **/
340static void
341cad_handler (void *data,
342 NihSignal *signal)
343{
Scott James Remnantbb3cc3f2006-09-08 17:17:47 +0100344 event_queue (CTRLALTDEL_EVENT);
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100345}
346
347/**
348 * kbd_handler:
349 * @data: unused,
350 * @signal: signal that called this handler.
351 *
352 * Handle having recieved the SIGWINCH signal, sent to us when somebody
353 * presses Alt-UpArrow on the console. We just generate a
354 * kbdrequest event.
355 **/
356static void
357kbd_handler (void *data,
358 NihSignal *signal)
359{
Scott James Remnantbb3cc3f2006-09-08 17:17:47 +0100360 event_queue (KBDREQUEST_EVENT);
Scott James Remnantf43bdf32006-08-27 18:20:29 +0100361}
Scott James Remnanteabb7802006-08-31 15:39:04 +0100362
363/**
364 * stop_handler:
365 * @data: unused,
366 * @signal: signal caught.
367 *
368 * This is called when we receive the STOP, TSTP or CONT signals; we
369 * adjust the paused variable appropriately so that the event queue and
370 * job idle detection is not run.
371 **/
372static void
373stop_handler (void *data,
374 NihSignal *signal)
375{
376 nih_assert (signal != NULL);
377
378 if (signal->signum == SIGCONT) {
379 nih_info (_("Event queue resumed"));
380 paused = FALSE;
381 } else {
382 nih_info (_("Event queue paused"));
383 paused = TRUE;
384 }
385}
Scott James Remnant3401ab72006-09-01 02:14:47 +0100386
387
388/**
Scott James Remnant1db88042006-09-01 03:14:19 +0100389 * term_handler:
Scott James Remnant3401ab72006-09-01 02:14:47 +0100390 * @argv0: program to run,
391 * @signal: signal caught.
392 *
Scott James Remnant1db88042006-09-01 03:14:19 +0100393 * This is called when we receive the TERM signal, which instructs us
Scott James Remnant3401ab72006-09-01 02:14:47 +0100394 * to reexec ourselves.
395 **/
396static void
Scott James Remnant1db88042006-09-01 03:14:19 +0100397term_handler (const char *argv0,
Scott James Remnant3401ab72006-09-01 02:14:47 +0100398 NihSignal *signal)
399{
Scott James Remnant6f464962006-09-01 04:10:20 +0100400 NihError *err;
Scott James Remnant3401ab72006-09-01 02:14:47 +0100401 sigset_t mask, oldmask;
402 int fds[2] = { -1, -1 };
403 pid_t pid;
Scott James Remnant3401ab72006-09-01 02:14:47 +0100404
405 nih_assert (argv0 != NULL);
406 nih_assert (signal != NULL);
407
408 nih_warn (_("Re-executing %s"), argv0);
409
Scott James Remnant1db88042006-09-01 03:14:19 +0100410 /* Block signals while we work. We're the last signal handler
411 * installed so this should mean that they're all handled now.
412 *
413 * The child must make sure that it unblocks these again when
414 * it's ready.
415 */
Scott James Remnant3401ab72006-09-01 02:14:47 +0100416 sigfillset (&mask);
417 sigprocmask (SIG_BLOCK, &mask, &oldmask);
418
Scott James Remnant28fcc922006-09-01 04:15:57 +0100419 /* Close the control connection */
420 control_close ();
421
Scott James Remnant3401ab72006-09-01 02:14:47 +0100422 /* Create pipe */
Scott James Remnant6f464962006-09-01 04:10:20 +0100423 if (pipe (fds) < 0) {
424 nih_error_raise_system ();
Scott James Remnant3401ab72006-09-01 02:14:47 +0100425 goto error;
Scott James Remnant6f464962006-09-01 04:10:20 +0100426 }
Scott James Remnant3401ab72006-09-01 02:14:47 +0100427
428 /* Fork a child that can send the state to the new init process */
429 pid = fork ();
430 if (pid < 0) {
Scott James Remnant6f464962006-09-01 04:10:20 +0100431 nih_error_raise_system ();
Scott James Remnant3401ab72006-09-01 02:14:47 +0100432 goto error;
433 } else if (pid == 0) {
Scott James Remnant6f464962006-09-01 04:10:20 +0100434 close (fds[0]);
435
436 write_state (fds[1]);
Scott James Remnant3401ab72006-09-01 02:14:47 +0100437 exit (0);
438 } else {
Scott James Remnant6f464962006-09-01 04:10:20 +0100439 if (dup2 (fds[0], STATE_FD) < 0) {
440 nih_error_raise_system ();
441 goto error;
442 }
443
444 close (fds[0]);
Scott James Remnant3401ab72006-09-01 02:14:47 +0100445 close (fds[1]);
Scott James Remnant6f464962006-09-01 04:10:20 +0100446 fds[0] = fds[1] = -1;
Scott James Remnant3401ab72006-09-01 02:14:47 +0100447 }
448
449 /* Argument list */
Scott James Remnant1db88042006-09-01 03:14:19 +0100450 execl (argv0, argv0, "--restart", NULL);
Scott James Remnant6f464962006-09-01 04:10:20 +0100451 nih_error_raise_system ();
Scott James Remnant3401ab72006-09-01 02:14:47 +0100452
453error:
Scott James Remnant6f464962006-09-01 04:10:20 +0100454 err = nih_error_get ();
455 nih_error (_("Failed to re-execute %s: %s"), argv0, err->message);
Scott James Remnant28fcc922006-09-01 04:15:57 +0100456 nih_free (err);
Scott James Remnant6f464962006-09-01 04:10:20 +0100457
Scott James Remnant3401ab72006-09-01 02:14:47 +0100458 close (fds[0]);
Scott James Remnant6f464962006-09-01 04:10:20 +0100459 close (fds[1]);
460
Scott James Remnant28fcc922006-09-01 04:15:57 +0100461 control_open ();
462
Scott James Remnant3401ab72006-09-01 02:14:47 +0100463 sigprocmask (SIG_SETMASK, &oldmask, NULL);
464}
465
466/**
Scott James Remnant3401ab72006-09-01 02:14:47 +0100467 * read_state:
468 * @fd: file descriptor to read from.
469 *
470 * Read event and job state from @fd, which is a trivial line-based
471 * protocol that we can keep the same without too much difficultly. It's
472 * tempting to use the control sockets for this, but they break too often.
473 **/
474static void
475read_state (int fd)
476{
477 Job *job = NULL;
478 Event *event = NULL;
479 FILE *state;
480 char buf[80];
481
482 nih_debug ("Reading state");
483
484 /* Use stdio as it's a light-weight thing that won't change */
485 state = fdopen (fd, "r");
486 if (! state) {
487 nih_warn (_("Unable to read from state descriptor: %s"),
488 strerror (errno));
489 return;
490 }
491
492 /* It's just a series of simple lines; if one begins Job then it
493 * indicates the start of a Job description, otherwise if it
494 * begins Event then it's the start of an Event description.
495 *
496 * Lines beginning "." are assumed to belong to the current job
497 * or event.
498 */
499 while (fgets (buf, sizeof (buf), state)) {
500 char *ptr;
501
502 /* Strip newline */
503 ptr = strchr (buf, '\n');
504 if (ptr)
505 *ptr = '\0';
506
507 if (! strncmp (buf, "Job ", 4)) {
508 job = job_read_state (NULL, buf);
509 event = NULL;
510 } else if (! strncmp (buf, "Event ", 5)) {
511 event = event_read_state (NULL, buf);
512 job = NULL;
513 } else if (buf[0] == '.') {
514 if (job) {
515 job = job_read_state (job, buf);
516 } else if (event) {
517 event = event_read_state (event, buf);
518 }
519 } else {
520 event = NULL;
521 job = NULL;
522 }
523 }
524
525 if (fclose (state))
526 nih_warn (_("Error after reading state: %s"),
527 strerror (errno));
528
529 nih_debug ("State read from parent");
530}
531
532/**
533 * write_state:
534 * @fd: file descriptor to write to.
535 *
536 * Write event and job state to @fd, which is a trivial line-based
537 * protocol that we can keep the same without too much difficultly. It's
538 * tempting to use the control sockets for this, but they break too often.
539 **/
540static void
541write_state (int fd)
542{
543 FILE *state;
544
545 /* Use stdio as it's a light-weight thing that won't change */
546 state = fdopen (fd, "w");
547 if (! state) {
548 nih_warn (_("Unable to write to state descriptor: %s"),
549 strerror (errno));
550 return;
551 }
552
553 event_write_state (state);
554 job_write_state (state);
555
556 if (fclose (state))
557 nih_warn (_("Error after writing state: %s"),
558 strerror (errno));
559}