End

Otlp\Http\OtlpHttpEndpointsBuilder.cs (2)

205httpContext.Request.BodyReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 215httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End);

Dcp\DcpHost.cs (1)

346reader.AdvanceTo(position, result.Buffer.End);

RawSample.cs (1)

96input.AdvanceTo(buffer.End);

Tcp\TcpConnection.cs (1)

229var end = buffer.End;

src\Shared\Http2cat\Http2Utilities.cs (1)

850consumed = examined = framePayload.End;

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (1)

73buffer = buffer.Slice(framePayload.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

850consumed = examined = framePayload.End;

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (1)

73buffer = buffer.Slice(framePayload.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

850consumed = examined = framePayload.End;

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (1)

73buffer = buffer.Slice(framePayload.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

850consumed = examined = framePayload.End;

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (1)

73buffer = buffer.Slice(framePayload.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

850consumed = examined = framePayload.End;

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (1)

73buffer = buffer.Slice(framePayload.End);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (1)

73buffer = buffer.Slice(framePayload.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

850consumed = examined = framePayload.End;

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (1)

73buffer = buffer.Slice(framePayload.End);

ChunkedRequestTests.cs (6)

53request.BodyReader.AdvanceTo(readResult.Buffer.End); 390request.BodyReader.AdvanceTo(result.Buffer.End); 919request.BodyReader.AdvanceTo(readResult.Buffer.End); 975request.BodyReader.AdvanceTo(readResult.Buffer.End); 1025request.BodyReader.AdvanceTo(readResult.Buffer.End); 1088request.BodyReader.AdvanceTo(readResult.Buffer.End);

Http2\Http2ConnectionTests.cs (4)

1406context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 1410context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 1417context.Request.BodyReader.AdvanceTo(readResult.Buffer.End); 5680context.Request.BodyReader.AdvanceTo(result.Buffer.Start, result.Buffer.End);

Http2\Http2StreamTests.cs (5)

1001context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 1006context.Request.BodyReader.AdvanceTo(readResult.Buffer.End); 1044context.Request.BodyReader.AdvanceTo(readResult.Buffer.End); 1284context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 1289context.Request.BodyReader.AdvanceTo(readResult.Buffer.End);

Http2\Http2TestBase.cs (1)

1244consumed = examined = framePayload.End;

Http2\TlsTests.cs (2)

118consumed = examined = framePayload.End; 123examined = buffer.End;

Http3\Http3StreamTests.cs (2)

625context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 630context.Request.BodyReader.AdvanceTo(readResult.Buffer.End);

RequestTests.cs (15)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (3)

571consumed = examined = framePayload.End; 586examined = buffer.End; 931var examined = readableBuffer.End;

HttpClientHttp2InteropTests.cs (6)

276reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 283reader.AdvanceTo(sequence.End); 333reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 340reader.AdvanceTo(sequence.End); 349reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 355reader.AdvanceTo(readResult.Buffer.End);

BlazorPack\SequenceOfT.cs (1)

119/// This is typically <see cref="ReadOnlySequence{T}.End"/> after reading all elements from that instance.

src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\SequenceReader.cs (1)

118this.nextPosition = this.sequence.End;

ServerStreamingServerCallHandlerTests.cs (1)

276pipeReader.AdvanceTo(buffer.Start, buffer.End);

Internal\Transports\LongPollingServerTransport.cs (1)

63_application.AdvanceTo(buffer.End);

Internal\Transports\ServerSentEventsServerTransport.cs (1)

76_application.AdvanceTo(buffer.End);

Internal\Transports\WebSocketsServerTransport.cs (1)

265_application.Input.AdvanceTo(buffer.End);

Internal\SendUtils.cs (1)

69application.Input.AdvanceTo(buffer.End);

Internal\WebSocketsTransport.cs (1)

585_application.Input.AdvanceTo(buffer.End);

HttpConnectionDispatcherTests.cs (10)

HttpConnectionManagerTests.cs (2)

110connection.Transport.Input.AdvanceTo(result.Buffer.End); 259connection.Transport.Input.AdvanceTo(result.Buffer.End);

WebSocketsTests.cs (2)

57connection.Transport.Input.AdvanceTo(buffer.End); 133connection.Transport.Input.AdvanceTo(result.Buffer.End);

RequestDelegateGenerator\RequestDelegateCreationTests.JsonBody.cs (4)

252httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End); 293httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End); 334httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End); 375httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End);

CachedResponseBodyTests.cs (2)

108reader.AdvanceTo(buffer.End, buffer.End);

ResponseCachingBenchmark.cs (2)

101reader.AdvanceTo(buffer.End, buffer.End);

CachedResponseBodyTests.cs (2)

113reader.AdvanceTo(buffer.End, buffer.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

850consumed = examined = framePayload.End;

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (1)

73buffer = buffer.Slice(framePayload.End);

Core\IISHttpContext.IO.cs (3)

48_bodyInputPipe.Reader.AdvanceTo(readableBuffer.End, readableBuffer.End); 206_bodyOutput.Reader.AdvanceTo(buffer.End);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

Internal\Http\Http1ChunkedEncodingMessageBody.cs (12)

282examined = readableBuffer.End; 360consumed = buffer.End; 361examined = buffer.End; 373examined = buffer.End; 386consumed = suffixBuffer.End; 387examined = suffixBuffer.End; 423examined = buffer.End; 431examined = suffixBuffer.End; 435consumed = suffixBuffer.End; 451examined = buffer.End; 459examined = trailerBuffer.End; 463consumed = trailerBuffer.End;

Internal\Http\Http1Connection.cs (1)

748Input.AdvanceTo(reader.Position, isConsumed ? reader.Position : result.Buffer.End);

Internal\Http\Http1ContentLengthMessageBody.cs (1)

216var buffer = _readResult.Buffer.Slice(consumed, _readResult.Buffer.End);

Internal\Http\Http1MessageBody.cs (2)

55AdvanceTo(readResult.Buffer.End); 94AdvanceTo(result.Buffer.End);

Internal\Http\HttpRequestStream.cs (2)

128var consumed = buffer.End; 136consumed = slice.End;

Internal\Http\MessageBody.cs (1)

295if (examined.Equals(readResult.Buffer.End))

Internal\Http2\Http2Connection.cs (5)

384Input.AdvanceTo(buffer.Start, buffer.End); 556var examined = readableBuffer.End; 661examined = buffer.End; 673consumed = examined = preface.End; 1876reader.AdvanceTo(bufferSlice.End);

Internal\Http2\Http2FrameWriter.cs (1)

310reader.AdvanceTo(buffer.End);

Internal\Http3\Http3ControlStream.cs (4)

156var examined = readableBuffer.End; 255var examined = readableBuffer.End; 266consumed = examined = framePayload.End; 293Input.AdvanceTo(readableBuffer.End);

Internal\Http3\Http3FrameReader.cs (1)

54readableBuffer = readableBuffer.Slice(framePayload.End);

Internal\Http3\Http3OutputProducer.cs (1)

455_pipeReader.AdvanceTo(readResult.Buffer.End);

Internal\Http3\Http3Stream.cs (2)

617var examined = readableBuffer.End; 627consumed = examined = framePayload.End;

src\Shared\runtime\Http3\Helpers\VariableLengthIntegerHelper.cs (1)

142examined = buffer.End;

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (1)

73buffer = buffer.Slice(framePayload.End);

BufferWriterTests.cs (1)

31Pipe.Reader.AdvanceTo(readResult.Buffer.End);

Http1\Http1ConnectionTests.cs (5)

201SequencePosition examined = read.Buffer.End; 221examined = read.Buffer.End; 1052examined = readableBuffer.End; 1069examined = readableBuffer.End; 1086examined = readableBuffer.End;

Http2\Http2FrameWriterTests.cs (1)

112pipeReader.AdvanceTo(buffer.Start, buffer.End);

HttpParserTests.cs (2)

574Assert.Equal(buffer.End, examined); 810examined = readableBuffer.End;

MessageBodyTests.cs (17)

PipelineExtensionTests.cs (1)

66_pipe.Reader.AdvanceTo(readResult.Buffer.End);

ChunkWriterBenchmark.cs (2)

40_reader.AdvanceTo(result.Buffer.End, result.Buffer.End);

Http2\Http2ConnectionBenchmarkBase.cs (2)

165consumed = examined = framePayload.End; 170examined = buffer.End;

InMemoryTransportBenchmark.cs (4)

199Output.AdvanceTo(buffer.End); 216var examined = buffer.End; 223consumed = response.End; 224examined = response.End;

PipeThroughputBenchmark.cs (4)

46_pipe.Reader.AdvanceTo(result.Buffer.End, result.Buffer.End); 62_pipe.Reader.AdvanceTo(result.Buffer.End, result.Buffer.End);

RequestParsingBenchmark.cs (1)

166Pipe.Reader.AdvanceTo(readableBuffer.End);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (3)

571consumed = examined = framePayload.End; 586examined = buffer.End; 931var examined = readableBuffer.End;

Internal\NamedPipeConnection.cs (1)

178Output.AdvanceTo(buffer.End);

Internal\QuicStreamContext.cs (1)

399var end = buffer.End;

QuicConnectionContextTests.cs (2)

111serverStream.Transport.Input.AdvanceTo(read.Buffer.End); 613serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End);

QuicTestHelpers.cs (1)

156serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End);

Internal\SocketConnection.cs (1)

314Output.AdvanceTo(buffer.End);

src\Shared\runtime\Http3\Helpers\VariableLengthIntegerHelper.cs (1)

142examined = buffer.End;

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (1)

73buffer = buffer.Slice(framePayload.End);

HubConnection.cs (2)

1520var examined = buffer.End; 1696input.AdvanceTo(buffer.Start, buffer.End);

TestTransport.cs (1)

73Application.Input.AdvanceTo(result.Buffer.End);

HubConnectionContext.cs (1)

514var examined = buffer.End;

HubConnectionHandler.cs (1)

360input.AdvanceTo(buffer.Start, buffer.End);

BroadcastBenchmark.cs (1)

83application.Input.AdvanceTo(buffer.End);

AuthConnectionHandler.cs (1)

30connection.Transport.Input.AdvanceTo(buffer.End);

EchoConnectionHandler.cs (1)

28connection.Transport.Input.AdvanceTo(buffer.End);

HttpHeaderConnectionHandler.cs (1)

34connection.Transport.Input.AdvanceTo(buffer.End);

WriteThenCloseConnectionHandler.cs (1)

22connection.Transport.Input.AdvanceTo(buffer.End);

PipeReaderExtensions.cs (5)

48pipeReader.AdvanceTo(result.Buffer.End); 60pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 81pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 92pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 100pipeReader.AdvanceTo(buffer.End);

ResponseBodyReaderStream.cs (1)

105_pipe.Reader.AdvanceTo(readableBuffer.End);

FormPipeReader.cs (3)

108_pipeReader.AdvanceTo(buffer.Start, buffer.End); 115_pipeReader.AdvanceTo(buffer.End); 124_pipeReader.AdvanceTo(buffer.Start, buffer.End);

EchoConnectionHandler.cs (1)

31connection.Transport.Input.AdvanceTo(result.Buffer.End);

ConnectionHandlers\MessagesConnectionHandler.cs (1)

46connection.Transport.Input.AdvanceTo(buffer.End);

SocialWeatherConnectionHandler.cs (1)

57connection.Transport.Input.AdvanceTo(buffer.End);

src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (1)

65connection.Transport.Input.AdvanceTo(result.Buffer.End);

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

79AdvanceTo(buffer.Start, buffer.End); 275consumed = buffer.End;

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

129consumed = slice.End;

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

34if (consumed.Equals(_sequence.End))

System\Buffers\SequenceReader.Search.cs (1)

754_currentPosition = Sequence.End;

src\libraries\Common\src\System\Net\Http\aspnetcore\Http3\Helpers\VariableLengthIntegerHelper.cs (1)

142examined = buffer.End;