Skip to content

Commit

Permalink
Add a sync checker reporting each sync resource last "bytes" and "speed"
Browse files Browse the repository at this point in the history
Example:

|- sync
|  |- sync#1.bytes                testmd  10292
|  |- sync#1.speed                testmd  211968.0
|  |- sync#2.bytes                testmd  0
|  |- sync#2.speed                testmd  0
|  |- sync#i0.bytes               testmd  605
|  |- sync#i0.speed               testmd  122.0
|  |- sync#i0.bytes               ha1     289
|  `- sync#i0.speed               ha1     57.0
  • Loading branch information
cvaroqui committed Jan 30, 2018
1 parent 4aaef7e commit 7ac7aff
Show file tree
Hide file tree
Showing 2 changed files with 25 additions and 22 deletions.
45 changes: 24 additions & 21 deletions lib/checks.py
@@ -1,5 +1,6 @@
from __future__ import print_function
from rcGlobalEnv import rcEnv
from rcUtilities import mimport
import os

class check(object):
Expand All @@ -24,24 +25,25 @@ class checks(check):

def __init__(self, svcs=[]):
self.svcs = svcs
self.register('checkFsUsage')
self.register('checkFsInode')
self.register('checkVgUsage')
self.register('checkEth')
self.register('checkLag')
self.register('checkMpath')
self.register('checkMpathPowerpath')
self.register('checkZfsUsage')
self.register('checkRaidSmartArray')
self.register('checkRaidMegaRaid')
self.register('checkRaidSas2')
self.register('checkFmFmadm')
self.register('checkFmOpenManage')
self.register('checkMce')
self.register('checkZpool')
self.register('checkBtrfsDevStats')
self.register('checkAdvfsUsage')
self.register('checkNuma')
self.register('Fs', 'Usage')
self.register('Fs', 'Inode')
self.register('Vg', 'Usage')
self.register('Eth')
self.register('Lag')
self.register('Mpath')
self.register('Mpath', 'Powerpath')
self.register('Zfs', 'Usage')
self.register('Raid', 'Smart', 'Array')
self.register('Raid', 'Mega', 'Raid')
self.register('Raid', 'Sas2')
self.register('Fm', 'Fmadm')
self.register('Fm', 'Open', 'Manage')
self.register('Mce')
self.register('Zpool')
self.register('Btrfs', 'Dev', 'Stats')
self.register('Advfs', 'Usage')
self.register('Numa')
self.register('Sync')
self.register_local_checkers()

def __iadd__(self, c):
Expand Down Expand Up @@ -70,10 +72,11 @@ def register_local_checkers(self):
print('Could not import check:', cname, file=sys.stderr)
print(e, file=sys.stderr)

def register(self, chk_name):
if not os.path.exists(os.path.join(rcEnv.paths.pathlib, chk_name+rcEnv.sysname+'.py')):
def register(self, *args):
try:
m = mimport("check", *args)
except ImportError:
return
m = __import__(chk_name+rcEnv.sysname)
self += m.check(svcs=self.svcs)

def do_checks(self):
Expand Down
2 changes: 1 addition & 1 deletion lib/rcUtilities.py
Expand Up @@ -234,7 +234,7 @@ def fmt(s):

mod = ""
for i, e in enumerate(args):
if e in ("res", "prov") and i == 0:
if e in ("res", "prov", "check") and i == 0:
mod += e
else:
mod += fmt(e)
Expand Down

0 comments on commit 7ac7aff

Please sign in to comment.