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

Revision 3e512563

                           idx + 1, len(self.tasklets))
             tl.CheckPrereq()
         else:
           raise NotImplementedError
           pass
       def Exec(self, feedback_fn):
         """Execute the LU.
-...
         hasn't been done before.
         """
         raise NotImplementedError
         pass
       def Exec(self, feedback_fn):
         """Execute the tasklet.
-...
         mn = self.cfg.GetMasterNode()
         return env, [], [mn]
       def CheckPrereq(self):
         """No prerequisites to check.
         """
         return True
       def Exec(self, feedback_fn):
         """Nothing to do.
-...
+        }
         self.share_locks = dict.fromkeys(locking.LEVELS, 1)
       def CheckPrereq(self):
         """Check prerequisites.
         This has no prerequisites.
         """
         pass
       def Exec(self, feedback_fn):
         """Verify integrity of cluster disks.
-...
+        }
         self.share_locks[locking.LEVEL_NODE] = 1
       def CheckPrereq(self):
         """Check prerequisites.
         """
       def Exec(self, feedback_fn):
         """Redistribute the configuration.
-...
         #self.share_locks[locking.LEVEL_NODE] = 1
         #self.needed_locks[locking.LEVEL_NODE] = locking.ALL_SET
       def CheckPrereq(self):
         """Check prerequisites.
         """
       @staticmethod
       def _DiagnoseByOS(rlist):
         """Remaps a per-node return list into an a per-os per-node dictionary
-...
           # if we don't request only static fields, we need to lock the nodes
           self.needed_locks[locking.LEVEL_NODE] = self.wanted
       def CheckPrereq(self):
         """Check prerequisites.
         """
         # The validation of the node list is done in the _GetWantedNodes,
         # if non empty, and if empty, there's no validation to do
         pass
       def Exec(self, feedback_fn):
         """Computes the list of nodes and their attributes.
-...
           self.needed_locks[locking.LEVEL_NODE] = \
             _GetWantedNodes(self, self.op.nodes)
       def CheckPrereq(self):
         """Check prerequisites.
         This checks that the fields required are valid output fields.
         """
         self.nodes = self.acquired_locks[locking.LEVEL_NODE]
       def Exec(self, feedback_fn):
         """Computes the list of nodes and their attributes.
         """
         nodenames = self.nodes
         nodenames = self.acquired_locks[locking.LEVEL_NODE]
         volumes = self.rpc.call_node_volumes(nodenames)
         ilist = [self.cfg.GetInstanceInfo(iname) for iname
-...
         else:
           self.needed_locks[locking.LEVEL_NODE] = locking.ALL_SET
       def CheckPrereq(self):
         """Check prerequisites.
         This checks that the fields required are valid output fields.
         """
         self.nodes = self.acquired_locks[locking.LEVEL_NODE]
       def Exec(self, feedback_fn):
         """Computes the list of nodes and their attributes.
         """
         self.nodes = self.acquired_locks[locking.LEVEL_NODE]
         # Always get name to sort by
         if constants.SF_NAME in self.op.output_fields:
           fields = self.op.output_fields[:]
-...
         """
         self.needed_locks = {}
       def CheckPrereq(self):
         """Check prerequisites.
         This LU has no prereqs.
         """
         pass
       def Exec(self, feedback_fn):
         """Reboots a node.
-...
       def ExpandNames(self):
         self.needed_locks = {}
       def CheckPrereq(self):
         """No prerequsites needed for this LU.
         """
         pass
       def Exec(self, feedback_fn):
         """Return cluster config.
-...
       def ExpandNames(self):
         self.needed_locks = {}
       def CheckPrereq(self):
         """No prerequisites.
         """
         pass
       def Exec(self, feedback_fn):
         """Dump a representation of the cluster config to the standard output.
-...
         if level == locking.LEVEL_NODE and self.do_locking:
           self._LockInstancesNodes()
       def CheckPrereq(self):
         """Check prerequisites.
         """
         pass
       def Exec(self, feedback_fn):
         """Computes the list of nodes and their attributes.
-...
           self.op.remote_node = _ExpandNodeName(self.cfg, self.op.remote_node)
           locks[locking.LEVEL_NODE] = self.op.nodes + [self.op.remote_node]
       def CheckPrereq(self):
         pass
       def Exec(self, feedback_fn):
         if self.op.remote_node is not None:
           instances = []
-...
         self.wanted_instances = [self.cfg.GetInstanceInfo(name) for name
                                  in self.wanted_names]
         return
       def _ComputeBlockdevStatus(self, node, instance_name, dev):
         """Returns the status of a block device
-...
           self.needed_locks[locking.LEVEL_NODE] = \
             _GetWantedNodes(self, self.op.nodes)
       def CheckPrereq(self):
         """Check prerequisites.
         """
         self.nodes = self.acquired_locks[locking.LEVEL_NODE]
       def Exec(self, feedback_fn):
         """Compute the list of all the exported system images.
-...
             that node.
         """
         self.nodes = self.acquired_locks[locking.LEVEL_NODE]
         rpcresult = self.rpc.call_export_list(self.nodes)
         result = {}
         for node in rpcresult:
-...
         # we can remove exports also for a removed instance)
         self.needed_locks[locking.LEVEL_NODE] = locking.ALL_SET
       def CheckPrereq(self):
         """Check prerequisites.
         """
         pass
       def Exec(self, feedback_fn):
         """Remove any export.
-...
           self.op.on_nodes = _GetWantedNodes(self, self.op.on_nodes)
           self.needed_locks[locking.LEVEL_NODE] = self.op.on_nodes
       def CheckPrereq(self):
         """Check prerequisites.
         """
       def _TestDelay(self):
         """Do the actual sleep.

Also available in: Unified diff

Synnefo » snf-ganeti » ganeti-local

Revision 3e512563