view release on metacpan or  search on metacpan

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

89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
   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

31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
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} });