FS/bin/freeside-queued

   1 #!/usr/bin/perl -w
   2
   3 use strict;
   4 use vars qw( $log_file $sigterm $sigint );
   5 use subs qw( _die _logmsg );
   6 use Fcntl qw(:flock);
   7 use POSIX qw(setsid);
   8 use Date::Format;
   9 use IO::File;
  10 use FS::UID qw(adminsuidsetup);
  11 use FS::Record qw(qsearchs);
  12 use FS::queue;
  13
  14 # no autoloading just yet
  15 use FS::cust_main;
  16 use FS::svc_acct;
  17 use Net::SSH;
  18
  19 my $pid_file = '/var/run/freeside-queued.pid';
  20
  21 $SIG{CHLD} = sub { wait }; #zombie prevention
  22
  23 my $user = shift or die &usage;
  24
  25 &daemonize;
  26
  27  $sigterm = 0;
  28  $sigint = 0;
  29 $SIG{INT} = sub { warn "SIGINT received; shutting down\n"; $sigint++; };
  30 $SIG{TERM} = sub { warn "SIGTERM received; shutting down\n"; $sigterm++; };
  31
  32 $> = $FS::UID::freeside_uid unless $>;
  33 $< = $>;
  34 $ENV{HOME} = (getpwuid($>))[7]; #for ssh
  35 adminsuidsetup $user;
  36
  37 $log_file = "/usr/local/etc/freeside/queuelog.". $FS::UID::datasrc;
  38
  39 $SIG{__DIE__} = \&_die;
  40 $SIG{__WARN__} = \&_logmsg;
  41
  42 warn "freesied-queued starting\n";
  43
  44 while (1) {
  45
  46   my $job = qsearchs(
  47     'queue',
  48     { 'status' => 'new' },
  49     '',
  50     'ORDER BY jobnum FOR UPDATE LIMIT 1'
  51   ) or do {
  52     sleep 5;
  53     next;
  54   };
  55
  56   my %hash = $job->hash;
  57   $hash{'status'} = 'locked';
  58   my $ljob = new FS::queue ( \%hash );
  59   my $error = $ljob->replace($job);
  60   die $error if $error;
  61
  62   my @args = $ljob->args;
  63
  64   #fork a child for each job (up to some maximum perhaps?)
  65   #single-threaded for now.
  66
  67   my $eval = "&". $ljob->job. '(@args);';
  68   warn "running $eval";
  69   eval $eval;
  70   if ( $@ ) {
  71     warn "job $eval failed";
  72     my %hash = $ljob->hash;
  73     $hash{'status'} = 'failed';
  74     my $fjob = new FS::queue( \%hash );
  75     my $error = $fjob->replace($ljob);
  76     die $error if $error;
  77   } else {
  78     $ljob->delete;
  79   }
  80
  81 } continue {
  82   if ( $sigterm ) {
  83     warn "received TERM signal; exiting\n";
  84     exit;
  85   }
  86   if ( $sigint ) {
  87     warn "received INT signal; exiting\n";
  88     exit;
  89   }
  90 }
  91
  92 sub usage {
  93   die "Usage:\n\n  freeside-queued user\n";
  94 }
  95
  96 sub _die {
  97   my $msg = shift;
  98   unlink $pid_file if -e $pid_file;
  99   _logmsg($msg);
 100 }
 101
 102 sub _logmsg {
 103   chomp( my $msg = shift );
 104   my $log = new IO::File ">>$log_file";
 105   flock($log, LOCK_EX);
 106   seek($log, 0, 2);
 107   print $log "[". time2str("%a %b %e %T %Y",time). "] [$$] $msg\n";
 108   flock($log, LOCK_UN);
 109   close $log;
 110 }
 111
 112 sub daemonize {
 113
 114   chdir "/" or die "Can't chdir to /: $!";
 115   open STDIN, '/dev/null'   or die "Can't read /dev/null: $!";
 116   defined(my $pid = fork) or die "Can't fork: $!";
 117   if ( $pid ) {
 118     print "freeside-queued started with pid $pid\n"; #logging to $log_file\n";
 119     exit unless $pid_file;
 120     my $pidfh = new IO::File ">$pid_file" or exit;
 121     print $pidfh "$pid\n";
 122     exit;
 123   }
 124   open STDOUT, '>/dev/null'
 125                             or die "Can't write to /dev/null: $!";
 126   setsid                  or die "Can't start a new session: $!";
 127   open STDERR, '>&STDOUT' or die "Can't dup stdout: $!";
 128
 129 }
 130
 131 =head1 NAME
 132
 133 freeside-queued - Job queue daemon
 134
 135 =head1 SYNOPSIS
 136
 137   freeside-queued user
 138
 139 =head1 DESCRIPTION
 140
 141 Job queue daemon.  Should be running at all times.
 142
 143 user: from the mapsecrets file - see config.html from the base documentation
 144
 145 =head1 VERSION
 146
 147 =head1 BUGS
 148
 149 =head1 SEE ALSO
 150
 151 =cut
 152