store ip for CPE.EasyGateway.queued

[APKPM.git] / persistant_worker.pl

diff --git a/persistant_worker.pl b/persistant_worker.pl
index a5e0b21..29a0ece 100755 (executable)
--- a/persistant_worker.pl
+++ b/persistant_worker.pl
@@ -197,6 +197,7 @@ $driver->add_job({
                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);
 
@@ -209,5 +210,9 @@ $driver->add_job({
        } ],
 });
 
+open(my $pid, '>', "/tmp/apkpm.$variant.pid");
+print $pid "$$\n";
+close $pid;
+
 $driver->run;