generate more stats in redis
authorDobrica Pavlinusic <dpavlin@rot13.org>
Wed, 25 May 2011 17:28:15 +0000 (19:28 +0200)
committerDobrica Pavlinusic <dpavlin@rot13.org>
Wed, 25 May 2011 17:28:15 +0000 (19:28 +0200)
persistant_worker.pl

index c67ef0c..ccddc86 100755 (executable)
@@ -137,15 +137,18 @@ $driver->add_job({
                        } 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";