Something went wrong. Try again.
Perl game server for TLE Community
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198use 5.010;use strict;use lib '/home/lacuna/server/lib';use Lacuna::DB;use Lacuna;use Lacuna::Util qw(randint format_date);use Getopt::Long;use App::Daemon qw(daemonize );use Data::Dumper;use Try::Tiny;use Log::Log4perl qw(:levels);
# --------------------------------------------------------------------# command line arguments:#my $daemonize = 1; # run the script as a daemonmy $loop = 1; # loop continuously waiting for jobsmy $initialize = 1; # (re)initialize the queue from the databaseour $quiet = 1; # don't output any text
GetOptions( 'daemonize!' => \$daemonize, 'loop!' => \$loop, 'quiet!' => \$quiet, 'initialize!' => \$initialize,);
$App::Daemon::loglevel = $quiet ? $WARN : $DEBUG;$App::Daemon::logfile = '/home/lacuna/server/log/scheduler/schedule_building.log';
chdir '/home/lacuna/server/bin';
my $pid_file = '/home/lacuna/server/bin/schedule_building.pid';
my $start = time;
# kill any existing processes#if (-f $pid_file) { open(PIDFILE, $pid_file); my $PID = <PIDFILE>; chomp $PID; if (grep /$PID/, `ps -p $PID`) { close (PIDFILE); out("Killing previous job, PID=$PID"); kill 9, $PID; sleep 5; }}
if ($initialize) { # (re)initialize all the jobs on the queues, replacing any # existing jobs out('Reinitializing all jobs'); out('Deleting existing jobs'); # Only delete the Schedule rows this script owns and is about to # recreate below. A blanket ->search (no filter) here would also wipe # out entries owned by other scheduler processes (e.g. the 'arrive' # rows created by schedule_ship_arrival.pl for Travelling ships), # deleting their beanstalk jobs along with them with nothing left to # recreate those jobs, since this script never re-adds 'arrive' rows. my $schedule_rs = Lacuna->db->resultset('Schedule')->search({ -or => [ { parent_table => 'Building' }, { parent_table => 'Ships', task => 'finish_construction' }, ], }); while (my $schedule = $schedule_rs->next) { # note. deleting the DB entry also deletes the entry on beanstalk $schedule->delete; }
out('Adding building working end'); my $building_rs = Lacuna->db->resultset('Building')->search({ is_working => 1, }); while (my $building = $building_rs->next) { # add to queue my $schedule = Lacuna->db->resultset('Schedule')->create({ delivery => $building->work_ends, parent_table => 'Building', parent_id => $building->id, task => 'finish_work', queue => 'default', }); }
out('Adding building upgrades'); $building_rs = Lacuna->db->resultset('Building')->search({ is_upgrading => 1, }); while (my $building = $building_rs->next) { # add to queue my $schedule = Lacuna->db->resultset('Schedule')->create({ delivery => $building->upgrade_ends, parent_table => 'Building', parent_id => $building->id, task => 'finish_upgrade', queue => 'default', }); }
out('Adding ship builds'); my $ship_rs = Lacuna->db->resultset('Ships')->search({ task => 'Building', }); while (my $ship = $ship_rs->next) { # add to queue my $schedule = Lacuna->db->resultset('Schedule')->create({ delivery => $ship->date_available, parent_table => 'Ships', parent_id => $ship->id, task => 'finish_construction', queue => 'default', }); }}
# --------------------------------------------------------------------# Daemonize
if ($daemonize) { daemonize(); out('Running as a daemon');}else { out('Running in the foreground');}
my $config = Lacuna->config;
my $queue = Lacuna::Queue->new({ max_timeouts => $config->get('beanstalk/max_timeouts'), max_reserves => $config->get('beanstalk/max_reserves'), server => $config->get('beanstalk/server'), ttr => $config->get('beanstalk/ttr'), debug => $config->get('beanstalk/debug'),});
out("queue = $queue");
# --------------------------------------------------------------------# Main processing loop
out('Started');# Timeout after an houreval { LOOP: do { my $job = $queue->consume('default'); my $args = $job->args; $job->delete, next unless ref $args eq 'HASH'; my $task = $args->{task}; my $task_args = $args->{args}; out('job received ['.$job->id.']');
my $payload = $job->payload;
try { # process the job out("Process class=$payload task=$task"); $payload->$task($task_args); out("Processing done. Delete job ".$job->id); $job->delete; } catch { # bury the job, it failed out("Job ".$job->id." failed: $_"); $job->bury; }; } while ($loop);};if ($@) { die unless $@ eq "alarm\n"; # propagate unexpected errors # timed out}
my $finish = time;out('Finished');out(int(($finish - $start)/60)." minutes have elapsed");exit 0;
################# SUBROUTINES###############
sub out { my ($message) = @_; my $logger = Log::Log4perl->get_logger; # STDERR is what actually lands in the log: under compose bin/run_scheduler.sh # tees it to log/scheduler/, and App::Daemon captures it to $logfile when # daemonized. Log4perl is never ->init'd here, so $logger->info is a no-op. print STDERR $message."\n"; $logger->info($message);}