5 types derived from MessageBody
Microsoft.AspNetCore.Server.Kestrel.Core (4)
Internal\Http\Http1MessageBody.cs (1)
16internal abstract class Http1MessageBody : MessageBody
Internal\Http\ZeroContentLengthMessageBody.cs (1)
8internal sealed class ZeroContentLengthMessageBody : MessageBody
Internal\Http2\Http2MessageBody.cs (1)
21internal sealed class Http2MessageBody : MessageBody
Internal\Http3\Http3MessageBody.cs (1)
12internal sealed class Http3MessageBody : MessageBody
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
BodyControlTests.cs (1)
141private class MockMessageBody : MessageBody
83 references to MessageBody
InMemory.FunctionalTests (2)
src\Servers\Kestrel\shared\test\TestHttp1Connection.cs (2)
29public MessageBody NextMessageBody { private get; set; } 36protected override MessageBody CreateMessageBody()
Microsoft.AspNetCore.Server.Kestrel.Core (20)
Internal\Http\Http1Connection.cs (1)
704protected override MessageBody CreateMessageBody()
Internal\Http\Http1MessageBody.cs (5)
124public static MessageBody For( 200return keepAlive ? MessageBody.ZeroContentLengthKeepAlive : MessageBody.ZeroContentLengthClose; 215return keepAlive ? MessageBody.ZeroContentLengthKeepAlive : MessageBody.ZeroContentLengthClose;
Internal\Http\HttpProtocol.cs (3)
324public void InitializeBodyControl(MessageBody messageBody) 463protected abstract MessageBody CreateMessageBody(); 664var messageBody = CreateMessageBody();
Internal\Http\HttpRequestPipeReader.cs (2)
15private MessageBody? _body; 73public void StartAcceptingReads(MessageBody body)
Internal\Http\MessageBody.cs (4)
13private static readonly MessageBody _zeroContentLengthClose = new ZeroContentLengthMessageBody(keepAlive: false); 14private static readonly MessageBody _zeroContentLengthKeepAlive = new ZeroContentLengthMessageBody(keepAlive: true); 32public static MessageBody ZeroContentLengthClose => _zeroContentLengthClose; 34public static MessageBody ZeroContentLengthKeepAlive => _zeroContentLengthKeepAlive;
Internal\Http2\Http2Stream.cs (2)
194protected override MessageBody CreateMessageBody() 198return MessageBody.ZeroContentLengthClose;
Internal\Http3\Http3Stream.cs (1)
967protected override MessageBody CreateMessageBody()
Internal\Infrastructure\BodyControl.cs (2)
58public (Stream request, Stream response, PipeReader reader, PipeWriter writer) Start(MessageBody body) 62_emptyRequestReader.StartAcceptingReads(MessageBody.ZeroContentLengthClose);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (57)
Http1\Http1ConnectionTests.cs (2)
378var messageBody = Http1MessageBody.For(Kestrel.Core.Internal.Http.HttpVersion.Http11, (HttpRequestHeaders)_http1Connection.RequestHeaders, _http1Connection); 960var mockMessageBody = new Mock<MessageBody>(null);
HttpRequestStreamTests.cs (1)
111var mockMessageBody = new Mock<MessageBody>(null);
MessageBodyTests.cs (52)
33var body = Http1MessageBody.For(httpVersion, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 63var body = Http1MessageBody.For(httpVersion, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 91var body = Http1MessageBody.For(httpVersion, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 118var body = Http1MessageBody.For(httpVersion, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 139var body = Http1MessageBody.For(httpVersion, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 160var body = Http1MessageBody.For(httpVersion, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 186var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 215var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 240var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 268var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 309var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 336var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 370var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 392var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 419var body = Http1MessageBody.For(httpVersion, new HttpRequestHeaders { HeaderConnection = "upgrade" }, input.Http1Connection); 448var body = Http1MessageBody.For(httpVersion, new HttpRequestHeaders { HeaderConnection = "upgrade" }, input.Http1Connection); 475var body = Http1MessageBody.For(httpVersion, new HttpRequestHeaders(), input.Http1Connection); 499var body = Http1MessageBody.For(httpVersion, new HttpRequestHeaders(), input.Http1Connection); 518var body = Http1MessageBody.For(HttpVersion.Http10, new HttpRequestHeaders { HeaderContentLength = "8197" }, input.Http1Connection); 566var result = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders(), input.Http1Connection); 568Assert.Same(MessageBody.ZeroContentLengthKeepAlive, result); 596var body = Http1MessageBody.For(HttpVersion.Http10, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 619var body = Http1MessageBody.For(HttpVersion.Http10, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 636var body = Http1MessageBody.For(HttpVersion.Http10, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 658var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderConnection = headerConnection }, input.Http1Connection); 685var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderConnection = headerConnection, ContentLength = 0 }, input.Http1Connection); 707var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "2" }, input.Http1Connection); 735var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 762var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 797var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 828var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "2" }, input.Http1Connection); 865var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "2" }, input.Http1Connection); 890var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "12" }, input.Http1Connection); 926var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 951var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderConnection = "upgrade" }, input.Http1Connection); 983var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 1004var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 1025var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderConnection = "upgrade" }, input.Http1Connection); 1046var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders(), input.Http1Connection); 1069var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 1088var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 1115var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderConnection = "upgrade" }, input.Http1Connection); 1141var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders(), input.Http1Connection); 1164var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 1188var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 1214var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 1241var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderContentLength = "5" }, input.Http1Connection); 1274var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 1301var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 1325var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderTransferEncoding = "chunked" }, input.Http1Connection); 1351var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders { HeaderConnection = "upgrade" }, input.Http1Connection); 1377var body = Http1MessageBody.For(HttpVersion.Http11, new HttpRequestHeaders(), input.Http1Connection);
src\Servers\Kestrel\shared\test\TestHttp1Connection.cs (2)
29public MessageBody NextMessageBody { private get; set; } 36protected override MessageBody CreateMessageBody()
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (4)
Http1LargeWritingBenchmark.cs (1)
87http1Connection.InitializeBodyControl(MessageBody.ZeroContentLengthKeepAlive);
Http1WritingBenchmark.cs (1)
121http1Connection.InitializeBodyControl(MessageBody.ZeroContentLengthKeepAlive);
src\Servers\Kestrel\shared\test\TestHttp1Connection.cs (2)
29public MessageBody NextMessageBody { private get; set; } 36protected override MessageBody CreateMessageBody()