File crm_tickets_825cb3e79d7b.patch of Package pacemaker

Overview Repositories Revisions Requests Users Attributes Meta

File crm_tickets_825cb3e79d7b.patch of Package pacemaker (Revision dfe7f20d16bdc8599cc9f54205957a96)

Currently displaying revision dfe7f20d16bdc8599cc9f54205957a96 , Show latest

# HG changeset patch
# User Dejan Muhamedagic <dejan@hello-penguin.com>
# Date 1314783705 -7200
# Node ID 825cb3e79d7bc1c4ac30468f8c028c9129d00541
# Parent  f77e52725f2d98c219d8b22208da0b89b3d42112
High: Shell: support for rsc_ticket

diff --git a/doc/crm.8.txt b/doc/crm.8.txt
--- a/doc/crm.8.txt
+++ b/doc/crm.8.txt
@@ -1639,6 +1639,34 @@ Example:
         order o1 inf: A ( B C )
 ...............
 
+[[cmdhelp_configure_rsc_ticket,resources ticket dependency]]
+==== `rsc_ticket`
+
+This constraint expresses dependency of resources on cluster-wide
+attributes, also known as tickets. Tickets are mainly used in
+geo-clusters, which consist of multiple sites. A ticket may be
+granted to a site, thus allowing resources to run there.
+
+The `loss-policy` attribute specifies what happens to the
+resource (or resources) if the ticket is revoked. The default is
+either `stop` or `demote` depending on whether a resource is
+multi-state.
+
+Usage:
+...............
+        rsc_ticket <id> <ticket_id>: <rsc>[:<role>] [<rsc>[:<role>] ...]
+          [loss-policy=<loss_policy_action>]
+
+        loss_policy_action :: stop | demote | fence | freeze
+...............
+Example:
+...............
+        rsc_ticket ticket-A_public-ip ticket-A: public-ip
+        rsc_ticket ticket-A_bigdb ticket-A: bigdb loss-policy=fence
+        rsc_ticket ticket-B_storage ticket-B: drbd-a:Master drbd-b:Master
+...............
+
+
 [[cmdhelp_configure_property,set a cluster property]]
 ==== `property`
 
diff --git a/shell/modules/cibconfig.py b/shell/modules/cibconfig.py
--- a/shell/modules/cibconfig.py
+++ b/shell/modules/cibconfig.py
@@ -1243,7 +1243,7 @@ class CibSimpleConstraint(CibObject):
         if node.getElementsByTagName("resource_set"):
             col = rsc_set_constraint(node,obj_type)
         else:
-            col = two_rsc_constraint(node,obj_type)
+            col = simple_rsc_constraint(node,obj_type)
         if not col:
             return None
         symm = node.getAttribute("symmetrical")
@@ -1264,6 +1264,27 @@ class CibSimpleConstraint(CibObject):
         remove_id_used_attributes(oldnode)
         return headnode
 
+class CibRscTicket(CibSimpleConstraint):
+    '''
+    rsc_ticket constraint.
+    '''
+    def repr_cli_head(self,node):
+        obj_type = vars.cib_cli_map[node.tagName]
+        node_id = node.getAttribute("id")
+        s = cli_display.keyword(obj_type)
+        id = cli_display.id(node_id)
+        ticket = cli_display.ticket(node.getAttribute("ticket"))
+        if node.getElementsByTagName("resource_set"):
+            col = rsc_set_constraint(node,obj_type)
+        else:
+            col = simple_rsc_constraint(node,obj_type)
+        if not col:
+            return None
+        a = node.getAttribute("loss-policy")
+        if a:
+            col.append("loss-policy=%s" % a)
+        return "%s %s %s: %s" % (s,id,ticket,' '.join(col))
+
 class CibProperty(CibObject):
     '''
     Cluster properties.
@@ -1371,6 +1392,7 @@ cib_object_map = {
     "rsc_location": ( "location", CibLocation, "constraints" ),
     "rsc_colocation": ( "colocation", CibSimpleConstraint, "constraints" ),
     "rsc_order": ( "order", CibSimpleConstraint, "constraints" ),
+    "rsc_ticket": ( "rsc_ticket", CibRscTicket, "constraints" ),
     "cluster_property_set": ( "property", CibProperty, "crm_config", "cib-bootstrap-options" ),
     "rsc_defaults": ( "rsc_defaults", CibProperty, "rsc_defaults", "rsc-options" ),
     "op_defaults": ( "op_defaults", CibProperty, "op_defaults", "op-options" ),
diff --git a/shell/modules/clidisplay.py b/shell/modules/clidisplay.py
--- a/shell/modules/clidisplay.py
+++ b/shell/modules/clidisplay.py
@@ -62,6 +62,8 @@ class CliDisplay(Singleton):
         return self.otherword(4, s)
     def score(self, s):
         return self.otherword(5, s)
+    def ticket(self, s):
+        return self.otherword(5, s)
 
 user_prefs = UserPrefs.getInstance()
 vars = Vars.getInstance()
diff --git a/shell/modules/cliformat.py b/shell/modules/cliformat.py
--- a/shell/modules/cliformat.py
+++ b/shell/modules/cliformat.py
@@ -226,22 +226,25 @@ def rsc_set_constraint(node,obj_type):
         action = n.getAttribute("action")
         for r in n.getElementsByTagName("resource_ref"):
             rsc = cli_display.rscref(r.getAttribute("id"))
-            q = (obj_type == "colocation") and role or action
+            q = (obj_type == "order") and action or role
             col.append(q and "%s:%s"%(rsc,q) or rsc)
             cnt += 1
         if not sequential:
             col.append(")")
-    if cnt <= 2: # a degenerate thingie
+    if (obj_type != "rsc_ticket" and cnt <= 2) or \
+            (obj_type == "rsc_ticket" and cnt <= 1): # a degenerate thingie
         col.insert(0,"_rsc_set_")
     return col
-def two_rsc_constraint(node,obj_type):
+def simple_rsc_constraint(node,obj_type):
     col = []
     if obj_type == "colocation":
         col.append(mkrscrole(node,"rsc"))
         col.append(mkrscrole(node,"with-rsc"))
-    else:
+    elif obj_type == "order":
         col.append(mkrscaction(node,"first"))
         col.append(mkrscaction(node,"then"))
+    else: # rsc_ticket
+        col.append(mkrscrole(node,"rsc"))
     return col
 
 # this pre (or post)-processing is oversimplified
diff --git a/shell/modules/completion.py b/shell/modules/completion.py
--- a/shell/modules/completion.py
+++ b/shell/modules/completion.py
@@ -467,6 +467,7 @@ completer_lists = {
         "location" : (null_list,rsc_id_list),
         "colocation" : (null_list,null_list,rsc_id_list,loop),
         "order" : (null_list,null_list,rsc_id_list,loop),
+        "rsc_ticket" : (null_list,null_list,rsc_id_list,loop),
         "property" : (property_complete,loop),
         "rsc_defaults" : (prim_complete_meta,loop),
         "op_defaults" : (op_attr_list,loop),
diff --git a/shell/modules/parse.py b/shell/modules/parse.py
--- a/shell/modules/parse.py
+++ b/shell/modules/parse.py
@@ -178,6 +178,15 @@ def parse_op(s):
     head_pl.append(["name",s[0]])
     return cli_list
 
+def cli_parse_ticket(ticket,pl):
+    if ticket.endswith(':'):
+        ticket = ticket.rstrip(':')
+    else:
+        syntax_err(ticket, context = 'rsc_ticket')
+        return False
+    pl.append(["ticket",ticket])
+    return True
+
 def cli_parse_score(score,pl,noattr = False):
     if score.endswith(':'):
         score = score.rstrip(':')
@@ -197,6 +206,7 @@ def cli_parse_score(score,pl,noattr = Fa
         else:
             pl.append(["score-attribute",score])
     return True
+
 def is_binary_op(s):
     l = s.split(':')
     if len(l) == 2:
@@ -302,13 +312,13 @@ def parse_location(s):
         return False
     return cli_list
 
-def cli_opt_symmetrical(p,pl):
+def cli_opt_attribute(type, p, pl, attr):
     if not p:
         return True
     pl1 = []
     cli_parse_attr([p],pl1)
-    if len(pl1) != 1 or not find_value(pl1,"symmetrical"):
-        syntax_err(p,context = "order")
+    if len(pl1) != 1 or not find_value(pl1, attr):
+        syntax_err(p,context = type)
         return False
     pl += pl1
     return True
@@ -490,7 +500,33 @@ def parse_order(s):
         resource_set_obj = ResourceSet(type,s[3:],cli_list)
         if not resource_set_obj.parse():
             return False
-    if not cli_opt_symmetrical(symm,head_pl):
+    if not cli_opt_attribute(type, symm, head_pl, "symmetrical"):
+        return False
+    return cli_list
+
+def parse_rsc_ticket(s):
+    cli_list = []
+    head_pl = []
+    type = "rsc_ticket"
+    cli_list.append([s[0],head_pl])
+    if len(s) < 4:
+        syntax_err(s,context = "rsc_ticket")
+        return False
+    head_pl.append(["id",s[1]])
+    if not cli_parse_ticket(s[2],head_pl):
+        return False
+    # save loss-policy for later (if it exists)
+    loss_policy = ""
+    if is_attribute(s[len(s)-1],"loss-policy"):
+        loss_policy = s.pop()
+    if len(s) == 4:
+        if not cli_parse_rsc_role(s[3], head_pl):
+            return False
+    else:
+        resource_set_obj = ResourceSet(type, s[3:], cli_list)
+        if not resource_set_obj.parse():
+            return False
+    if not cli_opt_attribute(type, loss_policy, head_pl, attr = "loss-policy"):
         return False
     return cli_list
 
@@ -501,6 +537,8 @@ def parse_constraint(s):
         return parse_colocation(s)
     elif keyword_cmp(s[0], "order"):
         return parse_order(s)
+    elif keyword_cmp(s[0], "rsc_ticket"):
+        return parse_rsc_ticket(s)
 def parse_property(s):
     cli_list = []
     head_pl = []
@@ -708,6 +746,7 @@ class CliParser(object):
         "colocation": (3,parse_constraint),
         "collocation": (3,parse_constraint),
         "order": (3,parse_constraint),
+        "rsc_ticket": (3,parse_constraint),
         "monitor": (3,parse_op),
         "node": (2,parse_node),
         "property": (2,parse_property),
diff --git a/shell/modules/ui.py.in b/shell/modules/ui.py.in
--- a/shell/modules/ui.py.in
+++ b/shell/modules/ui.py.in
@@ -1400,6 +1400,7 @@ cluster.
         self.cmd_table["location"] = (self.conf_location,(2,),1,0)
         self.cmd_table["colocation"] = (self.conf_colocation,(2,),1,0)
         self.cmd_table["order"] = (self.conf_order,(2,),1,0)
+        self.cmd_table["rsc_ticket"] = (self.conf_rsc_ticket,(2,),1,0)
         self.cmd_table["property"] = (self.conf_property,(1,),1,0)
         self.cmd_table["rsc_defaults"] = (self.conf_rsc_defaults,(1,),1,0)
         self.cmd_table["op_defaults"] = (self.conf_op_defaults,(1,),1,0)
@@ -1632,6 +1633,10 @@ cluster.
         """usage: order <id> score-type: <first-rsc>[:<action>] <then-rsc>[:<action>]
         [symmetrical=<bool>]"""
         return self.__conf_object(cmd,*args)
+    def conf_rsc_ticket(self,cmd,*args):
+        """usage: rsc_ticket <id> <ticket_id>: <rsc>[:<role>] [<rsc>[:<role>] ...]
+        [loss-policy=<loss_policy_action>]"""
+        return self.__conf_object(cmd,*args)
     def conf_property(self,cmd,*args):
         "usage: property [$id=<set_id>] <option>=<value>"
         return self.__conf_object(cmd,*args)
diff --git a/shell/modules/vars.py.in b/shell/modules/vars.py.in
--- a/shell/modules/vars.py.in
+++ b/shell/modules/vars.py.in
@@ -53,6 +53,7 @@ class Vars(Singleton):
     "rsc_location": "location",
     "rsc_colocation": "colocation",
     "rsc_order": "order",
+    "rsc_ticket": "rsc_ticket",
     "cluster_property_set": "property",
     "rsc_defaults": "rsc_defaults",
     "op_defaults": "op_defaults",
@@ -62,13 +63,13 @@ class Vars(Singleton):
     container_tags = ("group", "clone", "ms", "master")
     clonems_tags = ("clone", "ms", "master")
     resource_tags = ("primitive","group","clone","ms","master")
-    constraint_tags = ("rsc_location","rsc_colocation","rsc_order")
+    constraint_tags = ("rsc_location","rsc_colocation","rsc_order","rsc_ticket")
     constraint_rsc_refs = ("rsc","with-rsc","first","then")
     children_tags = ("group", "primitive")
     nvpairs_tags = ("meta_attributes", "instance_attributes", "utilization")
     defaults_tags = ("rsc_defaults","op_defaults")
     resource_cli_names = ("primitive","group","clone","ms","master")
-    constraint_cli_names = ("location","colocation","collocation","order")
+    constraint_cli_names = ("location","colocation","collocation","order","rsc_ticket")
     nvset_cli_names = ("property","rsc_defaults","op_defaults")
     op_cli_names = ("monitor", "start", "stop", "migrate_to", "migrate_from","promote","demote","notify")
     ra_operations = ("probe", "monitor", "start", "stop",
diff --git a/shell/modules/xmlutil.py b/shell/modules/xmlutil.py
--- a/shell/modules/xmlutil.py
+++ b/shell/modules/xmlutil.py
@@ -520,7 +520,8 @@ def mss(node_list):
 def constraints(node_list):
     return filter_on_tag(node_list,"rsc_location") \
         + filter_on_tag(node_list,"rsc_colocation") \
-        + filter_on_tag(node_list,"rsc_order")
+        + filter_on_tag(node_list,"rsc_order") \
+        + filter_on_tag(node_list,"rsc_ticket")
 def properties(node_list):
     return filter_on_tag(node_list,"cluster_property_set") \
         + filter_on_tag(node_list,"rsc_defaults") \
@@ -562,7 +563,8 @@ def constraints_cli(node_list):
     return filter_on_type(node_list,"location") \
         + filter_on_type(node_list,"colocation") \
         + filter_on_type(node_list,"collocation") \
-        + filter_on_type(node_list,"order")
+        + filter_on_type(node_list,"order") \
+        + filter_on_type(node_list,"rsc_ticket")
 def properties_cli(cl):
     return filter_on_type(cl,"property") \
         + filter_on_type(cl,"rsc_defaults") \
@@ -601,6 +603,8 @@ def referenced_resources(node):
     elif xml_obj_type == "rsc_order":
         node_list = node.getElementsByTagName("first") + \
             node.getElementsByTagName("then")
+    elif xml_obj_type == "rsc_ticket":
+        node_list = node.getElementsByTagName("rsc")
     return [x.getAttribute("id") for x in node_list]
 
 def rename_id(node,old_id,new_id):

Places

File crm_tickets_825cb3e79d7b.patch of Package pacemaker (Revision dfe7f20d16bdc8599cc9f54205957a96)

Places