/* Copyright (c) Citrix Systems, Inc. * All rights reserved. * * Redistribution and use in source and binary forms, * with or without modification, are permitted provided * that the following conditions are met: * * * Redistributions of source code must retain the above * copyright notice, this list of conditions and the * following disclaimer. * * Redistributions in binary form must reproduce the above * copyright notice, this list of conditions and the * following disclaimer in the documentation and/or other * materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. */ using System; using System.Collections.Generic; using System.Threading; using XenAPI; using XenAdmin.Core; using XenAdmin.Network; namespace XenAdmin.Actions { public class DestroyBondAction : AsyncAction { private static readonly log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); /// /// All bonds equivalent to the one given in the constructor (i.e. one per host). /// private readonly List Bonds = new List(); /// /// The masters of all the bonds in Bonds. /// private readonly List Masters = new List(); /// /// Masters that held secondary management interfaces. These are discovered when bringing masters down. /// private readonly List Secondaries = new List(); /// /// All slaves under each bond in Bonds. These will be plugged at the end, in order to /// get metrics like the carrier flag, if they haven't already been brought up as a /// management interface. /// private readonly List Slaves = new List(); /// /// The first slave (ordered by name) under each master. /// private readonly Dictionary FirstSlaves = new Dictionary(); /// /// A dictionary of copies of the equivalent entries in FirstSlaves, but with the IP details that we're carrying across. /// private readonly Dictionary NewFirstSlaves = new Dictionary(); /// /// The network that we're either going to destroy or rename. /// private readonly XenAPI.Network Network; /// /// The bond's name. /// private readonly string Name; /// /// /// /// public DestroyBondAction(Bond bond) : base(bond.Connection, string.Format(Messages.ACTION_DESTROY_BOND_TITLE, bond.Name()), string.Format(Messages.ACTION_DESTROY_BOND_DESCRIPTION, bond.Name())) { #region RBAC Dependencies ApiMethodsToRoleCheck.Add("host.management_reconfigure"); ApiMethodsToRoleCheck.Add("network.destroy"); ApiMethodsToRoleCheck.Add("vif.plug"); ApiMethodsToRoleCheck.Add("vif.unplug"); ApiMethodsToRoleCheck.Add("pif.reconfigure_ip"); ApiMethodsToRoleCheck.Add("pif.plug"); ApiMethodsToRoleCheck.Add("bond.destroy"); ApiMethodsToRoleCheck.AddRange(XenAPI.Role.CommonSessionApiList); ApiMethodsToRoleCheck.AddRange(XenAPI.Role.CommonTaskApiList); #endregion Name = bond.Name(); Pool = Helpers.GetPoolOfOne(Connection); foreach (Host host in Connection.Cache.Hosts) { Bond b = NetworkingHelper.FindBond(host, bond); if (b != null) { Bonds.Add(b); b.Locked = true; PIF master = Connection.Resolve(b.master); if (master != null) { Masters.Add(master); master.Locked = true; List slaves = Connection.ResolveAll(b.slaves); NetworkingHelper.Sort(slaves); foreach (PIF pif in slaves) { Slaves.Add(pif); pif.Locked = true; } FirstSlaves[master] = Connection.Resolve(b.primary_slave); if (!FirstSlaves.ContainsKey(master) && slaves.Count != 0) FirstSlaves[master] = slaves[0]; } AppliesTo.Add(host.opaque_ref); } } PIF master_master = Connection.Resolve(bond.master); if (master_master != null) { Network = Connection.Resolve(master_master.network); Network.Locked = true; } } protected override void Run() { Connection.ExpectDisruption = true; List unplugged_vifs = new List(); string old_network_name = Network == null ? "" : Network.Name(); Exception e = null; BestEffort(ref e, ReconfigureManagementInterfaces); if (e != null) throw e; PercentComplete = 50; int inc = 40 / Bonds.Count; int lo = PercentComplete; foreach (Bond bond in Bonds) { Bond bond1 = bond; int lo1 = lo; BestEffort(ref e, delegate() { RelatedTask = Bond.async_destroy(Session, bond1.opaque_ref);}); PollToCompletion(lo1, lo1 + inc); lo += inc; } if (Network != null) { // Destroy the old network log.DebugFormat("Destroying network {0} ({1})...", old_network_name, Network.uuid); BestEffort(ref e, delegate() { XenAPI.Network.destroy(Session, Network.opaque_ref); log.DebugFormat("Network {0} ({1}) destroyed.", old_network_name, Network.uuid); }); } if (e != null) throw e; Description = string.Format(Messages.ACTION_DESTROY_BOND_DONE, Name); } private void ReconfigureManagementInterfaces() { int progress = 0; int inc = 50 / Masters.Count; foreach (PIF master in Masters) { progress += inc; NetworkingActionHelpers.MoveManagementInterfaceName(this, master, FirstSlaves[master]); } } private void UnlockAll() { foreach (Bond bond in Bonds) { bond.Locked = false; } foreach (PIF master in Masters) { master.Locked = false; } if (Network != null) { Network.Locked = false; } } protected override void Clean() { Connection.ExpectDisruption = false; UnlockAll(); } } }