base: handle admin_socket connection failures gracefully

Connection errors are reported to the parent object and the cephmetrics
log file

diff --git a/collectors/base.py b/collectors/base.py
index dc3fdeedbb189e9891c5a6bc25c93261cc9d9522..3f2741c643d00df84460a560252a26eb73052e7c 100644 (file)
--- a/collectors/base.py
+++ b/collectors/base.py
@@ -40,15 +40,24 @@ class BaseCollector(object):
             cmds = ['perf', 'dump']
 
         start = time.time()
-        response = admin_socket(adm_socket, cmds,
-                                format='json')
+        try:
+            response = admin_socket(adm_socket, cmds,
+                                    format='json')
+        except RuntimeError as e:
+            self.logger.error("admin_socket error: {}".format(e.message))
+            self.error = True
+            self.error_msgs = [e.message]
+            resp = {}
+        else:
+            resp = json.loads(response)
+
         end = time.time()
 
         self.logger.debug("admin_socket call '{}' : "
                           "{:.3f}s".format(' '.join(cmds),
                                            (end - start)))
 
-        return json.loads(response)
+        return resp
 
     def get_version(self):
         """