From 5be69abaf3b2d626602845486970bb87f542b348 Mon Sep 17 00:00:00 2001 From: Sven Velt Date: Tue, 25 Jan 2011 12:44:23 +0100 Subject: [PATCH] Add "snapmirror" and "snapvault" checks Signed-off-by: Sven Velt --- check_naf.py | 111 +++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 111 insertions(+) diff --git a/check_naf.py b/check_naf.py index 622b409..596ee14 100755 --- a/check_naf.py +++ b/check_naf.py @@ -88,6 +88,25 @@ class CheckNAF(SNMPMonitoringPlugin): 'OPs_FCP': ['.1.3.6.1.4.1.789.1.17.25.0', '.1.3.6.1.4.1.789.1.17.14.0', '.1.3.6.1.4.1.789.1.17.13.0',], 'OPs_iSCSI': ['.1.3.6.1.4.1.789.1.17.24.0', '.1.3.6.1.4.1.789.1.17.12.0', '.1.3.6.1.4.1.789.1.17.11.0',], + 'Snapmirror_On': '.1.3.6.1.4.1.789.1.9.1.0', + 'Snapmirror_License': '.1.3.6.1.4.1.789.1.9.19.0', + 'Snapmirror_Index': '.1.3.6.1.4.1.789.1.9.20.1.1', + 'Snapmirror_Src': '.1.3.6.1.4.1.789.1.9.20.1.2', + 'Snapmirror_Dst': '.1.3.6.1.4.1.789.1.9.20.1.3', + 'Snapmirror_Status': '.1.3.6.1.4.1.789.1.9.20.1.4', + 'Snapmirror_State': '.1.3.6.1.4.1.789.1.9.20.1.5', + 'Snapmirror_Lag': '.1.3.6.1.4.1.789.1.9.20.1.6', + + 'Snapvault_On': '.1.3.6.1.4.1.789.1.19.1.0', + 'Snapvault_LicensePrimary': '.1.3.6.1.4.1.789.1.19.9.0', + 'Snapvault_LicenseSecondary': '.1.3.6.1.4.1.789.1.19.10.0', + 'Snapvault_Index': '.1.3.6.1.4.1.789.1.19.11.1.1', + 'Snapvault_Src': '.1.3.6.1.4.1.789.1.19.11.1.2', + 'Snapvault_Dst': '.1.3.6.1.4.1.789.1.19.11.1.3', + 'Snapvault_Status': '.1.3.6.1.4.1.789.1.19.11.1.4', + 'Snapvault_State': '.1.3.6.1.4.1.789.1.19.11.1.5', + 'Snapvault_Lag': '.1.3.6.1.4.1.789.1.19.11.1.6', + 'Model': '.1.3.6.1.4.1.789.1.1.5.0', 'ONTAP_Version': '.1.3.6.1.4.1.789.1.1.2.0', @@ -115,6 +134,8 @@ class CheckNAF(SNMPMonitoringPlugin): 'Cluster_State': ( (2,4,), (), (1,3,), ), 'Global_Status': ( (3,), (4,), (5,6), ), 'NVRAM_Status': ( (1,9), (2,5,8), (3,4,6), ), + 'Snapmirror_State': ( (2,5,), (1,4,6,), (3,), ), + 'Snapvault_State': ( (2,5,7,), (1,3,4,6,), (None,), ), } Status2String = { @@ -126,6 +147,10 @@ class CheckNAF(SNMPMonitoringPlugin): 'NVRAM_Status' : { '1' : 'ok', '2' : 'partiallyDischarged', '3' : 'fullyDischarged', '4' : 'notPresent', '5' : 'nearEndOfLife', '6' : 'atEndOfLife', '7' : 'unknown', '8' : 'overCharged', '9' : 'fullyCharged', }, 'df_FS_Status' : { '1' : 'unmounted', '2' : 'mounted', '3' : 'frozen', '4' : 'destroying', '5' : 'creating', '6' : 'mounting', '7' : 'unmounting', '8' : 'nofsinfo', '9' : 'replaying', '10': 'replayed', }, 'df_FS_Type' : { '1' : 'traditionalVolume', '2' : 'flexibleVolume', '3' : 'aggregate', }, + 'Snapmirror_Status': { '1' : 'idle', '2' : 'transferring', '3' : 'pending', '4' : 'aborting', '5' : 'migrating', '6' : 'quiescing', '7' : 'resyncing', '8' : 'waiting', '9' : 'syncing', '10': 'in-sync', }, + 'Snapmirror_State': { '1' : 'uninitialized', '2' : 'snapmirrored', '3' : 'broken-off', '4' : 'quiesced', '5' : 'source', '6' : 'unknown', }, + 'Snapvault_Status': { '1' : 'idle', '2' : 'transferring', '3' : 'pending', '4' : 'aborting', '5' : 'unknown_5', '6' : 'quiescing', '7' : 'resyncing', '8' : 'unknown_8', '9' : 'unknown_9', '10': 'unknown_10', '11': 'unknown_11', '12': 'paused', }, + 'Snapvault_State': { '1' : 'uninitialized', '2' : 'snapvaulted', '3' : 'brokenOff', '4' : 'quiesced', '5' : 'source', '6' : 'unknown', '7' : 'restoring', }, } @@ -368,6 +393,88 @@ class CheckNAF(SNMPMonitoringPlugin): return self.remember_check('ops', returncode, output, perfdata=perfdata) + def check_snapmirror(self, target, warn, crit): + if self.SNMPGET(self.OID['Snapmirror_License']) != '2': + return self.remember_check('snapmirror', self.RETURNCODE['CRITICAL'], 'No license for SnapMirror') + + if self.SNMPGET(self.OID['Snapmirror_On']) != '2': + return self.remember_check('snapmirror', self.RETURNCODE['CRITICAL'], 'SnapMirror is turned off!') + + if not target: + return self.remember_check('snapmirror', self.RETURNCODE['OK'], 'SnapMirror is turned on!') + + idx = self.find_in_table(self.OID['Snapmirror_Index'], self.OID['Snapmirror_Src'], target) + if idx == None: + idx = self.find_in_table(self.OID['Snapmirror_Index'], self.OID['Snapmirror_Dst'], target) + + if idx == None: + return self.remember_check('snapmirror', self.RETURNCODE['UNKNOWN'], 'No snapmirror with source or destination "' + target + '" found!') + + sm_src = self.SNMPGET(self.OID['Snapmirror_Src'], idx) + sm_dst = self.SNMPGET(self.OID['Snapmirror_Dst'], idx) + sm_status = int(self.SNMPGET(self.OID['Snapmirror_Status'], idx)) + sm_state = int(self.SNMPGET(self.OID['Snapmirror_State'], idx)) + sm_lag = long(self.SNMPGET(self.OID['Snapmirror_Lag'], idx)) / 100 + + rc_state = self.map_status_to_returncode(sm_state, self.OWC['Snapmirror_State']) + rc_lag = self.value_wc_to_returncode(sm_lag, warn, crit) + + returncode = self.max_returncode([rc_state, rc_lag]) + + if rc_lag in [1,2]: + max_lag = [None, warn, crit][rc_lag] + output = 'Lag too high (%s > %s)! ' % (sm_lag, max_lag) + else: + output = '' + + output += 'Source: "' + sm_src + '", Destination: "' + sm_dst + '", ' + output += 'State: ' + self.Status2String['Snapmirror_State'].get(str(sm_state)) + ', ' + output += 'Status: ' + self.Status2String['Snapmirror_Status'].get(str(sm_status)) + + return self.remember_check('snapmirror:' + target, returncode, output) + + + def check_snapvault(self, target, warn, crit): + if self.SNMPGET(self.OID['Snapvault_LicensePrimary']) != '2' and self.SNMPGET(self.OID['Snapvault_LicenseSecondary']) != '2': + return self.remember_check('snapvault', self.RETURNCODE['CRITICAL'], 'No license for SnapVault') + + if self.SNMPGET(self.OID['Snapvault_On']) != '2': + return self.remember_check('snapvault', self.RETURNCODE['CRITICAL'], 'SnapVault is turned off!') + + if not target: + return self.remember_check('snapvault', self.RETURNCODE['OK'], 'SnapVault is turned on!') + + idx = self.find_in_table(self.OID['Snapvault_Index'], self.OID['Snapvault_Src'], target) + if idx == None: + idx = self.find_in_table(self.OID['Snapvault_Index'], self.OID['Snapvault_Dst'], target) + + if idx == None: + return self.remember_check('snapvault', self.RETURNCODE['UNKNOWN'], 'No snapvault with source or destination "' + target + '" found!') + + sv_src = self.SNMPGET(self.OID['Snapvault_Src'], idx) + sv_dst = self.SNMPGET(self.OID['Snapvault_Dst'], idx) + sv_status = int(self.SNMPGET(self.OID['Snapvault_Status'], idx)) + sv_state = int(self.SNMPGET(self.OID['Snapvault_State'], idx)) + sv_lag = long(self.SNMPGET(self.OID['Snapvault_Lag'], idx)) / 100 + + rc_state = self.map_status_to_returncode(sv_state, self.OWC['Snapvault_State']) + rc_lag = self.value_wc_to_returncode(sv_lag, warn, crit) + + returncode = self.max_returncode([rc_state, rc_lag]) + + if rc_lag in [1,2]: + max_lag = [None, warn, crit][rc_lag] + output = 'Lag too high (%s > %s)! ' % (sv_lag, max_lag) + else: + output = '' + + output += 'Source: "' + sv_src + '", Destination: "' + sv_dst + '", ' + output += 'State: ' + self.Status2String['Snapvault_State'].get(str(sv_state)) + ', ' + output += 'Status: ' + self.Status2String['Snapvault_Status'].get(str(sv_status)) + + return self.remember_check('snapvault:' + target, returncode, output) + + def check_version(self): model = self.SNMPGET(self.OID['Model']) ontapversion = self.SNMPGET(self.OID['ONTAP_Version']) @@ -580,6 +687,10 @@ def main(): result = plugin.check_nvram() elif check == 'ops': result = plugin.check_ops() + elif check == 'snapmirror': + result = plugin.check_snapmirror(target, warn=warn, crit=crit) + elif check == 'snapvault': + result = plugin.check_snapvault(target, warn=warn, crit=crit) elif check == 'version': result = plugin.check_version() elif check == 'vol_data':