check_naf.py 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503
  1. #!/usr/bin/env python
  2. # -*- encoding: utf-8 -*-
  3. #####################################################################
  4. # (c) 2006-2010 by Sven Velt and team(ix) GmbH, Nuernberg, Germany #
  5. # sv@teamix.net #
  6. # #
  7. # This file is part of check_naf (FKA check_netappfiler) #
  8. # #
  9. # check_naf is free software: you can redistribute it and/or modify #
  10. # it under the terms of the GNU General Public License as published #
  11. # by the Free Software Foundation, either version 2 of the License, #
  12. # or (at your option) any later version. #
  13. # #
  14. # check_naf is distributed in the hope that it will be useful, but #
  15. # WITHOUT ANY WARRANTY; without even the implied warranty of #
  16. # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the #
  17. # GNU General Public License for more details. #
  18. # #
  19. # You should have received a copy of the GNU General Public License #
  20. # along with check_naf. If not, see <http://www.gnu.org/licenses/>. #
  21. #####################################################################
  22. from monitoringplugin import SNMPMonitoringPlugin
  23. class CheckNAF(SNMPMonitoringPlugin):
  24. OID = {
  25. 'Cluster_Settings': '.1.3.6.1.4.1.789.1.2.3.1.0',
  26. 'Cluster_State': '.1.3.6.1.4.1.789.1.2.3.2.0',
  27. 'Cluster_InterconnectStatus': '.1.3.6.1.4.1.789.1.2.3.8.0',
  28. 'Cluster_CannotTakeOverCause': '.1.3.6.1.4.1.789.1.2.3.3.0',
  29. 'CPU_Arch': '.1.3.6.1.4.1.789.1.1.11.0',
  30. 'CPU_Time_Busy': '.1.3.6.1.4.1.789.1.2.1.3.0',
  31. 'CPU_Time_Idle': '.1.3.6.1.4.1.789.1.2.1.5.0',
  32. 'CPU_Context_Switches': '.1.3.6.1.4.1.789.1.2.1.8.0',
  33. 'Disks_Total': '.1.3.6.1.4.1.789.1.6.4.1.0',
  34. 'Disks_Active': '.1.3.6.1.4.1.789.1.6.4.2.0',
  35. 'Disks_Reconstructing': '.1.3.6.1.4.1.789.1.6.4.3.0',
  36. 'Disks_ReconstParity': '.1.3.6.1.4.1.789.1.6.4.4.0',
  37. 'Disks_Scrubbing': '.1.3.6.1.4.1.789.1.6.4.6.0',
  38. 'Disks_Failed': '.1.3.6.1.4.1.789.1.6.4.7.0',
  39. 'Disks_Spare': '.1.3.6.1.4.1.789.1.6.4.8.0',
  40. 'Disks_ZeroDisks': '.1.3.6.1.4.1.789.1.6.4.9.0',
  41. 'Disks_Failed_Descr': '.1.3.6.1.4.1.789.1.6.4.10.0',
  42. 'ExtCache_Type': '.1.3.6.1.4.1.789.1.26.1.0',
  43. 'ExtCache_SubType': '.1.3.6.1.4.1.789.1.26.2.0',
  44. 'ExtCache_Size': '.1.3.6.1.4.1.789.1.26.4.0',
  45. 'ExtCache_Usedsize': '.1.3.6.1.4.1.789.1.26.5.0',
  46. 'ExtCache_Options': '.1.3.6.1.4.1.789.1.26.7.0',
  47. 'ExtCache_Hits': '.1.3.6.1.4.1.789.1.26.8.0',
  48. 'ExtCache_Misses': '.1.3.6.1.4.1.789.1.26.9.0',
  49. 'ExtCache_Inserts': '.1.3.6.1.4.1.789.1.26.10.0',
  50. 'ExtCache_Evicts': '.1.3.6.1.4.1.789.1.26.11.0',
  51. 'ExtCache_Invalidates': '.1.3.6.1.4.1.789.1.26.12.0',
  52. 'ExtCache_MetaData': '.1.3.6.1.4.1.789.1.26.15.0',
  53. 'Global_Status': '.1.3.6.1.4.1.789.1.2.2.4.0',
  54. 'Global_Status_Message': '.1.3.6.1.4.1.789.1.2.2.25.0',
  55. 'NVRAM_Status': '.1.3.6.1.4.1.789.1.2.5.1.0',
  56. 'OPs_NFS': ['.1.3.6.1.4.1.789.1.2.2.27.0', '.1.3.6.1.4.1.789.1.2.2.6.0', '.1.3.6.1.4.1.789.1.2.2.5.0',],
  57. 'OPs_CIFS': ['.1.3.6.1.4.1.789.1.2.2.28.0','.1.3.6.1.4.1.789.1.2.2.8.0', '.1.3.6.1.4.1.789.1.2.2.7.0',],
  58. 'OPs_HTTP': ['.1.3.6.1.4.1.789.1.2.2.29.0','.1.3.6.1.4.1.789.1.2.2.10.0', '.1.3.6.1.4.1.789.1.2.2.9.0',],
  59. 'Model': '.1.3.6.1.4.1.789.1.1.5.0',
  60. 'ONTAP_Version': '.1.3.6.1.4.1.789.1.1.2.0',
  61. 'df_FS_Index': '.1.3.6.1.4.1.789.1.5.4.1.1',
  62. 'df_FS_Name': '.1.3.6.1.4.1.789.1.5.4.1.2',
  63. 'df_FS_Mounted_On': '.1.3.6.1.4.1.789.1.5.4.1.10',
  64. 'df_FS_Status': '.1.3.6.1.4.1.789.1.5.4.1.20',
  65. 'df_FS_Type': '.1.3.6.1.4.1.789.1.5.4.1.23',
  66. 'df_FS_kBTotal': ['.1.3.6.1.4.1.789.1.5.4.1.29', '.1.3.6.1.4.1.789.1.5.4.1.15', '.1.3.6.1.4.1.789.1.5.4.1.14',],
  67. 'df_FS_kBUsed': ['.1.3.6.1.4.1.789.1.5.4.1.30', '.1.3.6.1.4.1.789.1.5.4.1.17', '.1.3.6.1.4.1.789.1.5.4.1.16',],
  68. 'df_FS_kBAvail': ['.1.3.6.1.4.1.789.1.5.4.1.31', '.1.3.6.1.4.1.789.1.5.4.1.19', '.1.3.6.1.4.1.789.1.5.4.1.18',],
  69. 'df_FS_INodeUsed': '.1.3.6.1.4.1.789.1.5.4.1.7',
  70. 'df_FS_INodeFree': '.1.3.6.1.4.1.789.1.5.4.1.8',
  71. 'df_FS_MaxFilesAvail': '.1.3.6.1.4.1.789.1.5.4.1.11',
  72. 'df_FS_MaxFilesUsed': '.1.3.6.1.4.1.789.1.5.4.1.12',
  73. 'df_FS_MaxFilesPossible': '.1.3.6.1.4.1.789.1.5.4.1.13',
  74. }
  75. OWC = {
  76. 'Cluster_InterconnectStatus': ( (4,), (3,), (1,2,), ),
  77. 'Cluster_Settings': ( (2,), (1,3,4,), (5,), ),
  78. 'Cluster_State': ( (2,4,), (), (1,3,), ),
  79. 'Global_Status': ( (3,), (4,), (5,6), ),
  80. 'NVRAM_Status': ( (1,9), (2,5,8), (3,4,6), ),
  81. }
  82. Status2String = {
  83. 'Cluster_CannotTakeOverCause': { '1' : 'ok', '2' : 'unknownReason', '3' : 'disabledByOperator', '4' : 'interconnectOffline', '5' : 'disabledByPartner', '6' : 'takeoverFailed', },
  84. 'Cluster_InterconnectStatus': { '1' : 'notPresent', '2' : 'down', '3' : 'partialFailure', '4' : 'up', },
  85. 'Cluster_Settings': { '1' : 'notConfigured', '2' : 'enabled', '3' : 'disabled', '4' : 'takeoverByPartnerDisabled', '5' : 'thisNodeDead', },
  86. 'Cluster_State': { '1' : 'dead', '2' : 'canTakeover', '3' : 'cannotTakeover', '4' : 'takeover', },
  87. 'CPU_Arch' : { '1' : 'x86', '2' : 'alpha', '3' : 'mips', '4' : 'sparc', '5' : 'amd64', },
  88. 'NVRAM_Status' : { '1' : 'ok', '2' : 'partiallyDischarged', '3' : 'fullyDischarged', '4' : 'notPresent', '5' : 'nearEndOfLife', '6' : 'atEndOfLife', '7' : 'unknown', '8' : 'overCharged', '9' : 'fullyCharged', },
  89. 'df_FS_Status' : { '1' : 'unmounted', '2' : 'mounted', '3' : 'frozen', '4' : 'destroying', '5' : 'creating', '6' : 'mounting', '7' : 'unmounting', '8' : 'nofsinfo', '9' : 'replaying', '10': 'replayed', },
  90. 'df_FS_Type' : { '1' : 'traditionalVolume', '2' : 'flexibleVolume', '3' : 'aggregate', },
  91. }
  92. def map_status_to_returncode(self, value, mapping):
  93. for returncode in xrange(0,3):
  94. if value in mapping[returncode]:
  95. return returncode
  96. return 3
  97. def check_cpu(self, warn='', crit=''):
  98. cpu_arch = self.SNMPGET(self.OID['CPU_Arch'])
  99. cpu_timebusy = int(self.SNMPGET(self.OID['CPU_Time_Busy']))
  100. # cputimeidle = int(self.SNMPGET(self.OID['CPU_Time_Idle']))
  101. cpu_cs = self.SNMPGET(self.OID['CPU_Context_Switches'])
  102. if '%' in warn:
  103. warn = warn[:-1]
  104. if '%' in crit:
  105. crit = crit[:-1]
  106. returncode = self.value_wc_to_returncode(cpu_timebusy, warn, crit)
  107. output = 'CPU ' + str(cpu_timebusy) + '% busy, CPU architecture: ' + self.Status2String['CPU_Arch'].get(cpu_arch)
  108. perfdata = []
  109. pd = {'label':'nacpu', 'value':cpu_timebusy, 'unit':'%', 'min':0, 'max':100}
  110. if warn:
  111. pd['warn'] = warn
  112. if crit:
  113. pd['crit'] = crit
  114. perfdata.append(pd)
  115. perfdata.append({'label':'nacs', 'value':cpu_cs, 'unit':'c'})
  116. return self.remember_check('cpu', returncode, output, perfdata=perfdata)
  117. def check_cluster(self):
  118. cl_settings = int(self.SNMPGET(self.OID['Cluster_Settings']))
  119. if cl_settings == 1: # notConfigured
  120. return self.remember_check('cluster', self.RETURNCODE['WARNING'], 'No cluster configured!')
  121. cl_state = int(self.SNMPGET(self.OID['Cluster_State']))
  122. cl_interconnectstatus = int(self.SNMPGET(self.OID['Cluster_InterconnectStatus']))
  123. returncode = []
  124. returncode.append(self.map_status_to_returncode(cl_settings, self.OWC['Cluster_Settings']))
  125. returncode.append(self.map_status_to_returncode(cl_state, self.OWC['Cluster_State']))
  126. returncode.append(self.map_status_to_returncode(cl_interconnectstatus, self.OWC['Cluster_InterconnectStatus']))
  127. returncode = max(returncode)
  128. output = 'Settings: ' + self.Status2String['Cluster_Settings'][str(cl_settings)] + ', '
  129. output += 'state: ' + self.Status2String['Cluster_State'][str(cl_state)] + ', '
  130. output += 'interconnect state: ' + self.Status2String['Cluster_InterconnectStatus'][str(cl_interconnectstatus)]
  131. if cl_state == 4: # cannotTakeover
  132. cl_cannottakeovercause = self.SNMPGET(self.OID['Cluster_CannotTakeOverCause'])
  133. output = 'Cannot takeover, reason: ' + self.Status2String['Cluster_CannotTakeOverCause'][cl_cannottakeovercause] + '! ' + output
  134. return self.remember_check('cluster', returncode, output)
  135. def check_disk(self, target='failed', warn='', crit=''):
  136. di_total = int(self.SNMPGET(self.OID['Disks_Total']))
  137. di_active = int(self.SNMPGET(self.OID['Disks_Active']))
  138. di_reconstructing = int(self.SNMPGET(self.OID['Disks_Reconstructing']))
  139. di_reconstparity = int(self.SNMPGET(self.OID['Disks_ReconstParity']))
  140. # di_scrubbing = int(self.SNMPGET(self.OID['Disks_Scrubbing']))
  141. di_failed = int(self.SNMPGET(self.OID['Disks_Failed']))
  142. di_spare = int(self.SNMPGET(self.OID['Disks_Spare']))
  143. # di_zerodisks = int(self.SNMPGET(self.OID['Disks_ZeroDisks']))
  144. di_reconstr = di_reconstructing + di_reconstparity
  145. if target == 'spare':
  146. returncode = self.value_wc_to_returncode(di_spare, warn, crit)
  147. output = str(di_spare) + ' spare disk'
  148. if di_spare > 1:
  149. output += 's'
  150. else:
  151. target = 'failed' # Set to defined value
  152. returncode = self.value_wc_to_returncode(di_failed, warn, crit)
  153. if returncode == 0:
  154. output = 'No failed disks'
  155. else:
  156. output = self.SNMPGET(self.OID['Disks_Failed_Descr'])
  157. perfdata = []
  158. perfdata.append({'label':'nadisk_total', 'value':di_total, 'unit':'', 'min':0})
  159. perfdata.append({'label':'nadisk_active', 'value':di_active, 'unit':'', 'min':0})
  160. pd = {'label':'nadisk_spare', 'value':di_spare, 'unit':'', 'min':0}
  161. if warn and target=='spare':
  162. pd['warn'] = warn
  163. if crit and target=='spare':
  164. pd['crit'] = crit
  165. perfdata.append(pd)
  166. pd = {'label':'nadisk_failed', 'value':di_failed, 'unit':'', 'min':0}
  167. if warn and target=='failed':
  168. pd['warn'] = warn
  169. if crit and target=='failed':
  170. pd['crit'] = crit
  171. perfdata.append(pd)
  172. return self.remember_check('disk', returncode, output, perfdata=perfdata, target=target)
  173. def check_extcache(self):
  174. if self.options.snmpversion in [1, '1']:
  175. return self.remember_check('extcache', self.RETURNCODE['UNKNOWN'], 'Need SNMP v2c/v3 for "extcache" check!',)
  176. ec_size = long(self.SNMPGET(self.OID['ExtCache_Size']))
  177. ec_usedsize = long(self.SNMPGET(self.OID['ExtCache_Usedsize']))
  178. ec_hits = long(self.SNMPGET(self.OID['ExtCache_Hits']))
  179. # ec_meta = long(self.SNMPGET(self.OID['ExtCache_MetaData']))
  180. ec_miss = long(self.SNMPGET(self.OID['ExtCache_Misses']))
  181. ec_evict = long(self.SNMPGET(self.OID['ExtCache_Evicts']))
  182. ec_inval = long(self.SNMPGET(self.OID['ExtCache_Invalidates']))
  183. ec_insert = long(self.SNMPGET(self.OID['ExtCache_Inserts']))
  184. ec_usage = float(ec_usedsize) / float(ec_size) * 100.0
  185. ec_hitpct = float(ec_hits) / float(ec_hits + ec_miss) * 100.0
  186. ec_size_human = self.value_to_human_binary(ec_size, unit='B')
  187. output = 'Cache size %s, cache usage %5.2f%%, total hits %5.2f%% ' % (ec_size_human, ec_usage, ec_hitpct)
  188. returncode = self.RETURNCODE['OK']
  189. perfdata = []
  190. perfdata.append({'label':'nacache_usage', 'value':float('%5.2f' % ec_usage), 'unit':'%'})
  191. perfdata.append({'label':'nacache_hits', 'value':ec_hits, 'unit':'c'})
  192. perfdata.append({'label':'nacache_miss', 'value':ec_miss, 'unit':'c'})
  193. perfdata.append({'label':'nacache_evict', 'value':ec_evict, 'unit':'c'})
  194. perfdata.append({'label':'nacache_inval', 'value':ec_inval, 'unit':'c'})
  195. perfdata.append({'label':'nacache_insert', 'value':ec_insert, 'unit':'c'})
  196. return self.remember_check('extcache', returncode, output, perfdata=perfdata)
  197. def check_extcache_info(self):
  198. ec_type = self.SNMPGET(self.OID['ExtCache_Type'])
  199. ec_subtype = self.SNMPGET(self.OID['ExtCache_SubType'])
  200. ec_size = long(self.SNMPGET(self.OID['ExtCache_Size']))
  201. ec_options = self.SNMPGET(self.OID['ExtCache_Options'])
  202. ec_size_human = self.value_to_human_binary(ec_size, unit='B')
  203. output = 'Cache type: "' + ec_type + '/' + ec_subtype + '", size: ' + ec_size_human + ', options: "' + ec_options + '"'
  204. returncode = 0
  205. return self.remember_check('extcache_info', returncode, output)
  206. def check_global(self):
  207. model = self.SNMPGET(self.OID['Model'])
  208. globalstatus = int(self.SNMPGET(self.OID['Global_Status']))
  209. globalstatusmsg = self.SNMPGET(self.OID['Global_Status_Message'])[:255]
  210. returncode = self.map_status_to_returncode(globalstatus, self.OWC['Global_Status'])
  211. output = model + ': ' + globalstatusmsg
  212. return self.remember_check('global', returncode, output)
  213. def check_nvram(self):
  214. nvramstatus = int(self.SNMPGET(self.OID['NVRAM_Status']))
  215. returncode = self.map_status_to_returncode(nvramstatus, self.OWC['NVRAM_Status'])
  216. output = 'NVRAM battery status is "' + self.Status2String['NVRAM_Status'].get(str(nvramstatus)) + '"'
  217. return self.remember_check('nvram', returncode, output)
  218. def check_ops(self):
  219. ops_nfs = self.SNMPGET(self.OID['OPs_NFS'])
  220. ops_cifs = self.SNMPGET(self.OID['OPs_CIFS'])
  221. ops_http = self.SNMPGET(self.OID['OPs_HTTP'])
  222. output = 'Total ops statistics'
  223. returncode = self.RETURNCODE['OK']
  224. perfdata = []
  225. perfdata.append({'label':'naops_nfs', 'value':ops_nfs, 'unit':'c'})
  226. perfdata.append({'label':'naops_cifs', 'value':ops_cifs, 'unit':'c'})
  227. perfdata.append({'label':'naops_http', 'value':ops_http, 'unit':'c'})
  228. return self.remember_check('ops', returncode, output, perfdata=perfdata)
  229. def check_version(self):
  230. model = self.SNMPGET(self.OID['Model'])
  231. ontapversion = self.SNMPGET(self.OID['ONTAP_Version'])
  232. return self.remember_check('version', 0, model + ': ' + ontapversion)
  233. def common_vol_idx(self, volume):
  234. if volume.endswith('.snapshot'):
  235. return None
  236. idx = str(self.find_in_table(self.OID['df_FS_Index'], self.OID['df_FS_Name'] , volume))
  237. sn_idx = int(idx) + 1
  238. return (idx, sn_idx)
  239. def check_vol_data(self, volume, warn, crit):
  240. (idx, sn_idx) = self.common_vol_idx(volume)
  241. fs_total = long(self.SNMPGET(self.OID['df_FS_kBTotal'], idx)) * 1024L
  242. fs_used = long(self.SNMPGET(self.OID['df_FS_kBUsed'], idx)) * 1024L
  243. # fs_avail = long(self.SNMPGET(self.OID['df_FS_kBAvail'], idx)) * 1024L
  244. sn_total = long(self.SNMPGET(self.OID['df_FS_kBTotal'], sn_idx)) * 1024L
  245. sn_used = long(self.SNMPGET(self.OID['df_FS_kBUsed'], sn_idx)) * 1024L
  246. # sn_avail = long(self.SNMPGET(self.OID['df_FS_kBAvail'], sn_idx)) * 1024L
  247. mountedon = self.SNMPGET(self.OID['df_FS_Mounted_On'] + "." + idx)
  248. status = self.Status2String['df_FS_Status'].get(self.SNMPGET(self.OID['df_FS_Status'] + "." + idx))
  249. fstype = self.Status2String['df_FS_Type'].get(self.SNMPGET(self.OID['df_FS_Type'] + "." + idx))
  250. fs_pctused = float(fs_used) / float(fs_total) * 100.0
  251. warn = self.range_dehumanize(warn, fs_total)
  252. crit = self.range_dehumanize(crit, fs_total)
  253. returncode = self.value_wc_to_returncode(fs_used, warn, crit)
  254. output = volume + ': Used ' + self.value_to_human_binary(fs_used, 'B')
  255. output += ' (' + '%3.1f' % fs_pctused + '%)'+ ' out of ' + self.value_to_human_binary(fs_total, 'B')
  256. target = volume.replace('/vol/', '')[:-1]
  257. perfdata = []
  258. perfdata.append({'label':'navdu_' + target, 'value':fs_used, 'unit':'B', 'warn':warn, 'crit':crit, 'min':0})
  259. perfdata.append({'label':'navdt_' + target, 'value':fs_total, 'unit':'B'})
  260. perfdata.append({'label':'navsu_' + target, 'value':sn_used, 'unit':'B', 'min':0})
  261. perfdata.append({'label':'navst_' + target, 'value':sn_total, 'unit':'B'})
  262. return self.remember_check('vol_data', returncode, output, perfdata=perfdata, target=target)
  263. def check_vol_snap(self, volume, warn, crit):
  264. (idx, sn_idx) = self.common_vol_idx(volume)
  265. # fs_total = long(self.SNMPGET(self.OID['df_FS_kBTotal'], idx)) * 1024L
  266. # fs_used = long(self.SNMPGET(self.OID['df_FS_kBUsed'], idx)) * 1024L
  267. # fs_avail = long(self.SNMPGET(self.OID['df_FS_kBAvail'], idx)) * 1024L
  268. sn_total = long(self.SNMPGET(self.OID['df_FS_kBTotal'], sn_idx)) * 1024L
  269. sn_used = long(self.SNMPGET(self.OID['df_FS_kBUsed'], sn_idx)) * 1024L
  270. # sn_avail = long(self.SNMPGET(self.OID['df_FS_kBAvail'], sn_idx)) * 1024L
  271. sn_pctused = float(sn_used) / float(sn_total) * 100.0
  272. warn = self.range_dehumanize(warn, sn_total)
  273. crit = self.range_dehumanize(crit, sn_total)
  274. returncode = self.value_wc_to_returncode(sn_used, warn, crit)
  275. output = volume + '.snapshot: Used ' + self.value_to_human_binary(sn_used, 'B')
  276. output += ' (' + '%3.1f' % sn_pctused + '%)'+ ' out of ' + self.value_to_human_binary(sn_total, 'B')
  277. target = volume.replace('/vol/', '')[:-1]
  278. perfdata = []
  279. perfdata.append({'label':'navsu_' + target, 'value':sn_used, 'unit':'B', 'warn':warn, 'crit':crit, 'min':0})
  280. perfdata.append({'label':'navst_' + target, 'value':sn_total, 'unit':'B'})
  281. return self.remember_check('vol_snap', returncode, output, perfdata=perfdata, target=target)
  282. def check_vol_inode(self, volume, warn, crit):
  283. (idx, sn_idx) = self.common_vol_idx(volume)
  284. in_used = long(self.SNMPGET(self.OID['df_FS_INodeUsed'] + '.' + idx))
  285. in_free = long(self.SNMPGET(self.OID['df_FS_INodeFree'] + '.' + idx))
  286. in_total = in_used + in_free
  287. in_pctused = float(in_used) / float(in_total) * 100.0
  288. warn = self.range_dehumanize(warn, in_total)
  289. crit = self.range_dehumanize(crit, in_total)
  290. returncode = self.value_wc_to_returncode(in_used, warn, crit)
  291. output = volume + ': Used inodes ' + self.value_to_human_si(in_used)
  292. output += ' (' + '%3.1f' % in_pctused + '%)'+ ' out of ' + self.value_to_human_si(in_total)
  293. target = volume.replace('/vol/', '')[:-1]
  294. perfdata = []
  295. perfdata.append({'label':'naviu_' + target, 'value':in_used, 'unit':None, 'warn':warn, 'crit':crit, 'min':0})
  296. perfdata.append({'label':'navit_' + target, 'value':in_total, 'unit':None})
  297. return self.remember_check('vol_inode', returncode, output, perfdata=perfdata, target=target)
  298. def check_vol_files(self, volume, warn, crit):
  299. (idx, sn_idx) = self.common_vol_idx(volume)
  300. fi_avail = long(self.SNMPGET(self.OID['df_FS_MaxFilesAvail'] + '.' + idx))
  301. fi_used = long(self.SNMPGET(self.OID['df_FS_MaxFilesUsed'] + '.' + idx))
  302. fi_possible = long(self.SNMPGET(self.OID['df_FS_MaxFilesPossible'] + '.' + idx))
  303. fi_total = fi_used + fi_avail
  304. fi_pctused = float(fi_used) / float(fi_total) * 100.0
  305. warn = self.range_dehumanize(warn, fi_total)
  306. crit = self.range_dehumanize(crit, fi_total)
  307. returncode = self.value_wc_to_returncode(fi_used, warn, crit)
  308. output = volume + ': Used files ' + self.value_to_human_si(fi_used)
  309. output += ' (' + '%3.1f' % fi_pctused + '%)'+ ' out of ' + self.value_to_human_si(fi_total)
  310. output += ', may raised to ' + self.value_to_human_si(fi_possible)
  311. target = volume.replace('/vol/', '')[:-1]
  312. perfdata = []
  313. perfdata.append({'label':'navfu_' + target, 'value':fi_used, 'unit':None, 'warn':warn, 'crit':crit, 'min':0})
  314. perfdata.append({'label':'navft_' + target, 'value':fi_total, 'unit':None})
  315. return self.remember_check('vol_files', returncode, output, perfdata=perfdata, target=target)
  316. def main():
  317. plugin = CheckNAF(pluginname='check_naf', tagforstatusline='NAF', description=u'Monitoring NetApp™ FAS systems', version='0.9')
  318. plugin.add_cmdlineoption('', '--check', 'check', 'OBSOLETE - use new syntax!', default='')
  319. plugin.add_cmdlineoption('', '--target', 'target', 'OBSOLETE - use new syntax!', default='')
  320. plugin.add_cmdlineoption('-w', '', 'warn', 'OBSOLETE - use new syntax!', default='')
  321. plugin.add_cmdlineoption('-c', '', 'crit', 'OBSOLETE - use new syntax!', default='')
  322. plugin.parse_cmdlineoptions()
  323. plugin.prepare_snmp()
  324. if plugin.options.check or plugin.options.target:
  325. import sys
  326. arguments = plugin.options.check
  327. for s in [plugin.options.target, plugin.options.warn, plugin.options.crit]:
  328. arguments += ':' + s
  329. plugin.back2nagios(3, 'Obsolete syntax - please use new syntax: "%s %s"' % (sys.argv[0], arguments))
  330. checks = []
  331. for quad in plugin.args:
  332. quad = quad.split(':')
  333. quad = (quad + ['', '', ''])[:4] # Fix length to 4, fill with ''
  334. # Convert list of checks to list
  335. if ',' in quad[0]:
  336. quad[0] = quad[0].split(',')
  337. else:
  338. quad[0] = [quad[0],]
  339. # Convert list of targets to list
  340. if ',' in quad[1]:
  341. quad[1] = quad[1].split(',')
  342. else:
  343. quad[1] = [quad[1],]
  344. for target in quad[1]:
  345. for check in quad[0]:
  346. checks.append(tuple([check, target, quad[2], quad[3]]))
  347. if len(checks) == 0:
  348. checks = [('global','','','')]
  349. for quad in checks:
  350. (check, target, warn, crit) = tuple(quad)
  351. if check == 'global' or check == 'environment':
  352. result = plugin.check_global()
  353. elif check == 'cluster':
  354. result = plugin.check_cluster()
  355. elif check == 'cpu':
  356. result = plugin.check_cpu(warn=warn, crit=crit)
  357. elif check == 'disk':
  358. result = plugin.check_disk(target=target, warn=warn, crit=crit)
  359. elif check == 'extcache':
  360. result = plugin.check_extcache()
  361. elif check == 'extcache_info':
  362. result = plugin.check_extcache_info()
  363. elif check == 'nvram':
  364. result = plugin.check_nvram()
  365. elif check == 'ops':
  366. result = plugin.check_ops()
  367. elif check == 'version':
  368. result = plugin.check_version()
  369. elif check == 'vol_data':
  370. result = plugin.check_vol_data(volume=target, warn=warn, crit=crit)
  371. elif check == 'vol_snap':
  372. result = plugin.check_vol_snap(volume=target, warn=warn, crit=crit)
  373. elif check =='vol_inode':
  374. result = plugin.check_vol_inode(volume=target, warn=warn, crit=crit)
  375. elif check =='vol_files':
  376. result = plugin.check_vol_files(volume=target, warn=warn, crit=crit)
  377. else:
  378. result = plugin.remember_check(check, plugin.RETURNCODE['UNKNOWN'], 'Unknown check "' + check + '"!')
  379. # from pprint import pprint
  380. # pprint(plugin.dump_brain())
  381. plugin.brain2output()
  382. plugin.exit()
  383. if __name__ == '__main__':
  384. main()
  385. #vim: ts=4 sw=4 foldmethod=indent