projects
/
collectd.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge pull request #3224 from mrunge/codeowners
[collectd.git]
/
contrib
/
collectd_unixsock.py
diff --git
a/contrib/collectd_unixsock.py
b/contrib/collectd_unixsock.py
index
ebe040d
..
5cd4ab8
100644
(file)
--- a/
contrib/collectd_unixsock.py
+++ b/
contrib/collectd_unixsock.py
@@
-68,8
+68,9
@@
class Collectd():
"""
numvalues = self._cmd('GETTHRESHOLD "%s"' % identifier)
lines = []
"""
numvalues = self._cmd('GETTHRESHOLD "%s"' % identifier)
lines = []
- if numvalues:
- lines = self._readlines(numvalues)
+ if not numvalues or numvalues < 0:
+ raise KeyError("Identifier '%s' not found" % identifier)
+ lines = self._readlines(numvalues)
return lines
def getval(self, identifier, flush_after=True):
return lines
def getval(self, identifier, flush_after=True):
@@
-83,8
+84,9
@@
class Collectd():
"""
numvalues = self._cmd('GETVAL "%s"' % identifier)
lines = []
"""
numvalues = self._cmd('GETVAL "%s"' % identifier)
lines = []
- if numvalues:
- lines = self._readlines(numvalues)
+ if not numvalues or numvalues < 0:
+ raise KeyError("Identifier '%s' not found" % identifier)
+ lines = self._readlines(numvalues)
if flush_after:
self.flush(identifiers=[identifier])
return lines
if flush_after:
self.flush(identifiers=[identifier])
return lines
@@
-156,7
+158,7
@@
class Collectd():
self._sock.send(c + "\n")
status_message = self._readline()
if self.noisy:
self._sock.send(c + "\n")
status_message = self._readline()
if self.noisy:
- print "[recive] %s" % status_message
+ print "[rec
e
ive] %s" % status_message
if not status_message:
return None
code, message = status_message.split(' ', 1)
if not status_message:
return None
code, message = status_message.split(' ', 1)