} elsif ( $port !~ m{\d+(/\d+)+} ) {
$redis->sadd("ZTEDSLAM.invalid.PORT" => $port);
next;
+ } elsif ( $seen->{ $ip }->{ $port }++ ) {
+ $redis->sadd("ZTEDSLAM.invalid.duplicate" => "$ip $port");
+ next;
}
$redis->sadd("ZTEDSLAM.queued" => "$ip $port");
+ $redis->incr("ZTEDSLAM.ip.$ip");
my $name = 'ZTEDSLAM_' . $ip;
$taskset->add_task( $name, $self->e_json( $user ), {
on_complete => sub { $redis->sadd("ZTEDSLAM.complete", "$ip $port") },
on_fail => sub { $redis->sadd("ZTEDSLAM.fail", "$ip $port") },
} )
- if ! $seen->{ $ip }->{ $port }++;
}
warn "# queue logouts";