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);
35 references to HttpConnectionContext
Microsoft.AspNetCore.Http.Connections (35)
Internal\HttpConnectionDispatcher.cs (18)
68HttpConnectionContext? connectionContext = null; 136var connection = await GetConnectionAsync(context); 166HttpConnectionContext? connection; 329private async Task DoPersistentConnection(HttpConnectionContext connection) 376HttpConnectionContext? connection = null; 452var connection = await GetConnectionAsync(context); 545var connection = await GetConnectionAsync(context); 571private async Task<bool> EnsureConnectionStateAsync(HttpConnectionContext connection, HttpContext context, HttpTransportType transportType, HttpTransportType supportedTransports, ConnectionLogScope logScope) 584case HttpConnectionContext.SetTransportState.Success: 587case HttpConnectionContext.SetTransportState.AlreadyActive: 595case HttpConnectionContext.SetTransportState.CannotChange: 667private static void UpdateExpiration(HttpConnectionContext connection, HttpContext context) 714private static void CloneHttpContext(HttpContext context, HttpConnectionContext connection) 778private async Task<HttpConnectionContext?> GetConnectionAsync(HttpContext context) 792if (!_manager.TryGetConnection(connectionToken.ToString(), out var connection)) 805private async Task<HttpConnectionContext?> GetOrCreateConnectionAsync(HttpContext context, HttpConnectionDispatcherOptions options) 808HttpConnectionContext? connection; 827private 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)