view release on metacpan or  search on metacpan

t/02-supervisor.t  view on Meta::CPAN

use IO::Socket::INET;

my $class = 'MethodWorker';

my $spawner = Gearman::Spawner->new(
    servers => [Gearman::Spawner::Server->address],
    workers => { },
);

my $pid = $spawner->pid;
ok(kill(0, $pid), 'supervisor is alive');

my $timed_out = 0;
$SIG{ALRM} = sub { $timed_out++ };
alarm 1;
undef $spawner;
waitpid $pid, 0;
ok(!$timed_out, 'supervisor dies on object destruction');

t/03-workers.t  view on Meta::CPAN

my $spawner = Gearman::Spawner->new(
    servers => [$server],
    workers => {
        $class => { },
    },
);
sleep 1; # give workers a chance to register

my $pid = $spawner->pid;
ok(kill(0, $pid), 'spawner is alive');

sub check_workers {
    my $mgmt = IO::Socket::INET->new($server);
    ok($mgmt, 'can connect to server');

    ok($mgmt->print("workers\n"), "can send workers command to server");
    $mgmt->shutdown(1);
    my $buf = '';
    while (<$mgmt>) {
        last if /^\./;