3 writes to _currentFlushTcs
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (3)
134_currentFlushTcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously); 168_currentFlushTcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously); 315_currentFlushTcs = null;
15 references to _currentFlushTcs
Microsoft.AspNetCore.Server.Kestrel.Core (15)
Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (15)
62Debug.Assert(_currentFlushTcs == null, "There should not be a pending flush."); 70if (_currentFlushTcs == null && _head == null) 81if (_currentFlushTcs == null && _head == null) 92if (_currentFlushTcs == null && _head == null) 111if (_currentFlushTcs != null) 113return new ValueTask<FlushResult>(_currentFlushTcs.Task); 125if (_currentFlushTcs != null) 135var result = new ValueTask<FlushResult>(_currentFlushTcs.Task); 163Debug.Assert(_currentFlushTcs != null); 166_currentFlushTcs.SetResult(flushResult); 199if (_currentFlushTcs == null) 226if (_currentFlushTcs == null) 305Debug.Assert(_currentFlushTcs != null); 308_currentFlushTcs.SetException(flushEx); 312_currentFlushTcs.SetResult(flushResult);