view release on metacpan or  search on metacpan

bin/rex-gearman-worker  view on Meta::CPAN

   say "{";
   say "   job_servers => [";
   say "                     '127.0.0.1:4730',";
   say "                     '192.168.7.2:4730',";
   say "                  ],";
   say "};";

   CORE::exit 1;
}

my $conf = eval eval { local(@ARGV, $/) = ("worker.conf"); <>; };

if($@) {
   say "Error parsing configuration file.";
   say $@;
   CORE::exit 1;
}

if(exists $opts{h}) {
   print "(R)?ex - (Remote)? Execution (Gearman Worker)\n";
   printf "  %-15s %s\n", "-Q", "Really quiet. Output nothing";

lib/Rex/TaskList/Gearman.pm  view on Meta::CPAN

sub run {
   my ($self, $task_name, %option) = @_;

   $option{params} ||= { Rex::Args->get };


   my $task = $self->get_task($task_name);
   my @all_server = @{ $task->server };

   my $client = Gearman::Client->new;
   my $conf = eval eval { local(@ARGV, $/) = ("client.conf"); <>; };

   if($@) {
      print "Error parsing configuration file.\n";
      print $@ . "\n";
      CORE::exit 1;
   }

   Rex::Logger::debug("Found worker servers: " . join(", ", @{ $conf->{job_servers} }));

   $client->job_servers(@{ $conf->{job_servers} });