4 use vars qw( $log_file $sigterm $sigint $kids $max_kids %kids );
5 use subs qw( _die _logmsg );
7 use POSIX qw(:sys_wait_h setsid);
10 use FS::UID qw(adminsuidsetup forksuidsetup driver_name dbh myconnect);
11 use FS::Record qw(qsearch qsearchs);
15 # no autoloading just yet
21 $max_kids = '10'; #guess it should be a config file...
24 my $user = shift or die &usage;
26 #my $pid_file = "/var/run/freeside-queued.$user.pid";
27 my $pid_file = "/var/run/freeside-queued.pid";
31 #sub REAPER { my $pid = wait; $SIG{CHLD} = \&REAPER; $kids--; }
32 #$SIG{CHLD} = \&REAPER;
36 $SIG{INT} = sub { warn "SIGINT received; shutting down\n"; $sigint++; };
37 $SIG{TERM} = sub { warn "SIGTERM received; shutting down\n"; $sigterm++; };
39 my $freeside_gid = scalar(getgrnam('freeside'))
40 or die "can't setgid to freeside group\n";
43 #if freebsd can't setuid(), presumably it can't setgid() either. grr fleabsd
47 $> = $FS::UID::freeside_uid;
48 $< = $FS::UID::freeside_uid;
49 #freebsd is sofa king broken, won't setuid()
51 $> = $FS::UID::freeside_uid;
53 $ENV{HOME} = (getpwuid($>))[7]; #for ssh
57 eval { adminsuidsetup $user; };
60 warn "sleeping for reconnect...\n";
65 $log_file = "/usr/local/etc/freeside/queuelog.". $FS::UID::datasrc;
69 $SIG{__DIE__} = \&_die;
70 $SIG{__WARN__} = \&_logmsg;
72 warn "freeside-queued starting\n";
78 #prevent runaway forking
79 if ( $kids >= $max_kids ) {
80 warn "WARNING: maximum $kids children reached\n" unless $warnkids++;
82 sleep 1; #waiting for signals is cheap
87 unless ( dbh && dbh->ping ) {
88 warn "WARNING: connection to database lost, reconnecting...\n";
90 eval { $FS::UID::dbh = myconnect; };
92 unless ( !$@ && dbh && dbh->ping ) {
93 warn "WARNING: still no connection to database, sleeping for retry...\n";
97 warn "WARNING: reconnected to database\n";
103 # my $oldAutoCommit = $FS::UID::AutoCommit;
104 # local $FS::UID::AutoCommit = 0;
105 $FS::UID::AutoCommit = 0;
107 #assuming mysql 4.1 w/subqueries now
108 #my $nodepend = driver_name eq 'mysql'
110 # : 'AND 0 = ( SELECT COUNT(*) FROM queue_depend'.
111 # ' WHERE queue_depend.jobnum = queue.jobnum ) ';
112 my $nodepend = 'AND 0 = ( SELECT COUNT(*) FROM queue_depend'.
113 ' WHERE queue_depend.jobnum = queue.jobnum ) ';
117 { 'status' => 'new' },
119 driver_name eq 'mysql'
120 ? "$nodepend ORDER BY jobnum LIMIT 1 FOR UPDATE"
121 : "$nodepend ORDER BY jobnum FOR UPDATE LIMIT 1"
123 # if $oldAutoCommit {
125 warn "WARNING: database error, closing connection: ". dbh->errstr;
130 sleep 5; #connecting to db is expensive
134 #assuming mysql 4.1 w/subqueries now
135 #if ( driver_name eq 'mysql'
136 # && qsearch('queue_depend', { 'jobnum' => $job->jobnum } ) ) {
137 # dbh->commit or die dbh->errstr; #if $oldAutoCommit;
138 # sleep 5; #would be better if mysql could do everything in query above
142 my %hash = $job->hash;
143 $hash{'status'} = 'locked';
144 my $ljob = new FS::queue ( \%hash );
145 my $error = $ljob->replace($job);
147 warn "WARNING: database error locking job, closing connection: ".
153 # if $oldAutoCommit {
155 warn "WARNING: database error, closing connection: ". dbh->errstr;
161 $FS::UID::AutoCommit = 1;
164 my @args = $ljob->args;
165 splice @args, 0, 1, $ljob if $args[0] eq '_JOB';
167 defined( my $pid = fork ) or do {
168 warn "WARNING: can't fork: $!\n";
169 my %hash = $job->hash;
170 $hash{'status'} = 'failed';
171 $hash{'statustext'} = "[freeside-queued] can't fork: $!";
172 my $ljob = new FS::queue ( \%hash );
173 my $error = $ljob->replace($job);
174 die $error if $error;
175 next; #don't increment the kid counter
184 $FS::UID::dbh->{InactiveDestroy} = 1;
186 forksuidsetup($user);
189 #if ( $ljob->job =~ /(FS::part_export::\w+)::/ ) {
190 if ( $ljob->job =~ /(FS::part_export::\w+)::/
191 || $ljob->job =~ /(FS::\w+)::/
197 warn "job use $class failed";
198 my %hash = $ljob->hash;
199 $hash{'status'} = 'failed';
200 $hash{'statustext'} = $@;
201 my $fjob = new FS::queue( \%hash );
202 my $error = $fjob->replace($ljob);
203 die $error if $error;
208 my $eval = "&". $ljob->job. '(@args);';
209 warn "running $eval";
210 eval $eval; #throw away return value? suppose so
212 warn "job $eval failed";
213 my %hash = $ljob->hash;
214 $hash{'status'} = 'failed';
215 $hash{'statustext'} = $@;
216 my $fjob = new FS::queue( \%hash );
217 my $error = $fjob->replace($ljob);
218 die $error if $error;
229 warn "received TERM signal; exiting\n";
233 warn "received INT signal; exiting\n";
239 die "Usage:\n\n freeside-queued user\n";
244 unlink $pid_file if -e $pid_file;
249 chomp( my $msg = shift );
250 my $log = new IO::File ">>$log_file";
251 flock($log, LOCK_EX);
253 print $log "[". time2str("%a %b %e %T %Y",time). "] [$$] $msg\n";
254 flock($log, LOCK_UN);
260 chdir "/" or die "Can't chdir to /: $!";
261 open STDIN, '/dev/null' or die "Can't read /dev/null: $!";
262 defined(my $pid = fork) or die "Can't fork: $!";
264 print "freeside-queued started with pid $pid\n"; #logging to $log_file\n";
265 exit unless $pid_file;
266 my $pidfh = new IO::File ">$pid_file" or exit;
267 print $pidfh "$pid\n";
270 #open STDOUT, '>/dev/null'
271 # or die "Can't write to /dev/null: $!";
272 #setsid or die "Can't start a new session: $!";
273 #open STDERR, '>&STDOUT' or die "Can't dup stdout: $!";
278 open STDOUT, '>/dev/null'
279 or die "Can't write to /dev/null: $!";
280 setsid or die "Can't start a new session: $!";
281 open STDERR, '>&STDOUT' or die "Can't dup stdout: $!";
285 foreach my $pid ( keys %kids ) {
286 my $kid = waitpid($pid, WNOHANG);
296 freeside-queued - Job queue daemon
304 Job queue daemon. Should be running at all times.
306 user: from the mapsecrets file - see config.html from the base documentation