2 instantiations of AppHostAuxiliaryBackchannel
aspire (1)
Backchannel\AppHostAuxiliaryBackchannel.cs (1)
218return new AppHostAuxiliaryBackchannel(appHostSocket, rpc, appHostInfo, isInScope, capabilitiesSet, logger, profilingTelemetry);
Aspire.Cli.Tests (1)
Mcp\ListAppHostsToolTests.cs (1)
177return new AppHostAuxiliaryBackchannel(new TestAppHostSocket(socketPath), rpc, appHostInfo, isInScope);
31 references to AppHostAuxiliaryBackchannel
aspire (12)
Backchannel\AppHostAuxiliaryBackchannel.cs (3)
132public static Task<AppHostAuxiliaryBackchannel> ConnectAsync( 156internal static Task<AppHostAuxiliaryBackchannel> CreateFromSocketAsync( 165internal static async Task<AppHostAuxiliaryBackchannel> CreateFromSocketAsync(
Backchannel\AppHostConnectionResolver.cs (2)
159var connection = await AppHostAuxiliaryBackchannel.ConnectAsync(
Backchannel\AuxiliaryBackchannelMonitor.cs (5)
42private readonly ConcurrentDictionary<string, AppHostAuxiliaryBackchannel> _connectionsBySocketPath = new(StringComparers.FileSystemPath); 425if (_connectionsBySocketPath.TryRemove(removedFile, out var connection)) 613var connection = await AppHostAuxiliaryBackchannel.CreateFromSocketAsync(appHostSocket, isInScope, logger, profilingTelemetry, socket, cancellationToken).ConfigureAwait(false); 622if (_connectionsBySocketPath.TryRemove(socketPath, out var conn))
Projects\RunningInstanceManager.cs (2)
53using var backchannel = await AppHostAuxiliaryBackchannel.ConnectAsync(appHostSocket, _logger, _profilingTelemetry, cancellationToken).ConfigureAwait(false);
Aspire.Cli.Tests (19)
Backchannel\AppHostAuxiliaryBackchannelTests.cs (10)
23using var backchannel = await server.ConnectAsync().DefaultTimeout(); 38using var backchannel = await server.ConnectAsync().DefaultTimeout(); 57using var backchannel = await server.ConnectAsync().DefaultTimeout(); 71using var backchannel = await server.ConnectAsync().DefaultTimeout(); 87using var backchannel = await server.ConnectAsync().DefaultTimeout(); 131public Task<AppHostAuxiliaryBackchannel> ConnectAsync() => ConnectAsyncCore(handshakeTimeout: null); 133public Task<AppHostAuxiliaryBackchannel> ConnectAsync(TimeSpan handshakeTimeout) => ConnectAsyncCore(handshakeTimeout); 135private async Task<AppHostAuxiliaryBackchannel> ConnectAsyncCore(TimeSpan? handshakeTimeout) 152return await AppHostAuxiliaryBackchannel.CreateFromSocketAsync(new TestAppHostSocket("socket.hash1"), isInScope: true, NullLogger.Instance, new ProfilingTelemetry(new ConfigurationBuilder().Build()), clientSocket, timeout, CancellationToken.None).DefaultTimeout(); 155return await AppHostAuxiliaryBackchannel.CreateFromSocketAsync(new TestAppHostSocket("socket.hash1"), isInScope: true, NullLogger.Instance, new ProfilingTelemetry(new ConfigurationBuilder().Build()), clientSocket, CancellationToken.None).DefaultTimeout();
Commands\PsCommandTests.cs (4)
200using var connection = await server.ConnectAsync().DefaultTimeout(); 404using var connection = await server.ConnectAsync().DefaultTimeout(); 854public async Task<AppHostAuxiliaryBackchannel> ConnectAsync() 868return await AppHostAuxiliaryBackchannel.CreateFromSocketAsync(new TestAppHostSocket("socket.hash1"), isInScope: true, NullLogger.Instance, new ProfilingTelemetry(new ConfigurationBuilder().Build()), clientSocket, CancellationToken.None).DefaultTimeout();
Mcp\ListAppHostsToolTests.cs (5)
54var connection = CreateAppHostConnection("hash1", "/tmp/socket1", appHostInfo, isInScope: true); 86var connection = CreateAppHostConnection("hash2", "/tmp/socket2", appHostInfo, isInScope: false); 118var inScopeConnection = CreateAppHostConnection("hash1", "/tmp/socket1", inScopeAppHostInfo, isInScope: true); 129var outOfScopeConnection = CreateAppHostConnection("hash2", "/tmp/socket2", outOfScopeAppHostInfo, isInScope: false); 172private static AppHostAuxiliaryBackchannel CreateAppHostConnection(string hash, string socketPath, AppHostInformation appHostInfo, bool isInScope)