Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use Abort method of Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client.ProxyDiscoveryManager class

Best Vstest code snippet using Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client.ProxyDiscoveryManager.Abort

ParallelProxyDiscoveryManager.cs

Source:ParallelProxyDiscoveryManager.cs

...27        private ITestDiscoveryEventsHandler2 currentDiscoveryEventsHandler;28        private ParallelDiscoveryDataAggregator currentDiscoveryDataAggregator;29        private IRequestData requestData;30        // This field indicates if abort was requested by testplatform (user)31        private bool discoveryAbortRequested = false;32        #endregion33        #region Concurrency Keeper Objects34        /// <summary>35        /// LockObject to update discovery status in parallel36        /// </summary>37        private object discoveryStatusLockObject = new object();38        #endregion39        public ParallelProxyDiscoveryManager(IRequestData requestData, Func<IProxyDiscoveryManager> actualProxyManagerCreator, int parallelLevel, bool sharedHosts)40            : this(requestData, actualProxyManagerCreator, JsonDataSerializer.Instance, parallelLevel, sharedHosts)41        {42        }43        internal ParallelProxyDiscoveryManager(IRequestData requestData, Func<IProxyDiscoveryManager> actualProxyManagerCreator, IDataSerializer dataSerializer, int parallelLevel, bool sharedHosts)44            : base(actualProxyManagerCreator, parallelLevel, sharedHosts)45        {46            this.requestData = requestData;47            this.dataSerializer = dataSerializer;48        }49        #region IProxyDiscoveryManager50        /// <inheritdoc/>51        public void Initialize(bool skipDefaultAdapters)52        {53            this.DoActionOnAllManagers((proxyManager) => proxyManager.Initialize(skipDefaultAdapters), doActionsInParallel: true);54        }55        /// <inheritdoc/>56        public void DiscoverTests(DiscoveryCriteria discoveryCriteria, ITestDiscoveryEventsHandler2 eventHandler)57        {58            this.actualDiscoveryCriteria = discoveryCriteria;59            // Set the enumerator for parallel yielding of sources60            // Whenever a concurrent executor becomes free, it picks up the next source using this enumerator61            this.sourceEnumerator = discoveryCriteria.Sources.GetEnumerator();62            this.availableTestSources = discoveryCriteria.Sources.Count();63            if (EqtTrace.IsVerboseEnabled)64            {65                EqtTrace.Verbose("ParallelProxyDiscoveryManager: Start discovery. Total sources: " + this.availableTestSources);66            }67            this.DiscoverTestsPrivate(eventHandler);68        }69        /// <inheritdoc/>70        public void Abort()71        {72            this.discoveryAbortRequested = true;73            this.DoActionOnAllManagers((proxyManager) => proxyManager.Abort(), doActionsInParallel: true);74        }75        /// <inheritdoc/>76        public void Close()77        {78            this.DoActionOnAllManagers(proxyManager => proxyManager.Close(), doActionsInParallel: true);79        }80        #endregion81        #region IParallelProxyDiscoveryManager methods82        /// <inheritdoc/>83        public bool HandlePartialDiscoveryComplete(IProxyDiscoveryManager proxyDiscoveryManager, long totalTests, IEnumerable<TestCase> lastChunk, bool isAborted)84        {85            var allDiscoverersCompleted = false;86            lock (this.discoveryStatusLockObject)87            {88                // Each concurrent Executor calls this method89                // So, we need to keep track of total discovery complete calls90                this.discoveryCompletedClients++;91                // If there are no more sources/testcases, a parallel executor is truly done with discovery92                allDiscoverersCompleted = this.discoveryCompletedClients == this.availableTestSources;93                if (EqtTrace.IsVerboseEnabled)94                {95                    EqtTrace.Verbose("ParallelProxyDiscoveryManager: HandlePartialDiscoveryComplete: Total completed clients = {0}, Discovery complete = {1}.", this.discoveryCompletedClients, allDiscoverersCompleted);96                }97            }98            /*99             If discovery is complete or discovery aborting was requsted by testPlatfrom(user)100             we need to stop all ongoing discoveries, because we want to separate aborting request101             when testhost crashed by itself and when user requested it (f.e. through TW)102             Schedule the clean up for managers and handlers.103            */104            if (allDiscoverersCompleted || discoveryAbortRequested)105            {106                // Reset enumerators107                this.sourceEnumerator = null;108                this.currentDiscoveryDataAggregator = null;109                this.currentDiscoveryEventsHandler = null;110                // Dispose concurrent executors111                this.UpdateParallelLevel(0);112                return true;113            }114            // Discovery is not complete.115            // First, clean up the used proxy discovery manager if the last run was aborted116            // or this run doesn't support shared hosts (netcore tests)117            if (!this.SharedHosts || isAborted)118            {119                if (EqtTrace.IsVerboseEnabled)120                {121                    EqtTrace.Verbose("ParallelProxyDiscoveryManager: HandlePartialDiscoveryComplete: Replace discovery manager. Shared: {0}, Aborted: {1}.", this.SharedHosts, isAborted);122                }123                this.RemoveManager(proxyDiscoveryManager);124                proxyDiscoveryManager = this.CreateNewConcurrentManager();125                var parallelEventsHandler = new ParallelDiscoveryEventsHandler(126                                               this.requestData,127                                               proxyDiscoveryManager,128                                               this.currentDiscoveryEventsHandler,129                                               this,130                                               this.currentDiscoveryDataAggregator);131                this.AddManager(proxyDiscoveryManager, parallelEventsHandler);132            }133            // Second, let's attempt to trigger discovery for the next source.134            this.DiscoverTestsOnConcurrentManager(proxyDiscoveryManager);135            return false;136        }137        #endregion138        private void DiscoverTestsPrivate(ITestDiscoveryEventsHandler2 discoveryEventsHandler)139        {140            this.currentDiscoveryEventsHandler = discoveryEventsHandler;141            // Reset the discovery complete data142            this.discoveryCompletedClients = 0;143            // One data aggregator per parallel discovery144            this.currentDiscoveryDataAggregator = new ParallelDiscoveryDataAggregator();145            foreach (var concurrentManager in this.GetConcurrentManagerInstances())146            {147                var parallelEventsHandler = new ParallelDiscoveryEventsHandler(148                                                this.requestData,149                                                concurrentManager,150                                                discoveryEventsHandler,151                                                this,152                                                this.currentDiscoveryDataAggregator);153                this.UpdateHandlerForManager(concurrentManager, parallelEventsHandler);154                this.DiscoverTestsOnConcurrentManager(concurrentManager);155            }156        }157        /// <summary>158        /// Triggers the discovery for the next data object on the concurrent discoverer159        /// Each concurrent discoverer calls this method, once its completed working on previous data160        /// </summary>161        /// <param name="ProxyDiscoveryManager">Proxy discovery manager instance.</param>162        private void DiscoverTestsOnConcurrentManager(IProxyDiscoveryManager proxyDiscoveryManager)163        {164            // Peek to see if we have sources to trigger a discovery165            if (this.TryFetchNextSource(this.sourceEnumerator, out string nextSource))166            {167                if (EqtTrace.IsVerboseEnabled)168                {169                    EqtTrace.Verbose("ProxyParallelDiscoveryManager: Triggering test discovery for next source: {0}", nextSource);170                }171                // Kick off another discovery task for the next source172                var discoveryCriteria = new DiscoveryCriteria(new[] { nextSource }, this.actualDiscoveryCriteria.FrequencyOfDiscoveredTestsEvent, this.actualDiscoveryCriteria.DiscoveredTestEventTimeout, this.actualDiscoveryCriteria.RunSettings);173                discoveryCriteria.TestCaseFilter = this.actualDiscoveryCriteria.TestCaseFilter;174                Task.Run(() =>175                    {176                        if (EqtTrace.IsVerboseEnabled)177                        {178                            EqtTrace.Verbose("ParallelProxyDiscoveryManager: Discovery started.");179                        }180                        proxyDiscoveryManager.DiscoverTests(discoveryCriteria, this.GetHandlerForGivenManager(proxyDiscoveryManager));181                    })182                    .ContinueWith(t =>183                    {184                        // Just in case, the actual discovery couldn't start for an instance. Ensure that185                        // we call discovery complete since we have already fetched a source. Otherwise186                        // discovery will not terminate187                        if (EqtTrace.IsErrorEnabled)188                        {189                            EqtTrace.Error("ParallelProxyDiscoveryManager: Failed to trigger discovery. Exception: " + t.Exception);190                        }191                        var handler = this.GetHandlerForGivenManager(proxyDiscoveryManager);192                        var testMessagePayload = new TestMessagePayload { MessageLevel = TestMessageLevel.Error, Message = t.Exception.ToString() };193                        handler.HandleRawMessage(this.dataSerializer.SerializePayload(MessageType.TestMessage, testMessagePayload));194                        handler.HandleLogMessage(TestMessageLevel.Error, t.Exception.ToString());195                        // Send discovery complete. Similar logic is also used in ProxyDiscoveryManager.DiscoverTests.196                        // Differences:197                        // Total tests must be zero here since parallel discovery events handler adds the count198                        // Keep `lastChunk` as null since we don't want a message back to the IDE (discovery didn't even begin)199                        // Set `isAborted` as true since we want this instance of discovery manager to be replaced200                        var discoveryCompleteEventsArgs = new DiscoveryCompleteEventArgs(-1, true);201                        handler.HandleDiscoveryComplete(discoveryCompleteEventsArgs, null);202                    },203                    TaskContinuationOptions.OnlyOnFaulted);204            }205            if (EqtTrace.IsVerboseEnabled)206            {207                EqtTrace.Verbose("ProxyParallelDiscoveryManager: No sources available for discovery.");208            }209        }210    }211}...

ProxyDiscoveryManager.cs

Source:ProxyDiscoveryManager.cs

...102                var rawMessage = this.dataSerializer.SerializePayload(MessageType.TestMessage, testMessagePayload);103                this.HandleRawMessage(rawMessage);104                // Log to vstest.console105                // Send a discovery complete to caller. Similar logic is also used in ParallelProxyDiscoveryManager.DiscoverTestsOnConcurrentManager106                // Aborted is `true`: in case of parallel discovery (or non shared host), an aborted message ensures another discovery manager107                // created to replace the current one. This will help if the current discovery manager is aborted due to irreparable error108                // and the test host is lost as well.109                this.HandleLogMessage(TestMessageLevel.Error, exception.Message);110                var discoveryCompleteEventsArgs = new DiscoveryCompleteEventArgs(-1, true);111                this.HandleDiscoveryComplete(discoveryCompleteEventsArgs, new List<ObjectModel.TestCase>());112            }113        }114        /// <inheritdoc/>115        public void Abort()116        {117            // This is no-op for the moment. There is no discovery abort message?118        }119        /// <inheritdoc/>120        public void HandleDiscoveryComplete(DiscoveryCompleteEventArgs discoveryCompleteEventArgs, IEnumerable<TestCase> lastChunk)121        {122            this.baseTestDiscoveryEventsHandler.HandleDiscoveryComplete(discoveryCompleteEventArgs, lastChunk);123        }124        /// <inheritdoc/>125        public void HandleDiscoveredTests(IEnumerable<TestCase> discoveredTestCases)126        {127            this.baseTestDiscoveryEventsHandler.HandleDiscoveredTests(discoveredTestCases);128        }129        /// <inheritdoc/>...

Abort

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client;7using Microsoft.VisualStudio.TestPlatform.ObjectModel;8using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;9using Microsoft.VisualStudio.TestPlatform.ObjectModel.Logging;10{11    {12        static void Main(string[] args)13        {14            ProxyDiscoveryManager discoveryManager = new ProxyDiscoveryManager();15            discoveryManager.Initialize();16            discoveryManager.DiscoverTests(new List<string> { "1.cs" }, null, new DiscoveryEventHandler());17            discoveryManager.Abort();18            Console.ReadLine();19        }20    }21    {22        public void HandleDiscoveryComplete(int totalTests, IEnumerable<TestCase> lastChunk, bool isAborted)23        {24            Console.WriteLine("Discovery complete");25        }26        public void HandleDiscoveredTests(IEnumerable<TestCase> discoveredTestCases)27        {28            Console.WriteLine("Discovered tests");29        }30        public void HandleLogMessage(TestMessageLevel level, string message)31        {32            Console.WriteLine("Log message");33        }34        public void HandleRawMessage(string rawMessage)35        {36            Console.WriteLine("Raw message");37        }38        public void HandleTestCaseStart(TestCase testCase)39        {40            Console.WriteLine("Test case start");41        }42    }43}44I have tried to use this code in my test project, but I can't find the Abort method in the ProxyDiscoveryManager class. I have also tried to use the Abort method of the ProxyExecutionManager class, but it doesn't work either. I have installed the Microsoft.TestPlatform.ObjectModel package (version 16.6.1) and the Microsoft.TestPlatform.TestHost package (version 16.6.1) in

Abort

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client;7using Microsoft.VisualStudio.TestPlatform.ObjectModel;8using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;9{10    {11        static void Main(string[] args)12        {13            var discoveryManager = new ProxyDiscoveryManager();14            var discoveryEvents = new DiscoveryEvents();15            var discoveryCriteria = new DiscoveryCriteria(new List<string> { "1.cs" }, 32, null);16            discoveryManager.DiscoverTests(discoveryCriteria, discoveryEvents);17            discoveryManager.Abort();18            Console.ReadLine();19        }20    }21    {22        public void HandleDiscoveryComplete(long totalTests, IEnumerable<TestCase> lastChunk, bool isAborted)23        {24            Console.WriteLine("Discovery Complete");25        }26        public void HandleDiscoveredTests(IEnumerable<TestCase> discoveredTestCases)27        {28            Console.WriteLine("Discovered Tests");29        }30        public void HandleLogMessage(TestMessageLevel level, string message)31        {32            Console.WriteLine("Log Message");33        }34        public void HandleRawMessage(string rawMessage)35        {36            Console.WriteLine("Raw Message");37        }38        public void HandleTestRunStatsChange(TestRunChangedEventArgs testRunChangedArgs)39        {40            Console.WriteLine("Test Run Stats Change");41        }42    }43}44using System;45using System.Collections.Generic;46using System.Linq;47using System.Text;48using System.Threading.Tasks;49using Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client;50using Microsoft.VisualStudio.TestPlatform.ObjectModel;51using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;52{53    {54        static void Main(string[] args)55        {56            var discoveryManager = new ProxyDiscoveryManager();57            var discoveryEvents = new DiscoveryEvents();58            var discoveryCriteria = new DiscoveryCriteria(new List<string> { "1.cs" }, 32, null);59            discoveryManager.DiscoverTests(discoveryCriteria, discoveryEvents);60            discoveryManager.Abort();61            Console.ReadLine();62        }63    }64    {65        public void HandleDiscoveryComplete(long totalTests, IEnumerable<TestCase> lastChunk, bool isAborted)66        {

Abort

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client;7using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;8using Microsoft.VisualStudio.TestPlatform.ObjectModel;9{10    {11        static void Main(string[] args)12        {13            var discoveryManager = new ProxyDiscoveryManager();14            var discoveryRequest = new DiscoveryRequest();15            discoveryManager.DiscoverTests(new List<string>() { "1.cs" }, null, discoveryRequest);16            discoveryManager.Abort();17        }18    }19}20using System;21using System.Collections.Generic;22using System.Linq;23using System.Text;24using System.Threading.Tasks;25using Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client;26using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;27using Microsoft.VisualStudio.TestPlatform.ObjectModel;28{29    {30        static void Main(string[] args)31        {32            var executionManager = new ProxyExecutionManager();33            var executionRequest = new TestRunRequest();34            executionManager.StartTestRun(new List<string>() { "1.cs" }, null, executionRequest);35            executionManager.Abort();36        }37    }38}39Error	CS0246	The type or namespace name 'ProxyDiscoveryManager' could not be found (are you missing a using directive or an assembly reference?)	ConsoleApp1	C:\Users\Yasser\Desktop\ConsoleApp1\ConsoleApp1\Program.cs	10	Active40Error	CS0246	The type or namespace name 'ProxyExecutionManager' could not be found (are you missing a using directive or an assembly reference?)	ConsoleApp1	C:\Users\Yasser\Desktop\ConsoleApp1\ConsoleApp1\Program.cs	15	Active

Abort

Using AI Code Generation

1using Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client;2using Microsoft.VisualStudio.TestPlatform.ObjectModel;3using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;4using Microsoft.VisualStudio.TestPlatform.ObjectModel.Engine;5using Microsoft.VisualStudio.TestPlatform.ObjectModel.Engine.ClientProtocol;6using Microsoft.VisualStudio.TestPlatform.ObjectModel.Engine.TesthostProtocol;7using Microsoft.VisualStudio.TestPlatform.ObjectModel.Logging;8using Microsoft.VisualStudio.TestPlatform.Utilities;9using Microsoft.VisualStudio.TestPlatform.Utilities.Helpers;10using Microsoft.VisualStudio.TestPlatform.Utilities.Helpers.Interfaces;11using System;12using System.Collections.Generic;13using System.Diagnostics;14using System.IO;15using System.Linq;16using System.Reflection;17using System.Threading.Tasks;18using System.Xml;19{20    {21        static void Main(string[] args)22        {23            Type proxyDiscoveryManagerType = typeof(ProxyDiscoveryManager);24            Type proxyDiscoveryManagerType2 = typeof(ProxyDiscoveryManager).GetTypeInfo().Assembly.GetType("Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client.ProxyDiscoveryManager");25            Type proxyDiscoveryManagerType3 = typeof(ProxyDiscoveryManager).GetTypeInfo().Assembly.GetType("Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client.ProxyDiscoveryManager", true);26            var proxyDiscoveryManager = (ProxyDiscoveryManager)Activator.CreateInstance(proxyDiscoveryManagerType3);

Abort

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6{7    {8        static void Main(string[] args)9        {10            Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client.ProxyDiscoveryManager proxyDiscoveryManager = new Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client.ProxyDiscoveryManager();11            proxyDiscoveryManager.Abort();12        }13    }14}15The type or namespace name 'TestPlatform' does not exist in the namespace 'Microsoft.VisualStudio' (are you missing an assembly reference?)

Abort

Using AI Code Generation

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using Microsoft.VisualStudio.TestPlatform.CrossPlatEngine.Client;7using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;8using Microsoft.VisualStudio.TestPlatform.ObjectModel;9using Microsoft.VisualStudio.TestPlatform.ObjectModel.Adapter;10using System.Threading;11using System.Diagnostics;12{13    {14        private static ManualResetEvent _discoveryComplete = new ManualResetEvent(false);15        private static ManualResetEvent _executionComplete = new ManualResetEvent(false);16        private static ManualResetEvent _executionComplete2 = new ManualResetEvent(false);17        private static ManualResetEvent _executionComplete3 = new ManualResetEvent(false);18        private static ManualResetEvent _executionComplete4 = new ManualResetEvent(false);19        private static ManualResetEvent _executionComplete5 = new ManualResetEvent(false);20        private static ManualResetEvent _executionComplete6 = new ManualResetEvent(false);21        private static ManualResetEvent _executionComplete7 = new ManualResetEvent(false);22        private static ManualResetEvent _executionComplete8 = new ManualResetEvent(false);23        private static ManualResetEvent _executionComplete9 = new ManualResetEvent(false);24        private static ManualResetEvent _executionComplete10 = new ManualResetEvent(false);25        private static ManualResetEvent _executionComplete11 = new ManualResetEvent(false);26        private static ManualResetEvent _executionComplete12 = new ManualResetEvent(false);27        private static ManualResetEvent _executionComplete13 = new ManualResetEvent(false);28        private static ManualResetEvent _executionComplete14 = new ManualResetEvent(false);29        private static ManualResetEvent _executionComplete15 = new ManualResetEvent(false);30        private static ManualResetEvent _executionComplete16 = new ManualResetEvent(false);31        private static ManualResetEvent _executionComplete17 = new ManualResetEvent(false);32        private static ManualResetEvent _executionComplete18 = new ManualResetEvent(false);33        private static ManualResetEvent _executionComplete19 = new ManualResetEvent(false);34        private static ManualResetEvent _executionComplete20 = new ManualResetEvent(false);35        private static ManualResetEvent _executionComplete21 = new ManualResetEvent(false);36        private static ManualResetEvent _executionComplete22 = new ManualResetEvent(false);37        private static ManualResetEvent _executionComplete23 = new ManualResetEvent(false);

Abort

Using AI Code Generation

1DiscoveryRequest discoveryRequest = new DiscoveryRequest();2discoveryRequest.DiscoveryCriteria = new DiscoveryCriteria();3discoveryRequest.DiscoveryCriteria.Sources = new List<string>() { "test.dll" };4discoveryRequest.DiscoveryCriteria.DiscoverySettings = new DiscoverySettings();5discoveryRequest.DiscoveryCriteria.DiscoverySettings.DiscoverTests = true;6discoveryRequest.DiscoveryCriteria.DiscoverySettings.DiscoverSources = true;7discoveryRequest.DiscoveryCriteria.DiscoverySettings.DiscoverExecutables = true;8discoveryRequest.DiscoveryCriteria.DiscoverySettings.DiscoverAdapters = true;9discoveryRequest.DiscoveryCriteria.DiscoverySettings.DiscoverSettings = true;10discoveryRequest.DiscoveryCriteria.DiscoverySettings.DiscoverRunSettings = true;11discoveryRequest.DiscoveryCriteria.DiscoverySettings.DiscoverDesignMode = true;12discoveryRequest.DiscoveryCriteria.DiscoverySettings.DiscoverAssemblies = true;

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.