from ganeti.cmdlib.base import ResultWithJobs, LogicalUnit, NoHooksLU, \
Tasklet, _QueryBase
from ganeti.cmdlib.common import _ExpandInstanceName, _ExpandItemName, \
- _ExpandNodeName
+ _ExpandNodeName, _ShareAll
+from ganeti.cmdlib.tags import LUTagsGet, LUTagsSearch, LUTagsSet, LUTagsDel
import ganeti.masterd.instance # pylint: disable=W0611
]))
-def _ShareAll():
- """Returns a dict declaring all lock levels shared.
-
- """
- return dict.fromkeys(locking.LEVELS, 1)
-
-
def _AnnotateDiskParams(instance, devs, cfg):
"""Little helper wrapper to the rpc annotation method.
return ResultWithJobs(jobs)
-class TagsLU(NoHooksLU): # pylint: disable=W0223
- """Generic tags LU.
-
- This is an abstract class which is the parent of all the other tags LUs.
-
- """
- def ExpandNames(self):
- self.group_uuid = None
- self.needed_locks = {}
-
- if self.op.kind == constants.TAG_NODE:
- self.op.name = _ExpandNodeName(self.cfg, self.op.name)
- lock_level = locking.LEVEL_NODE
- lock_name = self.op.name
- elif self.op.kind == constants.TAG_INSTANCE:
- self.op.name = _ExpandInstanceName(self.cfg, self.op.name)
- lock_level = locking.LEVEL_INSTANCE
- lock_name = self.op.name
- elif self.op.kind == constants.TAG_NODEGROUP:
- self.group_uuid = self.cfg.LookupNodeGroup(self.op.name)
- lock_level = locking.LEVEL_NODEGROUP
- lock_name = self.group_uuid
- elif self.op.kind == constants.TAG_NETWORK:
- self.network_uuid = self.cfg.LookupNetwork(self.op.name)
- lock_level = locking.LEVEL_NETWORK
- lock_name = self.network_uuid
- else:
- lock_level = None
- lock_name = None
-
- if lock_level and getattr(self.op, "use_locking", True):
- self.needed_locks[lock_level] = lock_name
-
- # FIXME: Acquire BGL for cluster tag operations (as of this writing it's
- # not possible to acquire the BGL based on opcode parameters)
-
- def CheckPrereq(self):
- """Check prerequisites.
-
- """
- if self.op.kind == constants.TAG_CLUSTER:
- self.target = self.cfg.GetClusterInfo()
- elif self.op.kind == constants.TAG_NODE:
- self.target = self.cfg.GetNodeInfo(self.op.name)
- elif self.op.kind == constants.TAG_INSTANCE:
- self.target = self.cfg.GetInstanceInfo(self.op.name)
- elif self.op.kind == constants.TAG_NODEGROUP:
- self.target = self.cfg.GetNodeGroup(self.group_uuid)
- elif self.op.kind == constants.TAG_NETWORK:
- self.target = self.cfg.GetNetwork(self.network_uuid)
- else:
- raise errors.OpPrereqError("Wrong tag type requested (%s)" %
- str(self.op.kind), errors.ECODE_INVAL)
-
-
-class LUTagsGet(TagsLU):
- """Returns the tags of a given object.
-
- """
- REQ_BGL = False
-
- def ExpandNames(self):
- TagsLU.ExpandNames(self)
-
- # Share locks as this is only a read operation
- self.share_locks = _ShareAll()
-
- def Exec(self, feedback_fn):
- """Returns the tag list.
-
- """
- return list(self.target.GetTags())
-
-
-class LUTagsSearch(NoHooksLU):
- """Searches the tags for a given pattern.
-
- """
- REQ_BGL = False
-
- def ExpandNames(self):
- self.needed_locks = {}
-
- def CheckPrereq(self):
- """Check prerequisites.
-
- This checks the pattern passed for validity by compiling it.
-
- """
- try:
- self.re = re.compile(self.op.pattern)
- except re.error, err:
- raise errors.OpPrereqError("Invalid search pattern '%s': %s" %
- (self.op.pattern, err), errors.ECODE_INVAL)
-
- def Exec(self, feedback_fn):
- """Returns the tag list.
-
- """
- cfg = self.cfg
- tgts = [("/cluster", cfg.GetClusterInfo())]
- ilist = cfg.GetAllInstancesInfo().values()
- tgts.extend([("/instances/%s" % i.name, i) for i in ilist])
- nlist = cfg.GetAllNodesInfo().values()
- tgts.extend([("/nodes/%s" % n.name, n) for n in nlist])
- tgts.extend(("/nodegroup/%s" % n.name, n)
- for n in cfg.GetAllNodeGroupsInfo().values())
- results = []
- for path, target in tgts:
- for tag in target.GetTags():
- if self.re.search(tag):
- results.append((path, tag))
- return results
-
-
-class LUTagsSet(TagsLU):
- """Sets a tag on a given object.
-
- """
- REQ_BGL = False
-
- def CheckPrereq(self):
- """Check prerequisites.
-
- This checks the type and length of the tag name and value.
-
- """
- TagsLU.CheckPrereq(self)
- for tag in self.op.tags:
- objects.TaggableObject.ValidateTag(tag)
-
- def Exec(self, feedback_fn):
- """Sets the tag.
-
- """
- try:
- for tag in self.op.tags:
- self.target.AddTag(tag)
- except errors.TagError, err:
- raise errors.OpExecError("Error while setting tag: %s" % str(err))
- self.cfg.Update(self.target, feedback_fn)
-
-
-class LUTagsDel(TagsLU):
- """Delete a list of tags from a given object.
-
- """
- REQ_BGL = False
-
- def CheckPrereq(self):
- """Check prerequisites.
-
- This checks that we have the given tag.
-
- """
- TagsLU.CheckPrereq(self)
- for tag in self.op.tags:
- objects.TaggableObject.ValidateTag(tag)
- del_tags = frozenset(self.op.tags)
- cur_tags = self.target.GetTags()
-
- diff_tags = del_tags - cur_tags
- if diff_tags:
- diff_names = ("'%s'" % i for i in sorted(diff_tags))
- raise errors.OpPrereqError("Tag(s) %s not found" %
- (utils.CommaJoin(diff_names), ),
- errors.ECODE_NOENT)
-
- def Exec(self, feedback_fn):
- """Remove the tag from the object.
-
- """
- for tag in self.op.tags:
- self.target.RemoveTag(tag)
- self.cfg.Update(self.target, feedback_fn)
-
-
class LUTestDelay(NoHooksLU):
"""Sleep for a specified amount of time.
projects / ganeti-local / blobdiff