return small stats hash

diff --git a/persistant_worker.pl b/persistant_worker.pl
index c569380..a6c2053 100755 (executable)
--- a/persistant_worker.pl
+++ b/persistant_worker.pl
@@ -31,7 +31,7 @@ warn "variant: $variant max_processes: $max_processes\n";
 
 my $driver = Gearman::Driver->new(
        server   => 'localhost:4730',
-       interval => 60,
+       interval => 15,
        loglevel   => 'DEBUG',
        logfile    => "log/$variant.log",
 ) || die $!;
@@ -130,6 +130,7 @@ $driver->add_job({
        name            => "poll_$variant",
        methods    => [ {
                name            => "poll_$variant",
+               encode => 'e_json',
                body   => sub {
 
                my ( $self, $job, $workload ) = @_;
@@ -187,10 +188,12 @@ $driver->add_job({
                $taskset->wait;
 
                $redis->set( "$variant.poll.finish" => $self->datetime_now );
-               warn "# seen ", dump($seen);
 
                my $ips = scalar keys %$seen;
-               return "polled $ips IPs"; # body end
+               my $ports = 0;
+               $ports += scalar keys %{ $seen->{$_} } foreach keys %$seen;
+               warn "# finish $ips ips with $ports ports\n";
+               return { ips => $ips, ports => $ports }  ; # body end
                }
        } ],
 });