1 instantiation of HttpConnectionContext
Microsoft.AspNetCore.Http.Connections (1)
Internal\HttpConnectionManager.cs (1)
81var connection = new HttpConnectionContext(id, connectionToken, _connectionLogger, metricsContext, pair.Application, pair.Transport, options, useStatefulReconnect);
48 references to HttpConnectionContext
Microsoft.AspNetCore.Http.Connections (48)
Internal\HttpConnectionContext.cs (3)
1128HttpConnectionContext connection, 1132private HttpConnectionContext? _connection = connection; 1144var connection = Interlocked.Exchange(ref _connection, null);
Internal\HttpConnectionDispatcher.cs (28)
70HttpConnectionContext? connectionContext = null; 160if (!_manager.TryGetConnection(connectionToken.ToString(), out var connection)) 199if (updateResult == HttpConnectionContext.UserUpdateResult.Rejected) 206else if (updateResult == HttpConnectionContext.UserUpdateResult.AdditionalPolicyRejected) 285var connection = await GetConnectionAsync(context); 315HttpConnectionContext? connection; 478private async Task DoPersistentConnection(HttpConnectionContext connection) 525HttpConnectionContext? connection = null; 618var connection = await GetConnectionAsync(context); 716var connection = await GetConnectionAsync(context); 747private async Task<bool> EnsureConnectionStateAsync(HttpConnectionContext connection, HttpContext context, HttpTransportType transportType, HttpTransportType supportedTransports, ConnectionLogScope logScope, HttpConnectionDispatcherOptions options) 760case HttpConnectionContext.SetTransportState.Success: 763case HttpConnectionContext.SetTransportState.AlreadyActive: 771case HttpConnectionContext.SetTransportState.CannotChange: 803var principalChanged = !HttpConnectionContext.ClaimsPrincipalContentEquals(currentUser, newPrincipal) 821if (updateResult == HttpConnectionContext.UserUpdateResult.Rejected) 826else if (updateResult == HttpConnectionContext.UserUpdateResult.AdditionalPolicyRejected) 906private static void UpdateExpiration(HttpConnectionContext connection, HttpContext context, HttpConnectionDispatcherOptions options) 919private static DateTimeOffset GetAuthenticationExpiration(HttpConnectionContext connection, HttpContext context, HttpConnectionDispatcherOptions options) 1003private static void CloneHttpContext(HttpContext context, HttpConnectionContext connection) 1069private async Task<bool> RejectIfConnectionUserChangedAsync(HttpConnectionContext connection, HttpContext context) 1090var originalIdentity = originalUser is null ? null : HttpConnectionContext.GetUserIdentityKey(originalUser); 1091var newIdentity = HttpConnectionContext.GetUserIdentityKey(newUser); 1095private async Task<HttpConnectionContext?> GetConnectionAsync(HttpContext context) 1109if (!_manager.TryGetConnection(connectionToken.ToString(), out var connection)) 1122private async Task<HttpConnectionContext?> GetOrCreateConnectionAsync(HttpContext context, HttpConnectionDispatcherOptions options) 1125HttpConnectionContext? connection; 1144private HttpConnectionContext CreateConnection(HttpConnectionDispatcherOptions options, int clientProtocolVersion = 0, bool useStatefulReconnect = false)
Internal\HttpConnectionManager.cs (11)
22private readonly ConcurrentDictionary<string, HttpConnectionContext> _connections = 23new ConcurrentDictionary<string, HttpConnectionContext>(StringComparer.Ordinal); 26private readonly ILogger<HttpConnectionContext> _connectionLogger; 33_connectionLogger = loggerFactory.CreateLogger<HttpConnectionContext>(); 49internal bool TryGetConnection(string id, [NotNullWhen(true)] out HttpConnectionContext? connection) 54internal HttpConnectionContext CreateConnection() 63internal HttpConnectionContext CreateConnection(HttpConnectionDispatcherOptions options, int negotiateVersion = 0, bool useStatefulReconnect = false) 81var connection = new HttpConnectionContext(id, connectionToken, _connectionLogger, metricsContext, pair.Application, pair.Transport, options, useStatefulReconnect); 91if (_connections.TryRemove(id, out var connection)) 149var connection = c.Value; 203internal 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)