1 write to Request
Microsoft.AspNetCore.Server.HttpSys (1)
RequestProcessing\RequestContext.FeatureCollection.cs (1)
112
Request
= new Request(this);
113 references to Request
Microsoft.AspNetCore.Server.HttpSys (58)
RequestProcessing\ClientCertLoader.cs (2)
163
RequestContext.
Request
.UConnectionId,
242
requestContext.
Request
.UConnectionId,
RequestProcessing\RequestContext.cs (13)
38
public WindowsPrincipal User =>
Request
.User;
55
var connectionDisconnectToken = Server.DisconnectListener.GetTokenForConnection(
Request
.UConnectionId);
79
*((ulong*)&guid) =
Request
.RequestId;
84
public bool IsUpgradableRequest =>
Request
.IsUpgradable;
92
if (
Request
.ProtocolVersion != System.Net.HttpVersion.Version11)
108
Request
.SwitchToOpaqueMode();
110
var opaqueStream = new OpaqueStream(
Request
.Body, Response.Body);
140
Request
.Dispose();
177
Request
?.Dispose();
240
var requestId = PinsReleased ?
Request
.RequestId : RequestId;
317
var statusCode = HttpApi.HttpSetRequestProperty(Server.RequestQueue.Handle,
Request
.RequestId, HTTP_REQUEST_PROPERTY.HttpRequestPropertyStreamError, &streamError,
345
if (
Request
.HasRequestBodyStarted)
372
Request
.RequestId,
RequestProcessing\RequestContext.FeatureCollection.cs (34)
129
_requestHeaders =
Request
.Headers;
130
_httpMethod =
Request
.Method;
131
_path =
Request
.Path;
132
_pathBase =
Request
.PathBase;
133
_query =
Request
.QueryString;
134
_rawTarget =
Request
.RawUrl;
135
_scheme =
Request
.Scheme;
163
_requestBody =
Request
.Body;
205
_httpProtocolVersion = HttpProtocol.GetHttpProtocol(
Request
.ProtocolVersion);
235
bool IHttpRequestBodyDetectionFeature.CanHaveBody =>
Request
.HasEntityBody;
243
_localIpAddress =
Request
.LocalIpAddress;
261
_remoteIpAddress =
Request
.RemoteIpAddress;
279
_localPort =
Request
.LocalPort;
297
_remotePort =
Request
.RemotePort;
315
_connectionId =
Request
.ConnectionId.ToString(CultureInfo.InvariantCulture);
336
_clientCert =
Request
.ClientCertificate;
363
||
Request
.ProtocolVersion >= HttpVersion.Version20)
372
return _clientCert = await
Request
.GetClientCertificateAsync(cancellation);
378
return
Request
.IsHttps ? this : null;
383
return
Request
.IsHttps ? this : null;
388
if (
Request
.ProtocolVersion >= HttpVersion.Version20 && HttpApi.SupportsTrailers)
397
if (
Request
.ProtocolVersion >= HttpVersion.Version20 && HttpApi.SupportsReset)
586
bool IHttpMaxRequestBodySizeFeature.IsReadOnly =>
Request
.HasRequestBodyStarted;
590
get =>
Request
.MaxRequestBodySize;
591
set =>
Request
.MaxRequestBodySize = value;
594
SslProtocols ITlsHandshakeFeature.Protocol =>
Request
.Protocol;
597
CipherAlgorithmType ITlsHandshakeFeature.CipherAlgorithm =>
Request
.CipherAlgorithm;
599
int ITlsHandshakeFeature.CipherStrength =>
Request
.CipherStrength;
601
HashAlgorithmType ITlsHandshakeFeature.HashAlgorithm =>
Request
.HashAlgorithm;
603
int ITlsHandshakeFeature.HashStrength =>
Request
.HashStrength;
605
ExchangeAlgorithmType ITlsHandshakeFeature.KeyExchangeAlgorithm =>
Request
.KeyExchangeAlgorithm;
607
int ITlsHandshakeFeature.KeyExchangeStrength =>
Request
.KeyExchangeStrength;
610
string ITlsHandshakeFeature.HostName =>
Request
.SniHostName;
618
public bool CanDelegate =>
Request
.CanDelegate;
RequestProcessing\RequestContextOfT.cs (2)
74
if (
Request
.ProtocolVersion == HttpVersion.Version20)
79
else if (
Request
.ProtocolVersion == HttpVersion.Version30)
RequestProcessing\RequestStream.cs (4)
38
private ulong RequestId => RequestContext.
Request
.RequestId;
118
dataRead = _requestContext.
Request
.GetChunks(ref _dataChunkIndex, ref _dataChunkOffset, buffer, offset, size);
209
dataRead = _requestContext.
Request
.GetChunks(ref _dataChunkIndex, ref _dataChunkOffset, buffer, offset, size);
323
var contentLength = RequestContext.
Request
.ContentLength;
RequestProcessing\Response.cs (1)
68
private Request Request => RequestContext.
Request
;
RequestProcessing\ResponseBody.cs (2)
36
private ulong RequestId => RequestContext.
Request
.RequestId;
471
if (_requestContext.
Request
.IsHeadMethod)
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (55)
Listener\RequestBodyTests.cs (13)
31
Assert.Throws<InvalidOperationException>(() => context.
Request
.Body.Read(input, 0, input.Length));
36
var read = context.
Request
.Body.Read(input, 0, input.Length);
59
Task<int> task = context.
Request
.Body.ReadAsync(input, 0, input.Length, cts.Token);
81
int read = await context.
Request
.Body.ReadAsync(input, 0, input.Length, cts.Token);
84
read = await context.
Request
.Body.ReadAsync(input, 0, input.Length, cts.Token);
106
int read = await context.
Request
.Body.ReadAsync(input, 0, input.Length, cts.Token);
109
read = await context.
Request
.Body.ReadAsync(input, 0, input.Length, cts.Token);
130
int read = await context.
Request
.Body.ReadAsync(input, 0, input.Length, cts.Token);
132
var readTask = context.
Request
.Body.ReadAsync(input, 0, input.Length, cts.Token);
155
int read = await context.
Request
.Body.ReadAsync(input, 0, input.Length, cts.Token);
158
var readTask = context.
Request
.Body.ReadAsync(input, 0, input.Length, cts.Token);
182
int read = await context.
Request
.Body.ReadAsync(input, 0, input.Length, context.DisconnectToken);
185
var assertTask = Assert.ThrowsAsync<IOException>(async () => await context.
Request
.Body.ReadAsync(input, 0, input.Length, context.DisconnectToken));
Listener\RequestHeaderTests.cs (7)
28
var requestHeaders = context.
Request
.Headers;
30
var headers = context.
Request
.Headers;
69
var requestHeaders = context.
Request
.Headers;
96
var requestHeaders = context.
Request
.Headers;
124
var requestHeaders = context.
Request
.Headers;
165
var requestHeaders = context.
Request
.Headers;
190
var requestHeaders = context.
Request
.Headers;
Listener\RequestTests.cs (7)
39
Assert.Equal("", context.
Request
.PathBase);
40
Assert.Equal("", context.
Request
.Path);
41
Assert.Equal("*", context.
Request
.RawUrl);
77
actualPath = context.
Request
.Path;
127
Assert.Equal(expectedPath, context.
Request
.Path);
164
Assert.Equal(expectedPathBase, context.
Request
.PathBase);
165
Assert.Equal(expectedPath, context.
Request
.Path);
Listener\ServerOnExistingQueueTests.cs (17)
61
string input = await new StreamReader(context.
Request
.Body).ReadToEndAsync();
99
Assert.Equal("/pathBase", context.
Request
.PathBase);
100
Assert.Equal("/paTh", context.
Request
.Path);
116
Assert.Equal(string.Empty, context.
Request
.PathBase);
117
Assert.Equal("/pathBase/paTh", context.
Request
.Path);
141
Assert.Equal(expectedPathBase, context.
Request
.PathBase);
142
Assert.Equal(expectedPath, context.
Request
.Path);
161
Assert.Equal("/basepath/secondTier", context.
Request
.PathBase);
162
Assert.Equal("/path/thing", context.
Request
.Path);
180
Assert.Equal(string.Empty, context.
Request
.PathBase);
181
Assert.Equal("/", context.
Request
.Path);
194
Assert.Equal("/pathbase", context.
Request
.PathBase);
195
Assert.Equal("/", context.
Request
.Path);
216
Assert.Equal("/pathbase", context.
Request
.PathBase);
217
Assert.Equal("/", context.
Request
.Path);
229
Assert.Equal(string.Empty, context.
Request
.PathBase);
230
Assert.Equal("/pathbase/", context.
Request
.Path);
Listener\ServerTests.cs (8)
153
Assert.Equal(string.Empty, context.
Request
.PathBase);
154
Assert.Equal("/", context.
Request
.Path);
166
Assert.Equal("/pathbase", context.
Request
.PathBase);
167
Assert.Equal("/", context.
Request
.Path);
186
Assert.Equal("/pathbase", context.
Request
.PathBase);
187
Assert.Equal("/", context.
Request
.Path);
198
Assert.Equal(string.Empty, context.
Request
.PathBase);
199
Assert.Equal("/pathbase/", context.
Request
.Path);
RequestHeaderTests.cs (3)
109
var request = httpContext.Features.Get<RequestContext>().
Request
;
132
var request = httpContext.Features.Get<RequestContext>().
Request
;
155
var request = httpContext.Features.Get<RequestContext>().
Request
;