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

           op = opcodes.OpQueryExports(nodes=nodes)
           return self._Query(op)
         elif method == luxi.REQ_QUERY_CONFIG_VALUES:
           fields = args
           op = opcodes.OpQueryConfigValues(output_fields=fields)
           return self._Query(op)
         else:
           raise ValueError("Invalid operation")

         return result
     class LUDumpClusterConfig(NoHooksLU):
       """Return a text-representation of the cluster-config.
     class LUQueryConfigValues(NoHooksLU):
       """Return configuration values.
       """
       _OP_REQP = []
-...
       def ExpandNames(self):
         self.needed_locks = {}
         static_fields = ["cluster_name", "master_node"]
         _CheckOutputFields(static=static_fields,
                            dynamic=[],
                            selected=self.op.output_fields)
       def CheckPrereq(self):
         """No prerequisites.
-...
         """Dump a representation of the cluster config to the standard output.
         """
         return self.cfg.DumpConfig()
         values = []
         for field in self.op.output_fields:
           if field == "cluster_name":
             values.append(self.cfg.GetClusterName())
           elif field == "master_node":
             values.append(self.cfg.GetMasterNode())
           else:
             raise errors.ParameterError(field)
         return values
     class LUActivateInstanceDisks(NoHooksLU):
-...
       """
       _OP_REQP = ["instances"]
       REQ_BGL = False
       def ExpandNames(self):
         self.needed_locks = {}
         self.share_locks = dict(((i, 1) for i in locking.LEVELS))

                         for node in self._UnlockedGetNodeList()])
         return my_dict
       @locking.ssynchronized(_config_lock, shared=1)
       def DumpConfig(self):
         """Return the entire configuration of the cluster.
         """
         self._OpenConfig()
         return self._config_data
       def _BumpSerialNo(self):
         """Bump up the serial number of the config.

     REQ_QUERY_INSTANCES = "QueryInstances"
     REQ_QUERY_NODES = "QueryNodes"
     REQ_QUERY_EXPORTS = "QueryExports"
     REQ_QUERY_CONFIG_VALUES = "QueryConfigValues"
     DEF_CTMO = 10
     DEF_RWTO = 60
-...
       def QueryExports(self, nodes):
         return self.CallMethod(REQ_QUERY_EXPORTS, nodes)
       def QueryConfigValues(self, fields):
         return self.CallMethod(REQ_QUERY_CONFIG_VALUES, fields)
     # TODO: class Server(object)

         opcodes.OpDestroyCluster: cmdlib.LUDestroyCluster,
         opcodes.OpQueryClusterInfo: cmdlib.LUQueryClusterInfo,
         opcodes.OpVerifyCluster: cmdlib.LUVerifyCluster,
         opcodes.OpDumpClusterConfig: cmdlib.LUDumpClusterConfig,
         opcodes.OpQueryConfigValues: cmdlib.LUQueryConfigValues,
         opcodes.OpRenameCluster: cmdlib.LURenameCluster,
         opcodes.OpVerifyDisks: cmdlib.LUVerifyDisks,
         opcodes.OpSetClusterParams: cmdlib.LUSetClusterParams,

       __slots__ = []
     class OpDumpClusterConfig(OpCode):
       """Dump the cluster configuration."""
       OP_ID = "OP_CLUSTER_DUMPCONFIG"
       __slots__ = []
     class OpQueryConfigValues(OpCode):
       """Query cluster configuration values."""
       OP_ID = "OP_CLUSTER_CONFIG_QUERY"
       __slots__ = ["output_fields"]
     class OpRenameCluster(OpCode):

Synnefo » snf-ganeti » ganeti-local