Buffer

Otlp\Http\OtlpHttpEndpointsBuilder.cs (5)

266if (result.Buffer.Length > MaxRequestSize) 280httpContext.Request.BodyReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 284return exporter(result.Buffer); 290httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End);

Dcp\DcpHost.cs (2)

409LogLines(result.Buffer, out var position); 411reader.AdvanceTo(position, result.Buffer.End);

Internal\Transports\LongPollingServerTransport.cs (1)

37var buffer = result.Buffer;

Internal\Transports\ServerSentEventsServerTransport.cs (1)

52var buffer = result.Buffer;

Internal\Transports\WebSocketsServerTransport.cs (1)

209var buffer = result.Buffer;

Internal\Http\Http1ChunkedEncodingMessageBody.cs (3)

52CountBytesRead(readResult.Buffer.Length); 77StopTimingRead(_readResult.Buffer.Length); 116var readableBuffer = result.Buffer;

Internal\Http\Http1Connection.cs (8)

854var reader = new SequenceReader<byte>(result.Buffer); 870var ex = CreateBadRequestException(parseResult, result.Buffer); 871HandleBadRequest(result.Buffer, ex); 882HandleBadRequest(result.Buffer, ex); 895Input.AdvanceTo(reader.Position, isConsumed ? reader.Position : result.Buffer.End); 906HandleBadRequest(result.Buffer, RequestRejectionReason.InvalidRequestLine); 910HandleBadRequest(result.Buffer, RequestRejectionReason.MalformedRequestInvalidHeaders); 926HandleBadRequest(result.Buffer, RequestRejectionReason.RequestHeadersTimeout);

Internal\Http\Http1ContentLengthMessageBody.cs (9)

39return new ReadResult(_readResult.Buffer, Interlocked.Exchange(ref _userCanceled, 0) == 1, isCompleted: true); 78_context.Input.AdvanceTo(_readResult.Buffer.Start); 126readResult = new ReadResult(_readResult.Buffer, Interlocked.Exchange(ref _userCanceled, 0) == 1, isCompleted: true); 151_context.Input.AdvanceTo(_readResult.Buffer.Start); 162_context.Input.AdvanceTo(_readResult.Buffer.Start); 187var initialLength = _readResult.Buffer.Length; 197_readResult.Buffer.Slice(0, maxLength), 216var buffer = _readResult.Buffer.Slice(consumed, _readResult.Buffer.End);

Internal\Http\Http1MessageBody.cs (2)

57AdvanceTo(readResult.Buffer.End); 96AdvanceTo(result.Buffer.End);

Internal\Http\HttpRequestStream.cs (1)

125var buffer = result.Buffer;

Internal\Http\MessageBody.cs (7)

286examinedLength = readResult.Buffer.Slice(readResult.Buffer.Start, examined).Length; 291consumedLength = readResult.Buffer.Slice(readResult.Buffer.Start, consumed).Length; 292examinedLength = consumedLength + readResult.Buffer.Slice(consumed, examined).Length; 295if (examined.Equals(readResult.Buffer.End)) 301totalLength = readResult.Buffer.Length;

Internal\Http2\Http2Connection.cs (5)

325var buffer = result.Buffer; 558var readableBuffer = result.Buffer; 1899if ((readResult.IsCompleted && readResult.Buffer.Length == 0) || readResult.IsCanceled) 1907var copyAmount = (int)Math.Min(outputBuffer.Length, readResult.Buffer.Length); 1908var bufferSlice = readResult.Buffer.Slice(0, copyAmount);

Internal\Http2\Http2FrameWriter.cs (1)

193var buffer = readResult.Buffer;

Internal\Http2\Http2MessageBody.cs (2)

93CountBytesRead(readResult.Buffer.Length); 120StopTimingRead(_readResult.Buffer.Length);

Internal\Http3\Http3ControlStream.cs (2)

161var readableBuffer = result.Buffer; 264var readableBuffer = result.Buffer;

Internal\Http3\Http3MessageBody.cs (2)

61CountBytesRead(readResult.Buffer.Length); 88StopTimingRead(_readResult.Buffer.Length);

Internal\Http3\Http3OutputProducer.cs (5)

425if (readResult.Buffer.Length > 0) 427flushResult = await _frameWriter.WriteDataAsync(readResult.Buffer); 435if (readResult.Buffer.Length != 0) 450flushResult = await _frameWriter.WriteDataAsync(readResult.Buffer); 453_pipeReader.AdvanceTo(readResult.Buffer.End);

Internal\Http3\Http3PendingStream.cs (1)

57var readableBuffer = result.Buffer;

Internal\Http3\Http3Stream.cs (1)

644var readableBuffer = result.Buffer;

Middleware\TlsListener.cs (1)

34var buffer = result.Buffer;

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

Internal\QuicStreamContext.cs (1)

397var buffer = result.Buffer;

HubConnectionContext.cs (1)

549var buffer = result.Buffer;

HubConnectionHandler.cs (1)

274var buffer = result.Buffer;

FormPipeReader.cs (1)

98var buffer = readResult.Buffer;

System\IO\Pipelines\PipeReader.cs (4)

71ReadOnlySequence<byte> buffer = result.Buffer; 86/// The <see cref="System.IO.Pipelines.ReadResult.Buffer" /> previously returned from <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> must not be accessed after this call. 96/// The <see cref="System.IO.Pipelines.ReadResult.Buffer" /> previously returned from <see cref="System.IO.Pipelines.PipeReader.ReadAsync(System.Threading.CancellationToken)" /> must not be accessed after this call. 237ReadOnlySequence<byte> buffer = result.Buffer;

System\IO\Pipelines\PipeReaderStream.cs (1)

118ReadOnlySequence<byte> sequence = result.Buffer;

System\IO\Pipelines\StreamPipeReader.cs (1)

228|| readResult.Buffer.Length >= minimumSize

System\Text\Json\Serialization\PipeReadBufferState.cs (1)

64bufferState._sequence = readResult.Buffer;