ConnectionContext

DefaultConnectionContext.cs (1)

19public class DefaultConnectionContext : ConnectionContext,

Internal\HttpConnectionContext.cs (1)

22internal sealed partial class HttpConnectionContext : ConnectionContext,

HttpConnection.cs (1)

29public partial class HttpConnection : ConnectionContext, IConnectionInherentKeepAliveFeature, IAuthenticationRefreshFeature

HttpsConfigurationService.cs (1)

189private sealed class ConnectionContextAdapter : ConnectionContext

Internal\WebTransport\WebTransportStream.cs (1)

16internal sealed class WebTransportStream : ConnectionContext, IStreamDirectionFeature, IStreamIdFeature, IConnectionItemsFeature

Middleware\LoggingMultiplexedConnectionMiddleware.cs (1)

86private sealed class LoggingConnectionContext : ConnectionContext

src\aspnetcore\src\Servers\Kestrel\shared\TransportConnection.cs (1)

14internal abstract partial class TransportConnection : ConnectionContext

src\aspnetcore\src\Servers\Kestrel\shared\TransportConnection.cs (1)

14internal abstract partial class TransportConnection : ConnectionContext

src\aspnetcore\src\Servers\Kestrel\shared\TransportConnection.cs (1)

14internal abstract partial class TransportConnection : ConnectionContext

src\aspnetcore\src\Servers\Kestrel\shared\TransportConnection.cs (1)

14internal abstract partial class TransportConnection : ConnectionContext

Authentication\Connection\ConnectionTypeMiddleware.cs (1)

24public async Task OnConnectionAsync(ConnectionContext context)

ConnectionBuilderExtensions.cs (6)

32/// If you aren't calling the next function, use <see cref="Run(IConnectionBuilder, Func{ConnectionContext, Task})"/> instead. 34/// Prefer using <see cref="Use(IConnectionBuilder, Func{ConnectionContext, ConnectionDelegate, Task})"/> for better performance as shown below: 46public static IConnectionBuilder Use(this IConnectionBuilder connectionBuilder, Func<ConnectionContext, Func<Task>, Task> middleware) 60/// If you aren't calling the next function, use <see cref="Run(IConnectionBuilder, Func{ConnectionContext, Task})"/> instead. 65public static IConnectionBuilder Use(this IConnectionBuilder connectionBuilder, Func<ConnectionContext, ConnectionDelegate, Task> middleware) 76public static IConnectionBuilder Run(this IConnectionBuilder connectionBuilder, Func<ConnectionContext, Task> middleware)

ConnectionDelegate.cs (2)

11/// <param name="connection">A <see cref="ConnectionContext" /> representing the connection.</param> 13public delegate Task ConnectionDelegate(ConnectionContext connection);

ConnectionHandler.cs (2)

16/// <param name="connection">The new <see cref="ConnectionContext"/></param> 18public abstract Task OnConnectedAsync(ConnectionContext connection);

DefaultConnectionContext.cs (1)

17/// The default implementation for the <see cref="ConnectionContext"/>.

IConnectionFactory.cs (2)

21/// A <see cref="ValueTask{TResult}" /> that represents the asynchronous connect, yielding the <see cref="ConnectionContext" /> for the new connection when completed. 23ValueTask<ConnectionContext> ConnectAsync(EndPoint endpoint, CancellationToken cancellationToken = default);

IConnectionListener.cs (2)

25/// <returns>A <see cref="ValueTask{ConnectionContext}"/> that completes when a connection is accepted, yielding the <see cref="ConnectionContext" /> representing the connection.</returns> 26ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default);

MultiplexedConnectionContext.cs (2)

21public abstract ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default); 29public abstract ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection? features = null, CancellationToken cancellationToken = default);

Features\IHttpContextFeature.cs (1)

9/// Feature set on the <see cref="ConnectionContext"/> that provides access to the underlying <see cref="Http.HttpContext"/>

Features\IHttpTransportFeature.cs (1)

9/// Feature set on the <see cref="ConnectionContext"/> that exposes the <see cref="HttpTransportType"/>

HttpConnectionContextExtensions.cs (2)

17/// <param name="connection">The <see cref="ConnectionContext"/> representing the connection.</param> 23public static HttpContext? GetHttpContext(this ConnectionContext connection)

HttpConnectionFactory.cs (2)

42/// A <see cref="ValueTask{TResult}" /> that represents the asynchronous connect, yielding the <see cref="ConnectionContext" /> for the new connection when completed. 44public async ValueTask<ConnectionContext> ConnectAsync(EndPoint endPoint, CancellationToken cancellationToken = default)

IWebTransportSession.cs (2)

33ValueTask<ConnectionContext?> AcceptStreamAsync(CancellationToken cancellationToken = default); 40ValueTask<ConnectionContext?> OpenUnidirectionalStreamAsync(CancellationToken cancellationToken = default);

DirectTlsEndpointOptions.cs (4)

37/// The first argument is the <see cref="ConnectionContext"/> for the connection being negotiated (already 45public Func<ConnectionContext?, string?, X509Certificate2?>? ServerCertificateSelector { get; set; } 80/// <see cref="ConnectionContext"/> for the connection being negotiated. 86public Action<ConnectionContext, ReadOnlySequence<byte>>? TlsClientHelloBytesCallback { get; set; }

HttpsConnectionAdapterOptions.cs (4)

51/// If SNI is not available then the name parameter will be null. The <see cref="ConnectionContext"/> will be null for HTTP/3 connections. 57public Func<ConnectionContext?, string?, X509Certificate2?>? ServerCertificateSelector { get; set; } 98public Action<ConnectionContext, SslServerAuthenticationOptions>? OnAuthenticate { get; set; } 111public Action<ConnectionContext, ReadOnlySequence<byte>>? TlsClientHelloBytesCallback { get; set; }

Internal\Http3\Http3Connection.cs (4)

365var streamContext = await _multiplexedContext.AcceptAsync(_acceptStreamsCts.Token); 595private async Task CreateHttp3Stream<TContext>(ConnectionContext streamContext, IHttpApplication<TContext> application, long streamId) where TContext : notnull 674internal Http3StreamContext CreateHttpStreamContext(ConnectionContext streamContext) 754var streamContext = await _multiplexedContext.ConnectAsync(features);

Internal\Http3\Http3FrameWriter.cs (2)

35private readonly ConnectionContext _connectionContext; 59public Http3FrameWriter(ConnectionContext connectionContext, ITimeoutControl timeoutControl, MinDataRate? minResponseDataRate, MemoryPool<byte> memoryPool, KestrelTrace log, IStreamIdFeature streamIdFeature, Http3PeerSettings clientPeerSettings, IHttp3Stream http3Stream)

Internal\Http3\Http3StreamContext.cs (2)

25ConnectionContext streamContext, 36public ConnectionContext StreamContext { get; }

Internal\Infrastructure\TransportManager.cs (2)

196private sealed class GenericConnectionListener : IConnectionListener<ConnectionContext> 207public ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default)

Internal\KestrelServerImpl.cs (1)

439return new ConnectionLimitMiddleware<ConnectionContext>(c => innerDelegate(c), connectionLimit.Value, trace, metrics).OnConnectionAsync;

Internal\SniOptionsSelector.cs (3)

25private readonly Func<ConnectionContext, string?, X509Certificate2?>? _fallbackServerCertificateSelector; 26private readonly Action<ConnectionContext, SslServerAuthenticationOptions>? _onAuthenticateCallback; 116public (SslServerAuthenticationOptions, ClientCertificateMode) GetOptions(ConnectionContext connection, string serverName)

Internal\TlsConnectionFeature.cs (2)

22private readonly ConnectionContext _context; 41internal TlsConnectionFeature(SslStream sslStream, ConnectionContext context, ILogger<HttpsConnectionMiddleware> logger)

Internal\WebTransport\WebTransportSession.cs (3)

122public async ValueTask<ConnectionContext?> OpenUnidirectionalStreamAsync(CancellationToken cancellationToken) 131var connectionContext = await _connection._multiplexedContext.ConnectAsync(features, cancellationToken); 166public async ValueTask<ConnectionContext?> AcceptStreamAsync(CancellationToken cancellationToken)

ListenOptionsHttpsExtensions.cs (2)

291/// The callback to invoke with the <see cref="ConnectionContext"/> and the raw TLS Client Hello bytes 304public static ListenOptions UseTlsClientHelloListener(this ListenOptions listenOptions, Action<ConnectionContext, ReadOnlySequence<byte>> tlsClientHelloBytesCallback, TimeSpan? timeout = null)

Middleware\HttpConnectionMiddleware.cs (1)

28public Task OnConnectionAsync(ConnectionContext connectionContext)

Middleware\HttpsConnectionMiddleware.cs (4)

43private readonly Func<ConnectionContext, string?, X509Certificate2?>? _serverCertificateSelector; 146public async Task OnConnectionAsync(ConnectionContext context) 347private Task DoOptionsBasedHandshakeAsync(ConnectionContext context, SslStream sslStream, Core.Internal.TlsConnectionFeature feature, CancellationToken cancellationToken) 472var (middleware, context, feature, metricsContext) = (ValueTuple<HttpsConnectionMiddleware, ConnectionContext, Core.Internal.TlsConnectionFeature, ConnectionMetricsContext>)state!;

Middleware\LoggingConnectionMiddleware.cs (1)

20public async Task OnConnectionAsync(ConnectionContext context)

Middleware\LoggingMultiplexedConnectionMiddleware.cs (6)

57public override async ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default) 59var context = await _inner.AcceptAsync(cancellationToken); 67public override async ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection? features = null, CancellationToken cancellationToken = default) 69var context = await _inner.ConnectAsync(features, cancellationToken); 88private readonly ConnectionContext _inner; 92public LoggingConnectionContext(ConnectionContext inner, ILogger logger)

Middleware\TlsListener.cs (3)

12private readonly Action<ConnectionContext, ReadOnlySequence<byte>> _tlsClientHelloBytesCallback; 14public TlsListener(Action<ConnectionContext, ReadOnlySequence<byte>> tlsClientHelloBytesCallback) 25internal async Task OnTlsClientHelloAsync(ConnectionContext connection, CancellationToken cancellationToken)

TlsHandshakeCallbackContext.cs (1)

42public ConnectionContext Connection { get; internal set; } = default!;

Connection\DirectTlsConnection.cs (1)

156/// had a stable <see cref="ConnectionContext"/>) to a fully-established connection by publishing the

Connection\DirectTlsConnectionListener.cs (5)

30private readonly Func<ConnectionContext?, string?, (TlsContext Context, RemoteCertificateValidationCallback? ClientCertificateValidation)>? _contextResolver; 32private readonly Action<ConnectionContext, ReadOnlySequence<byte>>? _clientHelloCallback; 58Func<ConnectionContext?, string?, (TlsContext Context, RemoteCertificateValidationCallback? ClientCertificateValidation)>? contextResolver, 64Action<ConnectionContext, ReadOnlySequence<byte>>? clientHelloCallback = null, 160public async ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default)

DirectTlsTransportFactory.cs (2)

109Func<ConnectionContext?, string?, (TlsContext Context, RemoteCertificateValidationCallback? ClientCertificateValidation)> contextResolver = 142Action<ConnectionContext, ReadOnlySequence<byte>>? clientHelloCallback = endpointOptions.TlsClientHelloBytesCallback;

TlsEventPump.cs (4)

77private Func<ConnectionContext?, string?, (TlsContext Context, RemoteCertificateValidationCallback? ClientCertificateValidation)>? _contextResolver; 91private Action<ConnectionContext, ReadOnlySequence<byte>>? _clientHelloCallback; 173Func<ConnectionContext?, string?, (TlsContext Context, RemoteCertificateValidationCallback? ClientCertificateValidation)>? contextResolver, 181Action<ConnectionContext, ReadOnlySequence<byte>>? clientHelloCallback = null,

TlsEventPumpPool.cs (2)

52Func<ConnectionContext?, string?, (TlsContext Context, RemoteCertificateValidationCallback? ClientCertificateValidation)>? contextResolver, 59Action<ConnectionContext, ReadOnlySequence<byte>>? clientHelloCallback = null,

Internal\NamedPipeConnectionListener.cs (4)

26private readonly Channel<ConnectionContext> _acceptedQueue; 52_acceptedQueue = Channel.CreateBounded<ConnectionContext>(new BoundedChannelOptions(capacity: 1)); 147public async ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default) 151if (_acceptedQueue.Reader.TryRead(out var connection))

Internal\QuicConnectionContext.cs (2)

94public override async ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default) 211public override async ValueTask<ConnectionContext> ConnectAsync(IFeatureCollection? features = null, CancellationToken cancellationToken = default)

Client\SocketConnectionFactory.cs (1)

47public async ValueTask<ConnectionContext> ConnectAsync(EndPoint endpoint, CancellationToken cancellationToken = default)

SocketConnectionContextFactory.cs (2)

84/// Create a <see cref="ConnectionContext"/> for a socket. 88public ConnectionContext Create(Socket socket)

SocketConnectionListener.cs (1)

59public async ValueTask<ConnectionContext?> AcceptAsync(CancellationToken cancellationToken = default)

HubConnection.cs (5)

525var connection = await _connectionFactory.ConnectAsync(_endPoint, cancellationToken).ConfigureAwait(false); 616var connection = connectionState.Connection; 836private static ValueTask CloseAsync(ConnectionContext connection) 2429public ConnectionContext Connection { get; } 2446public ConnectionState(ConnectionContext connection, HubConnection hubConnection)

src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (2)

64public MessageBuffer(ConnectionContext connection, IHubProtocol protocol, long bufferLimit, ILogger logger) 69public MessageBuffer(ConnectionContext connection, IHubProtocol protocol, long bufferLimit, ILogger logger, TimeProvider timeProvider)

HubConnectionContext.cs (3)

28private readonly ConnectionContext _connectionContext; 73/// <param name="connectionContext">The underlying <see cref="ConnectionContext"/>.</param> 76public HubConnectionContext(ConnectionContext connectionContext, HubConnectionContextOptions contextOptions, ILoggerFactory loggerFactory)

HubConnectionHandler.cs (1)

113public override async Task OnConnectedAsync(ConnectionContext connection)

src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (2)

64public MessageBuffer(ConnectionContext connection, IHubProtocol protocol, long bufferLimit, ILogger logger) 69public MessageBuffer(ConnectionContext connection, IHubProtocol protocol, long bufferLimit, ILogger logger, TimeProvider timeProvider)

src\aspnetcore\src\SignalR\common\testassets\Tests.Utils\HubConnectionContextUtils.cs (3)

17public static HubConnectionContext Create(ConnectionContext connection, IHubProtocol protocol = null, string userIdentifier = null) 31public static MockHubConnectionContext CreateMock(ConnectionContext connection) 44public MockHubConnectionContext(ConnectionContext connectionContext, HubConnectionContextOptions contextOptions, ILoggerFactory loggerFactory)