X-Git-Url: http://git.rot13.org/?a=blobdiff_plain;f=persistant_worker.pl;h=29a0ece2f23e3833ec3b59f8a81a57d57357c720;hb=4e897268ea351ae8a2e285ae62203a561b3f41ba;hp=91ec64f6812e18c310dd613abfff62e3c3ff24e1;hpb=24cf9daaeecf26c5989f9dfdad5fc82e41efa1dd;p=APKPM.git

diff --git a/persistant_worker.pl b/persistant_worker.pl
index 91ec64f..29a0ece 100755
--- a/persistant_worker.pl
+++ b/persistant_worker.pl
@@ -27,6 +27,7 @@ use Redis;
 use lib 'lib';
 use H1::ZTEDSLAM;
 use H1::ZTEMSAN;
+use APKPM::Model;
 
 my ($variant,$max_processes) = @ARGV;
 $variant ||= 'ZTEDSLAM';
@@ -193,14 +194,25 @@ $driver->add_job({
 
 		$redis->set( "$variant.poll.finish" => $self->datetime_now );
 
+		my $status = APKPM::Model->redis_status;
+		my $row = $status->{poll}->{$variant};
+		$row->{$_} = $status->{"$variant.poll.$_"} foreach ( 'start', 'finish' );
+		$row->{variant} = $variant;
+		$self->do_background_json('Store_insert', { _table => 'zte_poll', %$row });
+		warn "# zte_poll ",dump($row);
+
 		my $ips = scalar keys %$seen;
 		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
+		return { ips => $ips, ports => $ports, zte_poll => $row }  ; # body end
 		}
 	} ],
 });
 
+open(my $pid, '>', "/tmp/apkpm.$variant.pid");
+print $pid "$$\n";
+close $pid;
+
 $driver->run;