| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading/tests/ |
| H A D | BarrierCancellationTests.cs | 40 CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); in BarrierCancellationTestsCancelAfterWait_Negative()
41 CancellationToken cancellationToken = cancellationTokenSource.Token; in BarrierCancellationTestsCancelAfterWait_Negative()
46 Task.Run(() => cancellationTokenSource.Cancel()); in BarrierCancellationTestsCancelAfterWait_Negative()
61 CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); in BarrierCancellationTestsCancelAfterWait()
62 CancellationToken cancellationToken = cancellationTokenSource.Token; in BarrierCancellationTestsCancelAfterWait()
67 Task.Run(() => cancellationTokenSource.Cancel()); in BarrierCancellationTestsCancelAfterWait()
|
| H A D | ManualResetEventSlimCancellationTests.cs | 35 CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); in CancelAfterWait()
36 CancellationToken cancellationToken = cancellationTokenSource.Token; in CancelAfterWait()
44 cancellationTokenSource.Cancel(); in CancelAfterWait()
|
| H A D | CountdownEventCancellationTests.cs | 33 CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); in CancelAfterWait()
34 CancellationToken cancellationToken = cancellationTokenSource.Token; in CancelAfterWait()
40 cancellationTokenSource.Cancel(); in CancelAfterWait()
|
| H A D | SemaphoreSlimCancellationTests.cs | 32 CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); in CancelAfterWait()
33 CancellationToken cancellationToken = cancellationTokenSource.Token; in CancelAfterWait()
41 cancellationTokenSource.Cancel(); in CancelAfterWait()
|
| /dports/devel/grpc/grpc-1.42.0/src/csharp/Grpc.IntegrationTesting/ |
| H A D | XdsInteropClientTest.cs | 96 var cancellationTokenSource = new CancellationTokenSource(); in SmokeTest()
97 var runChannelsTask = xdsInteropClient.RunChannelsAsync(cancellationTokenSource.Token); in SmokeTest()
127 cancellationTokenSource.Cancel(); in SmokeTest()
141 var cancellationTokenSource = new CancellationTokenSource(); in HostnameReadFromResponseHeaders()
142 var runChannelsTask = xdsInteropClient.RunChannelsAsync(cancellationTokenSource.Token); in HostnameReadFromResponseHeaders()
154 cancellationTokenSource.Cancel(); in HostnameReadFromResponseHeaders()
|
| /dports/devel/grpc134/grpc-1.34.1/src/csharp/Grpc.IntegrationTesting/ |
| H A D | XdsInteropClientTest.cs | 96 var cancellationTokenSource = new CancellationTokenSource(); in SmokeTest()
97 var runChannelsTask = xdsInteropClient.RunChannelsAsync(cancellationTokenSource.Token); in SmokeTest()
127 cancellationTokenSource.Cancel(); in SmokeTest()
141 var cancellationTokenSource = new CancellationTokenSource(); in HostnameReadFromResponseHeaders()
142 var runChannelsTask = xdsInteropClient.RunChannelsAsync(cancellationTokenSource.Token); in HostnameReadFromResponseHeaders()
154 cancellationTokenSource.Cancel(); in HostnameReadFromResponseHeaders()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel/System/ServiceModel/Channels/ |
| H A D | HttpPipeline.cs | 404 HttpPipelineCancellationTokenSource cancellationTokenSource; field in System.ServiceModel.Channels.HttpPipeline.NormalHttpPipeline
414 … this.cancellationTokenSource = new HttpPipelineCancellationTokenSource(httpRequestContext); in NormalHttpPipeline()
498 this.cancellationTokenSource.Cancel(); in Cancel()
532 this.cancellationTokenSource.Cancel(); in BeginProcessInboundRequest()
568 this.cancellationTokenSource.CancelAfter(Timeout.Infinite); in OnParseComplete()
577 …this.cancellationTokenSource.CancelAfter(httpRequestContext.Listener.RequestInitializationTimeout); in SetPipelineIncomingTimeout()
584 this.cancellationTokenSource.Dispose(); in OnClose()
615 this.cancellationTokenSource.Dispose(); in SendHttpPipelineResponse()
751 … this.cancellationTokenSource.CancelAfter(TimeoutHelper.ToMilliseconds(this.defaultSendTimeout)); in CompleteChannelModelIntegrationHandlerTask()
781 …this.cancellationTokenSource.CancelAfter(TimeoutHelper.ToMilliseconds((httpRequestContext.Listener… in SetPipelineIncomingTimeout()
[all …]
|
| H A D | WebSocketTransportDuplexSessionChannel.cs | 210 …IOThreadCancellationTokenSource cancellationTokenSource = new IOThreadCancellationTokenSource(help… in StartWritingBufferedMessage()
220 … = this.WebSocket.SendAsync(messageData, outgoingMessageType, true, cancellationTokenSource.Token); in StartWritingBufferedMessage()
232 cancellationTokenSource.Dispose(); in StartWritingBufferedMessage()
285 …IOThreadCancellationTokenSource cancellationTokenSource = new IOThreadCancellationTokenSource(time… in BeginCloseOutput()
286 Task task = this.CloseOutputAsync(cancellationTokenSource.Token); in BeginCloseOutput()
293 cancellationTokenSource.Dispose(); in BeginCloseOutput()
1190 …IOThreadCancellationTokenSource cancellationTokenSource = new IOThreadCancellationTokenSource(help… in BeginRead()
1193 cancellationTokenSource.Dispose(); in BeginRead()
1348 …IOThreadCancellationTokenSource cancellationTokenSource = new IOThreadCancellationTokenSource(this… in BeginWrite()
1356 cancellationTokenSource.Dispose(); in BeginWrite()
[all …]
|
| /dports/devel/grpc130/grpc-1.30.2/src/csharp/Grpc.IntegrationTesting/ |
| H A D | XdsInteropClientTest.cs | 95 var cancellationTokenSource = new CancellationTokenSource(); in SmokeTest()
96 var runChannelsTask = xdsInteropClient.RunChannelsAsync(cancellationTokenSource.Token); in SmokeTest()
120 cancellationTokenSource.Cancel(); in SmokeTest()
|
| /dports/devel/msbuild/msbuild-0.06/src/Xunit.NetCore.Extensions/AssemblyFixtureSupport/ |
| H A D | XunitTestMethodRunnerWithAssemblyFixture.cs | 25 CancellationTokenSource cancellationTokenSource, in XunitTestMethodRunnerWithAssemblyFixture() argument
27 …ethod, testCases, diagnosticMessageSink, messageBus, aggregator, cancellationTokenSource, construc… in XunitTestMethodRunnerWithAssemblyFixture()
|
| H A D | XunitTestCollectionRunnerWithAssemblyFixture.cs | 24 … CancellationTokenSource cancellationTokenSource) in XunitTestCollectionRunnerWithAssemblyFixture() argument
25 …testCases, diagnosticMessageSink, messageBus, testCaseOrderer, aggregator, cancellationTokenSource) in XunitTestCollectionRunnerWithAssemblyFixture()
|
| H A D | XunitTestAssemblyRunnerWithAssemblyFixture.cs | 57 … CancellationTokenSource cancellationTokenSource) in RunTestCollectionAsync() argument
59 …essageBus, TestCaseOrderer, new ExceptionAggregator(Aggregator), cancellationTokenSource).RunAsync… in RunTestCollectionAsync()
|
| H A D | XunitTestClassRunnerWithAssemblyFixture.cs | 21 …CancellationTokenSource cancellationTokenSource, IDictionary<Type, object> collectionFixtureMappin… in XunitTestClassRunnerWithAssemblyFixture() argument
22 … diagnosticMessageSink, messageBus, testCaseOrderer, aggregator, cancellationTokenSource, collecti… in XunitTestClassRunnerWithAssemblyFixture()
|
| /dports/devel/msbuild/msbuild-0.06/src/Xunit.NetCore.Extensions/ |
| H A D | SkippedTestCase.cs | 47 ExceptionAggregator aggregator, CancellationTokenSource cancellationTokenSource) in RunAsync() argument
49 …nstructorArguments, TestMethodArguments, messageBus, aggregator, cancellationTokenSource).RunAsync… in RunAsync()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/csharp/Grpc.Core/Internal/ |
| H A D | AsyncCallServer.cs | 37 readonly CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); field in Grpc.Core.Internal.AsyncCallServer
165 return cancellationTokenSource.Token;
231 cancellationTokenSource.Cancel(); in HandleFinishedServerside()
|
| /dports/devel/grpc134/grpc-1.34.1/src/csharp/Grpc.Core/Internal/ |
| H A D | AsyncCallServer.cs | 37 readonly CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); field in Grpc.Core.Internal.AsyncCallServer
168 return cancellationTokenSource.Token;
234 cancellationTokenSource.Cancel(); in HandleFinishedServerside()
|
| /dports/devel/grpc/grpc-1.42.0/src/csharp/Grpc.Core/Internal/ |
| H A D | AsyncCallServer.cs | 37 readonly CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); field in Grpc.Core.Internal.AsyncCallServer
168 return cancellationTokenSource.Token;
234 cancellationTokenSource.Cancel(); in HandleFinishedServerside()
|
| /dports/devel/grpc130/grpc-1.30.2/src/csharp/Grpc.Core/Internal/ |
| H A D | AsyncCallServer.cs | 37 readonly CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); field in Grpc.Core.Internal.AsyncCallServer
168 return cancellationTokenSource.Token;
234 cancellationTokenSource.Cancel(); in HandleFinishedServerside()
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/csharp/src/Apache.Arrow.Flight/Internal/ |
| H A D | FlightDataStream.cs | 57 CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); in SendSchema()
58 …await WriteMessageAsync(MessageHeader.Schema, offset, 0, cancellationTokenSource.Token).ConfigureA… in SendSchema()
|
| /dports/databases/arrow/apache-arrow-6.0.1/csharp/src/Apache.Arrow.Flight/Internal/ |
| H A D | FlightDataStream.cs | 57 CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); in SendSchema()
58 …await WriteMessageAsync(MessageHeader.Schema, offset, 0, cancellationTokenSource.Token).ConfigureA… in SendSchema()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Parallel/tests/ |
| H A D | ParallelForTests.cs | 1250 var cancellationTokenSource = new CancellationTokenSource(); in CancelForIntTest()
1253 … var parallelOptions = new ParallelOptions { CancellationToken = cancellationTokenSource.Token }; in CancelForIntTest()
1266 if (!cancellationTokenSource.IsCancellationRequested) in CancelForIntTest()
1268 Task.Run(() => cancellationTokenSource.Cancel()); in CancelForIntTest()
1287 var cancellationTokenSource = new CancellationTokenSource(); in CancelForLongTest()
1290 … var parallelOptions = new ParallelOptions { CancellationToken = cancellationTokenSource.Token }; in CancelForLongTest()
1303 if (!cancellationTokenSource.IsCancellationRequested) in CancelForLongTest()
1305 Task.Run(() => cancellationTokenSource.Cancel()); in CancelForLongTest()
1332 var cancellationTokenSource = new CancellationTokenSource(); in CancelForEachTest()
1347 if (!cancellationTokenSource.IsCancellationRequested) in CancelForEachTest()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Data.Odbc/src/Common/System/Data/ProviderBase/ |
| H A D | DbConnectionFactory.cs | 185 … CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); in TryGetConnection()
225 … }, cancellationTokenSource.Token, TaskContinuationOptions.LongRunning, TaskScheduler.Default); in TryGetConnection()
235 cancellationTokenSource.CancelAfter(connectionTimeoutMilliseconds); in TryGetConnection()
241 cancellationTokenSource.Dispose(); in TryGetConnection()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Data.SqlClient/src/System/Data/ProviderBase/ |
| H A D | DbConnectionFactory.cs | 188 … CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); in TryGetConnection()
237 … }, cancellationTokenSource.Token, TaskContinuationOptions.LongRunning, TaskScheduler.Default); in TryGetConnection()
247 cancellationTokenSource.CancelAfter(connectionTimeoutMilliseconds); in TryGetConnection()
253 cancellationTokenSource.Dispose(); in TryGetConnection()
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Data/System/Data/ProviderBase/ |
| H A D | DbConnectionFactory.cs | 222 … CancellationTokenSource cancellationTokenSource = new CancellationTokenSource(); in TryGetConnection()
262 … }, cancellationTokenSource.Token, TaskContinuationOptions.LongRunning, TaskScheduler.Default); in TryGetConnection()
271 cancellationTokenSource.CancelAfter(connectionTimeoutMilliseconds); in TryGetConnection()
276 cancellationTokenSource.Dispose(); in TryGetConnection()
|
| /dports/lang/mono/mono-5.10.1.57/external/corert/src/System.Private.CoreLib/src/System/Threading/ |
| H A D | CancellationTokenSource.cs | 1015 …Callback, ExecutionContext targetExecutionContext, CancellationTokenSource cancellationTokenSource, in WithSyncContext() argument
1017 base(callback, stateForCallback, targetExecutionContext, cancellationTokenSource) in WithSyncContext()
1024 …Callback, ExecutionContext targetExecutionContext, CancellationTokenSource cancellationTokenSource) in CancellationCallbackInfo() argument
1029 CancellationTokenSource = cancellationTokenSource; in CancellationCallbackInfo()
|