]> git.ipfire.org Git - thirdparty/cups.git/blame - scheduler/main.c
Remove generated file.
[thirdparty/cups.git] / scheduler / main.c
CommitLineData
ef416fc2 1/*
b19ccc9e 2 * "$Id: main.c 7925 2008-09-10 17:47:26Z mike $"
ef416fc2 3 *
4 * Scheduler main loop for the Common UNIX Printing System (CUPS).
5 *
dfd5680b 6 * Copyright 2007-2009 by Apple Inc.
f7deaa1a 7 * Copyright 1997-2007 by Easy Software Products, all rights reserved.
ef416fc2 8 *
9 * These coded instructions, statements, and computer programs are the
bc44d920 10 * property of Apple Inc. and are protected by Federal copyright
11 * law. Distribution and use rights are outlined in the file "LICENSE.txt"
ef416fc2 12 * "LICENSE" which should have been included with this file. If this
bc44d920 13 * file is missing or damaged, see the license at "http://www.cups.org/".
ef416fc2 14 *
15 * Contents:
16 *
17 * main() - Main entry for the CUPS scheduler.
18 * cupsdClosePipe() - Close a pipe as necessary.
19 * cupsdOpenPipe() - Create a pipe which is closed on exec.
ef416fc2 20 * cupsdHoldSignals() - Hold child and termination signals.
ef416fc2 21 * cupsdReleaseSignals() - Release signals for delivery.
22 * cupsdSetString() - Set a string value.
23 * cupsdSetStringf() - Set a formatted string value.
a4d04587 24 * launchd_checkin() - Check-in with launchd and collect the
25 * listening fds.
f7deaa1a 26 * launchd_checkout() - Check-out with launchd.
ef416fc2 27 * parent_handler() - Catch USR1/CHLD signals...
28 * process_children() - Process all dead children...
e6013cfa 29 * select_timeout() - Calculate the select timeout value.
ef416fc2 30 * sigchld_handler() - Handle 'child' signals from old processes.
31 * sighup_handler() - Handle 'hangup' signals to reconfigure the
32 * scheduler.
33 * sigterm_handler() - Handle 'terminate' signals that stop the
34 * scheduler.
ef416fc2 35 * usage() - Show scheduler usage.
36 */
37
38/*
39 * Include necessary headers...
40 */
41
42#define _MAIN_C_
43#include "cupsd.h"
44#include <sys/resource.h>
45#include <syslog.h>
46#include <grp.h>
cc0d019f 47#include <cups/dir.h>
ef416fc2 48
a4d04587 49#ifdef HAVE_LAUNCH_H
50# include <launch.h>
51# include <libgen.h>
7594b224 52# define CUPS_KEEPALIVE CUPS_CACHEDIR "/org.cups.cupsd"
f7deaa1a 53 /* Name of the launchd KeepAlive file */
54# ifndef LAUNCH_JOBKEY_KEEPALIVE
55# define LAUNCH_JOBKEY_KEEPALIVE "KeepAlive"
56# endif /* !LAUNCH_JOBKEY_KEEPALIVE */
57# ifndef LAUNCH_JOBKEY_PATHSTATE
58# define LAUNCH_JOBKEY_PATHSTATE "PathState"
59# endif /* !LAUNCH_JOBKEY_PATHSTATE */
60# ifndef LAUNCH_JOBKEY_SERVICEIPC
61# define LAUNCH_JOBKEY_SERVICEIPC "ServiceIPC"
62# endif /* !LAUNCH_JOBKEY_SERVICEIPC */
a4d04587 63#endif /* HAVE_LAUNCH_H */
64
ef416fc2 65#if defined(HAVE_MALLOC_H) && defined(HAVE_MALLINFO)
66# include <malloc.h>
67#endif /* HAVE_MALLOC_H && HAVE_MALLINFO */
fa73b229 68#ifdef HAVE_NOTIFY_H
69# include <notify.h>
70#endif /* HAVE_NOTIFY_H */
ef416fc2 71
7594b224 72#if defined(__APPLE__) && defined(HAVE_DLFCN_H)
73# include <dlfcn.h>
74#endif /* __APPLE__ && HAVE_DLFCN_H */
75
ef416fc2 76
77/*
78 * Local functions...
79 */
80
a4d04587 81#ifdef HAVE_LAUNCHD
411affcf 82static void launchd_checkin(void);
f7deaa1a 83static void launchd_checkout(void);
a4d04587 84#endif /* HAVE_LAUNCHD */
411affcf 85static void parent_handler(int sig);
86static void process_children(void);
87static void sigchld_handler(int sig);
88static void sighup_handler(int sig);
89static void sigterm_handler(int sig);
90static long select_timeout(int fds);
91static void usage(int status);
ef416fc2 92
93
94/*
95 * Local globals...
96 */
97
411affcf 98static int parent_signal = 0;
99 /* Set to signal number from child */
100static int holdcount = 0; /* Number of times "hold" was called */
ef416fc2 101#if defined(HAVE_SIGACTION) && !defined(HAVE_SIGSET)
411affcf 102static sigset_t holdmask; /* Old POSIX signal mask */
ef416fc2 103#endif /* HAVE_SIGACTION && !HAVE_SIGSET */
411affcf 104static int dead_children = 0;
105 /* Dead children? */
106static int stop_scheduler = 0;
107 /* Should the scheduler stop? */
108
7594b224 109#if defined(__APPLE__) && defined(HAVE_DLFCN_H)
110static const char *PSQLibPath = "/usr/lib/libPrintServiceQuota.dylib";
111static const char *PSQLibFuncName = "PSQUpdateQuota";
112static void *PSQLibRef; /* libPrintServiceQuota.dylib */
113#endif /* HAVE_DLFCN_H */
114
ef416fc2 115
116/*
117 * 'main()' - Main entry for the CUPS scheduler.
118 */
119
120int /* O - Exit status */
bd7854cb 121main(int argc, /* I - Number of command-line args */
ef416fc2 122 char *argv[]) /* I - Command-line arguments */
123{
124 int i; /* Looping var */
125 char *opt; /* Option character */
126 int fg; /* Run in the foreground */
bd7854cb 127 int fds; /* Number of ready descriptors */
ef416fc2 128 cupsd_client_t *con; /* Current client */
129 cupsd_job_t *job; /* Current job */
130 cupsd_listener_t *lis; /* Current listener */
131 time_t current_time, /* Current time */
a4d04587 132 activity, /* Client activity timer */
ef416fc2 133 browse_time, /* Next browse send time */
134 senddoc_time, /* Send-Document time */
411affcf 135 expire_time, /* Subscription expire time */
50fe7201
MS
136 report_time, /* Malloc/client/job report time */
137 event_time; /* Last time an event notification was done */
f7deaa1a 138 long timeout; /* Timeout for cupsdDoSelect() */
ef416fc2 139 struct rlimit limit; /* Runtime limit */
140#if defined(HAVE_SIGACTION) && !defined(HAVE_SIGSET)
141 struct sigaction action; /* Actions for POSIX signals */
142#endif /* HAVE_SIGACTION && !HAVE_SIGSET */
143#ifdef __sgi
144 cups_file_t *fp; /* Fake lpsched lock file */
145 struct stat statbuf; /* Needed for checking lpsched FIFO */
146#endif /* __sgi */
a41f09e2
MS
147#ifdef __APPLE__
148 int run_as_child = 0;
149 /* Needed for Mac OS X fork/exec */
a4924f6c
MS
150#else
151 time_t netif_time = 0; /* Time since last network update */
a41f09e2 152#endif /* __APPLE__ */
a4d04587 153#if HAVE_LAUNCHD
4400e98d 154 int launchd_idle_exit;
a4d04587 155 /* Idle exit on select timeout? */
156#endif /* HAVE_LAUNCHD */
ef416fc2 157
158
db1f069b
MS
159#ifdef HAVE_GETEUID
160 /*
161 * Check for setuid invocation, which we do not support!
162 */
163
164 if (getuid() != geteuid())
165 {
166 fputs("cupsd: Cannot run as a setuid program!\n", stderr);
167 return (1);
168 }
169#endif /* HAVE_GETEUID */
170
ef416fc2 171 /*
172 * Check for command-line arguments...
173 */
174
4400e98d 175 fg = 0;
ef416fc2 176
09a101d6 177#ifdef HAVE_LAUNCHD
178 if (getenv("CUPSD_LAUNCHD"))
179 {
180 Launchd = 1;
181 fg = 1;
182 }
183#endif /* HAVE_LAUNCHD */
184
ef416fc2 185 for (i = 1; i < argc; i ++)
186 if (argv[i][0] == '-')
187 for (opt = argv[i] + 1; *opt != '\0'; opt ++)
188 switch (*opt)
189 {
a41f09e2
MS
190#ifdef __APPLE__
191 case 'C' : /* Run as child with config file */
192 run_as_child = 1;
193 fg = -1;
194#endif /* __APPLE__ */
195
ef416fc2 196 case 'c' : /* Configuration file */
197 i ++;
198 if (i >= argc)
a4d04587 199 {
200 _cupsLangPuts(stderr, _("cupsd: Expected config filename "
201 "after \"-c\" option!\n"));
202 usage(1);
203 }
ef416fc2 204
205 if (argv[i][0] == '/')
206 {
207 /*
208 * Absolute directory...
209 */
210
211 cupsdSetString(&ConfigurationFile, argv[i]);
212 }
213 else
214 {
215 /*
216 * Relative directory...
217 */
218
09ec0018 219 char *current; /* Current directory */
ef416fc2 220
221
09ec0018 222 /*
223 * Allocate a buffer for the current working directory to
224 * reduce run-time stack usage; this approximates the
225 * behavior of some implementations of getcwd() when they
226 * are passed a NULL pointer.
227 */
228
91c84a35
MS
229 if ((current = malloc(1024)) == NULL)
230 {
231 _cupsLangPuts(stderr,
232 _("cupsd: Unable to get current directory!\n"));
233 return (1);
234 }
235
236 if (!getcwd(current, 1024))
237 {
238 _cupsLangPuts(stderr,
239 _("cupsd: Unable to get current directory!\n"));
240 free(current);
241 return (1);
242 }
09ec0018 243
ef416fc2 244 cupsdSetStringf(&ConfigurationFile, "%s/%s", current, argv[i]);
09ec0018 245 free(current);
ef416fc2 246 }
247 break;
248
249 case 'f' : /* Run in foreground... */
250 fg = 1;
251 break;
252
bd7854cb 253 case 'F' : /* Run in foreground, but disconnect from terminal... */
ef416fc2 254 fg = -1;
255 break;
256
a4d04587 257 case 'h' : /* Show usage/help */
258 usage(0);
259 break;
260
261 case 'l' : /* Started by launchd... */
262#ifdef HAVE_LAUNCHD
4400e98d 263 Launchd = 1;
a4d04587 264 fg = 1;
265#else
266 _cupsLangPuts(stderr, _("cupsd: launchd(8) support not compiled "
267 "in, running in normal mode.\n"));
268 fg = 0;
269#endif /* HAVE_LAUNCHD */
270 break;
271
a74454a7 272 case 'p' : /* Stop immediately for profiling */
273 puts("Warning: -p option is for internal testing use only!");
274 stop_scheduler = 1;
275 fg = 1;
276 break;
277
2e4ff8af
MS
278 case 't' : /* Test the cupsd.conf file... */
279 TestConfigFile = 1;
280 fg = 1;
281 break;
282
ef416fc2 283 default : /* Unknown option */
a4d04587 284 _cupsLangPrintf(stderr, _("cupsd: Unknown option \"%c\" - "
285 "aborting!\n"), *opt);
286 usage(1);
ef416fc2 287 break;
288 }
289 else
290 {
a4d04587 291 _cupsLangPrintf(stderr, _("cupsd: Unknown argument \"%s\" - aborting!\n"),
292 argv[i]);
293 usage(1);
ef416fc2 294 }
295
296 if (!ConfigurationFile)
297 cupsdSetString(&ConfigurationFile, CUPS_SERVERROOT "/cupsd.conf");
298
299 /*
300 * If the user hasn't specified "-f", run in the background...
301 */
302
303 if (!fg)
304 {
305 /*
306 * Setup signal handlers for the parent...
307 */
308
309#ifdef HAVE_SIGSET /* Use System V signals over POSIX to avoid bugs */
310 sigset(SIGUSR1, parent_handler);
311 sigset(SIGCHLD, parent_handler);
312
313 sigset(SIGHUP, SIG_IGN);
314#elif defined(HAVE_SIGACTION)
315 memset(&action, 0, sizeof(action));
316 sigemptyset(&action.sa_mask);
317 sigaddset(&action.sa_mask, SIGUSR1);
318 action.sa_handler = parent_handler;
319 sigaction(SIGUSR1, &action, NULL);
320 sigaction(SIGCHLD, &action, NULL);
321
322 sigemptyset(&action.sa_mask);
323 action.sa_handler = SIG_IGN;
324 sigaction(SIGHUP, &action, NULL);
325#else
326 signal(SIGUSR1, parent_handler);
327 signal(SIGCLD, parent_handler);
328
329 signal(SIGHUP, SIG_IGN);
330#endif /* HAVE_SIGSET */
331
332 if (fork() > 0)
333 {
334 /*
335 * OK, wait for the child to startup and send us SIGUSR1 or to crash
336 * and the OS send us SIGCHLD... We also need to ignore SIGHUP which
337 * might be sent by the init script to restart the scheduler...
338 */
339
340 for (; parent_signal == 0;)
341 sleep(1);
342
343 if (parent_signal == SIGUSR1)
344 return (0);
345
346 if (wait(&i) < 0)
347 {
348 perror("cupsd");
349 return (1);
350 }
351 else if (WIFEXITED(i))
352 {
bd7854cb 353 fprintf(stderr, "cupsd: Child exited with status %d!\n",
354 WEXITSTATUS(i));
ef416fc2 355 return (2);
356 }
357 else
358 {
359 fprintf(stderr, "cupsd: Child exited on signal %d!\n", WTERMSIG(i));
360 return (3);
361 }
362 }
a41f09e2
MS
363
364#ifdef __APPLE__
365 /*
366 * Since CoreFoundation has an overly-agressive check for whether a
367 * process has forked but not exec'd (whether CF has been called or
368 * not...), we now have to exec ourselves with the "-f" option to
369 * eliminate their bogus warning messages.
370 */
371
372 execlp(argv[0], argv[0], "-C", ConfigurationFile, (char *)0);
373 exit(errno);
374#endif /* __APPLE__ */
ef416fc2 375 }
376
377 if (fg < 1)
378 {
379 /*
380 * Make sure we aren't tying up any filesystems...
381 */
382
383 chdir("/");
384
385#ifndef DEBUG
386 /*
387 * Disable core dumps...
388 */
389
390 getrlimit(RLIMIT_CORE, &limit);
391 limit.rlim_cur = 0;
392 setrlimit(RLIMIT_CORE, &limit);
393
394 /*
395 * Disconnect from the controlling terminal...
396 */
397
398 setsid();
399
400 /*
401 * Close all open files...
402 */
403
404 getrlimit(RLIMIT_NOFILE, &limit);
405
b94498cf 406 for (i = 0; i < limit.rlim_cur && i < 1024; i ++)
ef416fc2 407 close(i);
a4924f6c
MS
408
409 /*
410 * Redirect stdin/out/err to /dev/null...
411 */
412
413 open("/dev/null", O_RDONLY);
414 open("/dev/null", O_WRONLY);
415 open("/dev/null", O_WRONLY);
ef416fc2 416#endif /* DEBUG */
417 }
418
419 /*
420 * Set the timezone info...
421 */
422
423 tzset();
424
425#ifdef LC_TIME
426 setlocale(LC_TIME, "");
427#endif /* LC_TIME */
428
429 /*
430 * Set the maximum number of files...
431 */
432
433 getrlimit(RLIMIT_NOFILE, &limit);
434
f7deaa1a 435#if !defined(HAVE_POLL) && !defined(HAVE_EPOLL) && !defined(HAVE_KQUEUE)
f7faf1f5 436 if (limit.rlim_max > FD_SETSIZE)
437 MaxFDs = FD_SETSIZE;
ef416fc2 438 else
f7deaa1a 439#endif /* !HAVE_POLL && !HAVE_EPOLL && !HAVE_KQUEUE */
440#ifdef RLIM_INFINITY
441 if (limit.rlim_max == RLIM_INFINITY)
442 MaxFDs = 16384;
443 else
444#endif /* RLIM_INFINITY */
ef416fc2 445 MaxFDs = limit.rlim_max;
446
447 limit.rlim_cur = MaxFDs;
448
449 setrlimit(RLIMIT_NOFILE, &limit);
450
f7deaa1a 451 cupsdStartSelect();
ef416fc2 452
453 /*
454 * Read configuration...
455 */
456
457 if (!cupsdReadConfiguration())
458 {
2e4ff8af
MS
459 if (TestConfigFile)
460 printf("%s contains errors\n", ConfigurationFile);
461 else
462 syslog(LOG_LPR, "Unable to read configuration file \'%s\' - exiting!",
463 ConfigurationFile);
ef416fc2 464 return (1);
465 }
2e4ff8af
MS
466 else if (TestConfigFile)
467 {
468 printf("%s is OK\n", ConfigurationFile);
469 return (0);
470 }
ef416fc2 471
cc0d019f
MS
472 if (!strncmp(TempDir, RequestRoot, strlen(RequestRoot)))
473 {
474 /*
475 * Clean out the temporary directory...
476 */
477
478 cups_dir_t *dir; /* Temporary directory */
479 cups_dentry_t *dent; /* Directory entry */
480 char tempfile[1024]; /* Temporary filename */
481
482
483 if ((dir = cupsDirOpen(TempDir)) != NULL)
484 {
485 cupsdLogMessage(CUPSD_LOG_INFO,
486 "Cleaning out old temporary files in \"%s\"...", TempDir);
487
488 while ((dent = cupsDirRead(dir)) != NULL)
489 {
490 snprintf(tempfile, sizeof(tempfile), "%s/%s", TempDir, dent->filename);
491
75bd9771 492 if (unlink(tempfile))
cc0d019f
MS
493 cupsdLogMessage(CUPSD_LOG_ERROR,
494 "Unable to remove temporary file \"%s\" - %s",
495 tempfile, strerror(errno));
496 else
497 cupsdLogMessage(CUPSD_LOG_DEBUG, "Removed temporary file \"%s\"...",
498 tempfile);
499 }
500
501 cupsDirClose(dir);
502 }
503 else
504 cupsdLogMessage(CUPSD_LOG_ERROR,
505 "Unable to open temporary directory \"%s\" - %s",
506 TempDir, strerror(errno));
507 }
508
a4d04587 509#if HAVE_LAUNCHD
4400e98d 510 if (Launchd)
a4d04587 511 {
512 /*
b94498cf 513 * If we were started by launchd get the listen sockets file descriptors...
f7deaa1a 514 */
a4d04587 515
516 launchd_checkin();
e4572d57 517 launchd_checkout();
a4d04587 518 }
519#endif /* HAVE_LAUNCHD */
520
7594b224 521#if defined(__APPLE__) && defined(HAVE_DLFCN_H)
522 /*
523 * Load Print Service quota enforcement library (X Server only)
524 */
525
526 PSQLibRef = dlopen(PSQLibPath, RTLD_LAZY);
527
528 if (PSQLibRef)
529 PSQUpdateQuotaProc = dlsym(PSQLibRef, PSQLibFuncName);
530#endif /* __APPLE__ && HAVE_DLFCN_H */
531
a4d04587 532 /*
533 * Startup the server...
534 */
535
536 cupsdStartServer();
537
ef416fc2 538 /*
539 * Catch hangup and child signals and ignore broken pipes...
540 */
541
542#ifdef HAVE_SIGSET /* Use System V signals over POSIX to avoid bugs */
e1d6a774 543 sigset(SIGCHLD, sigchld_handler);
4744bd90 544 sigset(SIGHUP, sighup_handler);
ef416fc2 545 sigset(SIGPIPE, SIG_IGN);
546 sigset(SIGTERM, sigterm_handler);
547#elif defined(HAVE_SIGACTION)
548 memset(&action, 0, sizeof(action));
549
e1d6a774 550 sigemptyset(&action.sa_mask);
551 sigaddset(&action.sa_mask, SIGTERM);
552 sigaddset(&action.sa_mask, SIGCHLD);
553 action.sa_handler = sigchld_handler;
554 sigaction(SIGCHLD, &action, NULL);
555
ef416fc2 556 sigemptyset(&action.sa_mask);
557 sigaddset(&action.sa_mask, SIGHUP);
4744bd90 558 action.sa_handler = sighup_handler;
ef416fc2 559 sigaction(SIGHUP, &action, NULL);
560
561 sigemptyset(&action.sa_mask);
562 action.sa_handler = SIG_IGN;
563 sigaction(SIGPIPE, &action, NULL);
564
565 sigemptyset(&action.sa_mask);
566 sigaddset(&action.sa_mask, SIGTERM);
567 sigaddset(&action.sa_mask, SIGCHLD);
568 action.sa_handler = sigterm_handler;
569 sigaction(SIGTERM, &action, NULL);
570#else
e1d6a774 571 signal(SIGCLD, sigchld_handler); /* No, SIGCLD isn't a typo... */
4744bd90 572 signal(SIGHUP, sighup_handler);
ef416fc2 573 signal(SIGPIPE, SIG_IGN);
574 signal(SIGTERM, sigterm_handler);
575#endif /* HAVE_SIGSET */
576
577#ifdef __sgi
578 /*
579 * Try to create a fake lpsched lock file if one is not already there.
580 * Some Adobe applications need it under IRIX in order to enable
581 * printing...
582 */
583
584 if ((fp = cupsFileOpen("/var/spool/lp/SCHEDLOCK", "w")) == NULL)
585 {
586 syslog(LOG_LPR, "Unable to create fake lpsched lock file "
587 "\"/var/spool/lp/SCHEDLOCK\"\' - %s!",
588 strerror(errno));
589 }
590 else
591 {
592 fchmod(cupsFileNumber(fp), 0644);
593 fchown(cupsFileNumber(fp), User, Group);
594
595 cupsFileClose(fp);
596 }
597#endif /* __sgi */
598
599 /*
600 * Initialize authentication certificates...
601 */
602
603 cupsdInitCerts();
604
605 /*
606 * If we are running in the background, signal the parent process that
607 * we are up and running...
608 */
609
a41f09e2
MS
610#ifdef __APPLE__
611 if (!fg || run_as_child)
612#else
ef416fc2 613 if (!fg)
a41f09e2 614#endif /* __APPLE__ */
ef416fc2 615 {
616 /*
617 * Send a signal to the parent process, but only if the parent is
618 * not PID 1 (init). This avoids accidentally shutting down the
619 * system on OpenBSD if you CTRL-C the server before it is up...
620 */
621
622 i = getppid(); /* Save parent PID to avoid race condition */
623
624 if (i != 1)
625 kill(i, SIGUSR1);
626 }
627
e1d6a774 628#ifdef __APPLE__
09ec0018 629 /*
630 * Start power management framework...
631 */
632
633 cupsdStartSystemMonitor();
e1d6a774 634#endif /* __APPLE__ */
ef416fc2 635
49d87452
MS
636 /*
637 * Send server-started event...
638 */
639
640#ifdef HAVE_LAUNCHD
641 if (Launchd)
642 cupsdAddEvent(CUPSD_EVENT_SERVER_STARTED, NULL, NULL,
643 "Scheduler started via launchd.");
644 else
645#endif /* HAVE_LAUNCHD */
646 if (fg)
647 cupsdAddEvent(CUPSD_EVENT_SERVER_STARTED, NULL, NULL,
648 "Scheduler started in foreground.");
649 else
650 cupsdAddEvent(CUPSD_EVENT_SERVER_STARTED, NULL, NULL,
651 "Scheduler started in background.");
652
ef416fc2 653 /*
654 * Start any pending print jobs...
655 */
656
657 cupsdCheckJobs();
658
659 /*
660 * Loop forever...
661 */
662
50fe7201
MS
663 current_time = time(NULL);
664 browse_time = current_time;
665 event_time = current_time;
666 expire_time = current_time;
ef416fc2 667 fds = 1;
5bd77a73 668 report_time = 0;
50fe7201 669 senddoc_time = current_time;
ef416fc2 670
671 while (!stop_scheduler)
672 {
673#ifdef DEBUG
674 cupsdLogMessage(CUPSD_LOG_DEBUG2,
675 "main: Top of loop, dead_children=%d, NeedReload=%d",
676 dead_children, NeedReload);
677#endif /* DEBUG */
678
679 /*
680 * Check if there are dead children to handle...
681 */
682
683 if (dead_children)
684 process_children();
685
686 /*
687 * Check if we need to load the server configuration file...
688 */
689
690 if (NeedReload)
691 {
692 /*
693 * Close any idle clients...
694 */
695
bd7854cb 696 if (cupsArrayCount(Clients) > 0)
ef416fc2 697 {
bd7854cb 698 for (con = (cupsd_client_t *)cupsArrayFirst(Clients);
699 con;
700 con = (cupsd_client_t *)cupsArrayNext(Clients))
ef416fc2 701 if (con->http.state == HTTP_WAITING)
ef416fc2 702 cupsdCloseClient(con);
ef416fc2 703 else
704 con->http.keep_alive = HTTP_KEEPALIVE_OFF;
705
706 cupsdPauseListening();
707 }
708
709 /*
710 * Check for any active jobs...
711 */
712
713 for (job = (cupsd_job_t *)cupsArrayFirst(ActiveJobs);
714 job;
715 job = (cupsd_job_t *)cupsArrayNext(ActiveJobs))
bd7854cb 716 if (job->state_value == IPP_JOB_PROCESSING)
ef416fc2 717 break;
718
719 /*
720 * Restart if all clients are closed and all jobs finished, or
721 * if the reload timeout has elapsed...
722 */
723
bd7854cb 724 if ((cupsArrayCount(Clients) == 0 &&
725 (!job || NeedReload != RELOAD_ALL)) ||
ef416fc2 726 (time(NULL) - ReloadTime) >= ReloadTimeout)
727 {
a4d04587 728 /*
729 * Shutdown the server...
730 */
731
732 cupsdStopServer();
733
734 /*
735 * Read configuration...
736 */
737
ef416fc2 738 if (!cupsdReadConfiguration())
739 {
740 syslog(LOG_LPR, "Unable to read configuration file \'%s\' - exiting!",
741 ConfigurationFile);
742 break;
743 }
a4d04587 744
745#if HAVE_LAUNCHD
4400e98d 746 if (Launchd)
a4d04587 747 {
b94498cf 748 /*
749 * If we were started by launchd get the listen sockets file descriptors...
750 */
751
a4d04587 752 launchd_checkin();
e4572d57 753 launchd_checkout();
a4d04587 754 }
755#endif /* HAVE_LAUNCHD */
756
757 /*
758 * Startup the server...
759 */
760
761 cupsdStartServer();
49d87452
MS
762
763 /*
764 * Send a server-restarted event...
765 */
766
767 cupsdAddEvent(CUPSD_EVENT_SERVER_RESTARTED, NULL, NULL,
768 "Scheduler restarted.");
ef416fc2 769 }
770 }
771
772 /*
f7deaa1a 773 * Check for available input or ready output. If cupsdDoSelect()
774 * returns 0 or -1, something bad happened and we should exit
775 * immediately.
ef416fc2 776 *
777 * Note that we at least have one listening socket open at all
778 * times.
779 */
780
50fe7201
MS
781 if ((timeout = select_timeout(fds)) > 1 && LastEvent)
782 timeout = 1;
ef416fc2 783
a4d04587 784#if HAVE_LAUNCHD
785 /*
786 * If no other work is scheduled and we're being controlled by
411affcf 787 * launchd then timeout after 'LaunchdTimeout' seconds of
a4d04587 788 * inactivity...
789 */
790
f7deaa1a 791 if (timeout == 86400 && Launchd && LaunchdTimeout && !NumPolled &&
bc44d920 792 !cupsArrayCount(ActiveJobs) &&
f7deaa1a 793 (!Browsing ||
794 (!BrowseRemoteProtocols &&
795 (!NumBrowsers || !BrowseLocalProtocols ||
796 cupsArrayCount(Printers) == 0))))
a4d04587 797 {
f7deaa1a 798 timeout = LaunchdTimeout;
a4d04587 799 launchd_idle_exit = 1;
800 }
801 else
802 launchd_idle_exit = 0;
803#endif /* HAVE_LAUNCHD */
804
f7deaa1a 805 if ((fds = cupsdDoSelect(timeout)) < 0)
ef416fc2 806 {
ef416fc2 807 /*
808 * Got an error from select!
809 */
810
f7deaa1a 811#ifdef HAVE_DNSSD
812 cupsd_printer_t *p; /* Current printer */
813#endif /* HAVE_DNSSD */
814
815
816 if (errno == EINTR) /* Just interrupted by a signal */
ef416fc2 817 continue;
818
819 /*
820 * Log all sorts of debug info to help track down the problem.
821 */
822
f7deaa1a 823 cupsdLogMessage(CUPSD_LOG_EMERG, "cupsdDoSelect() failed - %s!",
ef416fc2 824 strerror(errno));
825
bd7854cb 826 for (i = 0, con = (cupsd_client_t *)cupsArrayFirst(Clients);
827 con;
828 i ++, con = (cupsd_client_t *)cupsArrayNext(Clients))
ef416fc2 829 cupsdLogMessage(CUPSD_LOG_EMERG,
830 "Clients[%d] = %d, file = %d, state = %d",
831 i, con->http.fd, con->file, con->http.state);
832
bd7854cb 833 for (i = 0, lis = (cupsd_listener_t *)cupsArrayFirst(Listeners);
834 lis;
835 i ++, lis = (cupsd_listener_t *)cupsArrayNext(Listeners))
ef416fc2 836 cupsdLogMessage(CUPSD_LOG_EMERG, "Listeners[%d] = %d", i, lis->fd);
837
838 cupsdLogMessage(CUPSD_LOG_EMERG, "BrowseSocket = %d", BrowseSocket);
839
923edb68 840 cupsdLogMessage(CUPSD_LOG_EMERG, "CGIPipes[0] = %d", CGIPipes[0]);
841
09ec0018 842#ifdef __APPLE__
843 cupsdLogMessage(CUPSD_LOG_EMERG, "SysEventPipes[0] = %d",
844 SysEventPipes[0]);
845#endif /* __APPLE__ */
846
ef416fc2 847 for (job = (cupsd_job_t *)cupsArrayFirst(ActiveJobs);
848 job;
849 job = (cupsd_job_t *)cupsArrayNext(ActiveJobs))
850 cupsdLogMessage(CUPSD_LOG_EMERG, "Jobs[%d] = %d < [%d %d] > [%d %d]",
851 job->id,
852 job->status_buffer ? job->status_buffer->fd : -1,
853 job->print_pipes[0], job->print_pipes[1],
854 job->back_pipes[0], job->back_pipes[1]);
f7deaa1a 855
856#ifdef HAVE_DNSSD
857 for (p = (cupsd_printer_t *)cupsArrayFirst(Printers);
858 p;
859 p = (cupsd_printer_t *)cupsArrayNext(Printers))
7a14d768
MS
860 cupsdLogMessage(CUPSD_LOG_EMERG, "printer[%s] reg_name=\"%s\"", p->name,
861 p->reg_name ? p->reg_name : "(null)");
f7deaa1a 862#endif /* HAVE_DNSSD */
863
ef416fc2 864 break;
865 }
866
867 current_time = time(NULL);
868
3dfe78b3
MS
869 /*
870 * Write dirty config/state files...
871 */
872
873 if (DirtyCleanTime && current_time >= DirtyCleanTime)
3dfe78b3 874 cupsdCleanDirty();
3dfe78b3 875
e6013cfa
MS
876#ifdef __APPLE__
877 /*
878 * If we are going to sleep and still have pending jobs, stop them after
879 * a period of time...
880 */
881
882 if (SleepJobs > 0 && current_time >= SleepJobs &&
883 cupsArrayCount(PrintingJobs) > 0)
884 {
885 SleepJobs = 0;
886 cupsdStopAllJobs(0);
887 }
888#endif /* __APPLE__ */
889
a4924f6c
MS
890#ifndef __APPLE__
891 /*
892 * Update the network interfaces once a minute...
893 */
894
895 if ((current_time - netif_time) >= 60)
896 {
897 netif_time = current_time;
898 NetIFUpdate = 1;
899 }
900#endif /* !__APPLE__ */
901
a4d04587 902#if HAVE_LAUNCHD
903 /*
411affcf 904 * If no other work was scheduled and we're being controlled by launchd
a4d04587 905 * then timeout after 'LaunchdTimeout' seconds of inactivity...
906 */
907
908 if (!fds && launchd_idle_exit)
909 {
910 cupsdLogMessage(CUPSD_LOG_INFO,
911 "Printer sharing is off and there are no jobs pending, "
912 "will restart on demand.");
913 stop_scheduler = 1;
914 break;
915 }
916#endif /* HAVE_LAUNCHD */
917
76cd9e37
MS
918 /*
919 * Resume listening for new connections as needed...
920 */
921
922 if (ListeningPaused && ListeningPaused <= current_time &&
923 cupsArrayCount(Clients) < MaxClients)
924 cupsdResumeListening();
925
ef416fc2 926 /*
bd7854cb 927 * Expire subscriptions and unload completed jobs as needed...
ef416fc2 928 */
929
bd7854cb 930 if (current_time > expire_time)
ef416fc2 931 {
bd7854cb 932 if (cupsArrayCount(Subscriptions) > 0)
933 cupsdExpireSubscriptions(NULL, NULL);
934
935 cupsdUnloadCompletedJobs();
ef416fc2 936
937 expire_time = current_time;
938 }
939
940 /*
941 * Update the browse list as needed...
942 */
943
f7deaa1a 944 if (Browsing)
ef416fc2 945 {
ef416fc2 946#ifdef HAVE_LIBSLP
b423cd4c 947 if ((BrowseRemoteProtocols & BROWSE_SLP) &&
ef416fc2 948 BrowseSLPRefresh <= current_time)
949 cupsdUpdateSLPBrowse();
950#endif /* HAVE_LIBSLP */
b423cd4c 951
952#ifdef HAVE_LDAP
953 if ((BrowseRemoteProtocols & BROWSE_LDAP) &&
954 BrowseLDAPRefresh <= current_time)
955 cupsdUpdateLDAPBrowse();
956#endif /* HAVE_LDAP */
fa73b229 957 }
ef416fc2 958
1f0275e3 959 if (Browsing && current_time > browse_time)
fa73b229 960 {
961 cupsdSendBrowseList();
962 browse_time = current_time;
ef416fc2 963 }
964
965 /*
f7deaa1a 966 * Update the root certificate once every 5 minutes if we have client
967 * connections...
ef416fc2 968 */
969
f7deaa1a 970 if ((current_time - RootCertTime) >= RootCertDuration && RootCertDuration &&
971 !RunUser && cupsArrayCount(Clients))
972 {
973 /*
974 * Update the root certificate...
975 */
976
977 cupsdDeleteCert(0);
5bd77a73 978 cupsdAddCert(0, "root", NULL);
f7deaa1a 979 }
ef416fc2 980
981 /*
982 * Check for new data on the client sockets...
983 */
984
bd7854cb 985 for (con = (cupsd_client_t *)cupsArrayFirst(Clients);
986 con;
987 con = (cupsd_client_t *)cupsArrayNext(Clients))
ef416fc2 988 {
989 /*
f7deaa1a 990 * Process pending data in the input buffer...
ef416fc2 991 */
992
f7deaa1a 993 if (con->http.used)
ef416fc2 994 {
f7deaa1a 995 cupsdReadClient(con);
996 continue;
ef416fc2 997 }
998
999 /*
1000 * Check the activity and close old clients...
1001 */
1002
1003 activity = current_time - Timeout;
1004 if (con->http.activity < activity && !con->pipe_pid)
1005 {
1006 cupsdLogMessage(CUPSD_LOG_DEBUG,
1007 "Closing client %d after %d seconds of inactivity...",
1008 con->http.fd, Timeout);
1009
1010 cupsdCloseClient(con);
ef416fc2 1011 continue;
1012 }
1013 }
1014
1015 /*
1016 * Update any pending multi-file documents...
1017 */
1018
1019 if ((current_time - senddoc_time) >= 10)
1020 {
1021 cupsdCheckJobs();
1022 senddoc_time = current_time;
1023 }
1024
ef416fc2 1025 /*
5bd77a73 1026 * Log statistics at most once a minute when in debug mode...
ef416fc2 1027 */
1028
5bd77a73 1029 if ((current_time - report_time) >= 60 && LogLevel >= CUPSD_LOG_DEBUG)
ef416fc2 1030 {
5bd77a73
MS
1031 size_t string_count, /* String count */
1032 alloc_bytes, /* Allocated string bytes */
1033 total_bytes; /* Total string bytes */
4400e98d 1034#ifdef HAVE_MALLINFO
5bd77a73 1035 struct mallinfo mem; /* Malloc information */
ef416fc2 1036
1037
1038 mem = mallinfo();
5bd77a73
MS
1039 cupsdLogMessage(CUPSD_LOG_DEBUG, "Report: malloc-arena=%lu", mem.arena);
1040 cupsdLogMessage(CUPSD_LOG_DEBUG, "Report: malloc-used=%lu",
1041 mem.usmblks + mem.uordblks);
1042 cupsdLogMessage(CUPSD_LOG_DEBUG, "Report: malloc-free=%lu",
ef416fc2 1043 mem.fsmblks + mem.fordblks);
4400e98d 1044#endif /* HAVE_MALLINFO */
1045
5bd77a73
MS
1046 cupsdLogMessage(CUPSD_LOG_DEBUG, "Report: clients=%d",
1047 cupsArrayCount(Clients));
1048 cupsdLogMessage(CUPSD_LOG_DEBUG, "Report: jobs=%d",
1049 cupsArrayCount(Jobs));
1050 cupsdLogMessage(CUPSD_LOG_DEBUG, "Report: jobs-active=%d",
1051 cupsArrayCount(ActiveJobs));
1052 cupsdLogMessage(CUPSD_LOG_DEBUG, "Report: printers=%d",
1053 cupsArrayCount(Printers));
1054 cupsdLogMessage(CUPSD_LOG_DEBUG, "Report: printers-implicit=%d",
1055 cupsArrayCount(ImplicitPrinters));
1056
757d2cad 1057 string_count = _cupsStrStatistics(&alloc_bytes, &total_bytes);
5bd77a73
MS
1058 cupsdLogMessage(CUPSD_LOG_DEBUG,
1059 "Report: stringpool-string-count=" CUPS_LLFMT,
1060 CUPS_LLCAST string_count);
1061 cupsdLogMessage(CUPSD_LOG_DEBUG,
1062 "Report: stringpool-alloc-bytes=" CUPS_LLFMT,
1063 CUPS_LLCAST alloc_bytes);
1064 cupsdLogMessage(CUPSD_LOG_DEBUG,
1065 "Report: stringpool-total-bytes=" CUPS_LLFMT,
4400e98d 1066 CUPS_LLCAST total_bytes);
1067
5bd77a73 1068 report_time = current_time;
ef416fc2 1069 }
ef416fc2 1070
fa73b229 1071 /*
1072 * Handle OS-specific event notification for any events that have
1073 * accumulated. Don't send these more than once a second...
1074 */
1075
50fe7201 1076 if (LastEvent && (current_time - event_time) >= 1)
fa73b229 1077 {
1078#ifdef HAVE_NOTIFY_POST
a41f09e2
MS
1079 if (LastEvent & (CUPSD_EVENT_PRINTER_ADDED |
1080 CUPSD_EVENT_PRINTER_DELETED |
1081 CUPSD_EVENT_PRINTER_MODIFIED))
fa73b229 1082 {
e00b005a 1083 cupsdLogMessage(CUPSD_LOG_DEBUG2,
fa73b229 1084 "notify_post(\"com.apple.printerListChange\")");
1085 notify_post("com.apple.printerListChange");
1086 }
1087
1088 if (LastEvent & CUPSD_EVENT_PRINTER_STATE_CHANGED)
1089 {
e00b005a 1090 cupsdLogMessage(CUPSD_LOG_DEBUG2,
fa73b229 1091 "notify_post(\"com.apple.printerHistoryChange\")");
1092 notify_post("com.apple.printerHistoryChange");
1093 }
1094
1095 if (LastEvent & (CUPSD_EVENT_JOB_STATE_CHANGED |
1096 CUPSD_EVENT_JOB_CONFIG_CHANGED |
1097 CUPSD_EVENT_JOB_PROGRESS))
1098 {
e00b005a 1099 cupsdLogMessage(CUPSD_LOG_DEBUG2,
fa73b229 1100 "notify_post(\"com.apple.jobChange\")");
1101 notify_post("com.apple.jobChange");
1102 }
1103#endif /* HAVE_NOTIFY_POST */
1104
1105 /*
e53920b9 1106 * Reset the accumulated events...
fa73b229 1107 */
1108
50fe7201
MS
1109 LastEvent = CUPSD_EVENT_NONE;
1110 event_time = current_time;
fa73b229 1111 }
ef416fc2 1112 }
1113
1114 /*
1115 * Log a message based on what happened...
1116 */
1117
1118 if (stop_scheduler)
49d87452 1119 {
ef416fc2 1120 cupsdLogMessage(CUPSD_LOG_INFO, "Scheduler shutting down normally.");
49d87452
MS
1121 cupsdAddEvent(CUPSD_EVENT_SERVER_STOPPED, NULL, NULL,
1122 "Scheduler shutting down normally.");
1123 }
ef416fc2 1124 else
49d87452 1125 {
ef416fc2 1126 cupsdLogMessage(CUPSD_LOG_ERROR,
1127 "Scheduler shutting down due to program error.");
49d87452
MS
1128 cupsdAddEvent(CUPSD_EVENT_SERVER_STOPPED, NULL, NULL,
1129 "Scheduler shutting down due to program error.");
1130 }
ef416fc2 1131
1132 /*
7ff4fea9 1133 * Close all network clients...
ef416fc2 1134 */
1135
1136 cupsdStopServer();
1137
7ff4fea9
MS
1138#ifdef HAVE_LAUNCHD
1139 /*
1140 * Update the launchd KeepAlive file as needed...
1141 */
1142
1143 if (Launchd)
1144 launchd_checkout();
1145#endif /* HAVE_LAUNCHD */
1146
1147 /*
1148 * Stop all jobs...
1149 */
1150
bd7854cb 1151 cupsdFreeAllJobs();
ef416fc2 1152
e1d6a774 1153#ifdef __APPLE__
7ff4fea9
MS
1154 /*
1155 * Stop monitoring system event monitoring...
1156 */
1157
09ec0018 1158 cupsdStopSystemMonitor();
e1d6a774 1159#endif /* __APPLE__ */
09ec0018 1160
c24d2134 1161#ifdef HAVE_GSSAPI
7ff4fea9
MS
1162 /*
1163 * Free the scheduler's Kerberos context...
1164 */
1165
c24d2134
MS
1166# ifdef __APPLE__
1167 /*
1168 * If the weak-linked GSSAPI/Kerberos library is not present, don't try
1169 * to use it...
1170 */
1171
1172 if (krb5_init_context != NULL)
1173# endif /* __APPLE__ */
a41f09e2
MS
1174 if (KerberosContext)
1175 krb5_free_context(KerberosContext);
c24d2134
MS
1176#endif /* HAVE_GSSAPI */
1177
ed6e7faf 1178#if defined(__APPLE__) && defined(HAVE_DLFCN_H)
b94498cf 1179 /*
1180 * Unload Print Service quota enforcement library (X Server only)
1181 */
411affcf 1182
b94498cf 1183 PSQUpdateQuotaProc = NULL;
1184 if (PSQLibRef)
1185 {
1186 dlclose(PSQLibRef);
1187 PSQLibRef = NULL;
f7deaa1a 1188 }
ed6e7faf 1189#endif /* __APPLE__ && HAVE_DLFCN_H */
a4d04587 1190
ef416fc2 1191#ifdef __sgi
1192 /*
1193 * Remove the fake IRIX lpsched lock file, but only if the existing
1194 * file is not a FIFO which indicates that the real IRIX lpsched is
1195 * running...
1196 */
1197
1198 if (!stat("/var/spool/lp/FIFO", &statbuf))
1199 if (!S_ISFIFO(statbuf.st_mode))
1200 unlink("/var/spool/lp/SCHEDLOCK");
1201#endif /* __sgi */
1202
f7deaa1a 1203 cupsdStopSelect();
ef416fc2 1204
1205 return (!stop_scheduler);
1206}
1207
1208
1209/*
1210 * 'cupsdClosePipe()' - Close a pipe as necessary.
1211 */
1212
1213void
1214cupsdClosePipe(int *fds) /* I - Pipe file descriptors (2) */
1215{
1216 /*
1217 * Close file descriptors as needed...
1218 */
1219
1220 if (fds[0] >= 0)
1221 {
1222 close(fds[0]);
1223 fds[0] = -1;
1224 }
1225
1226 if (fds[1] >= 0)
1227 {
1228 close(fds[1]);
1229 fds[1] = -1;
1230 }
1231}
1232
1233
1234/*
1235 * 'cupsdOpenPipe()' - Create a pipe which is closed on exec.
1236 */
1237
1238int /* O - 0 on success, -1 on error */
1239cupsdOpenPipe(int *fds) /* O - Pipe file descriptors (2) */
1240{
1241 /*
1242 * Create the pipe...
1243 */
1244
1245 if (pipe(fds))
e1d6a774 1246 {
1247 fds[0] = -1;
1248 fds[1] = -1;
1249
ef416fc2 1250 return (-1);
e1d6a774 1251 }
ef416fc2 1252
1253 /*
1254 * Set the "close on exec" flag on each end of the pipe...
1255 */
1256
1257 if (fcntl(fds[0], F_SETFD, fcntl(fds[0], F_GETFD) | FD_CLOEXEC))
1258 {
1259 close(fds[0]);
1260 close(fds[1]);
e1d6a774 1261
1262 fds[0] = -1;
1263 fds[1] = -1;
1264
ef416fc2 1265 return (-1);
1266 }
1267
1268 if (fcntl(fds[1], F_SETFD, fcntl(fds[1], F_GETFD) | FD_CLOEXEC))
1269 {
1270 close(fds[0]);
1271 close(fds[1]);
e1d6a774 1272
1273 fds[0] = -1;
1274 fds[1] = -1;
1275
ef416fc2 1276 return (-1);
1277 }
1278
1279 /*
1280 * Return 0 indicating success...
1281 */
1282
1283 return (0);
1284}
1285
1286
ef416fc2 1287/*
1288 * 'cupsdClearString()' - Clear a string.
1289 */
1290
1291void
1292cupsdClearString(char **s) /* O - String value */
1293{
1294 if (s && *s)
1295 {
e53920b9 1296 _cupsStrFree(*s);
ef416fc2 1297 *s = NULL;
1298 }
1299}
1300
1301
1302/*
1303 * 'cupsdHoldSignals()' - Hold child and termination signals.
1304 */
1305
1306void
1307cupsdHoldSignals(void)
1308{
1309#if defined(HAVE_SIGACTION) && !defined(HAVE_SIGSET)
1310 sigset_t newmask; /* New POSIX signal mask */
1311#endif /* HAVE_SIGACTION && !HAVE_SIGSET */
1312
1313
1314 holdcount ++;
1315 if (holdcount > 1)
1316 return;
1317
1318#ifdef HAVE_SIGSET
1319 sighold(SIGTERM);
1320 sighold(SIGCHLD);
1321#elif defined(HAVE_SIGACTION)
1322 sigemptyset(&newmask);
1323 sigaddset(&newmask, SIGTERM);
1324 sigaddset(&newmask, SIGCHLD);
1325 sigprocmask(SIG_BLOCK, &newmask, &holdmask);
1326#endif /* HAVE_SIGSET */
1327}
1328
1329
ef416fc2 1330/*
1331 * 'cupsdReleaseSignals()' - Release signals for delivery.
1332 */
1333
1334void
1335cupsdReleaseSignals(void)
1336{
1337 holdcount --;
1338 if (holdcount > 0)
1339 return;
1340
1341#ifdef HAVE_SIGSET
1342 sigrelse(SIGTERM);
1343 sigrelse(SIGCHLD);
1344#elif defined(HAVE_SIGACTION)
1345 sigprocmask(SIG_SETMASK, &holdmask, NULL);
1346#endif /* HAVE_SIGSET */
1347}
1348
1349
1350/*
1351 * 'cupsdSetString()' - Set a string value.
1352 */
1353
1354void
1355cupsdSetString(char **s, /* O - New string */
1356 const char *v) /* I - String value */
1357{
1358 if (!s || *s == v)
1359 return;
1360
1361 if (*s)
e53920b9 1362 _cupsStrFree(*s);
ef416fc2 1363
1364 if (v)
e53920b9 1365 *s = _cupsStrAlloc(v);
ef416fc2 1366 else
1367 *s = NULL;
1368}
1369
1370
1371/*
1372 * 'cupsdSetStringf()' - Set a formatted string value.
1373 */
1374
1375void
1376cupsdSetStringf(char **s, /* O - New string */
1377 const char *f, /* I - Printf-style format string */
1378 ...) /* I - Additional args as needed */
1379{
1380 char v[4096]; /* Formatting string value */
1381 va_list ap; /* Argument pointer */
1382 char *olds; /* Old string */
1383
1384
1385 if (!s)
1386 return;
1387
1388 olds = *s;
1389
1390 if (f)
1391 {
1392 va_start(ap, f);
1393 vsnprintf(v, sizeof(v), f, ap);
1394 va_end(ap);
1395
e53920b9 1396 *s = _cupsStrAlloc(v);
ef416fc2 1397 }
1398 else
1399 *s = NULL;
1400
1401 if (olds)
e53920b9 1402 _cupsStrFree(olds);
ef416fc2 1403}
1404
1405
a4d04587 1406#ifdef HAVE_LAUNCHD
1407/*
1408 * 'launchd_checkin()' - Check-in with launchd and collect the listening fds.
1409 */
1410
1411static void
1412launchd_checkin(void)
1413{
06d4e77b
MS
1414 size_t i, /* Looping var */
1415 count; /* Numebr of listeners */
1416 int portnum; /* Port number */
a4d04587 1417 launch_data_t ld_msg, /* Launch data message */
1418 ld_resp, /* Launch data response */
1419 ld_array, /* Launch data array */
1420 ld_sockets, /* Launch data sockets dictionary */
a4d04587 1421 tmp; /* Launch data */
1422 cupsd_listener_t *lis; /* Listeners array */
1423 http_addr_t addr; /* Address variable */
1424 socklen_t addrlen; /* Length of address */
f7deaa1a 1425 int fd; /* File descriptor */
1426 char s[256]; /* String addresss */
a4d04587 1427
1428
1429 cupsdLogMessage(CUPSD_LOG_DEBUG, "launchd_checkin: pid=%d", (int)getpid());
1430
1431 /*
1432 * Check-in with launchd...
1433 */
1434
1435 ld_msg = launch_data_new_string(LAUNCH_KEY_CHECKIN);
1436 if ((ld_resp = launch_msg(ld_msg)) == NULL)
1437 {
bd7854cb 1438 cupsdLogMessage(CUPSD_LOG_ERROR,
a4d04587 1439 "launchd_checkin: launch_msg(\"" LAUNCH_KEY_CHECKIN
1440 "\") IPC failure");
1441 exit(EXIT_FAILURE);
749b1e90 1442 return; /* anti-compiler-warning */
a4d04587 1443 }
bd7854cb 1444
a4d04587 1445 if (launch_data_get_type(ld_resp) == LAUNCH_DATA_ERRNO)
1446 {
1447 errno = launch_data_get_errno(ld_resp);
1448 cupsdLogMessage(CUPSD_LOG_ERROR, "launchd_checkin: Check-in failed: %s",
1449 strerror(errno));
1450 exit(EXIT_FAILURE);
749b1e90 1451 return; /* anti-compiler-warning */
a4d04587 1452 }
1453
a4d04587 1454 /*
1455 * Get the sockets dictionary...
1456 */
1457
749b1e90
MS
1458 if ((ld_sockets = launch_data_dict_lookup(ld_resp, LAUNCH_JOBKEY_SOCKETS))
1459 == NULL)
a4d04587 1460 {
1461 cupsdLogMessage(CUPSD_LOG_ERROR,
1462 "launchd_checkin: No sockets found to answer requests on!");
1463 exit(EXIT_FAILURE);
749b1e90 1464 return; /* anti-compiler-warning */
a4d04587 1465 }
bd7854cb 1466
a4d04587 1467 /*
1468 * Get the array of listener sockets...
1469 */
1470
749b1e90 1471 if ((ld_array = launch_data_dict_lookup(ld_sockets, "Listeners")) == NULL)
a4d04587 1472 {
1473 cupsdLogMessage(CUPSD_LOG_ERROR,
1474 "launchd_checkin: No sockets found to answer requests on!");
1475 exit(EXIT_FAILURE);
749b1e90 1476 return; /* anti-compiler-warning */
a4d04587 1477 }
1478
1479 /*
1480 * Add listening fd(s) to the Listener array...
1481 */
1482
1483 if (launch_data_get_type(ld_array) == LAUNCH_DATA_ARRAY)
1484 {
f7deaa1a 1485 count = launch_data_array_get_count(ld_array);
bd7854cb 1486
1487 for (i = 0; i < count; i ++)
a4d04587 1488 {
1489 /*
f7deaa1a 1490 * Get the launchd file descriptor and address...
a4d04587 1491 */
bd7854cb 1492
749b1e90 1493 if ((tmp = launch_data_array_get_index(ld_array, i)) != NULL)
bd7854cb 1494 {
749b1e90
MS
1495 fd = launch_data_get_fd(tmp);
1496 addrlen = sizeof(addr);
bd7854cb 1497
749b1e90
MS
1498 if (getsockname(fd, (struct sockaddr *)&addr, &addrlen))
1499 {
1500 cupsdLogMessage(CUPSD_LOG_ERROR,
1501 "launchd_checkin: Unable to get local address - %s",
1502 strerror(errno));
1503 continue;
1504 }
bd7854cb 1505
749b1e90
MS
1506 /*
1507 * Try to match the launchd socket address to one of the listeners...
1508 */
f7deaa1a 1509
749b1e90
MS
1510 for (lis = (cupsd_listener_t *)cupsArrayFirst(Listeners);
1511 lis;
1512 lis = (cupsd_listener_t *)cupsArrayNext(Listeners))
1513 if (httpAddrEqual(&lis->address, &addr))
1514 break;
a4d04587 1515
749b1e90
MS
1516 /*
1517 * Add a new listener If there's no match...
1518 */
f7deaa1a 1519
749b1e90
MS
1520 if (lis)
1521 {
1522 cupsdLogMessage(CUPSD_LOG_DEBUG,
1523 "launchd_checkin: Matched existing listener %s with fd %d...",
1524 httpAddrString(&(lis->address), s, sizeof(s)), fd);
1525 }
1526 else
1527 {
1528 cupsdLogMessage(CUPSD_LOG_DEBUG,
1529 "launchd_checkin: Adding new listener %s with fd %d...",
1530 httpAddrString(&addr, s, sizeof(s)), fd);
f7deaa1a 1531
749b1e90
MS
1532 if ((lis = calloc(1, sizeof(cupsd_listener_t))) == NULL)
1533 {
1534 cupsdLogMessage(CUPSD_LOG_ERROR,
1535 "launchd_checkin: Unable to allocate listener - %s.",
1536 strerror(errno));
1537 exit(EXIT_FAILURE);
1538 }
f7deaa1a 1539
749b1e90 1540 cupsArrayAdd(Listeners, lis);
bd7854cb 1541
749b1e90
MS
1542 memcpy(&lis->address, &addr, sizeof(lis->address));
1543 }
1544
1545 lis->fd = fd;
f7deaa1a 1546
a4d04587 1547# ifdef HAVE_SSL
749b1e90 1548 portnum = 0;
bd7854cb 1549
a4d04587 1550# ifdef AF_INET6
749b1e90
MS
1551 if (lis->address.addr.sa_family == AF_INET6)
1552 portnum = ntohs(lis->address.ipv6.sin6_port);
1553 else
a4d04587 1554# endif /* AF_INET6 */
749b1e90
MS
1555 if (lis->address.addr.sa_family == AF_INET)
1556 portnum = ntohs(lis->address.ipv4.sin_port);
a4d04587 1557
749b1e90
MS
1558 if (portnum == 443)
1559 lis->encryption = HTTP_ENCRYPT_ALWAYS;
a4d04587 1560# endif /* HAVE_SSL */
749b1e90 1561 }
a4d04587 1562 }
1563 }
1564
a4d04587 1565 launch_data_free(ld_msg);
1566 launch_data_free(ld_resp);
1567}
1568
1569
f7deaa1a 1570/*
1571 * 'launchd_checkout()' - Update the launchd KeepAlive file as needed.
1572 */
1573
1574static void
1575launchd_checkout(void)
1576{
1577 int fd; /* File descriptor */
1578
1579
1580 /*
1581 * Create or remove the launchd KeepAlive file based on whether
1582 * there are active jobs, polling, browsing for remote printers or
1583 * shared printers to advertise...
1584 */
1585
1586 if ((cupsArrayCount(ActiveJobs) || NumPolled ||
1587 (Browsing &&
1588 (BrowseRemoteProtocols ||
1589 (BrowseLocalProtocols && NumBrowsers && cupsArrayCount(Printers))))))
1590 {
1591 cupsdLogMessage(CUPSD_LOG_DEBUG,
1592 "Creating launchd keepalive file \"" CUPS_KEEPALIVE "\"...");
1593
1594 if ((fd = open(CUPS_KEEPALIVE, O_RDONLY | O_CREAT | O_EXCL, S_IRUSR)) >= 0)
1595 close(fd);
1596 }
1597 else
1598 {
1599 cupsdLogMessage(CUPSD_LOG_DEBUG,
1600 "Removing launchd keepalive file \"" CUPS_KEEPALIVE "\"...");
1601
1602 unlink(CUPS_KEEPALIVE);
1603 }
1604}
a4d04587 1605#endif /* HAVE_LAUNCHD */
1606
1607
ef416fc2 1608/*
1609 * 'parent_handler()' - Catch USR1/CHLD signals...
1610 */
1611
1612static void
1613parent_handler(int sig) /* I - Signal */
1614{
1615 /*
1616 * Store the signal we got from the OS and return...
1617 */
1618
1619 parent_signal = sig;
1620}
1621
1622
1623/*
1624 * 'process_children()' - Process all dead children...
1625 */
1626
1627static void
1628process_children(void)
1629{
1630 int status; /* Exit status of child */
1631 int pid; /* Process ID of child */
1632 cupsd_job_t *job; /* Current job */
1633 int i; /* Looping var */
e00b005a 1634 char name[1024]; /* Process name */
ef416fc2 1635
1636
1637 cupsdLogMessage(CUPSD_LOG_DEBUG2, "process_children()");
1638
1639 /*
1640 * Reset the dead_children flag...
1641 */
1642
1643 dead_children = 0;
1644
1645 /*
1646 * Collect the exit status of some children...
1647 */
1648
1649#ifdef HAVE_WAITPID
1650 while ((pid = waitpid(-1, &status, WNOHANG)) > 0)
1651#elif defined(HAVE_WAIT3)
1652 while ((pid = wait3(&status, WNOHANG, NULL)) > 0)
1653#else
1654 if ((pid = wait(&status)) > 0)
1655#endif /* HAVE_WAITPID */
1656 {
ef416fc2 1657 /*
745129be 1658 * Collect the name of the process that finished...
ef416fc2 1659 */
1660
e00b005a 1661 cupsdFinishProcess(pid, name, sizeof(name));
1662
ef416fc2 1663 /*
1664 * Delete certificates for CGI processes...
1665 */
1666
1667 if (pid)
1668 cupsdDeleteCert(pid);
1669
1670 /*
1671 * Lookup the PID in the jobs list...
1672 */
1673
1674 for (job = (cupsd_job_t *)cupsArrayFirst(ActiveJobs);
1675 job;
1676 job = (cupsd_job_t *)cupsArrayNext(ActiveJobs))
79e1d494 1677 if (job->state_value >= IPP_JOB_HELD && (job->filters[0] || job->backend))
ef416fc2 1678 {
1679 for (i = 0; job->filters[i]; i ++)
1680 if (job->filters[i] == pid)
1681 break;
1682
1683 if (job->filters[i] || job->backend == pid)
1684 {
1685 /*
1686 * OK, this process has gone away; what's left?
1687 */
1688
1689 if (job->filters[i])
1690 job->filters[i] = -pid;
1691 else
1692 job->backend = -pid;
1693
1694 if (status && job->status >= 0)
1695 {
1696 /*
1697 * An error occurred; save the exit status so we know to stop
1698 * the printer or cancel the job when all of the filters finish...
1699 *
1700 * A negative status indicates that the backend failed and the
1701 * printer needs to be stopped.
1702 */
1703
1704 if (job->filters[i])
1705 job->status = status; /* Filter failed */
1706 else
1707 job->status = -status; /* Backend failed */
e00b005a 1708
ac884b6a
MS
1709 if (job->printer && !(job->printer->type & CUPS_PRINTER_FAX) &&
1710 job->status_level > CUPSD_LOG_ERROR)
e00b005a 1711 {
ac884b6a
MS
1712 job->status_level = CUPSD_LOG_ERROR;
1713
e00b005a 1714 snprintf(job->printer->state_message,
1715 sizeof(job->printer->state_message), "%s failed", name);
1716 cupsdAddPrinterHistory(job->printer);
1717 }
ef416fc2 1718 }
1719
1720 /*
1721 * If this is not the last file in a job, see if all of the
1722 * filters are done, and if so move to the next file.
1723 */
1724
1725 if (job->current_file < job->num_files)
1726 {
1727 for (i = 0; job->filters[i] < 0; i ++);
1728
1729 if (!job->filters[i])
1730 {
1731 /*
1732 * Process the next file...
1733 */
1734
1735 cupsdFinishJob(job);
1736 }
1737 }
1738 break;
1739 }
1740 }
3dfe78b3
MS
1741
1742 /*
745129be
MS
1743 * Show the exit status as needed, ignoring SIGTERM and SIGKILL errors
1744 * since they come when we kill/end a process...
3dfe78b3
MS
1745 */
1746
745129be
MS
1747 if (status == SIGTERM || status == SIGKILL)
1748 {
1749 cupsdLogMessage(CUPSD_LOG_DEBUG,
1750 "PID %d (%s) was terminated normally with signal %d.",
1751 pid, name, status);
1752 }
1753 else if (status)
3dfe78b3
MS
1754 {
1755 if (WIFEXITED(status))
7a14d768 1756 cupsdLogMessage(CUPSD_LOG_DEBUG, "PID %d (%s) stopped with status %d!",
3dfe78b3
MS
1757 pid, name, WEXITSTATUS(status));
1758 else
1759 cupsdLogMessage(CUPSD_LOG_ERROR, "PID %d (%s) crashed on signal %d!",
1760 pid, name, WTERMSIG(status));
1761
1762 if (LogLevel < CUPSD_LOG_DEBUG)
1763 cupsdLogMessage(CUPSD_LOG_INFO,
1764 "Hint: Try setting the LogLevel to \"debug\" to find "
1765 "out more.");
1766 }
1767 else
1768 cupsdLogMessage(CUPSD_LOG_DEBUG, "PID %d (%s) exited with no errors.",
1769 pid, name);
ef416fc2 1770 }
dfd5680b
MS
1771
1772 /*
1773 * If wait*() is interrupted by a signal, tell main() to call us again...
1774 */
1775
1776 if (pid < 0 && errno == EINTR)
1777 dead_children = 1;
ef416fc2 1778}
1779
1780
ef416fc2 1781/*
1782 * 'select_timeout()' - Calculate the select timeout value.
1783 *
1784 */
1785
1786static long /* O - Number of seconds */
bd7854cb 1787select_timeout(int fds) /* I - Number of descriptors returned */
ef416fc2 1788{
ef416fc2 1789 long timeout; /* Timeout for select */
1790 time_t now; /* Current time */
1791 cupsd_client_t *con; /* Client information */
1792 cupsd_printer_t *p; /* Printer information */
1793 cupsd_job_t *job; /* Job information */
1794 cupsd_subscription_t *sub; /* Subscription information */
1795 const char *why; /* Debugging aid */
1796
1797
1798 /*
1799 * Check to see if any of the clients have pending data to be
1800 * processed; if so, the timeout should be 0...
1801 */
1802
bd7854cb 1803 for (con = (cupsd_client_t *)cupsArrayFirst(Clients);
1804 con;
1805 con = (cupsd_client_t *)cupsArrayNext(Clients))
ef416fc2 1806 if (con->http.used > 0)
1807 return (0);
1808
1809 /*
f7deaa1a 1810 * If select has been active in the last second (fds > 0) or we have
ef416fc2 1811 * many resources in use then don't bother trying to optimize the
1812 * timeout, just make it 1 second.
1813 */
1814
f7deaa1a 1815 if (fds > 0 || cupsArrayCount(Clients) > 50)
ef416fc2 1816 return (1);
1817
1818 /*
1819 * Otherwise, check all of the possible events that we need to wake for...
1820 */
1821
1822 now = time(NULL);
1823 timeout = now + 86400; /* 86400 == 1 day */
1824 why = "do nothing";
1825
e6013cfa
MS
1826#ifdef __APPLE__
1827 /*
1828 * When going to sleep, wake up to cancel jobs that don't complete in time.
1829 */
1830
1831 if (SleepJobs > 0 && SleepJobs < timeout)
1832 {
1833 timeout = SleepJobs;
1834 why = "cancel jobs before sleeping";
1835 }
1836#endif /* __APPLE__ */
1837
76cd9e37
MS
1838 /*
1839 * Check whether we are accepting new connections...
1840 */
1841
1842 if (ListeningPaused > 0 && cupsArrayCount(Clients) < MaxClients &&
1843 ListeningPaused < timeout)
1844 {
1845 if (ListeningPaused <= now)
1846 timeout = now;
1847 else
1848 timeout = ListeningPaused;
1849
1850 why = "resume listening";
1851 }
1852
ef416fc2 1853 /*
1854 * Check the activity and close old clients...
1855 */
1856
bd7854cb 1857 for (con = (cupsd_client_t *)cupsArrayFirst(Clients);
1858 con;
1859 con = (cupsd_client_t *)cupsArrayNext(Clients))
ef416fc2 1860 if ((con->http.activity + Timeout) < timeout)
1861 {
1862 timeout = con->http.activity + Timeout;
1863 why = "timeout a client connection";
1864 }
1865
1866 /*
1867 * Update the browse list as needed...
1868 */
1869
1870 if (Browsing && BrowseLocalProtocols)
1871 {
1872#ifdef HAVE_LIBSLP
1873 if ((BrowseLocalProtocols & BROWSE_SLP) && (BrowseSLPRefresh < timeout))
1874 {
1875 timeout = BrowseSLPRefresh;
1876 why = "update SLP browsing";
1877 }
1878#endif /* HAVE_LIBSLP */
1879
b423cd4c 1880#ifdef HAVE_LDAP
1881 if ((BrowseLocalProtocols & BROWSE_LDAP) && (BrowseLDAPRefresh < timeout))
1882 {
1883 timeout = BrowseLDAPRefresh;
1884 why = "update LDAP browsing";
1885 }
1886#endif /* HAVE_LDAP */
1887
f7deaa1a 1888 if ((BrowseLocalProtocols & BROWSE_CUPS) && NumBrowsers)
ef416fc2 1889 {
1890 for (p = (cupsd_printer_t *)cupsArrayFirst(Printers);
1891 p;
1892 p = (cupsd_printer_t *)cupsArrayNext(Printers))
1893 {
1894 if (p->type & CUPS_PRINTER_REMOTE)
1895 {
1896 if ((p->browse_time + BrowseTimeout) < timeout)
1897 {
1898 timeout = p->browse_time + BrowseTimeout;
1899 why = "browse timeout a printer";
1900 }
1901 }
f7deaa1a 1902 else if (p->shared && !(p->type & CUPS_PRINTER_IMPLICIT))
ef416fc2 1903 {
1904 if (BrowseInterval && (p->browse_time + BrowseInterval) < timeout)
1905 {
1906 timeout = p->browse_time + BrowseInterval;
1907 why = "send browse update";
1908 }
1909 }
1910 }
1911 }
1912 }
1913
3dfe78b3 1914 /*
bf3816c7 1915 * Write out changes to configuration and state files...
3dfe78b3
MS
1916 */
1917
1918 if (DirtyCleanTime && timeout > DirtyCleanTime)
1919 {
1920 timeout = DirtyCleanTime;
1921 why = "write dirty config/state files";
1922 }
1923
ef416fc2 1924 /*
1925 * Check for any active jobs...
1926 */
1927
bf3816c7 1928 if (cupsArrayCount(ActiveJobs) > 0)
ef416fc2 1929 {
1930 for (job = (cupsd_job_t *)cupsArrayFirst(ActiveJobs);
1931 job;
1932 job = (cupsd_job_t *)cupsArrayNext(ActiveJobs))
bf3816c7
MS
1933 if (job->state_value == IPP_JOB_HELD && job->hold_until < timeout)
1934 {
1935 timeout = job->hold_until;
1936 why = "release held jobs";
1937 }
1938 else if (job->state_value == IPP_JOB_PENDING && timeout > (now + 10))
ef416fc2 1939 {
1940 timeout = now + 10;
bf3816c7 1941 why = "start pending jobs";
ef416fc2 1942 break;
1943 }
1944 }
1945
1946#ifdef HAVE_MALLINFO
1947 /*
1948 * Log memory usage every minute...
1949 */
1950
1951 if (LogLevel >= CUPSD_LOG_DEBUG && (mallinfo_time + 60) < timeout)
1952 {
1953 timeout = mallinfo_time + 60;
1954 why = "display memory usage";
1955 }
1956#endif /* HAVE_MALLINFO */
1957
ef416fc2 1958 /*
1959 * Expire subscriptions as needed...
1960 */
1961
1962 for (sub = (cupsd_subscription_t *)cupsArrayFirst(Subscriptions);
1963 sub;
1964 sub = (cupsd_subscription_t *)cupsArrayNext(Subscriptions))
bd7854cb 1965 if (!sub->job && sub->expire && sub->expire < timeout)
ef416fc2 1966 {
1967 timeout = sub->expire;
1968 why = "expire subscription";
1969 }
1970
1971 /*
1972 * Adjust from absolute to relative time. If p->browse_time above
1973 * was 0 then we can end up with a negative value here, so check.
1974 * We add 1 second to the timeout since events occur after the
1975 * timeout expires, and limit the timeout to 86400 seconds (1 day)
1976 * to avoid select() timeout limits present on some operating
1977 * systems...
1978 */
1979
1980 timeout = timeout - now + 1;
1981
1982 if (timeout < 1)
1983 timeout = 1;
1984 else if (timeout > 86400)
1985 timeout = 86400;
1986
1987 /*
1988 * Log and return the timeout value...
1989 */
1990
f7deaa1a 1991 cupsdLogMessage(CUPSD_LOG_DEBUG2, "select_timeout(%d): %ld seconds to %s",
1992 fds, timeout, why);
ef416fc2 1993
1994 return (timeout);
1995}
1996
1997
e6013cfa
MS
1998/*
1999 * 'sigchld_handler()' - Handle 'child' signals from old processes.
2000 */
2001
2002static void
2003sigchld_handler(int sig) /* I - Signal number */
2004{
2005 (void)sig;
2006
2007 /*
2008 * Flag that we have dead children...
2009 */
2010
2011 dead_children = 1;
2012
2013 /*
2014 * Reset the signal handler as needed...
2015 */
2016
2017#if !defined(HAVE_SIGSET) && !defined(HAVE_SIGACTION)
2018 signal(SIGCLD, sigchld_handler);
2019#endif /* !HAVE_SIGSET && !HAVE_SIGACTION */
2020}
2021
2022
2023/*
2024 * 'sighup_handler()' - Handle 'hangup' signals to reconfigure the scheduler.
2025 */
2026
2027static void
2028sighup_handler(int sig) /* I - Signal number */
2029{
2030 (void)sig;
2031
2032 NeedReload = RELOAD_ALL;
2033 ReloadTime = time(NULL);
2034
2035#if !defined(HAVE_SIGSET) && !defined(HAVE_SIGACTION)
2036 signal(SIGHUP, sighup_handler);
2037#endif /* !HAVE_SIGSET && !HAVE_SIGACTION */
2038}
2039
2040
2041/*
2042 * 'sigterm_handler()' - Handle 'terminate' signals that stop the scheduler.
2043 */
2044
2045static void
2046sigterm_handler(int sig) /* I - Signal number */
2047{
2048 (void)sig; /* remove compiler warnings... */
2049
2050 /*
2051 * Flag that we should stop and return...
2052 */
2053
2054 stop_scheduler = 1;
2055}
2056
2057
ef416fc2 2058/*
2059 * 'usage()' - Show scheduler usage.
2060 */
2061
2062static void
a4d04587 2063usage(int status) /* O - Exit status */
ef416fc2 2064{
a4d04587 2065 _cupsLangPuts(status ? stderr : stdout,
2066 _("Usage: cupsd [-c config-file] [-f] [-F] [-h] [-l]\n"
2067 "\n"
2068 "-c config-file Load alternate configuration file\n"
2069 "-f Run in the foreground\n"
2070 "-F Run in the foreground but detach\n"
2071 "-h Show this usage message\n"
2072 "-l Run cupsd from launchd(8)\n"));
2073 exit(status);
ef416fc2 2074}
2075
2076
2077/*
b19ccc9e 2078 * End of "$Id: main.c 7925 2008-09-10 17:47:26Z mike $".
ef416fc2 2079 */