105 references to ValueTaskSourceStatus
http2cat (3)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
IIS.FunctionalTests (3)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
IIS.LongTests (3)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
IIS.NewHandler.FunctionalTests (3)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
IIS.NewShim.FunctionalTests (3)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
IIS.ShadowCopy.Tests (3)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
IISExpress.FunctionalTests (3)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
InMemory.FunctionalTests (5)
TestTransport\InMemoryTransportConnection.cs (5)
178public ValueTaskSourceStatus GetStatus(short token) 182return ValueTaskSourceStatus.Canceled; 186return ValueTaskSourceStatus.Faulted; 190return ValueTaskSourceStatus.Succeeded; 192return ValueTaskSourceStatus.Pending;
Microsoft.AspNetCore.ConcurrencyLimiter.Tests (2)
MiddlewareTests.cs (2)
227public ValueTaskSourceStatus GetStatus(short token) 229return ValueTaskSourceStatus.Succeeded;
Microsoft.AspNetCore.Server.HttpSys (1)
AsyncAcceptContext.cs (1)
278public ValueTaskSourceStatus GetStatus(short token)
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (3)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
Microsoft.AspNetCore.Server.IIS (9)
Core\IO\AsyncIOOperation.cs (4)
21public ValueTaskSourceStatus GetStatus(short token) 25return ValueTaskSourceStatus.Pending; 28return _exception != null ? ValueTaskSourceStatus.Succeeded : ValueTaskSourceStatus.Faulted;
Core\NativeSafeHandle.cs (2)
26if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending) 39public ValueTaskSourceStatus GetStatus(short token)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
Microsoft.AspNetCore.Server.Kestrel.Core (4)
Internal\Http3\Http3Stream.cs (1)
89public bool IsDraining => _appCompletedTaskSource.GetStatus() != ValueTaskSourceStatus.Pending; // Draining starts once app is complete
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (4)
Internal\SocketAwaitableEventArgs.cs (4)
64public ValueTaskSourceStatus GetStatus(short token) 66return !ReferenceEquals(_continuation, _continuationCompleted) ? ValueTaskSourceStatus.Pending : 67SocketError == SocketError.Success ? ValueTaskSourceStatus.Succeeded : 68ValueTaskSourceStatus.Faulted;
Microsoft.AspNetCore.Shared.Tests (3)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (3)
23public ValueTaskSourceStatus GetStatus(short token) => _core.GetStatus(token); 26public ValueTaskSourceStatus GetStatus() => _core.GetStatus(_core.Version); 30if (_core.GetStatus(_core.Version) == ValueTaskSourceStatus.Pending)
mscorlib (1)
mscorlib.cs (1)
111[assembly:System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.ValueTaskSourceStatus))]
netstandard (1)
netstandard.cs (1)
2116[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.ValueTaskSourceStatus))]
System.IO.Pipelines (10)
System\IO\Pipelines\Pipe.cs (8)
902internal ValueTaskSourceStatus GetReadAsyncStatus() 908return ValueTaskSourceStatus.Faulted; 911return ValueTaskSourceStatus.Succeeded; 913return ValueTaskSourceStatus.Pending; 994internal ValueTaskSourceStatus GetFlushAsyncStatus() 1000return ValueTaskSourceStatus.Faulted; 1003return ValueTaskSourceStatus.Succeeded; 1005return ValueTaskSourceStatus.Pending;
System\IO\Pipelines\Pipe.DefaultPipeReader.cs (1)
40public ValueTaskSourceStatus GetStatus(short token) => _pipe.GetReadAsyncStatus();
System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (1)
40public ValueTaskSourceStatus GetStatus(short token) => _pipe.GetFlushAsyncStatus();
System.Private.CoreLib (30)
src\libraries\System.Private.CoreLib\src\Microsoft\Win32\SafeHandles\SafeFileHandle.ThreadPoolValueTaskSource.cs (1)
59public ValueTaskSourceStatus GetStatus(short token) =>
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\PoolingAsyncValueTaskMethodBuilderT.cs (1)
257public ValueTaskSourceStatus GetStatus(short token) => _valueTaskSource.GetStatus(token);
src\libraries\System.Private.CoreLib\src\System\Threading\PeriodicTimer.cs (1)
302ValueTaskSourceStatus IValueTaskSource<bool>.GetStatus(short token) => _mrvtsc.GetStatus(token);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\IValueTaskSource.cs (2)
48ValueTaskSourceStatus GetStatus(short token); 68ValueTaskSourceStatus GetStatus(short token);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\ManualResetValueTaskSourceCore.cs (5)
84public ValueTaskSourceStatus GetStatus(short token) 88Volatile.Read(ref _continuation) is null || !_completed ? ValueTaskSourceStatus.Pending : 89_error is null ? ValueTaskSourceStatus.Succeeded : 90_error.SourceException is OperationCanceledException ? ValueTaskSourceStatus.Canceled : 91ValueTaskSourceStatus.Faulted;
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (2)
6943Debug.Assert(_waitForNextCompletedTask.GetStatus(_waitForNextCompletedTask.Version) == ValueTaskSourceStatus.Pending); 6952ValueTaskSourceStatus IValueTaskSource.GetStatus(short token) => _waitForNextCompletedTask.GetStatus(token);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ValueTask.cs (18)
192ValueTaskSourceStatus status = t.GetStatus(_token); 193if (status != ValueTaskSourceStatus.Pending) 209if (status == ValueTaskSourceStatus.Canceled) 255ValueTaskSourceStatus status = source.GetStatus(vtst._token); 263if (status == ValueTaskSourceStatus.Canceled) 313return Unsafe.As<IValueTaskSource>(obj).GetStatus(_token) != ValueTaskSourceStatus.Pending; 336return Unsafe.As<IValueTaskSource>(obj).GetStatus(_token) == ValueTaskSourceStatus.Succeeded; 358return Unsafe.As<IValueTaskSource>(obj).GetStatus(_token) == ValueTaskSourceStatus.Faulted; 385return Unsafe.As<IValueTaskSource>(obj).GetStatus(_token) == ValueTaskSourceStatus.Canceled; 601ValueTaskSourceStatus status = t.GetStatus(_token); 602if (status != ValueTaskSourceStatus.Pending) 617if (status == ValueTaskSourceStatus.Canceled) 663ValueTaskSourceStatus status = source.GetStatus(vtst._token); 670if (status == ValueTaskSourceStatus.Canceled) 720return Unsafe.As<IValueTaskSource<TResult>>(obj).GetStatus(_token) != ValueTaskSourceStatus.Pending; 743return Unsafe.As<IValueTaskSource<TResult>>(obj).GetStatus(_token) == ValueTaskSourceStatus.Succeeded; 765return Unsafe.As<IValueTaskSource<TResult>>(obj).GetStatus(_token) == ValueTaskSourceStatus.Faulted; 792return Unsafe.As<IValueTaskSource<TResult>>(obj).GetStatus(_token) == ValueTaskSourceStatus.Canceled;
System.Runtime (1)
artifacts\obj\System.Runtime\Debug\net10.0\System.Runtime.Forwards.cs (1)
819[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.ValueTaskSourceStatus))]
System.ServiceModel.UnixDomainSocket (4)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (4)
106public ValueTaskSourceStatus GetStatus(short token) 108return !ReferenceEquals(_continuation, _continuationCompleted) ? ValueTaskSourceStatus.Pending : 109SocketError == SocketError.Success ? ValueTaskSourceStatus.Succeeded : 110ValueTaskSourceStatus.Faulted;
System.Threading.Channels (5)
System\Threading\Channels\AsyncOperation.cs (5)
430public ValueTaskSourceStatus GetStatus(short token) 438!IsCompleted ? ValueTaskSourceStatus.Pending : 439_error is null ? ValueTaskSourceStatus.Succeeded : 440_error.SourceException is OperationCanceledException ? ValueTaskSourceStatus.Canceled : 441ValueTaskSourceStatus.Faulted;
System.Threading.Tasks.Extensions (1)
System.Threading.Tasks.Extensions.cs (1)
14[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.ValueTaskSourceStatus))]