2 * "$Id: main.c 5056 2006-02-02 19:46:32Z mike $"
4 * Scheduler main loop for the Common UNIX Printing System (CUPS).
6 * Copyright 1997-2006 by Easy Software Products, all rights reserved.
8 * These coded instructions, statements, and computer programs are the
9 * property of Easy Software Products and are protected by Federal
10 * copyright law. Distribution and use rights are outlined in the file
11 * "LICENSE" which should have been included with this file. If this
12 * file is missing or damaged please contact Easy Software Products
15 * Attn: CUPS Licensing Information
16 * Easy Software Products
17 * 44141 Airport View Drive, Suite 204
18 * Hollywood, Maryland 20636 USA
20 * Voice: (301) 373-9600
21 * EMail: cups-info@cups.org
22 * WWW: http://www.cups.org
26 * main() - Main entry for the CUPS scheduler.
27 * cupsdClosePipe() - Close a pipe as necessary.
28 * cupsdOpenPipe() - Create a pipe which is closed on exec.
29 * cupsdCatchChildSignals() - Catch SIGCHLD signals...
30 * cupsdHoldSignals() - Hold child and termination signals.
31 * cupsdIgnoreChildSignals() - Ignore SIGCHLD signals...
32 * cupsdReleaseSignals() - Release signals for delivery.
33 * cupsdSetString() - Set a string value.
34 * cupsdSetStringf() - Set a formatted string value.
35 * launchd_checkin() - Check-in with launchd and collect the
37 * launchd_reload() - Tell launchd to reload the configuration
38 * file to pick up the new listening directives.
39 * launchd_sync_conf() - Re-write the launchd(8) config file
40 * org.cups.cupsd.plist based on cupsd.conf.
41 * parent_handler() - Catch USR1/CHLD signals...
42 * process_children() - Process all dead children...
43 * sigchld_handler() - Handle 'child' signals from old processes.
44 * sighup_handler() - Handle 'hangup' signals to reconfigure the
46 * sigterm_handler() - Handle 'terminate' signals that stop the
48 * select_timeout() - Calculate the select timeout value.
49 * usage() - Show scheduler usage.
53 * Include necessary headers...
58 #include <sys/resource.h>
65 #endif /* HAVE_LAUNCH_H */
67 #if defined(HAVE_MALLOC_H) && defined(HAVE_MALLINFO)
69 #endif /* HAVE_MALLOC_H && HAVE_MALLINFO */
72 #endif /* HAVE_NOTIFY_H */
80 static void launchd_checkin(void);
81 static void launchd_reload(void);
82 static int launchd_sync_conf(void);
83 #endif /* HAVE_LAUNCHD */
85 static void parent_handler(int sig
);
86 static void process_children(void);
87 static void sigchld_handler(int sig
);
88 static void sighup_handler(int sig
);
89 static void sigterm_handler(int sig
);
90 static long select_timeout(int fds
);
91 static void usage(int status
);
98 static int parent_signal
= 0; /* Set to signal number from child */
99 static int holdcount
= 0; /* Number of times "hold" was called */
100 #if defined(HAVE_SIGACTION) && !defined(HAVE_SIGSET)
101 static sigset_t holdmask
; /* Old POSIX signal mask */
102 #endif /* HAVE_SIGACTION && !HAVE_SIGSET */
103 static int dead_children
= 0; /* Dead children? */
104 static int stop_scheduler
= 0; /* Should the scheduler stop? */
108 * 'main()' - Main entry for the CUPS scheduler.
111 int /* O - Exit status */
112 main(int argc
, /* I - Number of command-line arguments */
113 char *argv
[]) /* I - Command-line arguments */
115 int i
; /* Looping var */
116 char *opt
; /* Option character */
117 int fg
; /* Run in the foreground */
118 int fds
; /* Number of ready descriptors select returns */
119 fd_set
*input
, /* Input set for select() */
120 *output
; /* Output set for select() */
121 cupsd_client_t
*con
; /* Current client */
122 cupsd_job_t
*job
; /* Current job */
123 cupsd_listener_t
*lis
; /* Current listener */
124 time_t current_time
, /* Current time */
125 activity
, /* Client activity timer */
126 browse_time
, /* Next browse send time */
127 senddoc_time
, /* Send-Document time */
128 expire_time
; /* Subscription expire time */
129 time_t mallinfo_time
; /* Malloc information time */
130 size_t string_count
, /* String count */
131 alloc_bytes
, /* Allocated string bytes */
132 total_bytes
; /* Total string bytes */
133 struct timeval timeout
; /* select() timeout */
134 struct rlimit limit
; /* Runtime limit */
135 #if defined(HAVE_SIGACTION) && !defined(HAVE_SIGSET)
136 struct sigaction action
; /* Actions for POSIX signals */
137 #endif /* HAVE_SIGACTION && !HAVE_SIGSET */
139 cups_file_t
*fp
; /* Fake lpsched lock file */
140 struct stat statbuf
; /* Needed for checking lpsched FIFO */
143 int launchd_idle_exit
;
144 /* Idle exit on select timeout? */
145 #endif /* HAVE_LAUNCHD */
149 * Check for command-line arguments...
154 for (i
= 1; i
< argc
; i
++)
155 if (argv
[i
][0] == '-')
156 for (opt
= argv
[i
] + 1; *opt
!= '\0'; opt
++)
159 case 'c' : /* Configuration file */
163 _cupsLangPuts(stderr
, _("cupsd: Expected config filename "
164 "after \"-c\" option!\n"));
168 if (argv
[i
][0] == '/')
171 * Absolute directory...
174 cupsdSetString(&ConfigurationFile
, argv
[i
]);
179 * Relative directory...
182 char *current
; /* Current directory */
186 * Allocate a buffer for the current working directory to
187 * reduce run-time stack usage; this approximates the
188 * behavior of some implementations of getcwd() when they
189 * are passed a NULL pointer.
192 current
= malloc(1024);
193 getcwd(current
, 1024);
195 cupsdSetStringf(&ConfigurationFile
, "%s/%s", current
, argv
[i
]);
201 case 'f' : /* Run in foreground... */
205 case 'F' : /* Run in foreground, but still disconnect from terminal... */
209 case 'h' : /* Show usage/help */
213 case 'l' : /* Started by launchd... */
218 _cupsLangPuts(stderr
, _("cupsd: launchd(8) support not compiled "
219 "in, running in normal mode.\n"));
221 #endif /* HAVE_LAUNCHD */
224 default : /* Unknown option */
225 _cupsLangPrintf(stderr
, _("cupsd: Unknown option \"%c\" - "
226 "aborting!\n"), *opt
);
232 _cupsLangPrintf(stderr
, _("cupsd: Unknown argument \"%s\" - aborting!\n"),
237 if (!ConfigurationFile
)
238 cupsdSetString(&ConfigurationFile
, CUPS_SERVERROOT
"/cupsd.conf");
241 * If the user hasn't specified "-f", run in the background...
247 * Setup signal handlers for the parent...
250 #ifdef HAVE_SIGSET /* Use System V signals over POSIX to avoid bugs */
251 sigset(SIGUSR1
, parent_handler
);
252 sigset(SIGCHLD
, parent_handler
);
254 sigset(SIGHUP
, SIG_IGN
);
255 #elif defined(HAVE_SIGACTION)
256 memset(&action
, 0, sizeof(action
));
257 sigemptyset(&action
.sa_mask
);
258 sigaddset(&action
.sa_mask
, SIGUSR1
);
259 action
.sa_handler
= parent_handler
;
260 sigaction(SIGUSR1
, &action
, NULL
);
261 sigaction(SIGCHLD
, &action
, NULL
);
263 sigemptyset(&action
.sa_mask
);
264 action
.sa_handler
= SIG_IGN
;
265 sigaction(SIGHUP
, &action
, NULL
);
267 signal(SIGUSR1
, parent_handler
);
268 signal(SIGCLD
, parent_handler
);
270 signal(SIGHUP
, SIG_IGN
);
271 #endif /* HAVE_SIGSET */
276 * OK, wait for the child to startup and send us SIGUSR1 or to crash
277 * and the OS send us SIGCHLD... We also need to ignore SIGHUP which
278 * might be sent by the init script to restart the scheduler...
281 for (; parent_signal
== 0;)
284 if (parent_signal
== SIGUSR1
)
292 else if (WIFEXITED(i
))
294 fprintf(stderr
, "cupsd: Child exited with status %d!\n", WEXITSTATUS(i
));
299 fprintf(stderr
, "cupsd: Child exited on signal %d!\n", WTERMSIG(i
));
308 * Make sure we aren't tying up any filesystems...
315 * Disable core dumps...
318 getrlimit(RLIMIT_CORE
, &limit
);
320 setrlimit(RLIMIT_CORE
, &limit
);
323 * Disconnect from the controlling terminal...
329 * Close all open files...
332 getrlimit(RLIMIT_NOFILE
, &limit
);
334 for (i
= 0; i
< limit
.rlim_cur
; i
++)
340 * Set the timezone info...
346 setlocale(LC_TIME
, "");
350 * Set the maximum number of files...
353 getrlimit(RLIMIT_NOFILE
, &limit
);
355 if (limit
.rlim_max
> CUPS_MAX_FDS
)
356 MaxFDs
= CUPS_MAX_FDS
;
358 MaxFDs
= limit
.rlim_max
;
360 limit
.rlim_cur
= MaxFDs
;
362 setrlimit(RLIMIT_NOFILE
, &limit
);
365 * Allocate memory for the input and output sets...
368 SetSize
= (MaxFDs
+ 31) / 8 + 4;
369 if (SetSize
< sizeof(fd_set
))
370 SetSize
= sizeof(fd_set
);
372 InputSet
= (fd_set
*)calloc(1, SetSize
);
373 OutputSet
= (fd_set
*)calloc(1, SetSize
);
374 input
= (fd_set
*)calloc(1, SetSize
);
375 output
= (fd_set
*)calloc(1, SetSize
);
377 if (InputSet
== NULL
|| OutputSet
== NULL
|| input
== NULL
|| output
== NULL
)
379 syslog(LOG_LPR
, "Unable to allocate memory for select() sets - exiting!");
384 * Read configuration...
387 if (!cupsdReadConfiguration())
389 syslog(LOG_LPR
, "Unable to read configuration file \'%s\' - exiting!",
398 * If we were started by launchd make sure the cupsd plist file contains the
399 * same listeners as cupsd.conf; If it didn't then reload it before getting
400 * the list of listening file descriptors...
403 if (launchd_sync_conf())
408 * Until rdar://3854821 is fixed we have to exit after the reload...
411 cupsdLogMessage(CUPSD_LOG_DEBUG2
, "Exiting on launchd_reload");
417 #endif /* HAVE_LAUNCHD */
420 * Startup the server...
426 * Catch hangup and child signals and ignore broken pipes...
429 #ifdef HAVE_SIGSET /* Use System V signals over POSIX to avoid bugs */
431 sigset(SIGHUP
, sigterm_handler
);
433 sigset(SIGHUP
, sighup_handler
);
435 sigset(SIGPIPE
, SIG_IGN
);
436 sigset(SIGTERM
, sigterm_handler
);
437 #elif defined(HAVE_SIGACTION)
438 memset(&action
, 0, sizeof(action
));
440 sigemptyset(&action
.sa_mask
);
441 sigaddset(&action
.sa_mask
, SIGHUP
);
444 action
.sa_handler
= sigterm_handler
;
446 action
.sa_handler
= sighup_handler
;
448 sigaction(SIGHUP
, &action
, NULL
);
450 sigemptyset(&action
.sa_mask
);
451 action
.sa_handler
= SIG_IGN
;
452 sigaction(SIGPIPE
, &action
, NULL
);
454 sigemptyset(&action
.sa_mask
);
455 sigaddset(&action
.sa_mask
, SIGTERM
);
456 sigaddset(&action
.sa_mask
, SIGCHLD
);
457 action
.sa_handler
= sigterm_handler
;
458 sigaction(SIGTERM
, &action
, NULL
);
461 signal(SIGHUP
, sigterm_handler
);
463 signal(SIGHUP
, sighup_handler
);
465 signal(SIGPIPE
, SIG_IGN
);
466 signal(SIGTERM
, sigterm_handler
);
467 #endif /* HAVE_SIGSET */
471 * Try to create a fake lpsched lock file if one is not already there.
472 * Some Adobe applications need it under IRIX in order to enable
476 if ((fp
= cupsFileOpen("/var/spool/lp/SCHEDLOCK", "w")) == NULL
)
478 syslog(LOG_LPR
, "Unable to create fake lpsched lock file "
479 "\"/var/spool/lp/SCHEDLOCK\"\' - %s!",
484 fchmod(cupsFileNumber(fp
), 0644);
485 fchown(cupsFileNumber(fp
), User
, Group
);
492 * Initialize authentication certificates...
498 * If we are running in the background, signal the parent process that
499 * we are up and running...
505 * Send a signal to the parent process, but only if the parent is
506 * not PID 1 (init). This avoids accidentally shutting down the
507 * system on OpenBSD if you CTRL-C the server before it is up...
510 i
= getppid(); /* Save parent PID to avoid race condition */
517 * Start power management framework...
520 cupsdStartSystemMonitor();
523 * If the administrator has configured the server to run as an unpriviledged
524 * user, change to that user now...
530 setgroups(1, &Group
);
538 cupsdCatchChildSignals();
541 * Start any pending print jobs...
551 browse_time
= time(NULL
);
552 senddoc_time
= time(NULL
);
553 expire_time
= time(NULL
);
556 while (!stop_scheduler
)
559 cupsdLogMessage(CUPSD_LOG_DEBUG2
,
560 "main: Top of loop, dead_children=%d, NeedReload=%d",
561 dead_children
, NeedReload
);
565 * Check if there are dead children to handle...
572 * Check if we need to load the server configuration file...
578 * Close any idle clients...
583 for (i
= NumClients
, con
= Clients
; i
> 0; i
--, con
++)
584 if (con
->http
.state
== HTTP_WAITING
)
586 cupsdCloseClient(con
);
590 con
->http
.keep_alive
= HTTP_KEEPALIVE_OFF
;
592 cupsdPauseListening();
596 * Check for any active jobs...
599 for (job
= (cupsd_job_t
*)cupsArrayFirst(ActiveJobs
);
601 job
= (cupsd_job_t
*)cupsArrayNext(ActiveJobs
))
602 if (job
->state
->values
[0].integer
== IPP_JOB_PROCESSING
)
606 * Restart if all clients are closed and all jobs finished, or
607 * if the reload timeout has elapsed...
610 if ((NumClients
== 0 && (!job
|| NeedReload
!= RELOAD_ALL
)) ||
611 (time(NULL
) - ReloadTime
) >= ReloadTimeout
)
614 * Shutdown the server...
620 * Read configuration...
623 if (!cupsdReadConfiguration())
625 syslog(LOG_LPR
, "Unable to read configuration file \'%s\' - exiting!",
633 if (launchd_sync_conf())
638 * Until rdar://3854821 is fixed we have to exit after the reload...
641 cupsdLogMessage(CUPSD_LOG_DEBUG2
, "Exiting on launchd_reload");
648 #endif /* HAVE_LAUNCHD */
651 * Startup the server...
659 * Check for available input or ready output. If select() returns
660 * 0 or -1, something bad happened and we should exit immediately.
662 * Note that we at least have one listening socket open at all
666 memcpy(input
, InputSet
, SetSize
);
667 memcpy(output
, OutputSet
, SetSize
);
669 timeout
.tv_sec
= select_timeout(fds
);
674 * If no other work is scheduled and we're being controlled by
675 * launchd(8) then timeout after 'LaunchdTimeout' seconds of
679 if (timeout
.tv_sec
== 86400 && Launchd
&& LaunchdTimeout
&&
680 (!Browsing
|| !(BrowseLocalProtocols
& BROWSE_DNSSD
) ||
681 cupsArrayCount(Printers
) == 0))
683 timeout
.tv_sec
= LaunchdTimeout
;
684 launchd_idle_exit
= 1;
687 launchd_idle_exit
= 0;
688 #endif /* HAVE_LAUNCHD */
690 if (timeout
.tv_sec
< 86400) /* Only use timeout for < 1 day */
691 fds
= select(MaxFDs
, input
, output
, NULL
, &timeout
);
693 fds
= select(MaxFDs
, input
, output
, NULL
, NULL
);
697 char s
[16384], /* String buffer */
698 *sptr
; /* Pointer into buffer */
699 int slen
; /* Length of string buffer */
703 * Got an error from select!
706 if (errno
== EINTR
) /* Just interrupted by a signal */
710 * Log all sorts of debug info to help track down the problem.
713 cupsdLogMessage(CUPSD_LOG_EMERG
, "select() failed - %s!",
716 strcpy(s
, "InputSet =");
720 for (i
= 0; i
< MaxFDs
; i
++)
721 if (FD_ISSET(i
, InputSet
))
723 snprintf(sptr
, sizeof(s
) - slen
, " %d", i
);
724 slen
+= strlen(sptr
);
725 sptr
+= strlen(sptr
);
728 cupsdLogMessage(CUPSD_LOG_EMERG
, s
);
730 strcpy(s
, "OutputSet =");
734 for (i
= 0; i
< MaxFDs
; i
++)
735 if (FD_ISSET(i
, OutputSet
))
737 snprintf(sptr
, sizeof(s
) - slen
, " %d", i
);
738 slen
+= strlen(sptr
);
739 sptr
+= strlen(sptr
);
742 cupsdLogMessage(CUPSD_LOG_EMERG
, s
);
744 for (i
= 0, con
= Clients
; i
< NumClients
; i
++, con
++)
745 cupsdLogMessage(CUPSD_LOG_EMERG
,
746 "Clients[%d] = %d, file = %d, state = %d",
747 i
, con
->http
.fd
, con
->file
, con
->http
.state
);
749 for (i
= 0, lis
= Listeners
; i
< NumListeners
; i
++, lis
++)
750 cupsdLogMessage(CUPSD_LOG_EMERG
, "Listeners[%d] = %d", i
, lis
->fd
);
752 cupsdLogMessage(CUPSD_LOG_EMERG
, "BrowseSocket = %d", BrowseSocket
);
754 cupsdLogMessage(CUPSD_LOG_EMERG
, "CGIPipes[0] = %d", CGIPipes
[0]);
757 cupsdLogMessage(CUPSD_LOG_EMERG
, "SysEventPipes[0] = %d",
759 #endif /* __APPLE__ */
761 for (job
= (cupsd_job_t
*)cupsArrayFirst(ActiveJobs
);
763 job
= (cupsd_job_t
*)cupsArrayNext(ActiveJobs
))
764 cupsdLogMessage(CUPSD_LOG_EMERG
, "Jobs[%d] = %d < [%d %d] > [%d %d]",
766 job
->status_buffer
? job
->status_buffer
->fd
: -1,
767 job
->print_pipes
[0], job
->print_pipes
[1],
768 job
->back_pipes
[0], job
->back_pipes
[1]);
772 current_time
= time(NULL
);
776 * If no other work was scheduled and we're being controlled by launchd(8)
777 * then timeout after 'LaunchdTimeout' seconds of inactivity...
780 if (!fds
&& launchd_idle_exit
)
782 cupsdLogMessage(CUPSD_LOG_INFO
,
783 "Printer sharing is off and there are no jobs pending, "
784 "will restart on demand.");
788 #endif /* HAVE_LAUNCHD */
791 * Check for status info from job filters...
794 for (job
= (cupsd_job_t
*)cupsArrayFirst(ActiveJobs
);
796 job
= (cupsd_job_t
*)cupsArrayNext(ActiveJobs
))
797 if (job
->status_buffer
&& FD_ISSET(job
->status_buffer
->fd
, input
))
800 * Clear the input bit to avoid updating the next job
801 * using the same status pipe file descriptor...
804 FD_CLR(job
->status_buffer
->fd
, input
);
807 * Read any status messages from the filters...
814 * Update CGI messages as needed...
817 if (CGIPipes
[0] >= 0 && FD_ISSET(CGIPipes
[0], input
))
821 * Handle system management events as needed...
825 if (SysEventPipes
[0] >= 0 && FD_ISSET(SysEventPipes
[0], input
))
826 cupsdUpdateSystemMonitor();
827 #endif /* __APPLE__ */
830 * Update notifier messages as needed...
833 if (NotifierPipes
[0] >= 0 && FD_ISSET(NotifierPipes
[0], input
))
834 cupsdUpdateNotifierStatus();
837 * Expire subscriptions as needed...
840 if (cupsArrayCount(Subscriptions
) > 0 && current_time
> expire_time
)
842 cupsdExpireSubscriptions(NULL
, NULL
);
844 expire_time
= current_time
;
848 * Update the browse list as needed...
851 if (Browsing
&& BrowseRemoteProtocols
)
853 if (BrowseSocket
>= 0 && FD_ISSET(BrowseSocket
, input
))
854 cupsdUpdateCUPSBrowse();
856 if (PollPipe
>= 0 && FD_ISSET(PollPipe
, input
))
857 cupsdUpdatePolling();
860 if (((BrowseLocalProtocols
| BrowseRemoteProtocols
) & BROWSE_SLP
) &&
861 BrowseSLPRefresh
<= current_time
)
862 cupsdUpdateSLPBrowse();
863 #endif /* HAVE_LIBSLP */
866 if (Browsing
&& BrowseLocalProtocols
&& current_time
> browse_time
)
868 cupsdSendBrowseList();
869 browse_time
= current_time
;
873 * Check for new connections on the "listen" sockets...
876 for (i
= NumListeners
, lis
= Listeners
; i
> 0; i
--, lis
++)
877 if (lis
->fd
>= 0 && FD_ISSET(lis
->fd
, input
))
879 FD_CLR(lis
->fd
, input
);
880 cupsdAcceptClient(lis
);
884 * Check for new data on the client sockets...
887 for (i
= NumClients
, con
= Clients
; i
> 0; i
--, con
++)
890 * Process the input buffer...
893 if (FD_ISSET(con
->http
.fd
, input
) || con
->http
.used
)
895 FD_CLR(con
->http
.fd
, input
);
897 if (!cupsdReadClient(con
))
900 FD_CLR(con
->file
, input
);
908 * Write data as needed...
911 if (con
->pipe_pid
&& FD_ISSET(con
->file
, input
))
914 * Keep track of pending input from the file/pipe separately
915 * so that we don't needlessly spin on select() when the web
916 * client is not ready to receive data...
919 FD_CLR(con
->file
, input
);
923 cupsdLogMessage(CUPSD_LOG_DEBUG2
, "main: Data ready file %d!",
927 if (!FD_ISSET(con
->http
.fd
, output
))
929 cupsdLogMessage(CUPSD_LOG_DEBUG2
,
930 "main: Removing fd %d from InputSet...", con
->file
);
931 FD_CLR(con
->file
, input
);
932 FD_CLR(con
->file
, InputSet
);
936 if (FD_ISSET(con
->http
.fd
, output
))
938 FD_CLR(con
->http
.fd
, output
);
940 if (!con
->pipe_pid
|| con
->file_ready
)
941 if (!cupsdWriteClient(con
))
949 * Check the activity and close old clients...
952 activity
= current_time
- Timeout
;
953 if (con
->http
.activity
< activity
&& !con
->pipe_pid
)
955 cupsdLogMessage(CUPSD_LOG_DEBUG
,
956 "Closing client %d after %d seconds of inactivity...",
957 con
->http
.fd
, Timeout
);
959 cupsdCloseClient(con
);
966 * Update any pending multi-file documents...
969 if ((current_time
- senddoc_time
) >= 10)
972 senddoc_time
= current_time
;
976 * Log memory usage every minute...
979 if ((current_time
- mallinfo_time
) >= 60 && LogLevel
>= CUPSD_LOG_DEBUG
)
982 struct mallinfo mem
; /* Malloc information */
986 cupsdLogMessage(CUPSD_LOG_DEBUG
,
987 "mallinfo: arena = %d, used = %d, free = %d\n",
988 mem
.arena
, mem
.usmblks
+ mem
.uordblks
,
989 mem
.fsmblks
+ mem
.fordblks
);
990 #endif /* HAVE_MALLINFO */
992 string_count
= _cups_sp_statistics(&alloc_bytes
, &total_bytes
);
993 cupsdLogMessage(CUPSD_LOG_DEBUG
,
994 "stringpool: " CUPS_LLFMT
" strings, "
995 CUPS_LLFMT
" allocated, " CUPS_LLFMT
" total bytes",
996 CUPS_LLCAST string_count
, CUPS_LLCAST alloc_bytes
,
997 CUPS_LLCAST total_bytes
);
999 mallinfo_time
= current_time
;
1003 * Update the root certificate once every 5 minutes...
1006 if ((current_time
- RootCertTime
) >= RootCertDuration
&& RootCertDuration
&&
1010 * Update the root certificate...
1014 cupsdAddCert(0, "root");
1018 * Handle OS-specific event notification for any events that have
1019 * accumulated. Don't send these more than once a second...
1022 if (LastEvent
&& (time(NULL
) - LastEventTime
) > 1)
1024 #ifdef HAVE_NOTIFY_POST
1025 if (LastEvent
& CUPSD_EVENT_PRINTER_CHANGED
)
1027 cupsdLogMessage(CUPSD_LOG_DEBUG2
,
1028 "notify_post(\"com.apple.printerListChange\")");
1029 notify_post("com.apple.printerListChange");
1032 if (LastEvent
& CUPSD_EVENT_PRINTER_STATE_CHANGED
)
1034 cupsdLogMessage(CUPSD_LOG_DEBUG2
,
1035 "notify_post(\"com.apple.printerHistoryChange\")");
1036 notify_post("com.apple.printerHistoryChange");
1039 if (LastEvent
& (CUPSD_EVENT_JOB_STATE_CHANGED
|
1040 CUPSD_EVENT_JOB_CONFIG_CHANGED
|
1041 CUPSD_EVENT_JOB_PROGRESS
))
1043 cupsdLogMessage(CUPSD_LOG_DEBUG2
,
1044 "notify_post(\"com.apple.jobChange\")");
1045 notify_post("com.apple.jobChange");
1047 #endif /* HAVE_NOTIFY_POST */
1050 * Reset the accumulated events and notification time...
1053 LastEventTime
= time(NULL
);
1054 LastEvent
= CUPSD_EVENT_NONE
;
1059 * Log a message based on what happened...
1063 cupsdLogMessage(CUPSD_LOG_INFO
, "Scheduler shutting down normally.");
1065 cupsdLogMessage(CUPSD_LOG_ERROR
,
1066 "Scheduler shutting down due to program error.");
1069 * Close all network clients and stop all jobs...
1076 cupsdStopSystemMonitor();
1080 * Update the launchd config file as needed...
1083 launchd_sync_conf();
1084 #endif /* HAVE_LAUNCHD */
1088 * Remove the fake IRIX lpsched lock file, but only if the existing
1089 * file is not a FIFO which indicates that the real IRIX lpsched is
1093 if (!stat("/var/spool/lp/FIFO", &statbuf
))
1094 if (!S_ISFIFO(statbuf
.st_mode
))
1095 unlink("/var/spool/lp/SCHEDLOCK");
1099 * Free memory used by FD sets and return...
1107 return (!stop_scheduler
);
1112 * 'cupsdClosePipe()' - Close a pipe as necessary.
1116 cupsdClosePipe(int *fds
) /* I - Pipe file descriptors (2) */
1119 * Close file descriptors as needed...
1137 * 'cupsdOpenPipe()' - Create a pipe which is closed on exec.
1140 int /* O - 0 on success, -1 on error */
1141 cupsdOpenPipe(int *fds
) /* O - Pipe file descriptors (2) */
1144 * Create the pipe...
1151 * Set the "close on exec" flag on each end of the pipe...
1154 if (fcntl(fds
[0], F_SETFD
, fcntl(fds
[0], F_GETFD
) | FD_CLOEXEC
))
1161 if (fcntl(fds
[1], F_SETFD
, fcntl(fds
[1], F_GETFD
) | FD_CLOEXEC
))
1169 * Return 0 indicating success...
1177 * 'cupsdCatchChildSignals()' - Catch SIGCHLD signals...
1181 cupsdCatchChildSignals(void)
1183 #if defined(HAVE_SIGACTION) && !defined(HAVE_SIGSET)
1184 struct sigaction action
; /* Actions for POSIX signals */
1185 #endif /* HAVE_SIGACTION && !HAVE_SIGSET */
1188 #ifdef HAVE_SIGSET /* Use System V signals over POSIX to avoid bugs */
1189 sigset(SIGCHLD
, sigchld_handler
);
1190 #elif defined(HAVE_SIGACTION)
1191 memset(&action
, 0, sizeof(action
));
1193 sigemptyset(&action
.sa_mask
);
1194 sigaddset(&action
.sa_mask
, SIGTERM
);
1195 sigaddset(&action
.sa_mask
, SIGCHLD
);
1196 action
.sa_handler
= sigchld_handler
;
1197 sigaction(SIGCHLD
, &action
, NULL
);
1199 signal(SIGCLD
, sigchld_handler
); /* No, SIGCLD isn't a typo... */
1200 #endif /* HAVE_SIGSET */
1205 * 'cupsdClearString()' - Clear a string.
1209 cupsdClearString(char **s
) /* O - String value */
1220 * 'cupsdHoldSignals()' - Hold child and termination signals.
1224 cupsdHoldSignals(void)
1226 #if defined(HAVE_SIGACTION) && !defined(HAVE_SIGSET)
1227 sigset_t newmask
; /* New POSIX signal mask */
1228 #endif /* HAVE_SIGACTION && !HAVE_SIGSET */
1238 #elif defined(HAVE_SIGACTION)
1239 sigemptyset(&newmask
);
1240 sigaddset(&newmask
, SIGTERM
);
1241 sigaddset(&newmask
, SIGCHLD
);
1242 sigprocmask(SIG_BLOCK
, &newmask
, &holdmask
);
1243 #endif /* HAVE_SIGSET */
1248 * 'cupsdIgnoreChildSignals()' - Ignore SIGCHLD signals...
1250 * We don't really ignore them, we set the signal handler to SIG_DFL,
1251 * since some OS's rely on signals for the wait4() function to work.
1255 cupsdIgnoreChildSignals(void)
1257 #if defined(HAVE_SIGACTION) && !defined(HAVE_SIGSET)
1258 struct sigaction action
; /* Actions for POSIX signals */
1259 #endif /* HAVE_SIGACTION && !HAVE_SIGSET */
1262 #ifdef HAVE_SIGSET /* Use System V signals over POSIX to avoid bugs */
1263 sigset(SIGCHLD
, SIG_DFL
);
1264 #elif defined(HAVE_SIGACTION)
1265 memset(&action
, 0, sizeof(action
));
1267 sigemptyset(&action
.sa_mask
);
1268 sigaddset(&action
.sa_mask
, SIGCHLD
);
1269 action
.sa_handler
= SIG_DFL
;
1270 sigaction(SIGCHLD
, &action
, NULL
);
1272 signal(SIGCLD
, SIG_DFL
); /* No, SIGCLD isn't a typo... */
1273 #endif /* HAVE_SIGSET */
1278 * 'cupsdReleaseSignals()' - Release signals for delivery.
1282 cupsdReleaseSignals(void)
1291 #elif defined(HAVE_SIGACTION)
1292 sigprocmask(SIG_SETMASK
, &holdmask
, NULL
);
1293 #endif /* HAVE_SIGSET */
1298 * 'cupsdSetString()' - Set a string value.
1302 cupsdSetString(char **s
, /* O - New string */
1303 const char *v
) /* I - String value */
1319 * 'cupsdSetStringf()' - Set a formatted string value.
1323 cupsdSetStringf(char **s
, /* O - New string */
1324 const char *f
, /* I - Printf-style format string */
1325 ...) /* I - Additional args as needed */
1327 char v
[4096]; /* Formatting string value */
1328 va_list ap
; /* Argument pointer */
1329 char *olds
; /* Old string */
1340 vsnprintf(v
, sizeof(v
), f
, ap
);
1355 * 'launchd_checkin()' - Check-in with launchd and collect the listening fds.
1359 launchd_checkin(void)
1361 int i
, /* Looping var */
1362 portnum
; /* Port number */
1363 launch_data_t ld_msg
, /* Launch data message */
1364 ld_resp
, /* Launch data response */
1365 ld_array
, /* Launch data array */
1366 ld_sockets
, /* Launch data sockets dictionary */
1367 ld_runatload
, /* Run-at-load setting */
1368 tmp
; /* Launch data */
1369 cupsd_listener_t
*lis
; /* Listeners array */
1370 http_addr_t addr
; /* Address variable */
1371 socklen_t addrlen
; /* Length of address */
1372 bool runatload
; /* Run-at-load setting value */
1375 cupsdLogMessage(CUPSD_LOG_DEBUG
, "launchd_checkin: pid=%d", (int)getpid());
1378 * Check-in with launchd...
1381 ld_msg
= launch_data_new_string(LAUNCH_KEY_CHECKIN
);
1382 if ((ld_resp
= launch_msg(ld_msg
)) == NULL
)
1384 cupsdLogMessage(CUPSD_LOG_ERROR
,
1385 "launchd_checkin: launch_msg(\"" LAUNCH_KEY_CHECKIN
1390 if (launch_data_get_type(ld_resp
) == LAUNCH_DATA_ERRNO
)
1392 errno
= launch_data_get_errno(ld_resp
);
1393 cupsdLogMessage(CUPSD_LOG_ERROR
, "launchd_checkin: Check-in failed: %s",
1399 * Get the "run-at-load" setting...
1402 if ((ld_runatload
= launch_data_dict_lookup(ld_resp
,
1403 LAUNCH_JOBKEY_RUNATLOAD
)) != NULL
&&
1404 launch_data_get_type(ld_runatload
) == LAUNCH_DATA_BOOL
)
1405 runatload
= launch_data_get_bool(ld_runatload
);
1408 errno
= launch_data_get_errno(ld_resp
);
1409 cupsdLogMessage(CUPSD_LOG_ERROR
,
1410 "launchd_checkin: Unable to find Run-at-load setting: %s",
1415 cupsdLogMessage(CUPSD_LOG_DEBUG
, "launchd_checkin: Run-at-load=%s",
1416 runatload
? "true" : "false");
1419 * Get the sockets dictionary...
1422 if (!(ld_sockets
= launch_data_dict_lookup(ld_resp
, LAUNCH_JOBKEY_SOCKETS
)))
1424 cupsdLogMessage(CUPSD_LOG_ERROR
,
1425 "launchd_checkin: No sockets found to answer requests on!");
1430 * Get the array of listener sockets...
1433 if (!(ld_array
= launch_data_dict_lookup(ld_sockets
, "Listeners")))
1435 cupsdLogMessage(CUPSD_LOG_ERROR
,
1436 "launchd_checkin: No sockets found to answer requests on!");
1441 * Add listening fd(s) to the Listener array...
1444 if (launch_data_get_type(ld_array
) == LAUNCH_DATA_ARRAY
)
1447 * Free the listeners array built from cupsd.conf...
1450 if (NumListeners
> 0)
1453 NumListeners
= launch_data_array_get_count(ld_array
);
1454 Listeners
= calloc(NumListeners
, sizeof(cupsd_listener_t
));
1458 cupsdLogMessage(CUPSD_LOG_ERROR
,
1459 "launchd_checkin: Unable to allocate new Listeners - %s.",
1465 * Note: launchd wants us to access the array in ascending order,
1466 * thus "i" counts up and not down as we normally do elsewhere...
1469 for (i
= 0, lis
= Listeners
; i
< NumListeners
; i
++, lis
++)
1472 * Copy the current address and log it...
1475 tmp
= launch_data_array_get_index(ld_array
, i
);
1476 lis
->fd
= launch_data_get_fd(tmp
);
1477 addrlen
= sizeof(lis
->address
);
1479 if (getsockname(lis
->fd
, (struct sockaddr
*)&(lis
->address
), &addrlen
))
1481 cupsdLogMessage(CUPSD_LOG_ERROR
,
1482 "launchd_checkin: Unable to get local address - %s",
1490 if (addr
.addr
.sa_family
== AF_INET6
)
1491 portnum
= ntohs(addr
.ipv6
.sin6_port
);
1493 # endif /* AF_INET6 */
1494 if (addr
.addr
.sa_family
== AF_INET
)
1495 portnum
= ntohs(addr
.ipv4
.sin_port
);
1498 lis
->encryption
= HTTP_ENCRYPT_ALWAYS
;
1499 # endif /* HAVE_SSL */
1504 * Collect the browse socket (if there is one)...
1507 if ((ld_array
= launch_data_dict_lookup(ld_sockets
, "BrowseSockets")))
1509 if (launch_data_get_type(ld_array
) == LAUNCH_DATA_ARRAY
)
1511 tmp
= launch_data_array_get_index(ld_array
, 0);
1513 if (launch_data_get_type(tmp
) == LAUNCH_DATA_FD
)
1515 if (BrowseSocket
!= -1)
1516 close(BrowseSocket
);
1518 BrowseSocket
= launch_data_get_fd(tmp
);
1521 cupsdLogMessage(CUPSD_LOG_WARN
,
1522 "launchd_checkin: BrowseSocket not a fd!");
1525 cupsdLogMessage(CUPSD_LOG_WARN
,
1526 "launchd_checkin: BrowseSockets is not an array!");
1529 cupsdLogMessage(CUPSD_LOG_DEBUG
, "launchd_checkin: No BrowseSockets");
1531 launch_data_free(ld_msg
);
1532 launch_data_free(ld_resp
);
1537 * 'launchd_reload()' - Tell launchd to reload the configuration file to pick
1538 * up the new listening directives.
1542 launchd_reload(void)
1544 int child_status
; /* Exit status of child process */
1545 pid_t child_pid
, /* Child PID */
1546 waitpid_status
; /* Child process exit status */
1547 char *argv
[4]; /* Argument strings */
1551 * The current launchd doesn't support a reload option (rdar://3854821).
1552 * Until this is fixed we need to reload the config file by execing launchctl
1553 * twice (to unload then load). NOTE: This will cause us to exit on SIGTERM
1554 * which will cancel all client & job activity.
1556 * After this is fixed we'll be able to tell launchd to reload the file
1557 * and pick up the new listening descriptors without disrupting current
1562 * Unloading the current configuration will cause launchd to send us a SIGTERM;
1563 * block it for now so we can get our work done...
1569 * Set up the unload arguments to launchctl...
1572 argv
[0] = "/bin/launchctl";
1574 argv
[2] = LaunchdConf
;
1577 if (cupsdStartProcess(argv
[0], argv
, NULL
, -1, -1, -1, -1, 1, &child_pid
) < 0)
1578 cupsdLogMessage(CUPSD_LOG_ERROR
,
1579 "launchd_reload: Unable to execute %s - %s", argv
[0],
1585 waitpid_status
= waitpid(child_pid
, &child_status
, 0);
1587 while (waitpid_status
== (pid_t
)-1 && errno
== EINTR
);
1589 if (WIFSIGNALED(child_status
))
1590 cupsdLogMessage(CUPSD_LOG_DEBUG
,
1591 "launchd_reload: %s pid %d crashed on signal %d!",
1592 basename(argv
[0]), child_pid
, WTERMSIG(child_status
));
1594 cupsdLogMessage(CUPSD_LOG_DEBUG
,
1595 "launchd_reload: %s pid %d stopped with status %d!",
1596 basename(argv
[0]), child_pid
, WEXITSTATUS(child_status
));
1599 * Do it again with the load command...
1604 if (cupsdStartProcess(argv
[0], argv
, NULL
, -1, -1, -1, -1, 1,
1607 cupsdLogMessage(CUPSD_LOG_ERROR
,
1608 "launchd_reload: Unable to fork for %s - %s", argv
[0],
1615 waitpid_status
= waitpid(child_pid
, &child_status
, 0);
1616 } while (waitpid_status
== (pid_t
)-1 && errno
== EINTR
);
1618 if (WIFSIGNALED(child_status
))
1619 cupsdLogMessage(CUPSD_LOG_DEBUG
,
1620 "launchd_reload: %s pid %d crashed on signal %d!",
1621 basename(argv
[0]), child_pid
, WTERMSIG(child_status
));
1623 cupsdLogMessage(CUPSD_LOG_DEBUG
,
1624 "launchd_reload: %s pid %d stopped with status %d",
1625 basename(argv
[0]), child_pid
,
1626 WEXITSTATUS(child_status
));
1631 * Leave signals blocked since exit() will be called momentarily anyways...
1637 * 'launchd_sync_conf()' - Re-write the launchd(8) config file
1638 * org.cups.cupsd.plist based on cupsd.conf.
1641 static int /* O - 1 if the file was updated */
1642 launchd_sync_conf(void)
1644 int i
, /* Looping var */
1645 portnum
; /* Port number */
1646 CFMutableDictionaryRef cupsd_dict
, /* org.cups.cupsd.plist dictionary */
1647 sockets
, /* Sockets dictionary */
1648 listener
; /* Listener dictionary */
1649 CFDataRef resourceData
; /* XML representation of the property list */
1650 CFMutableArrayRef array
; /* Array */
1651 CFNumberRef socket_mode
; /* Domain socket mode bits */
1652 CFStringRef socket_path
; /* Domain socket path */
1653 CFTypeRef value
; /* CF value */
1654 CFURLRef fileURL
; /* File URL */
1655 SInt32 errorCode
; /* Error code */
1656 cupsd_listener_t
*lis
; /* Current listening socket */
1657 struct servent
*service
; /* Services data base entry */
1658 char temp
[1024]; /* Temporary buffer for value */
1659 struct stat cupsd_sb
, /* File info for cupsd.conf */
1660 launchd_sb
; /* File info for org.cups.cupsd.plist */
1664 * If the launchd conf file modification time is newer than the cupsd.conf
1665 * time then there's nothing to do...
1668 if (!stat(ConfigurationFile
, &cupsd_sb
) &&
1669 !stat(LaunchdConf
, &launchd_sb
) &&
1670 launchd_sb
.st_mtimespec
.tv_sec
>= cupsd_sb
.st_mtimespec
.tv_sec
)
1672 cupsdLogMessage(CUPSD_LOG_DEBUG
,
1673 "launchd_sync_conf: Nothing to do, pid=%d.",
1679 * Time to write a new 'org.cups.cupsd.plist' file.
1680 * Create the new dictionary and populate it with values...
1683 if ((cupsd_dict
= CFDictionaryCreateMutable(kCFAllocatorDefault
, 0,
1684 &kCFTypeDictionaryKeyCallBacks
,
1685 &kCFTypeDictionaryValueCallBacks
)) != NULL
)
1687 CFDictionaryAddValue(cupsd_dict
, CFSTR(LAUNCH_JOBKEY_LABEL
),
1688 CFSTR("org.cups.cupsd"));
1689 CFDictionaryAddValue(cupsd_dict
, CFSTR("Enabled"), kCFBooleanTrue
);
1690 CFDictionaryAddValue(cupsd_dict
, CFSTR(LAUNCH_JOBKEY_ONDEMAND
),
1693 if ((Browsing
&& BrowseLocalProtocols
&& cupsArrayCount(Printers
)) ||
1694 cupsArrayCount(ActiveJobs
))
1695 CFDictionaryAddValue(cupsd_dict
, CFSTR(LAUNCH_JOBKEY_RUNATLOAD
),
1698 CFDictionaryAddValue(cupsd_dict
, CFSTR(LAUNCH_JOBKEY_RUNATLOAD
),
1701 #ifdef LAUNCH_JOBKEY_SERVICEIPC
1702 CFDictionaryAddValue(cupsd_dict
, CFSTR(LAUNCH_JOBKEY_SERVICEIPC
),
1704 #endif /* LAUNCH_JOBKEY_SERVICEIPC */
1706 if ((array
= CFArrayCreateMutable(kCFAllocatorDefault
, 2,
1707 &kCFTypeArrayCallBacks
)) != NULL
)
1709 CFDictionaryAddValue(cupsd_dict
, CFSTR(LAUNCH_JOBKEY_PROGRAMARGUMENTS
),
1711 CFArrayAppendValue(array
, CFSTR("/usr/sbin/cupsd"));
1712 CFArrayAppendValue(array
, CFSTR("-l"));
1717 * Add a sockets dictionary...
1720 if ((sockets
= (CFMutableDictionaryRef
)CFDictionaryCreateMutable(
1721 kCFAllocatorDefault
, 0,
1722 &kCFTypeDictionaryKeyCallBacks
,
1723 &kCFTypeDictionaryValueCallBacks
)) != NULL
)
1725 CFDictionaryAddValue(cupsd_dict
, CFSTR(LAUNCH_JOBKEY_SOCKETS
), sockets
);
1728 * Add a Listeners array to the sockets dictionary...
1731 if ((array
= CFArrayCreateMutable(kCFAllocatorDefault
, 0,
1732 &kCFTypeArrayCallBacks
)) != NULL
)
1734 CFDictionaryAddValue(sockets
, CFSTR("Listeners"), array
);
1737 * For each listener add a dictionary to the listeners array...
1740 for (i
= NumListeners
, lis
= Listeners
; i
> 0; i
--, lis
++)
1742 if ((listener
= CFDictionaryCreateMutable(kCFAllocatorDefault
, 0,
1743 &kCFTypeDictionaryKeyCallBacks
,
1744 &kCFTypeDictionaryValueCallBacks
)) != NULL
)
1746 CFArrayAppendValue(array
, listener
);
1749 if (lis
->address
.addr
.sa_family
== AF_LOCAL
)
1751 if ((socket_path
= CFStringCreateWithCString(kCFAllocatorDefault
,
1752 lis
->address
.un
.sun_path
,
1753 kCFStringEncodingUTF8
)))
1755 CFDictionaryAddValue(listener
,
1756 CFSTR(LAUNCH_JOBSOCKETKEY_PATHNAME
),
1758 CFRelease(socket_path
);
1760 portnum
= 0140777; /* (S_IFSOCK|S_IRWXU|S_IRWXG|S_IRWXO) or *
1762 if ((socket_mode
= CFNumberCreate(kCFAllocatorDefault
,
1763 kCFNumberIntType
, &portnum
)))
1765 CFDictionaryAddValue(listener
, CFSTR("SockPathMode"),
1767 CFRelease(socket_mode
);
1771 # endif /* AF_LOCAL */
1774 if (lis
->address
.addr
.sa_family
== AF_INET6
)
1776 CFDictionaryAddValue(listener
,
1777 CFSTR(LAUNCH_JOBSOCKETKEY_FAMILY
),
1779 portnum
= lis
->address
.ipv6
.sin6_port
;
1782 # endif /* AF_INET6 */
1784 CFDictionaryAddValue(listener
,
1785 CFSTR(LAUNCH_JOBSOCKETKEY_FAMILY
),
1787 portnum
= lis
->address
.ipv4
.sin_port
;
1790 if ((service
= getservbyport(portnum
, NULL
)))
1791 value
= CFStringCreateWithCString(kCFAllocatorDefault
,
1793 kCFStringEncodingUTF8
);
1795 value
= CFNumberCreate(kCFAllocatorDefault
,
1796 kCFNumberIntType
, &portnum
);
1800 CFDictionaryAddValue(listener
,
1801 CFSTR(LAUNCH_JOBSOCKETKEY_SERVICENAME
),
1806 httpAddrString(&lis
->address
, temp
, sizeof(temp
));
1807 if ((value
= CFStringCreateWithCString(kCFAllocatorDefault
, temp
,
1808 kCFStringEncodingUTF8
)))
1810 CFDictionaryAddValue(listener
,
1811 CFSTR(LAUNCH_JOBSOCKETKEY_NODENAME
),
1817 CFRelease(listener
);
1825 * Add the BrowseSocket to the sockets dictionary...
1828 if (Browsing
&& (BrowseRemoteProtocols
& BROWSE_CUPS
))
1830 if ((array
= CFArrayCreateMutable(kCFAllocatorDefault
, 0,
1831 &kCFTypeArrayCallBacks
)) != NULL
)
1833 CFDictionaryAddValue(sockets
, CFSTR("BrowseSockets"), array
);
1835 if ((listener
= CFDictionaryCreateMutable(kCFAllocatorDefault
, 0,
1836 &kCFTypeDictionaryKeyCallBacks
,
1837 &kCFTypeDictionaryValueCallBacks
)) != NULL
)
1839 CFArrayAppendValue(array
, listener
);
1841 CFDictionaryAddValue(listener
, CFSTR(LAUNCH_JOBSOCKETKEY_FAMILY
),
1843 CFDictionaryAddValue(listener
, CFSTR(LAUNCH_JOBSOCKETKEY_TYPE
),
1846 if ((service
= getservbyport(BrowsePort
, NULL
)))
1847 value
= CFStringCreateWithCString(kCFAllocatorDefault
,
1849 kCFStringEncodingUTF8
);
1851 value
= CFNumberCreate(kCFAllocatorDefault
, kCFNumberIntType
,
1854 CFDictionaryAddValue(listener
,
1855 CFSTR(LAUNCH_JOBSOCKETKEY_SERVICENAME
), value
);
1858 CFRelease(listener
);
1868 cupsdLogMessage(CUPSD_LOG_DEBUG
,
1869 "launchd_sync_conf: Updating \"%s\", pid=%d\n",
1870 LaunchdConf
, (int)getpid());
1872 if ((fileURL
= CFURLCreateFromFileSystemRepresentation(kCFAllocatorDefault
,
1873 (const unsigned char *)LaunchdConf
,
1874 strlen(LaunchdConf
), false)))
1876 if ((resourceData
= CFPropertyListCreateXMLData(kCFAllocatorDefault
,
1879 if (!CFURLWriteDataAndPropertiesToResource(fileURL
, resourceData
,
1882 cupsdLogMessage(CUPSD_LOG_WARN
,
1883 "launchd_sync_conf: "
1884 "CFURLWriteDataAndPropertiesToResource(\"%s\") "
1886 LaunchdConf
, (int)errorCode
);
1889 CFRelease(resourceData
);
1895 CFRelease(cupsd_dict
);
1899 * Let the caller know we updated the file...
1904 #endif /* HAVE_LAUNCHD */
1908 * 'parent_handler()' - Catch USR1/CHLD signals...
1912 parent_handler(int sig
) /* I - Signal */
1915 * Store the signal we got from the OS and return...
1918 parent_signal
= sig
;
1923 * 'process_children()' - Process all dead children...
1927 process_children(void)
1929 int status
; /* Exit status of child */
1930 int pid
; /* Process ID of child */
1931 cupsd_job_t
*job
; /* Current job */
1932 int i
; /* Looping var */
1933 char name
[1024]; /* Process name */
1936 cupsdLogMessage(CUPSD_LOG_DEBUG2
, "process_children()");
1939 * Reset the dead_children flag...
1945 * Collect the exit status of some children...
1949 while ((pid
= waitpid(-1, &status
, WNOHANG
)) > 0)
1950 #elif defined(HAVE_WAIT3)
1951 while ((pid
= wait3(&status
, WNOHANG
, NULL
)) > 0)
1953 if ((pid
= wait(&status
)) > 0)
1954 #endif /* HAVE_WAITPID */
1957 * Ignore SIGTERM errors - that comes when a job is cancelled...
1960 cupsdFinishProcess(pid
, name
, sizeof(name
));
1962 if (status
== SIGTERM
)
1967 if (WIFEXITED(status
))
1968 cupsdLogMessage(CUPSD_LOG_ERROR
, "PID %d (%s) stopped with status %d!",
1969 pid
, name
, WEXITSTATUS(status
));
1971 cupsdLogMessage(CUPSD_LOG_ERROR
, "PID %d (%s) crashed on signal %d!",
1972 pid
, name
, WTERMSIG(status
));
1974 if (LogLevel
< CUPSD_LOG_DEBUG
)
1975 cupsdLogMessage(CUPSD_LOG_INFO
,
1976 "Hint: Try setting the LogLevel to \"debug\" to find out more.");
1979 cupsdLogMessage(CUPSD_LOG_DEBUG
, "PID %d (%s) exited with no errors.",
1983 * Delete certificates for CGI processes...
1987 cupsdDeleteCert(pid
);
1990 * Lookup the PID in the jobs list...
1993 for (job
= (cupsd_job_t
*)cupsArrayFirst(ActiveJobs
);
1995 job
= (cupsd_job_t
*)cupsArrayNext(ActiveJobs
))
1996 if (job
->state
!= NULL
&&
1997 job
->state
->values
[0].integer
== IPP_JOB_PROCESSING
)
1999 for (i
= 0; job
->filters
[i
]; i
++)
2000 if (job
->filters
[i
] == pid
)
2003 if (job
->filters
[i
] || job
->backend
== pid
)
2006 * OK, this process has gone away; what's left?
2009 if (job
->filters
[i
])
2010 job
->filters
[i
] = -pid
;
2012 job
->backend
= -pid
;
2014 if (status
&& job
->status
>= 0)
2017 * An error occurred; save the exit status so we know to stop
2018 * the printer or cancel the job when all of the filters finish...
2020 * A negative status indicates that the backend failed and the
2021 * printer needs to be stopped.
2024 if (job
->filters
[i
])
2025 job
->status
= status
; /* Filter failed */
2027 job
->status
= -status
; /* Backend failed */
2029 if (job
->printer
&& !(job
->printer
->type
& CUPS_PRINTER_FAX
))
2031 snprintf(job
->printer
->state_message
,
2032 sizeof(job
->printer
->state_message
), "%s failed", name
);
2033 cupsdAddPrinterHistory(job
->printer
);
2038 * If this is not the last file in a job, see if all of the
2039 * filters are done, and if so move to the next file.
2042 if (job
->current_file
< job
->num_files
)
2044 for (i
= 0; job
->filters
[i
] < 0; i
++);
2046 if (!job
->filters
[i
])
2049 * Process the next file...
2052 cupsdFinishJob(job
);
2063 * 'sigchld_handler()' - Handle 'child' signals from old processes.
2067 sigchld_handler(int sig
) /* I - Signal number */
2072 * Flag that we have dead children...
2078 * Reset the signal handler as needed...
2081 #if !defined(HAVE_SIGSET) && !defined(HAVE_SIGACTION)
2082 signal(SIGCLD
, sigchld_handler
);
2083 #endif /* !HAVE_SIGSET && !HAVE_SIGACTION */
2088 * 'sighup_handler()' - Handle 'hangup' signals to reconfigure the scheduler.
2092 sighup_handler(int sig
) /* I - Signal number */
2096 NeedReload
= RELOAD_ALL
;
2097 ReloadTime
= time(NULL
);
2099 #if !defined(HAVE_SIGSET) && !defined(HAVE_SIGACTION)
2100 signal(SIGHUP
, sighup_handler
);
2101 #endif /* !HAVE_SIGSET && !HAVE_SIGACTION */
2106 * 'sigterm_handler()' - Handle 'terminate' signals that stop the scheduler.
2110 sigterm_handler(int sig
) /* I - Signal */
2112 (void)sig
; /* remove compiler warnings... */
2115 * Flag that we should stop and return...
2123 * 'select_timeout()' - Calculate the select timeout value.
2127 static long /* O - Number of seconds */
2128 select_timeout(int fds
) /* I - Number of ready descriptors select returned */
2130 int i
; /* Looping var */
2131 long timeout
; /* Timeout for select */
2132 time_t now
; /* Current time */
2133 cupsd_client_t
*con
; /* Client information */
2134 cupsd_printer_t
*p
; /* Printer information */
2135 cupsd_job_t
*job
; /* Job information */
2136 cupsd_subscription_t
*sub
; /* Subscription information */
2137 const char *why
; /* Debugging aid */
2141 * Check to see if any of the clients have pending data to be
2142 * processed; if so, the timeout should be 0...
2145 for (i
= NumClients
, con
= Clients
; i
> 0; i
--, con
++)
2146 if (con
->http
.used
> 0)
2150 * If select has been active in the last second (fds != 0) or we have
2151 * many resources in use then don't bother trying to optimize the
2152 * timeout, just make it 1 second.
2155 if (fds
|| NumClients
> 50)
2159 * If we had a recent event notification, timeout in 1 second...
2166 * Otherwise, check all of the possible events that we need to wake for...
2170 timeout
= now
+ 86400; /* 86400 == 1 day */
2174 * Check the activity and close old clients...
2177 for (i
= NumClients
, con
= Clients
; i
> 0; i
--, con
++)
2178 if ((con
->http
.activity
+ Timeout
) < timeout
)
2180 timeout
= con
->http
.activity
+ Timeout
;
2181 why
= "timeout a client connection";
2185 * Update the browse list as needed...
2188 if (Browsing
&& BrowseLocalProtocols
)
2191 if ((BrowseLocalProtocols
& BROWSE_SLP
) && (BrowseSLPRefresh
< timeout
))
2193 timeout
= BrowseSLPRefresh
;
2194 why
= "update SLP browsing";
2196 #endif /* HAVE_LIBSLP */
2198 if (BrowseLocalProtocols
& BROWSE_CUPS
)
2200 for (p
= (cupsd_printer_t
*)cupsArrayFirst(Printers
);
2202 p
= (cupsd_printer_t
*)cupsArrayNext(Printers
))
2204 if (p
->type
& CUPS_PRINTER_REMOTE
)
2206 if ((p
->browse_time
+ BrowseTimeout
) < timeout
)
2208 timeout
= p
->browse_time
+ BrowseTimeout
;
2209 why
= "browse timeout a printer";
2212 else if (!(p
->type
& CUPS_PRINTER_IMPLICIT
))
2214 if (BrowseInterval
&& (p
->browse_time
+ BrowseInterval
) < timeout
)
2216 timeout
= p
->browse_time
+ BrowseInterval
;
2217 why
= "send browse update";
2225 * Check for any active jobs...
2228 if (timeout
> (now
+ 10) && ActiveJobs
)
2230 for (job
= (cupsd_job_t
*)cupsArrayFirst(ActiveJobs
);
2232 job
= (cupsd_job_t
*)cupsArrayNext(ActiveJobs
))
2233 if (job
->state
->values
[0].integer
<= IPP_JOB_PROCESSING
)
2236 why
= "process active jobs";
2241 #ifdef HAVE_MALLINFO
2243 * Log memory usage every minute...
2246 if (LogLevel
>= CUPSD_LOG_DEBUG
&& (mallinfo_time
+ 60) < timeout
)
2248 timeout
= mallinfo_time
+ 60;
2249 why
= "display memory usage";
2251 #endif /* HAVE_MALLINFO */
2254 * Expire subscriptions as needed...
2257 for (sub
= (cupsd_subscription_t
*)cupsArrayFirst(Subscriptions
);
2259 sub
= (cupsd_subscription_t
*)cupsArrayNext(Subscriptions
))
2260 if (!sub
->job
&& sub
->expire
< timeout
)
2262 timeout
= sub
->expire
;
2263 why
= "expire subscription";
2267 * Adjust from absolute to relative time. If p->browse_time above
2268 * was 0 then we can end up with a negative value here, so check.
2269 * We add 1 second to the timeout since events occur after the
2270 * timeout expires, and limit the timeout to 86400 seconds (1 day)
2271 * to avoid select() timeout limits present on some operating
2275 timeout
= timeout
- now
+ 1;
2279 else if (timeout
> 86400)
2283 * Log and return the timeout value...
2286 cupsdLogMessage(CUPSD_LOG_DEBUG2
, "select_timeout: %ld seconds to %s",
2294 * 'usage()' - Show scheduler usage.
2298 usage(int status
) /* O - Exit status */
2300 _cupsLangPuts(status
? stderr
: stdout
,
2301 _("Usage: cupsd [-c config-file] [-f] [-F] [-h] [-l]\n"
2303 "-c config-file Load alternate configuration file\n"
2304 "-f Run in the foreground\n"
2305 "-F Run in the foreground but detach\n"
2306 "-h Show this usage message\n"
2307 "-l Run cupsd from launchd(8)\n"));
2313 * End of "$Id: main.c 5056 2006-02-02 19:46:32Z mike $".