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);
41 references to HttpConnectionContext
Microsoft.AspNetCore.Http.Connections (41)
Internal\HttpConnectionContext.cs (3)
885HttpConnectionContext connection, 889private HttpConnectionContext? _connection = connection; 901var connection = Interlocked.Exchange(ref _connection, null);
Internal\HttpConnectionDispatcher.cs (21)
70HttpConnectionContext? connectionContext = null; 160if (!_manager.TryGetConnection(connectionToken.ToString(), out var connection)) 272HttpConnectionContext connection, HttpContext context, 359var connection = await GetConnectionAsync(context); 389HttpConnectionContext? connection; 552private async Task DoPersistentConnection(HttpConnectionContext connection) 599HttpConnectionContext? connection = null; 692var connection = await GetConnectionAsync(context); 785var connection = await GetConnectionAsync(context); 811private async Task<bool> EnsureConnectionStateAsync(HttpConnectionContext connection, HttpContext context, HttpTransportType transportType, HttpTransportType supportedTransports, ConnectionLogScope logScope, HttpConnectionDispatcherOptions options) 824case HttpConnectionContext.SetTransportState.Success: 827case HttpConnectionContext.SetTransportState.AlreadyActive: 835case HttpConnectionContext.SetTransportState.CannotChange: 1011private static void UpdateExpiration(HttpConnectionContext connection, HttpContext context) 1024private static DateTimeOffset GetAuthenticationExpiration(HttpConnectionContext connection, HttpContext context) 1087private static void CloneHttpContext(HttpContext context, HttpConnectionContext connection) 1151private async Task<HttpConnectionContext?> GetConnectionAsync(HttpContext context) 1165if (!_manager.TryGetConnection(connectionToken.ToString(), out var connection)) 1178private async Task<HttpConnectionContext?> GetOrCreateConnectionAsync(HttpContext context, HttpConnectionDispatcherOptions options) 1181HttpConnectionContext? connection; 1200private 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)