1 write to _context
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\Http1MessageBody.cs (1)
25_context = context;
47 references to _context
Microsoft.AspNetCore.Server.Kestrel.Core (47)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (9)
100var awaitable = _context.Input.ReadAsync(); 111if (_context.RequestTimedOut) 143KestrelMetrics.AddConnectionEndReason(_context.MetricsContext, ConnectionEndReason.UnexpectedEndOfRequestContent); 149_context.Input.AdvanceTo(consumed, examined); 152awaitable = _context.Input.ReadAsync(); 167if (!_context.HasStartedConsumingRequestBody) 192_context.Input.CancelPendingRead(); 278if (_context.TakeMessageHeaders(ref reader, trailers: true)) 498_context.OnTrailersComplete();
Internal\Http\Http1ContentLengthMessageBody.cs (15)
45if (_context.RequestTimedOut) 60var readAwaitable = _context.Input.ReadAsync(cancellationToken); 79_context.Input.AdvanceTo(_readResult.Buffer.Start); 83if (_context.RequestTimedOut) 131if (_context.RequestTimedOut) 141if (!_context.Input.TryRead(out _readResult)) 152_context.Input.AdvanceTo(_readResult.Buffer.Start); 163_context.Input.AdvanceTo(_readResult.Buffer.Start); 224_context.Input.AdvanceTo(consumed); 226_context.OnTrailersComplete(); 242_context.Input.AdvanceTo(consumed, examined); 247var maxRequestBodySize = _context.MaxRequestBodySize; 250_context.DisableKeepAlive(ConnectionEndReason.MaxRequestBodySizeExceeded); 258_context.Input.CancelPendingRead(); 276if (_context.RequestTimedOut)
Internal\Http\Http1MessageBody.cs (18)
48_context.ReportApplicationError(exception); 69_context.SetBadRequestState(ex); 74Log.RequestBodyDrainBodyReaderInvalidState(_context.ConnectionIdFeature, _context.TraceIdentifier, ex); 77_context.StopProcessingNextRequest(ConnectionEndReason.InvalidBodyReaderState); 86Log.RequestBodyNotEntirelyRead(_context.ConnectionIdFeature, _context.TraceIdentifier); 88_context.TimeoutControl.SetTimeout(Constants.RequestBodyDrainTimeout, TimeoutReason.RequestBodyDrain); 101_context.SetBadRequestState(ex); 105Log.RequestBodyDrainTimedOut(_context.ConnectionIdFeature, _context.TraceIdentifier); 109Log.RequestBodyDrainBodyReaderInvalidState(_context.ConnectionIdFeature, _context.TraceIdentifier, ex); 112_context.StopProcessingNextRequest(ConnectionEndReason.InvalidBodyReaderState); 116_context.TimeoutControl.CancelTimeout(); 122_context.DisableKeepAlive(ConnectionEndReason.MaxRequestBodySizeExceeded); 247KestrelMetrics.AddConnectionEndReason(_context.MetricsContext, ConnectionEndReason.UnexpectedEndOfRequestContent); 254((IHttpOutputAborter)_context).OnInputOrOutputCompleted();
Internal\Http\Http1UpgradeMessageBody.cs (5)
40_context.Input.AdvanceTo(consumed, examined); 46_context.Input.CancelPendingRead(); 64if (!_context.Input.TryRead(out readResult)) 80var readTask = _context.Input.ReadAsync(cancellationToken); 102readResult = await _context.Input.ReadAsync(cancellationToken);