or die "Couldn't prepare qlock";
my $qunlock = $dbh->prepare("UPDATE switches SET locked='f', last_updated=now() WHERE switch=?")
or die "Couldn't prepare qunlock";
-my $qpoll = $dbh->prepare("INSERT INTO polls (time, switch, port, bytes_in, bytes_out) VALUES (timeofday()::timestamp,?,?,?,?)")
+my $qpoll = $dbh->prepare("INSERT INTO polls (time, switch, port, bytes_in, bytes_out, errors_in, errors_out) VALUES (timeofday()::timestamp,?,?,?,?,?,?)")
or die "Couldn't prepare qpoll";
my $qtemppoll = $dbh->prepare("INSERT INTO temppoll (time, switch, temp) VALUES (timeofday()::timestamp,?::text::int,?::text::float)")
or die "Couldn't prepare qtemppoll";
for my $port (@ports) {
my $in = fetch_data($session, $port, 0, $switch->{'wide_counters'});
my $out = fetch_data($session, $port, 1, $switch->{'wide_counters'});
+ my $ine = fetch_errors($session, $port, 0);
+ my $oute = fetch_errors($session, $port, 1);
- $qpoll->execute($switch->{'switch'}, $port, $in, $out);
+ $qpoll->execute($switch->{'switch'}, $port, $in, $out, $ine, $oute);
}
my $conn = switch_connect($ip);
if (!defined($conn)) {
return fetch_snmp($session, $oid);
}
+sub fetch_errors {
+ my ($session, $port, $out) = @_;
+
+ my $oid;
+ if ($out) {
+ $oid = BER::encode_oid(1, 3, 6, 1, 2, 1, 2, 2, 1, 20, $port); # interfaces.ifTable.ifEntry.ifOutErrors
+ } else {
+ $oid = BER::encode_oid(1, 3, 6, 1, 2, 1, 2, 2, 1, 14, $port); # interfaces.ifTable.ifEntry.ifInErrors
+ }
+
+ return fetch_snmp($session, $oid);
+}
sub fetch_snmp {
my ($session, $oid) = @_;