x
/
monitoring-for-openstack
Code Issues Proposed changes

Merge pull request #53 from enovance/fix-amqp-checks 

oschecks/utils.py: fix amqp check
This commit is contained in:
Emilien Macchi 2014-09-19 20:00:54 -04:00
parent 7469c996ab 7667272059
commit 86a68575cf
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
scripts/oschecks/utils.py Normal file → Executable file
View File

@ -50,8 +50,16 @@ def ok(msg):
sys.exit(0)
def check_process_name(name, p):
# name can be truncated and a script so check also if it can be an
# argument to an interpreter
return p.name == name or \
len(p.cmdline) > 1 and p.cmdline[1].find(name) != -1
def check_process_exists_and_amqp_connected(name):
processes = filter(lambda p: p.name == name, psutil.process_iter())
processes = filter(lambda p: check_process_name(name, p),
psutil.process_iter())
if not processes:
critical("%s is not running" % name)
for p in processes:
@ -60,8 +68,9 @@ def check_process_exists_and_amqp_connected(name):
except psutil.NoSuchProcess:
continue
found_amqp = (
len(itertools.takewhile(lambda c: c.remote_address[1]
!= AMQP_PORT, connections))
len(list(itertools.takewhile(lambda c: len(c.remote_address) <= 1
or c.remote_address[1]
!= AMQP_PORT, connections)))
!= len(connections))
if found_amqp:
ok("%s is working." % name)