/ - Diff - snf-ganeti - Greek Research and Technology Network's projects

       # This ensures we're running on the master daemon
       cl = GetClient()
       # Query client
       qcl = GetClient(query=True)
       (cluster_name, master_node) = \
         cl.QueryConfigValues(["cluster_name", "master_node"])
       online_nodes = GetOnlineNodes([], cl=cl)
       ssh_ports = GetNodesSshPorts(online_nodes, cl)
       online_nodes = GetOnlineNodes([], cl=qcl)
       ssh_ports = GetNodesSshPorts(online_nodes, qcl)
       # Don't keep a reference to the client. The master daemon will go away.
       del cl
       del qcl
       assert master_node in online_nodes
-...
       """
       if cl is None:
         cl = GetClient()
         cl = GetClient(query=True)
       qfilter = []

                                    errors.ECODE_INVAL)
       cl = GetClient()
       qcl = GetClient(query=True)
       try:
         cluster_name = cl.QueryConfigValues(["cluster_name"])[0]
         results = GetOnlineNodes(nodes=opts.nodes, cl=cl, filter_master=True,
         results = GetOnlineNodes(nodes=opts.nodes, cl=qcl, filter_master=True,
                                  secondary_ips=opts.use_replication_network,
                                  nodegroup=opts.nodegroup)
         ports = GetNodesSshPorts(opts.nodes, cl)
         ports = GetNodesSshPorts(opts.nodes, qcl)
       finally:
         cl.Close()
         qcl.Close()
       srun = ssh.SshRunner(cluster_name)
       for (node, port) in zip(results, ports):
-...
       """
       cl = GetClient()
       qcl = GetClient(query=True)
       command = " ".join(args)
       nodes = GetOnlineNodes(nodes=opts.nodes, cl=cl, nodegroup=opts.nodegroup)
       ports = GetNodesSshPorts(nodes, cl)
       nodes = GetOnlineNodes(nodes=opts.nodes, cl=qcl, nodegroup=opts.nodegroup)
       ports = GetNodesSshPorts(nodes, qcl)
       cluster_name, master_node = cl.QueryConfigValues(["cluster_name",
                                                         "master_node"])
-...
         return constants.EXIT_FAILURE
     def Epo(opts, args, cl=None, _on_fn=_EpoOn, _off_fn=_EpoOff,
     def Epo(opts, args, cl=None, qcl=None, _on_fn=_EpoOn, _off_fn=_EpoOff,
             _confirm_fn=ConfirmOperation,
             _stdout_fn=ToStdout, _stderr_fn=ToStderr):
       """EPO operations.
-...
       if cl is None:
         cl = GetClient()
       if qcl is None:
         # Query client
         qcl = GetClient(query=True)
       if opts.groups:
         node_query_list = \
-...
       else:
         node_query_list = args
       result = cl.QueryNodes(node_query_list, ["name", "master", "pinst_list",
                                                "sinst_list", "powered", "offline"],
                              False)
       result = qcl.QueryNodes(node_query_list, ["name", "master", "pinst_list",
                                                 "sinst_list", "powered", "offline"],
                               False)
       all_nodes = map(compat.fst, result)
       node_list = []

       """
       cl = GetClient()
       query_cl = GetClient(query=True)
       node = netutils.GetHostname(name=args[0]).name
       readd = opts.readd
-...
         pass
       try:
         output = cl.QueryNodes(names=[node],
                                fields=["name", "sip", "master", "ndp/ssh_port"],
                                use_locking=False)
         output = query_cl.QueryNodes(names=[node],
                                      fields=["name", "sip", "master",
                                              "ndp/ssh_port"],
                                      use_locking=False)
         node_exists, sip, is_master, ssh_port = output[0]
       except (errors.OpPrereqError, errors.OpExecError):
         node_exists = ""
-...
       # these fields are static data anyway, so it doesn't matter, but
       # locking=True should be safer
       qcl = GetClient(query=True)
       result = cl.QueryNodes(names=args, fields=selected_fields,
                              use_locking=False)
       result = qcl.QueryNodes(names=args, fields=selected_fields,
                               use_locking=False)
       qcl.Close()
       node, pinst = result[0]
-...
       selected_fields = ["name", "pinst_list"]
       qcl = GetClient(query=True)
       result = cl.QueryNodes(names=args, fields=selected_fields, use_locking=False)
       result = qcl.QueryNodes(names=args, fields=selected_fields, use_locking=False)
       qcl.Close()
       ((node, pinst), ) = result

         """Returns a list of all available instances.
         """
         client = self.GetClient()
         client = self.GetClient(query=True)
         use_locking = self.useLocking()
         if self.useBulk():
-...
         """Send information about an instance.
         """
         client = self.GetClient()
         client = self.GetClient(query=True)
         instance_name = self.items[0]
         result = baserlib.HandleItemQueryErrors(client.QueryInstances,
-...
       PUT_OPCODE = opcodes.OpQuery
       def _Query(self, fields, qfilter):
         return self.GetClient().Query(self.items[0], fields, qfilter).ToDict()
         client = self.GetClient()
         return client.Query(self.items[0], fields, qfilter).ToDict()
       def GET(self):
         """Returns resource information.

           off_fn = compat.partial(self._Off, ["node1.example.com"])
           result = self._Test(opts, [], cl=client, _off_fn=off_fn,
           result = self._Test(opts, [], cl=client, qcl=client, _off_fn=off_fn,
                               _confirm_fn=confirm_fn)
           if force or confirm_result:
             self.assertEqual(result, self._OFF_EXITCODE)
-...
             self.assertFalse(inst_map)
             return self._ON_EXITCODE
           result = self._Test(opts, [], cl=client, _on_fn=_On,
           result = self._Test(opts, [], cl=client, qcl=client, _on_fn=_On,
                               _confirm_fn=self._ConfirmForce)
           self.assertEqual(result, self._ON_EXITCODE)
-...
         client = _ClientForEpo(NotImplemented, [
           ("node1.example.com", True, [], [], True, False),
           ])
         result = self._Test(opts, [], cl=client, _confirm_fn=self._ConfirmForce)
         result = self._Test(opts, [], cl=client, qcl=client,
                             _confirm_fn=self._ConfirmForce)
         self.assertEqual(result, constants.EXIT_FAILURE)

Synnefo » snf-ganeti

Revision bc57fa8d