my $driver = Gearman::Driver->new(
server => 'localhost:4730',
- interval => 15,
+ interval => 3,
loglevel => 'DEBUG',
logfile => "log/$variant.log",
) || die $!;
$driver->add_job({
max_processes => $max_procs,
- min_processes => 0,
+ min_processes => 1,
name => $method,
worker => $worker,
methods => [
{
decode => 'd_json',
-# encode => 'e_json',
+ encode => 'e_json',
name => $method,
body => sub {
if ( $@ ) {
$redis->sadd("$variant.$ip.error" => $@);
- return "error: $@";
+ return { error => $@ };
} elsif ( ! $hash ) {
$redis->sadd("$variant.$ip.empty" => $port);
- return "empty";
+ return { error => 'empty' };
} else {
$redis->sadd("$variant.$ip.ok" => $port);
}
h => $hash,
});
- return "ok $username $ip $port"; # body end
+ return $hash; # body end
# XXX -- worker body
},