1 write to _context
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\Http1MessageBody.cs (1)
23_context = context;
47 references to _context
Microsoft.AspNetCore.Server.Kestrel.Core (47)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (9)
97var awaitable = _context.Input.ReadAsync(); 108if (_context.RequestTimedOut) 140KestrelMetrics.AddConnectionEndReason(_context.MetricsContext, ConnectionEndReason.UnexpectedEndOfRequestContent); 146_context.Input.AdvanceTo(consumed, examined); 149awaitable = _context.Input.ReadAsync(); 164if (!_context.HasStartedConsumingRequestBody) 189_context.Input.CancelPendingRead(); 275if (_context.TakeMessageHeaders(ref reader, trailers: true)) 467_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)
46_context.ReportApplicationError(exception); 67_context.SetBadRequestState(ex); 72Log.RequestBodyDrainBodyReaderInvalidState(_context.ConnectionIdFeature, _context.TraceIdentifier, ex); 75_context.StopProcessingNextRequest(ConnectionEndReason.InvalidBodyReaderState); 84Log.RequestBodyNotEntirelyRead(_context.ConnectionIdFeature, _context.TraceIdentifier); 86_context.TimeoutControl.SetTimeout(Constants.RequestBodyDrainTimeout, TimeoutReason.RequestBodyDrain); 99_context.SetBadRequestState(ex); 103Log.RequestBodyDrainTimedOut(_context.ConnectionIdFeature, _context.TraceIdentifier); 107Log.RequestBodyDrainBodyReaderInvalidState(_context.ConnectionIdFeature, _context.TraceIdentifier, ex); 110_context.StopProcessingNextRequest(ConnectionEndReason.InvalidBodyReaderState); 114_context.TimeoutControl.CancelTimeout(); 120_context.DisableKeepAlive(ConnectionEndReason.MaxRequestBodySizeExceeded); 231KestrelMetrics.AddConnectionEndReason(_context.MetricsContext, ConnectionEndReason.UnexpectedEndOfRequestContent); 238((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);