05-SlotManagerWork.t

package main;

use lib './t','./lib';
use Test::More tests=>12;
use Gear;
use AnyEvent;
use AnyEvent::Gearman;
use Gearman::SlotManager;
use Log::Log4perl qw(:easy);
Log::Log4perl->easy_init($ERROR);

use Scalar::Util qw(weaken);
my $port = '9955';
my @js = ("localhost:$port");

use_ok('Gearman::Server');
gstart($port);

my $cv = AE::cv;

my $sig = AE::signal 'INT'=> sub{ 
DEBUG "TERM!!";
$cv->send;
};

my $t = AE::timer 10,0,sub{ $cv->send('timeout')};
my $slotman = Gearman::SlotManager->new(
    config=>
    {
        global=>{
            job_servers=>\@js,
            libs=>['./t','./lib'],
            max=>3,
            },
        slots=>{
            'TestWorker'=>{
            min=>3, 
            max=>5,
            workleft=>10,
            }
        }
    },
    port=>55595,
);

$slotman->start();

my $c = gearman_client @js;
foreach (1 .. 10){
    my $n = $_;
    my $str = "HELLO$n";
    DEBUG 'cl';

    $c->add_task(
        'TestWorker::reverse'=>$str,
        on_complete=>sub{is $_[1], reverse($str),"check $n";},
    );
}
my $tt = AE::timer 5,0,sub{ 
    $cv->send;
};

my $res = $cv->recv;
isnt $res,'timeout','ends successfully';
undef($tt);
$slotman->stop;
undef($slotman);
gstop();

done_testing();