index c482ac6185fee8a1988e65271d24b40397c659b7..1b8e6b174ed8d8ad1a7abc1237842e03d5908075 100644 (file)
"""
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):
"""
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
print "[socket] connected to %s" % self.path
return sock
except socket.error, (errno, errstr):
- sys.stderror.write("[error] Connecting to socket failed: [%d] %s"
- % (errno, errstr))
+ sys.stderr.write("[error] Connecting to socket failed: [%d] %s"
+ % (errno, errstr))
return None
def _readline(self):
buf.append(data)
return ''.join(buf)
except socket.error, (errno, errstr):
- sys.stderror.write("[error] Reading from socket failed: [%d] %s"
- % (errno, errstr))
+ sys.stderr.write("[error] Reading from socket failed: [%d] %s"
+ % (errno, errstr))
self._sock = self._connect()
return None
try:
self._sock.close()
except socket.error, (errno, errstr):
- sys.stderror.write("[error] Closing socket failed: [%d] %s"
- % (errno, errstr))
+ sys.stderr.write("[error] Closing socket failed: [%d] %s"
+ % (errno, errstr))
if __name__ == '__main__':