xenserver: Set fail_mode on internal bridges.
authorEthan Jackson <ethan@nicira.com>
Wed, 9 Feb 2011 02:55:17 +0000 (18:55 -0800)
committerEthan Jackson <ethan@nicira.com>
Wed, 9 Feb 2011 19:28:29 +0000 (11:28 -0800)
The fail_mode was not getting set on internal bridges.  This commit
forces ovs-external-ids to automatically set fail_mode on all new
bridges.

Signed-off-by: Ethan Jackson <ethan@nicira.com>
Bug #4494.

xenserver/usr_share_openvswitch_scripts_ovs-external-ids

index 07303e3eabd29792c9c75a6b2a7b3491bba08f32..0ebb7ce5306fac0753ac7f4fbac3f84338c8ea0e 100755 (executable)
@@ -68,21 +68,29 @@ def init_session():
 
     return True
 
-# By default, the "bridge-id" external id in the Bridge table is the
-# same as "xs-network-uuids".  This may be overridden by defining a
-# "nicira-bridge-id" key in the "other_config" field of the network
-# record of XAPI.
-def get_bridge_id(br_name, default=None):
+def get_network_by_bridge(br_name):
     if not init_session():
         s_log.warning("Failed to get bridge id %s because"
                 " XAPI session could not be initialized" % br_name)
-        return default
+        return None
 
     for n in session.xenapi.network.get_all():
         rec = session.xenapi.network.get_record(n)
-        if rec['bridge'] != br_name:
-            continue
+        if rec['bridge'] == br_name:
+            return rec
+
+    return None
+
+# By default, the "bridge-id" external id in the Bridge table is the
+# same as "xs-network-uuids".  This may be overridden by defining a
+# "nicira-bridge-id" key in the "other_config" field of the network
+# record of XAPI.  If nicira-bridge-id is undefined returns default.
+# On error returns None.
+def get_bridge_id(br_name, default=None):
+    rec = get_network_by_bridge(br_name)
+    if rec:
         return rec['other_config'].get('nicira-bridge-id', default)
+    return None
 
 # By default, the "iface-id" external id in the Interface table is the
 # same as "xs-vif-uuid".  This may be overridden by defining a
@@ -107,13 +115,16 @@ def get_iface_id(if_name, xs_vif_uuid):
         s_log.warning("Could not find XAPI entry for VIF %s" % if_name)
         return xs_vif_uuid
 
-def set_external_id(table, record, key, value):
-    col = 'external-ids:"' + key + '"="' + value + '"'
-    cmd = [vsctl, "--timeout=30", "-vANY:console:emer", "set", table, record, col]
+def call_vsctl(args):
+    cmd = [vsctl, "--timeout=30", "-vANY:console:emer"] + args
     exitcode = subprocess.call(cmd)
     if exitcode != 0:
         s_log.warning("Couldn't call ovs-vsctl")
 
+def set_external_id(table, record, key, value):
+    col = 'external-ids:"' + key + '"="' + value + '"'
+    call_vsctl(["set", table, record, col])
+
 # XAPI on XenServer 5.6 uses the external-id "network-uuids" for internal
 # networks, but we now prefer "xs-network-uuids".  Look for its use and
 # write our preferred external-id.
@@ -122,6 +133,25 @@ def update_network_uuids(name, ids):
         set_external_id("Bridge", name, "xs-network-uuids",
                 ids["network-uuids"])
 
+def update_fail_mode(name):
+    rec = get_network_by_bridge(name)
+
+    if not rec:
+        return
+
+    fail_mode = rec['other_config'].get('vswitch-controller-fail-mode')
+
+    if not fail_mode:
+        pools = session.xenapi.pool.get_all()
+        if len(pools) == 1:
+            prec = session.xenapi.pool.get_record(pools[0])
+            fail_mode = prec['other_config'].get('vswitch-controller-fail-mode')
+
+    if fail_mode not in ['standalone', 'secure']:
+        fail_mode = 'standalone'
+
+    call_vsctl(["set", "bridge", name, "fail_mode=" + fail_mode])
+
 def update_bridge_id(name, ids):
     id = get_bridge_id(name, ids.get("xs-network-uuids"))
 
@@ -257,6 +287,7 @@ def main(argv):
                 # so only check for "network-uuids" on creation.
                 if name not in bridges:
                     update_network_uuids(name, ids)
+                    update_fail_mode(name)
 
                 if (name not in bridges) or (bridges[name] != ids):
                     update_bridge_id(name, ids)