Buffer

Otlp\Http\OtlpHttpEndpointsBuilder.cs (5)

191if (result.Buffer.Length > MaxRequestSize) 205httpContext.Request.BodyReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 209return exporter(result.Buffer); 215httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End);

Dcp\DcpHost.cs (2)

355LogLines(result.Buffer, out var position); 357reader.AdvanceTo(position, result.Buffer.End);

RawSample.cs (1)

80var buffer = result.Buffer;

Tcp\TcpConnection.cs (1)

222var buffer = result.Buffer;

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

840var buffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

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

840var buffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

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

840var buffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

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

840var buffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

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

840var buffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

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

840var buffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

ChunkedRequestTests.cs (7)

51await response.BodyWriter.WriteAsync(readResult.Buffer.ToArray()); 53request.BodyReader.AdvanceTo(readResult.Buffer.End); 390request.BodyReader.AdvanceTo(result.Buffer.End); 922request.BodyReader.AdvanceTo(readResult.Buffer.End); 978request.BodyReader.AdvanceTo(readResult.Buffer.End); 1028request.BodyReader.AdvanceTo(readResult.Buffer.End); 1091request.BodyReader.AdvanceTo(readResult.Buffer.End);

Http2\Http2ConnectionTests.cs (13)

1404while (readResult.Buffer.Length != _maxData.Length * 4) 1406context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 1410context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 1413Assert.Equal(readResult.Buffer.Length, _maxData.Length * 5); 1415await context.Response.BodyWriter.WriteAsync(readResult.Buffer.ToArray()); 1417context.Request.BodyReader.AdvanceTo(readResult.Buffer.End); 5131Assert.True(result.Buffer.IsEmpty); 5308Assert.True(result.Buffer.IsEmpty); 5679result.Buffer.CopyTo(buffer); 5680context.Request.BodyReader.AdvanceTo(result.Buffer.Start, result.Buffer.End);

Http2\Http2StreamTests.cs (10)

1001context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 1005Assert.Equal(12, readResult.Buffer.Length); 1006context.Request.BodyReader.AdvanceTo(readResult.Buffer.End); 1043Assert.Equal(1, readResult.Buffer.Length); 1044context.Request.BodyReader.AdvanceTo(readResult.Buffer.End); 1284context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 1288Assert.Equal(12, readResult.Buffer.Length); 1289context.Request.BodyReader.AdvanceTo(readResult.Buffer.End);

Http2\Http2TestBase.cs (4)

1218return result.Buffer.ToArray(); 1222_pair.Application.Input.AdvanceTo(result.Buffer.Start, result.Buffer.End); 1233var buffer = result.Buffer;

Http2\TlsTests.cs (1)

110var buffer = result.Buffer;

Http3\Http3StreamTests.cs (14)

627context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 631Assert.Equal(12, readResult.Buffer.Length); 632context.Request.BodyReader.AdvanceTo(readResult.Buffer.End); 3080Assert.Equal(sendSize, res.Buffer.Length); 3081c.Request.BodyReader.AdvanceTo(res.Buffer.Slice(1).Start); 3086Assert.Equal(sendSize - 1, res.Buffer.Length); 3087c.Request.BodyReader.AdvanceTo(res.Buffer.End); 3174for (var i = 0; i < res.Buffer.Length; i++) 3177mem.Span[0] = res.Buffer.Slice(i).FirstSpan[0]; 3184bufferPipe.Reader.AdvanceTo(res.Buffer.End); 3299for (var i = 0; i < res.Buffer.Length; i++) 3302mem.Span[0] = res.Buffer.Slice(i).FirstSpan[0]; 3309reader.AdvanceTo(res.Buffer.End);

KestrelMetricsTests.cs (3)

176Assert.True(result.Buffer.Length > 0); 177Assert.Equal(result.Buffer.ToSpan(), "Hello World?"u8[..(int)result.Buffer.Length]);

RequestTests.cs (34)

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

553var buffer = result.Buffer; 928var readableBuffer = result.Buffer;

HttpClientHttp2InteropTests.cs (16)

274while (!readResult.IsCompleted && readResult.Buffer.Length < "Hello World".Length) 276reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 280var sequence = readResult.Buffer.Slice(0, "Hello World".Length); 287Assert.True(finalResult.IsCompleted && finalResult.Buffer.Length == 0); 331while (!readResult.IsCompleted && readResult.Buffer.Length < "Hello World".Length) 333reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 337var sequence = readResult.Buffer.Slice(0, "Hello World".Length); 347while (!readResult.IsCompleted && readResult.Buffer.Length < "Hello World".Length) 349reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 353Assert.True(readResult.Buffer.IsSingleSegment); 354var result = Encoding.UTF8.GetString(readResult.Buffer.FirstSpan); 355reader.AdvanceTo(readResult.Buffer.End); 358Assert.True(finalResult.IsCompleted && finalResult.Buffer.Length == 0);

ServerStreamingServerCallHandlerTests.cs (1)

269var buffer = result.Buffer;

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\SendUtils.cs (1)

28var buffer = result.Buffer;

Internal\WebSocketsTransport.cs (1)

541var buffer = result.Buffer;

HttpConnectionDispatcherTests.cs (19)

HttpConnectionManagerTests.cs (4)

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

MapConnectionHandlerTests.cs (1)

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

WebSocketsTests.cs (2)

55var buffer = result.Buffer; 133connection.Transport.Input.AdvanceTo(result.Buffer.End);

RequestDelegateGenerator\RequestDelegateCreationTests.JsonBody.cs (10)

250Assert.Equal(requestBodyBytes.Length, result.Buffer.Length); 251Assert.Equal(requestBodyBytes, result.Buffer.ToArray()); 252httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End); 291Assert.Equal(requestBodyBytes.Length, result.Buffer.Length); 292Assert.Equal(requestBodyBytes, result.Buffer.ToArray()); 293httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End); 332Assert.Equal(0, result.Buffer.Length); 334httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End); 373Assert.Equal(0, result.Buffer.Length); 375httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End);

Features\RequestBodyPipeFeatureTests.cs (1)

67return Encoding.ASCII.GetString(data.Buffer.ToArray());

CachedResponseBodyTests.cs (1)

104var buffer = result.Buffer;

ResponseCachingBenchmark.cs (1)

99var buffer = result.Buffer;

CachedResponseBodyTests.cs (1)

108var buffer = result.Buffer;

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

840var buffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

Core\IISHttpContext.IO.cs (2)

31var readableBuffer = result.Buffer; 165var buffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

Internal\Http\Http1ChunkedEncodingMessageBody.cs (3)

49CountBytesRead(readResult.Buffer.Length); 74StopTimingRead(_readResult.Buffer.Length); 113var readableBuffer = result.Buffer;

Internal\Http\Http1Connection.cs (3)

723var reader = new SequenceReader<byte>(result.Buffer); 737OnBadRequest(result.Buffer, ex); 748Input.AdvanceTo(reader.Position, isConsumed ? reader.Position : result.Buffer.End);

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)

55AdvanceTo(readResult.Buffer.End); 94AdvanceTo(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)

321var buffer = result.Buffer; 554var readableBuffer = result.Buffer; 1859if ((readResult.IsCompleted && readResult.Buffer.Length == 0) || readResult.IsCanceled) 1867var copyAmount = (int)Math.Min(outputBuffer.Length, readResult.Buffer.Length); 1868var 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 (3)

160var readableBuffer = result.Buffer; 263var readableBuffer = result.Buffer; 323var 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)

616var readableBuffer = result.Buffer;

Middleware\TlsListener.cs (1)

31var buffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

BufferWriterTests.cs (3)

30byte[] data = readResult.Buffer.ToArray(); 31Pipe.Reader.AdvanceTo(readResult.Buffer.End); 206Assert.Equal(13, readResult.Buffer.Length);

Http1\Http1ConnectionTests.cs (25)

Http2\Http2FrameWriterTests.cs (1)

105var buffer = result.Buffer;

MessageBodyTests.cs (32)

PipelineExtensionTests.cs (9)

48AssertExtensions.Equal(expected, reader.Buffer.Slice(0, numAsStr.Length).ToArray()); 65AssertExtensions.Equal(expected, readResult.Buffer.Slice(0, numAsStr.Length).ToArray()); 66_pipe.Reader.AdvanceTo(readResult.Buffer.End); 90var written = reader.Buffer.Slice(spacer.Length, numAsString.Length); 120reader.Buffer.ToArray()); 124Assert.Equal(0, reader.Buffer.Length); 144Assert.Equal(input.Length, reader.Buffer.Length); 161var data = reader.Buffer.Slice(0, maxAscii).ToArray(); 194var written = reader.Buffer.Slice(spacer.Length, stringLength);

TlsListenerTests.cs (3)

154Assert.Equal(5, readResult.Buffer.Length); 210Assert.Equal(fullLength, readResult.Buffer.Length); 247Assert.Equal(packetBytes.Length, readResult.Buffer.Length);

ChunkWriterBenchmark.cs (2)

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

Http1LargeWritingBenchmark.cs (1)

100reader.AdvanceTo(readResult.Buffer.End);

Http1ReadingBenchmark.cs (1)

128reader.AdvanceTo(readResult.Buffer.End);

Http1WritingBenchmark.cs (1)

134reader.AdvanceTo(readResult.Buffer.End);

Http2\Http2ConnectionBenchmarkBase.cs (1)

157var buffer = result.Buffer;

InMemoryTransportBenchmark.cs (2)

197var buffer = result.Buffer; 214var buffer = result.Buffer;

PipeThroughputBenchmark.cs (5)

45remaining -= result.Buffer.Length; 46_pipe.Reader.AdvanceTo(result.Buffer.End, result.Buffer.End); 62_pipe.Reader.AdvanceTo(result.Buffer.End, result.Buffer.End);

RequestParsingBenchmark.cs (3)

148var readableBuffer = awaitable.GetAwaiter().GetResult().Buffer; 181var readableBuffer = result.Buffer; 193readableBuffer = result.Buffer;

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

553var buffer = result.Buffer; 928var readableBuffer = result.Buffer;

Internal\NamedPipeConnection.cs (1)

163var buffer = result.Buffer;

Internal\QuicStreamContext.cs (1)

397var buffer = result.Buffer;

QuicConnectionContextTests.cs (13)

QuicStreamContextTests.cs (9)

QuicTestHelpers.cs (1)

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

Internal\SocketConnection.cs (1)

281var buffer = result.Buffer;

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

122var readableBuffer = result.Buffer;

HubConnection.cs (2)

1522var buffer = result.Buffer; 1641var buffer = result.Buffer;

HttpConnectionTests.Transport.cs (1)

410Assert.Equal("This is a test", Encoding.UTF8.GetString(message.Buffer));

LongPollingTransportTests.cs (1)

89longPollingTransport.Input.AdvanceTo(result.Buffer.End);

TestConnection.cs (1)

149var buffer = result.Buffer;

TestTransport.cs (1)

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

HubConnectionContext.cs (1)

512var buffer = result.Buffer;

HubConnectionHandler.cs (1)

274var buffer = result.Buffer;

BroadcastBenchmark.cs (1)

79var buffer = result.Buffer;

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

249var buffer = result.Buffer; 282var buffer = result.Buffer;

AuthConnectionHandler.cs (1)

19var buffer = result.Buffer;

EchoConnectionHandler.cs (1)

17var buffer = result.Buffer;

HttpHeaderConnectionHandler.cs (1)

19var buffer = result.Buffer;

WebSocketsTransportTests.cs (4)

119var userAgent = Encoding.UTF8.GetString(result.Buffer.ToArray()); 150var headerValue = Encoding.UTF8.GetString(result.Buffer.ToArray()); 187Assert.Equal(new byte[] { 0x42 }, result.Buffer.ToArray()); 188webSocketsTransport.Input.AdvanceTo(result.Buffer.End);

WriteThenCloseConnectionHandler.cs (1)

15var buffer = result.Buffer;

PipeReaderExtensions.cs (16)

18if (!result.Buffer.IsEmpty) 31pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.Start); 44return result.Buffer.ToArray(); 48pipeReader.AdvanceTo(result.Buffer.End); 58if (result.Buffer.Length < numBytes) 60pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 64pipeReader.AdvanceTo(result.Buffer.GetPosition(numBytes)); 77return result.Buffer.ToArray(); 81pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 90if (result.Buffer.Length < numBytes) 92pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 96var buffer = result.Buffer.Slice(0, numBytes);

TestClient.cs (2)

249var buffer = result.Buffer; 282var buffer = result.Buffer;

ResponseBodyReaderStream.cs (2)

94if (result.Buffer.IsEmpty && result.IsCompleted) 101var readableBuffer = result.Buffer;

FormPipeReader.cs (1)

98var buffer = readResult.Buffer;

FormPipeReaderTests.cs (5)

114Assert.Equal(Encoding.UTF8.GetBytes(content), readResult.Buffer.ToArray()); 129Assert.Equal(Encoding.UTF8.GetBytes(content), readResult.Buffer.ToArray()); 157Assert.Equal(Encoding.UTF8.GetBytes(content), readResult.Buffer.ToArray()); 185Assert.Equal(Encoding.UTF8.GetBytes(content), readResult.Buffer.ToArray()); 210Assert.Equal(Encoding.UTF8.GetBytes("baz=12345678901"), readResult.Buffer.ToArray());

RemoteHostAssetReader.cs (4)

80_pipeReader.AdvanceTo(fillReadResult.Buffer.Start); 104_pipeReader.AdvanceTo(lengthReadResult.Buffer.GetPosition(HeaderSize)); 122var sequenceReader = new SequenceReader<byte>(readResult.Buffer); 130var sequenceReader = new SequenceReader<byte>(readResult.Buffer);

EchoConnectionHandler.cs (2)

16var buffer = result.Buffer; 31connection.Transport.Input.AdvanceTo(result.Buffer.End);

ConnectionHandlers\MessagesConnectionHandler.cs (1)

28var buffer = result.Buffer;

SocialWeatherConnectionHandler.cs (1)

38var buffer = result.Buffer;

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

63await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 65connection.Transport.Input.AdvanceTo(result.Buffer.End);

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)

226|| readResult.Buffer.Length >= minimumSize