#!/usr/bin/perl


require Net::SNMP;
#use Data::Dump "pp";
$| = 1;

$howmany = $ARGV[0] or die;

$ipCidrRouteProto = "1.3.6.1.2.1.4.24.4.1.7";
$ipCidrRouteIfIndex = "1.3.6.1.2.1.4.24.4.1.5";
$ipCidrRouteType = "1.3.6.1.2.1.4.24.4.1.6";
$ipRouteMask = "1.3.6.1.2.1.4.21.1.11";
$ipRouteIfIndex = "1.3.6.1.2.1.4.21.1.2";
$ipRouteType = "1.3.6.1.2.1.4.21.1.8";
$ipRouteNextHop = "1.3.6.1.2.1.4.21.1.7";
$ipRouteProto = "1.3.6.1.2.1.4.21.1.9";

open IPFILE, "<allips.txt" or die;

for $i (1 .. $howmany) {
    my ($host, $commstr) = split / /, <IPFILE>;
    chomp $commstr;
    print "$host, $commstr ";
    last unless $commstr;
    &poll($host, $commstr);
    if ($i % 5 == 0) {
        my $memusage = (`ps -p $$ -o vsz `)[1];
        chomp $memusage;
        print " __${memusage}__";
    }
    print "\n";
}
print "\n";




sub poll {
    my ($devarg, $commstr) = @_ or die;
    my ($sessionO, $error) = Net::SNMP->session(
        -hostname => $devarg, -community => $commstr, -port => 161, -t
+ranslate => 1, -version => SNMPv1, 
        -timeout => 30,    -retries => 2, -domain => "udp", -debug => 
+0x00 );
    if (!defined($sessionO)) {
        print STDERR "Error making object($devarg $commstr): ", $error
+, " \n";
        print "Error making object($devarg $commstr): ", $error, " \n"
+;
        die;
    }
    $sessionO->translate([-timeticks => 0]);
    my $session = \$sessionO;

    my $result6;
    $result6 = $$session->get_entries(-columns => [$ipCidrRouteIfIndex
+, $ipCidrRouteProto, $ipCidrRouteType ]);
    $result6 = $$session->get_entries(-columns => [$ipRouteNextHop, $i
+pRouteIfIndex, $ipRouteMask, $ipRouteProto, $ipRouteType]) unless %$r
+esult6;
    if (!defined($result6)) {
        printf(" %s", $$session->error);
    }

    print "'", scalar %$result6, "' ", length join( "", %$result6);
#    print "\npre\n", pp($session), "\n", pp($sessionO), "\n";
    $$session->close;
#    print "\npost\n", pp($session), "\n", pp($sessionO), "\n";
}
[download]

#!/usr/bin/perl

use threads ('stack_size' => 131072);
use threads::shared;
use Thread::Queue;
use Thread::Semaphore;
require Net::SNMP;
#use Data::Dump "pp";
$| = 1;

$howmany = $ARGV[0] or die;

$ipCidrRouteProto = "1.3.6.1.2.1.4.24.4.1.7";
$ipCidrRouteIfIndex = "1.3.6.1.2.1.4.24.4.1.5";
$ipCidrRouteType = "1.3.6.1.2.1.4.24.4.1.6";
$ipRouteMask = "1.3.6.1.2.1.4.21.1.11";
$ipRouteIfIndex = "1.3.6.1.2.1.4.21.1.2";
$ipRouteType = "1.3.6.1.2.1.4.21.1.8";
$ipRouteNextHop = "1.3.6.1.2.1.4.21.1.7";
$ipRouteProto = "1.3.6.1.2.1.4.21.1.9";

open IPFILE, "<allips.txt" or die;
@ips = <IPFILE>;
close IPFILE;
$howmany = $#ips if $howmany > $#ips;

$queue = new Thread::Queue;
$queue->enqueue(@ips[0 .. $howmany]);
undef @ips;

share($on);
share($count);
share($printlock);
$semaphore = new Thread::Semaphore(0);
$count = 0;

for $i (0 .. 99) {
    $threads[$i] = threads->create("entrypoint");
}
print "\n";
$semaphore->up(100);

while ($on) {
    if ($slept % 60 == 0) {
        my $memusage = (`ps -p $$ -o vsz `)[1];
        chomp $memusage;
        lock $count;
        lock $printlock;
        print "\ncount: $count, ${memusage} KB \n\n";
    }
    sleep 1;
    $slept++;
}
print "\n";

foreach $i (@threads) {
    $i->join;
}
print "done\n";

exit;

sub entrypoint {
    {lock $on; $on++;}
    { lock $printlock; print "+"; }
    local $mytid = threads->self->tid();
    $semaphore->down;
    my $string;
    while ($string = $queue->dequeue_nb) {
        my ($host, $commstr) = split / /, $string;
        chomp $commstr;
        last unless $commstr;
        &poll($host, $commstr);
        { lock $count; $count++; }
    }
    {lock $on; $on--;}
}




sub poll {
    my ($devarg, $commstr) = @_ or die;
    my ($sessionO, $error) = Net::SNMP->session(
        -hostname => $devarg, -community => $commstr, -port => 161, -t
+ranslate => 1, -version => SNMPv1, 
        -timeout => 30,    -retries => 2, -domain => "udp", -debug => 
+0x00 );
    if (!defined($sessionO)) {
        print "Error making object($devarg $commstr): ", $error, " \n"
+;
        die;
    }
    $sessionO->translate([-timeticks => 0]);
    my $session = \$sessionO;

    my $result6;
    $result6 = $$session->get_entries(-columns => [$ipCidrRouteIfIndex
+, $ipCidrRouteProto, $ipCidrRouteType ]);
    $result6 = $$session->get_entries(-columns => [$ipRouteNextHop, $i
+pRouteIfIndex, $ipRouteMask, $ipRouteProto, $ipRouteType]) unless %$r
+esult6;
    if (!defined($result6)) {
        lock $printlock;
        print "t$mytid $devarg 'no routing table' ", "\n";
        $$session->close;
        return;
    }
    { lock $printlock;
    print "t$mytid $devarg '", scalar %$result6, "' ", length join( ""
+, %$result6), "\n";
    }
#    print "\npre\n", pp($session), "\n", pp($sessionO), "\n";
    $$session->close;
#    print "\npost\n", pp($session), "\n", pp($sessionO), "\n";
}
[download]