12 #require 'SNMP_Session.pm';
14 # Tweak timeouit og sjekk med :support||:net hva passord vil bli
15 my $password = 'removed';
17 my $location = 'skipet';
19 my $dbh = nms::db_connect();
20 $dbh->{AutoCommit} = 0;
22 my $qswitch = $dbh->prepare(<<"EOF")
27 NATURAL LEFT JOIN switchtypes
29 (locked='f' OR now() - last_updated > '15 minutes'::interval)
31 FOR UPDATE OF switches
33 or die "Couldn't prepare qswitch";
34 my $qlock = $dbh->prepare("UPDATE switches SET locked='t', last_updated=now() WHERE switch=?")
35 or die "Couldn't prepare qlock";
36 my $qunlock = $dbh->prepare("UPDATE switches SET locked='f', last_updated=now() WHERE switch=?")
37 or die "Couldn't prepare qunlock";
38 my $qpoll = $dbh->prepare("INSERT INTO temppoll (time, switch, temp) VALUES (timeofday()::timestamp,?::text::int,?::text::float)")
39 or die "Couldn't prepare qpoll";
42 # Find a switch to grab
44 or die "Couldn't get switch";
45 my $switch = $qswitch->fetchrow_hashref();
47 if (!defined($switch)) {
49 mylog("No available switches in pool, sleeping.");
54 $qlock->execute($switch->{'switch'})
55 or die "Couldn't lock switch";
58 if ($switch->{'locked'}) {
59 mylog("WARNING: Lock timed out on $switch->{'ip'}, breaking lock");
63 if (defined($switch->{'overdue'})) {
64 $msg = sprintf "Polling temp on %s (%s), %s overdue.",
65 $switch->{'ip'}, $switch->{'sysname'}, $switch->{'overdue'};
67 $msg = sprintf "Polling temp on %s (%s), never polled before.",
68 $switch->{'ip'}, $switch->{'sysname'};
72 my $ip = $switch->{'ip'};
73 my $start = [Time::HiRes::gettimeofday];
75 my $conn = switch_connect($ip);
76 if (!defined($conn)) {
77 print "Could not connect to switch ".$switch->{'switch'}."\n";
79 my @data = switch_exec('sys monitor status', $conn);
80 my @fields = split(/\s+/, $data[2]);
81 # The temp fields are 6, 7, 8
82 my $avgtemp = ($fields[6] + $fields[7] + $fields[8]) / 3;
83 print $avgtemp." avgtemp\n";
84 $qpoll->execute($switch->{'switch'},
85 $avgtemp) or die "Could not exec qpoll";
87 my $elapsed = Time::HiRes::tv_interval($start);
88 $msg = sprintf "Polled $switch->{'ip'} in %5.3f seconds.", $elapsed;
91 $qunlock->execute($switch->{'switch'})
92 or die "Couldn't unlock switch";
98 my ($cmd, $conn) = @_;
100 # Send the command and get data from switch
101 my @data = $conn->cmd($cmd);
103 foreach my $line (@data) {
104 # Remove escape-7 sequence
105 $line =~ s/\x1b\x37//g;
106 push (@lines, $line);
115 my $conn = new Net::Telnet( Timeout => $timeout,
116 Dump_Log => '/tmp/dumplog',
118 Prompt => '/(es3024|e\d+\-\dsw)>/i');
119 my $ret = $conn->open( Host => $ip);
120 if (!$ret || $ret != 1) {
123 # XXX: Just send the password as text, I did not figure out how to
124 # handle authentication with only password through $conn->login().
125 #$conn->login( Prompt => '/password[: ]*$/i',
127 # Password => $password);
128 my @data = $conn->cmd($password);
137 my $time = POSIX::ctime(time);
139 printf STDERR "[%s] %s\n", $time, $msg;