1 instantiation of HttpConnectionContext
Microsoft.AspNetCore.Http.Connections (1)
Internal\HttpConnectionManager.cs (1)
157var connection = new HttpConnectionContext(
55 references to HttpConnectionContext
Microsoft.AspNetCore.Http.Connections (55)
Internal\HttpConnectionContext.cs (3)
1228HttpConnectionContext connection, 1232private HttpConnectionContext? _connection = connection; 1244var connection = Interlocked.Exchange(ref _connection, null);
Internal\HttpConnectionDispatcher.cs (30)
70HttpConnectionContext? connectionContext = null; 169if (!_manager.TryGetConnection(connectionToken.ToString(), endpointMetadata, out var connection)) 219if (updateResult == HttpConnectionContext.UserUpdateResult.Rejected) 226else if (updateResult == HttpConnectionContext.UserUpdateResult.AdditionalPolicyRejected) 237if (updateResult != HttpConnectionContext.UserUpdateResult.Updated 321var connection = await GetConnectionAsync(context, endpointMetadata); 351HttpConnectionContext? connection; 514private async Task DoPersistentConnection(HttpConnectionContext connection) 565HttpConnectionContext? connection = null; 678var connection = await GetConnectionAsync(context, endpointMetadata); 783var connection = await GetConnectionAsync(context, endpointMetadata); 814private async Task<bool> EnsureConnectionStateAsync(HttpConnectionContext connection, HttpContext context, HttpTransportType transportType, HttpTransportType supportedTransports, ConnectionLogScope logScope, HttpConnectionDispatcherOptions options) 834case HttpConnectionContext.SetTransportState.Success: 837case HttpConnectionContext.SetTransportState.AlreadyActive: 845case HttpConnectionContext.SetTransportState.CannotChange: 877var principalChanged = !HttpConnectionContext.ClaimsPrincipalContentEquals(currentUser, newPrincipal) 896if (updateResult == HttpConnectionContext.UserUpdateResult.Rejected) 901else if (updateResult == HttpConnectionContext.UserUpdateResult.AdditionalPolicyRejected) 909userRefreshApplied = updateResult == HttpConnectionContext.UserUpdateResult.Updated; 995private static void UpdateExpiration(HttpConnectionContext connection, HttpContext context, HttpConnectionDispatcherOptions options) 1008private static DateTimeOffset GetAuthenticationExpiration(HttpConnectionContext connection, HttpContext context, HttpConnectionDispatcherOptions options) 1058newContext.User = HttpConnectionContext.CloneUserIfNeeded(oldContext.User, out _); 1061private static void CloneHttpContext(HttpContext context, HttpConnectionContext connection) 1127private async Task<bool> RejectIfConnectionUserChangedAsync(HttpConnectionContext connection, HttpContext context) 1153private async Task<HttpConnectionContext?> GetConnectionAsync(HttpContext context, HttpConnectionEndpointMetadata? endpointMetadata) 1167if (!_manager.TryGetConnection(connectionToken.ToString(), endpointMetadata, out var connection)) 1180private async Task<HttpConnectionContext?> GetOrCreateConnectionAsync( 1186HttpConnectionContext? connection; 1205private HttpConnectionContext CreateConnection( 1214private HttpConnectionContext CreateConnection(
Internal\HttpConnectionManager.cs (16)
23private readonly ConcurrentDictionary<string, HttpConnectionContext> _connections = 24new ConcurrentDictionary<string, HttpConnectionContext>(StringComparer.Ordinal); 27private readonly ILogger<HttpConnectionContext> _connectionLogger; 34_connectionLogger = loggerFactory.CreateLogger<HttpConnectionContext>(); 51internal bool TryGetConnection(string id, [NotNullWhen(true)] out HttpConnectionContext? connection) 56internal bool TryGetConnection(string id, HttpConnectionEndpointMetadata? endpointMetadata, [NotNullWhen(true)] out HttpConnectionContext? connection) 68internal HttpConnectionContext CreateConnection() 77internal HttpConnectionContext CreateConnection( 92internal HttpConnectionContext CreateConnection( 104internal HttpConnectionContext CreateConnection( 117internal HttpConnectionContext CreateConnection( 133private HttpConnectionContext CreateConnection( 157var connection = new HttpConnectionContext( 180if (_connections.TryRemove(id, out var connection)) 238var connection = c.Value; 292internal async Task DisposeAndRemoveAsync(HttpConnectionContext connection, bool closeGracefully, HttpConnectionStopStatus status)
Internal\Transports\LongPollingServerTransport.cs (2)
15private readonly HttpConnectionContext? _connection; 21public LongPollingServerTransport(CancellationToken timeoutToken, PipeReader application, ILoggerFactory loggerFactory, HttpConnectionContext? connection)
Internal\Transports\ServerSentEventsServerTransport.cs (2)
15private readonly HttpConnectionContext? _connection; 21public ServerSentEventsServerTransport(PipeReader application, string connectionId, HttpConnectionContext? connection, ILoggerFactory loggerFactory)
Internal\Transports\WebSocketsServerTransport.cs (2)
17private readonly HttpConnectionContext _connection; 23public WebSocketsServerTransport(WebSocketOptions options, IDuplexPipe application, HttpConnectionContext connection, ILoggerFactory loggerFactory)