Start

Otlp\Http\OtlpHttpEndpointsBuilder.cs (1)

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

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

Http2\Http2ConnectionTests.cs (3)

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

Http2\Http2StreamTests.cs (2)

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

Http2\TlsTests.cs (2)

111var consumed = buffer.Start; 112var examined = buffer.Start;

Http3\Http3StreamTests.cs (1)

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

RequestTests.cs (10)

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

553var consumed = buffer.Start; 554var examined = buffer.Start; 596BytesReceived += copyBuffer.Slice(copyBuffer.Start, consumed).Length; 930var consumed = readableBuffer.Start;

HttpClientHttp2InteropTests.cs (3)

276reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 333reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 349reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End);

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

65this.currentPosition = sequence.Start; 117this.currentPosition = this.sequence.Start; 273this.currentPosition = this.Sequence.Start;

ServerStreamingServerCallHandlerTests.cs (1)

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

ServerSentEventsMessageFormatter.cs (3)

51var position = source.Start; 82lineSegment = payload.Slice(payload.Start, sliceEnd.Value); 90lineSegment = lineSegment.Slice(lineSegment.Start, offset + memory.Length - 1);

src\SignalR\common\Shared\StreamExtensions.cs (1)

33var position = buffer.Start;

src\SignalR\common\Shared\WebSocketExtensions.cs (1)

41var position = buffer.Start;

src\SignalR\common\Shared\StreamExtensions.cs (1)

33var position = buffer.Start;

src\SignalR\common\Shared\WebSocketExtensions.cs (1)

41var position = buffer.Start;

MapConnectionHandlerTests.cs (1)

444connection.Transport.Input.AdvanceTo(result.Buffer.Start);

RecyclableReadOnlySequenceSegment.cs (1)

64var obj = value.Start.GetObject() as RecyclableReadOnlySequenceSegment;

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

Internal\Http\Http1ChunkedEncodingMessageBody.cs (6)

114var consumed = readableBuffer.Start; 115var examined = readableBuffer.Start; 293consumed = buffer.Start; 352examined = buffer.Start; 419consumed = buffer.Start; 447consumed = buffer.Start;

Internal\Http\Http1ContentLengthMessageBody.cs (3)

78_context.Input.AdvanceTo(_readResult.Buffer.Start); 151_context.Input.AdvanceTo(_readResult.Buffer.Start); 162_context.Input.AdvanceTo(_readResult.Buffer.Start);

Internal\Http\HttpParser.cs (1)

340SequencePosition position = currentSlice.Start;

Internal\Http\MessageBody.cs (2)

286examinedLength = readResult.Buffer.Slice(readResult.Buffer.Start, examined).Length; 291consumedLength = readResult.Buffer.Slice(readResult.Buffer.Start, consumed).Length;

Internal\Http2\Http2Connection.cs (3)

384Input.AdvanceTo(buffer.Start, buffer.End); 555var consumed = readableBuffer.Start; 660consumed = buffer.Start;

Internal\Http3\Http3ControlStream.cs (2)

155var consumed = readableBuffer.Start; 254var consumed = readableBuffer.Start;

Internal\Http3\Http3PendingStream.cs (2)

58consumed = readableBuffer.Start; 59start = readableBuffer.Start;

Internal\Http3\Http3Stream.cs (1)

616var consumed = readableBuffer.Start;

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

Http1\Http1ConnectionTests.cs (2)

200SequencePosition consumed = read.Buffer.Start; 220consumed = read.Buffer.Start;

Http2\Http2FrameWriterTests.cs (1)

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

HttpParserTests.cs (2)

73Assert.Equal(buffer.Start, consumed); 573Assert.Equal(buffer.Start, consumed);

MessageBodyTests.cs (1)

1249reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End);

Http2\Http2ConnectionBenchmarkBase.cs (2)

158var consumed = buffer.Start; 159var examined = buffer.Start;

InMemoryTransportBenchmark.cs (1)

215var consumed = buffer.Start;

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

553var consumed = buffer.Start; 554var examined = buffer.Start; 596BytesReceived += copyBuffer.Slice(copyBuffer.Start, consumed).Length; 930var consumed = readableBuffer.Start;

src\Shared\ServerInfrastructure\BufferExtensions.cs (1)

90SequencePosition position = source.Start;

HubConnection.cs (3)

1519var consumed = buffer.Start; 1532consumed = buffer.Start; 1696input.AdvanceTo(buffer.Start, buffer.End);

TestConnection.cs (2)

150var consumed = buffer.Start; 156consumed = buffer.Start;

HubConnectionContext.cs (3)

513var consumed = buffer.Start; 533segment = segment.Slice(segment.Start, _maxMessageSize.Value); 540consumed = segment.Start;

HubConnectionHandler.cs (3)

314segment = segment.Slice(segment.Start, maxMessageSize); 336buffer = buffer.Slice(segment.Start); 360input.AdvanceTo(buffer.Start, buffer.End);

src\SignalR\common\Http.Connections\src\ServerSentEventsMessageFormatter.cs (3)

51var position = source.Start; 82lineSegment = payload.Slice(payload.Start, sliceEnd.Value); 90lineSegment = lineSegment.Slice(lineSegment.Start, offset + memory.Length - 1);

src\SignalR\common\testassets\Tests.Utils\TestClient.cs (2)

265Connection.Application.Input.AdvanceTo(buffer.Start); 304Connection.Application.Input.AdvanceTo(buffer.Start);

Internal\MessageBufferTests.cs (25)

PipeReaderExtensions.cs (5)

31pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.Start); 60pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 81pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 92pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End);

TestClient.cs (2)

265Connection.Application.Input.AdvanceTo(buffer.Start); 304Connection.Application.Input.AdvanceTo(buffer.Start);

FormPipeReader.cs (2)

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

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

79AdvanceTo(buffer.Start, buffer.End); 238SequencePosition position = buffer.Start;

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

120SequencePosition consumed = sequence.Start;

System\Buffers\BuffersExtensions.cs (2)

37SequencePosition position = source.Start; 83SequencePosition position = sequence.Start;

System\Buffers\ReadOnlySequence.cs (2)

468return SliceImpl(positionIsNotNull ? start : Start); 625_next = sequence.Start;

System\Buffers\SequenceReader.cs (2)

25_currentPosition = sequence.Start; 256_currentPosition = Sequence.Start;

System\Text\Json\Reader\Utf8JsonReader.MultiSegment.cs (2)

59_currentPosition = jsonData.Start; 65_currentPosition = jsonData.Start;