X-Git-Url: https://code.grnet.gr/git/ganeti-local/blobdiff_plain/4ef0399b755ea91f2cae00aaac2663b22f5c3dfc..d4e297b88c3402c099bbc093a31716a0d1519564:/tools/confd-client

diff --git a/tools/confd-client b/tools/confd-client
index 285fb72..e6755ab 100755
--- a/tools/confd-client
+++ b/tools/confd-client
@@ -33,6 +33,7 @@ import time
 from ganeti import constants
 from ganeti import cli
 from ganeti import utils
+from ganeti import pathutils
 
 from ganeti.confd import client as confd_client
 
@@ -41,7 +42,7 @@ USAGE = ("\tconfd-client [--addr=host] [--hmac=key]")
 LOG_HEADERS = {
   0: "- ",
   1: "* ",
-  2: ""
+  2: "",
   }
 
 OPTIONS = [
@@ -57,6 +58,7 @@ OPTIONS = [
                  type="int", metavar="<REQUESTS>"),
   ]
 
+
 def Log(msg, *args, **kwargs):
   """Simple function that prints out its argument.
 
@@ -124,7 +126,7 @@ class TestClient(object):
       Usage()
 
     if options.hmac is None:
-      options.hmac = utils.ReadFile(constants.CONFD_HMAC_KEY)
+      options.hmac = utils.ReadFile(pathutils.CONFD_HMAC_KEY)
     self.hmac_key = options.hmac
 
     self.mc_list = [options.mc]
@@ -207,20 +209,20 @@ class TestClient(object):
                                                  counting_callback)
 
     tests = [
-      {"type": constants.CONFD_REQ_PING },
-      {"type": constants.CONFD_REQ_CLUSTER_MASTER },
+      {"type": constants.CONFD_REQ_PING},
+      {"type": constants.CONFD_REQ_CLUSTER_MASTER},
       {"type": constants.CONFD_REQ_CLUSTER_MASTER,
-       "query": {constants.CONFD_REQQ_FIELDS : [
-            constants.CONFD_REQFIELD_NAME,
-            constants.CONFD_REQFIELD_IP,
-            constants.CONFD_REQFIELD_MNODE_PIP,
-            ]}},
-      {"type": constants.CONFD_REQ_NODE_ROLE_BYNAME },
-      {"type": constants.CONFD_REQ_NODE_PIP_LIST },
-      {"type": constants.CONFD_REQ_MC_PIP_LIST },
+       "query": {constants.CONFD_REQQ_FIELDS:
+                 [constants.CONFD_REQFIELD_NAME,
+                  constants.CONFD_REQFIELD_IP,
+                  constants.CONFD_REQFIELD_MNODE_PIP,
+                  ]}},
+      {"type": constants.CONFD_REQ_NODE_ROLE_BYNAME},
+      {"type": constants.CONFD_REQ_NODE_PIP_LIST},
+      {"type": constants.CONFD_REQ_MC_PIP_LIST},
       {"type": constants.CONFD_REQ_INSTANCES_IPS_LIST,
        "query": None},
-      {"type": constants.CONFD_REQ_NODE_PIP_BY_INSTANCE_IP },
+      {"type": constants.CONFD_REQ_NODE_PIP_BY_INSTANCE_IP},
       ]
 
     for kwargs in tests:
@@ -228,7 +230,7 @@ class TestClient(object):
         assert self.cluster_master is not None
         kwargs["query"] = self.cluster_master
       elif kwargs["type"] == constants.CONFD_REQ_NODE_PIP_BY_INSTANCE_IP:
-        kwargs["query"] = { constants.CONFD_REQQ_IPLIST : self.instance_ips }
+        kwargs["query"] = {constants.CONFD_REQQ_IPLIST: self.instance_ips}
 
       # pylint: disable=W0142
       # used ** magic
@@ -253,11 +255,12 @@ class TestClient(object):
 
     """
     start = time.time()
-    for i in range(self.opts.requests):
+    for _ in range(self.opts.requests):
+      # pylint: disable=W0142
       req = confd_client.ConfdClientRequest(**kwargs)
       self.DoConfdRequestReply(req)
     stop = time.time()
-    per_req = 1000 * (stop-start) / self.opts.requests
+    per_req = 1000 * (stop - start) / self.opts.requests
     Log("%.3fms per %s request", per_req, name, indent=1)
 
   def Run(self):
@@ -267,6 +270,7 @@ class TestClient(object):
     self.TestConfd()
     self.TestTiming()
 
+
 def main():
   """Main function.