1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
#! /usr/bin/perl
use strict;
use warnings;
use BER;
use DBI;
use POSIX;
use Time::HiRes;
use Net::Ping;
use lib '../include';
use nms;
use threads;
poll_loop();
sub poll_loop {
my $dbh = nms::db_connect();
my $qcores = $dbh->prepare('SELECT DISTINCT coreswitches.sysname, coreswitches.switch, coreswitches.ip, coreswitches.community FROM uplinks JOIN switches AS coreswitches ON (uplinks.coreswitch = coreswitches.switch)');
my $qaps = $dbh->prepare("SELECT switches.sysname, switches.switch, uplinks.blade, uplinks.port FROM uplinks NATURAL JOIN switches WHERE uplinks.coreswitch = ?");
my $qpoll = $dbh->prepare("UPDATE ap_poll SET model=?, last_poll=now() WHERE switch = ?");
while (1) {
$qcores->execute();
my $cores = $qcores->fetchall_hashref("sysname");
foreach my $core (keys %$cores) {
my $ip = $cores->{$core}{'ip'};
my $community = $cores->{$core}{'community'};
printf "Polling %s (%s)\n", $core, $ip;
eval {
my $session = nms::snmp_open_session($ip, $community);
$qaps->execute($cores->{$core}{'switch'});
while (my $aps = $qaps->fetchrow_hashref()) {
my $sysname = $aps->{'sysname'};
my $blade = $aps->{'blade'};
my $port = $aps->{'port'};
my $oid = "1.3.6.1.2.1.105.1.1.1.9.$blade.$port"; # POWER-ETHERNET-MIB...pethPsePortType
my $mode = $session->get($oid);
$qpoll->execute($mode, $aps->{'switch'});
printf "%s (%s:%s/%s): %s\n", $sysname, $core, $blade, $port, $mode;
}
};
if ($@) {
mylog("ERROR: $@ (during poll of $ip)");
$dbh->rollback;
}
}
sleep 2;
}
}
sub mylog {
my $msg = shift;
my $time = POSIX::ctime(time);
$time =~ s/\n.*$//;
printf STDERR "[%s] %s\n", $time, $msg;
}
|
