1 write to Request
Microsoft.AspNetCore.Server.HttpSys (1)
RequestProcessing\RequestContext.FeatureCollection.cs (1)
113Request = new Request(this);
115 references to Request
Microsoft.AspNetCore.Server.HttpSys (60)
RequestProcessing\ClientCertLoader.cs (2)
163RequestContext.Request.UConnectionId, 242requestContext.Request.UConnectionId,
RequestProcessing\RequestContext.cs (14)
39public WindowsPrincipal User => Request.User; 56var connectionDisconnectToken = Server.DisconnectListener.GetTokenForConnection(Request.UConnectionId); 80*((ulong*)&guid) = Request.RequestId; 85public bool IsUpgradableRequest => Request.IsUpgradable; 93if (Request.ProtocolVersion != System.Net.HttpVersion.Version11) 109Request.SwitchToOpaqueMode(); 111var opaqueStream = new OpaqueStream(Request.Body, Response.Body); 141Request.Dispose(); 178Request?.Dispose(); 237var requestId = PinsReleased ? Request.RequestId : RequestId; 280var requestId = PinsReleased ? Request.RequestId : RequestId; 357var statusCode = HttpApi.HttpSetRequestProperty(Server.RequestQueue.Handle, Request.RequestId, HTTP_REQUEST_PROPERTY.HttpRequestPropertyStreamError, &streamError, 385if (Request.HasRequestBodyStarted) 412Request.RequestId,
RequestProcessing\RequestContext.FeatureCollection.cs (35)
130_requestHeaders = Request.Headers; 131_httpMethod = Request.Method; 132_path = Request.Path; 133_pathBase = Request.PathBase; 134_query = Request.QueryString; 135_rawTarget = Request.RawUrl; 136_scheme = Request.Scheme; 164_requestBody = Request.Body; 206_httpProtocolVersion = HttpProtocol.GetHttpProtocol(Request.ProtocolVersion); 236bool IHttpRequestBodyDetectionFeature.CanHaveBody => Request.HasEntityBody; 244_localIpAddress = Request.LocalIpAddress; 262_remoteIpAddress = Request.RemoteIpAddress; 280_localPort = Request.LocalPort; 298_remotePort = Request.RemotePort; 316_connectionId = Request.ConnectionId.ToString(CultureInfo.InvariantCulture); 337_clientCert = Request.ClientCertificate; 364|| Request.ProtocolVersion >= HttpVersion.Version20) 373return _clientCert = await Request.GetClientCertificateAsync(cancellation); 379return Request.IsHttps ? this : null; 384return Request.IsHttps ? this : null; 389if (Request.ProtocolVersion >= HttpVersion.Version20 && HttpApi.SupportsTrailers) 398if (Request.ProtocolVersion >= HttpVersion.Version20 && HttpApi.SupportsReset) 587bool IHttpMaxRequestBodySizeFeature.IsReadOnly => Request.HasRequestBodyStarted; 591get => Request.MaxRequestBodySize; 592set => Request.MaxRequestBodySize = value; 595SslProtocols ITlsHandshakeFeature.Protocol => Request.Protocol; 597TlsCipherSuite? ITlsHandshakeFeature.NegotiatedCipherSuite => Request.NegotiatedCipherSuite; 600CipherAlgorithmType ITlsHandshakeFeature.CipherAlgorithm => Request.CipherAlgorithm; 602int ITlsHandshakeFeature.CipherStrength => Request.CipherStrength; 604HashAlgorithmType ITlsHandshakeFeature.HashAlgorithm => Request.HashAlgorithm; 606int ITlsHandshakeFeature.HashStrength => Request.HashStrength; 608ExchangeAlgorithmType ITlsHandshakeFeature.KeyExchangeAlgorithm => Request.KeyExchangeAlgorithm; 610int ITlsHandshakeFeature.KeyExchangeStrength => Request.KeyExchangeStrength; 613string ITlsHandshakeFeature.HostName => Request.SniHostName; 621public bool CanDelegate => Request.CanDelegate;
RequestProcessing\RequestContextOfT.cs (2)
74if (Request.ProtocolVersion == HttpVersion.Version20) 79else if (Request.ProtocolVersion == HttpVersion.Version30)
RequestProcessing\RequestStream.cs (4)
38private ulong RequestId => RequestContext.Request.RequestId; 118dataRead = _requestContext.Request.GetChunks(ref _dataChunkIndex, ref _dataChunkOffset, buffer, offset, size); 209dataRead = _requestContext.Request.GetChunks(ref _dataChunkIndex, ref _dataChunkOffset, buffer, offset, size); 323var contentLength = RequestContext.Request.ContentLength;
RequestProcessing\Response.cs (1)
68private Request Request => RequestContext.Request;
RequestProcessing\ResponseBody.cs (2)
36private ulong RequestId => RequestContext.Request.RequestId; 471if (_requestContext.Request.IsHeadMethod)
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (55)
Listener\RequestBodyTests.cs (13)
31Assert.Throws<InvalidOperationException>(() => context.Request.Body.Read(input, 0, input.Length)); 36var read = context.Request.Body.Read(input, 0, input.Length); 59Task<int> task = context.Request.Body.ReadAsync(input, 0, input.Length, cts.Token); 81int read = await context.Request.Body.ReadAsync(input, 0, input.Length, cts.Token); 84read = await context.Request.Body.ReadAsync(input, 0, input.Length, cts.Token); 106int read = await context.Request.Body.ReadAsync(input, 0, input.Length, cts.Token); 109read = await context.Request.Body.ReadAsync(input, 0, input.Length, cts.Token); 130int read = await context.Request.Body.ReadAsync(input, 0, input.Length, cts.Token); 132var readTask = context.Request.Body.ReadAsync(input, 0, input.Length, cts.Token); 155int read = await context.Request.Body.ReadAsync(input, 0, input.Length, cts.Token); 158var readTask = context.Request.Body.ReadAsync(input, 0, input.Length, cts.Token); 182int read = await context.Request.Body.ReadAsync(input, 0, input.Length, context.DisconnectToken); 185var assertTask = Assert.ThrowsAsync<IOException>(async () => await context.Request.Body.ReadAsync(input, 0, input.Length, context.DisconnectToken));
Listener\RequestHeaderTests.cs (7)
28var requestHeaders = context.Request.Headers; 30var headers = context.Request.Headers; 69var requestHeaders = context.Request.Headers; 96var requestHeaders = context.Request.Headers; 124var requestHeaders = context.Request.Headers; 165var requestHeaders = context.Request.Headers; 190var requestHeaders = context.Request.Headers;
Listener\RequestTests.cs (7)
39Assert.Equal("", context.Request.PathBase); 40Assert.Equal("", context.Request.Path); 41Assert.Equal("*", context.Request.RawUrl); 77actualPath = context.Request.Path; 127Assert.Equal(expectedPath, context.Request.Path); 164Assert.Equal(expectedPathBase, context.Request.PathBase); 165Assert.Equal(expectedPath, context.Request.Path);
Listener\ServerOnExistingQueueTests.cs (17)
61string input = await new StreamReader(context.Request.Body).ReadToEndAsync(); 99Assert.Equal("/pathBase", context.Request.PathBase); 100Assert.Equal("/paTh", context.Request.Path); 116Assert.Equal(string.Empty, context.Request.PathBase); 117Assert.Equal("/pathBase/paTh", context.Request.Path); 141Assert.Equal(expectedPathBase, context.Request.PathBase); 142Assert.Equal(expectedPath, context.Request.Path); 161Assert.Equal("/basepath/secondTier", context.Request.PathBase); 162Assert.Equal("/path/thing", context.Request.Path); 180Assert.Equal(string.Empty, context.Request.PathBase); 181Assert.Equal("/", context.Request.Path); 194Assert.Equal("/pathbase", context.Request.PathBase); 195Assert.Equal("/", context.Request.Path); 216Assert.Equal("/pathbase", context.Request.PathBase); 217Assert.Equal("/", context.Request.Path); 229Assert.Equal(string.Empty, context.Request.PathBase); 230Assert.Equal("/pathbase/", context.Request.Path);
Listener\ServerTests.cs (8)
153Assert.Equal(string.Empty, context.Request.PathBase); 154Assert.Equal("/", context.Request.Path); 166Assert.Equal("/pathbase", context.Request.PathBase); 167Assert.Equal("/", context.Request.Path); 186Assert.Equal("/pathbase", context.Request.PathBase); 187Assert.Equal("/", context.Request.Path); 198Assert.Equal(string.Empty, context.Request.PathBase); 199Assert.Equal("/pathbase/", context.Request.Path);
RequestHeaderTests.cs (3)
109var request = httpContext.Features.Get<RequestContext>().Request; 132var request = httpContext.Features.Get<RequestContext>().Request; 155var request = httpContext.Features.Get<RequestContext>().Request;