/* 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.ComponentModel; using XenAPI; namespace XenAdmin.Actions.GUIActions { /// /// MeddlingActionManager handles task events, categorises tasks depending upon whether they /// are ours or not, and creates MeddlingAction instances when necessary /// public class MeddlingActionManager { #region Predicates private static readonly ITaskSpecification taskFinishedSuccessfully = new TaskHasFinishedSuccessfullySpecification(); private static readonly ITaskSpecification taskIsSuitableForMeddlingAction = new TaskIsSuitableForMeddlingActionSpecification(); private static readonly ITaskSpecification taskIsUnwanted = new TaskIsUnwantedSpecification(); #endregion private static readonly log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); /// /// Tasks that we've seen, but haven't categorised yet. May only be acccesed under the DictionaryLock. /// private static readonly List UnmatchedTasks = new List(); /// /// Tasks that we've categorised as not being ours, and the corresponding MeddlingAction that we created. May /// only be accessed under the DictionaryLock. /// private static readonly Dictionary MatchedTasks = new Dictionary(); private static readonly object DictionaryLock = new object(); public static void TaskCollectionChanged(object sender, CollectionChangeEventArgs e) { lock (DictionaryLock) { Task task = (Task)e.Element; if (e.Action == CollectionChangeAction.Add) { if (!UnmatchedTasks.Contains(task.opaque_ref)) AddTaskToUnmatchedList(task); } else if (e.Action == CollectionChangeAction.Remove) { CompletelyForgetTask(task); } else { log.DebugFormat(String.Format("Unmatched action from sender -- Action: {0}; Task: {1}", e.Action, task.opaque_ref)); } } } private static void AddTaskToUnmatchedList(Task task) { task.PropertyChanged += Task_PropertyChanged; UnmatchedTasks.Add(task.opaque_ref); } private static void CompletelyForgetTask(Task task) { task.PropertyChanged -= Task_PropertyChanged; if (MatchedTasks.ContainsKey(task.opaque_ref)) { MatchedTasks[task.opaque_ref].Update(task, true); } UnmatchedTasks.Remove(task.opaque_ref); MatchedTasks.Remove(task.opaque_ref); } public static void ForceAddTask(Task task) { TaskCollectionChanged(task, new CollectionChangeEventArgs(CollectionChangeAction.Add, task)); } public static void Task_PropertyChanged(object sender, PropertyChangedEventArgs e) { Task task = (Task)sender; lock (DictionaryLock) { if (UnmatchedTasks.Contains(task.opaque_ref)) { if (taskIsUnwanted.IsSatisfiedBy(task)) { RemoveUnmatchedTask(task); } else if (taskIsSuitableForMeddlingAction.IsSatisfiedBy(task)) { CreateMeddlingActionForTask(task); } else { log.DebugFormat("Unmatched meddling task skipped -- " + task.opaque_ref); } } else if (MatchedTasks.ContainsKey(task.opaque_ref)) { if (taskFinishedSuccessfully.IsSatisfiedBy(task)) { UpdateAndDeleteTask(task); } else UpdateTask(task); } else { // else - it is a hidden (etc..) task that has called already and been removed from unmatched //(and not put into matched) - so ignore it log.DebugFormat("Uncategorised meddling task skipped -- " + task.opaque_ref); } } } private static void UpdateTask(Task task) { MatchedTasks[task.opaque_ref].Update(task, false); } private static void UpdateAndDeleteTask(Task task) { task.PropertyChanged -= Task_PropertyChanged; MatchedTasks[task.opaque_ref].Update(task, true); MatchedTasks.Remove(task.opaque_ref); } private static void CreateMeddlingActionForTask(Task task) { // If AppliesTo is set, then the client that created this task knows about our scheme for passing // info between clients. We give the client a window (AwareClientHeuristic) to set this field // before deciding that it's a non-aware client. Having decided that it's one of those two cases, // we make a MeddlingAction. MeddlingAction a = new MeddlingAction(task); UnmatchedTasks.Remove(task.opaque_ref); MatchedTasks[task.opaque_ref] = a; } private static void RemoveUnmatchedTask(Task task) { // This is one of our tasks, or it's a subtask of something else, or it's one that we // just don't care about. We're going to do no more with it. task.PropertyChanged -= Task_PropertyChanged; UnmatchedTasks.Remove(task.opaque_ref); } } }