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)
44if (_context.RequestTimedOut) 59var readAwaitable = _context.Input.ReadAsync(cancellationToken); 78_context.Input.AdvanceTo(_readResult.Buffer.Start); 82if (_context.RequestTimedOut) 130if (_context.RequestTimedOut) 140if (!_context.Input.TryRead(out _readResult)) 151_context.Input.AdvanceTo(_readResult.Buffer.Start); 162_context.Input.AdvanceTo(_readResult.Buffer.Start); 223_context.Input.AdvanceTo(consumed); 225_context.OnTrailersComplete(); 241_context.Input.AdvanceTo(consumed, examined); 246var maxRequestBodySize = _context.MaxRequestBodySize; 249_context.DisableKeepAlive(ConnectionEndReason.MaxRequestBodySizeExceeded); 257_context.Input.CancelPendingRead(); 275if (_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); 101readResult = await _context.Input.ReadAsync(cancellationToken);