FISLib_Old/Vinno.vCloud.Common.FIS/Test/VCloudTestItem.cs

using System;
using System.Threading;
using Vinno.IUS.Common.Log;

namespace Vinno.vCloud.Common.FIS.Test
{
    public enum VCloudTestItemStatus
    {
        None,
        TestBeginned,
        TestDone,
        TestFailed,
        CanSkipped,
        Skipped,
        TestTimeout
    }

    public enum VCloudSubItemTestStatus
    {
        Failed,
        Successful,
        Timeout,
    }

    public abstract class VCloudTestItem
    {
        protected readonly string TimeoutError = "VCloudTestTimeoutError";

        protected VCloudServiceTest VCloudServiceTest;

        /// <summary>
        /// Item test status
        /// </summary>
        public VCloudTestItemStatus Status { get; set; }

        /// <summary>
        /// Name for test item
        /// </summary>
        public string Id { get; }

        /// <summary>
        /// Indicate this service is enabled
        /// </summary>
        public bool IsEnabled { get; }

        protected VCloudTestItem(string id, VCloudServiceTest vCloudServiceTest)
        {
            VCloudServiceTest = vCloudServiceTest;
            Id = id;
            IsEnabled = true;
        }

        /// <summary>
        /// Execute this item test
        /// </summary>
        public abstract VCloudServiceTestResult Execute();

        protected VCloudSubItemTestStatus TimeoutExecute(Func<VCloudSubItemTestStatus> func, int timeout = 5000)
        {
            VCloudSubItemTestStatus result = VCloudSubItemTestStatus.Failed;
            var thread = new Thread(() =>
            {
                try
                {
                    result = func();
                }
                catch (Exception e)
                {
                    Logger.WriteLineError($"VCloudServiceTest - Exetute test [{Id}] ex:{e}");
                }
            });
            thread.Start();
            if (!thread.Join(timeout))
            {
                try
                {
                    thread.Abort();
                }
                catch (Exception ex)
                {
                    Logger.WriteLineError($"VCloudServiceTest - Exetute test [{Id}] - Abort thread failed.{ex}");
                }
                Logger.WriteLineError($"VCloudServiceTest - Exetute test [{Id}] timeout.");
                result = VCloudSubItemTestStatus.Timeout;
            }

            return result;
        }

        protected VCloudSubItemTestStatus TimeoutExecute(Func<string, VCloudSubItemTestStatus> func, string parameter, int timeout = 5000)
        {
            VCloudSubItemTestStatus result = VCloudSubItemTestStatus.Failed;
            var thread = new Thread(() =>
            {
                try
                {
                    result = func(parameter);
                }
                catch (Exception e)
                {
                    Logger.WriteLineError($"VCloudServiceTest - Exetute test [{Id}] ex:{e}");
                }
            });
            thread.Start();
            if (!thread.Join(timeout))
            {
                try
                {
                    thread.Abort();
                }
                catch (Exception ex)
                {
                    Logger.WriteLineError($"VCloudServiceTest - Exetute test [{Id}] - Abort thread failed.{ex}");
                }
                Logger.WriteLineError($"VCloudServiceTest - Exetute test [{Id}] timeout.");
                result = VCloudSubItemTestStatus.Timeout;
            }

            return result;
        }
    }
}