use lib 'lib';
use H1::ZTEDSLAM;
use H1::ZTEMSAN;
+use APKPM::Model;
my ($variant,$max_processes) = @ARGV;
$variant ||= 'ZTEDSLAM';
}
$self->do_background_json( 'Store_insert', {
- _table => 'dslam_h',
+ _table => 'dslam',
ip => $crm->{IP_MANAGEMENT}, # FIXME IP_UREDAJA ?
username => $username,
timestamp => $self->datetime_now,
- h => $self->to_hstore($hash),
+ variant => $variant,
+ h => $hash,
});
return "ok $username $ip $port"; # body end
max_processes => 1,
min_processes => 0,
worker => $worker,
- name => "poll_$variant",
+ name => $variant . '_poll',
methods => [ {
- name => "poll_$variant",
+ name => $variant . '_poll',
encode => 'e_json',
body => sub {
$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 => 'dslam_poll', %$row });
+ warn "# dslam_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, dslam_poll => $row } ; # body end
}
} ],
});
+open(my $pid, '>', "/tmp/apkpm.$variant.pid");
+print $pid "$$\n";
+close $pid;
+
$driver->run;