3 instantiations of AppHostAuxiliaryBackchannel
aspire (1)
Backchannel\AppHostAuxiliaryBackchannel.cs (1)
218return new AppHostAuxiliaryBackchannel(appHostSocket, rpc, appHostInfo, isInScope, capabilitiesSet, logger, profilingTelemetry);
Aspire.Cli.Tests (2)
Mcp\AppHostConnectionSelectionLogicTests.cs (1)
103return new AppHostAuxiliaryBackchannel(
Mcp\ListAppHostsToolTests.cs (1)
177return new AppHostAuxiliaryBackchannel(new TestAppHostSocket(socketPath), rpc, appHostInfo, isInScope);
39 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)
157var connection = await AppHostAuxiliaryBackchannel.ConnectAsync(
Backchannel\AuxiliaryBackchannelMonitor.cs (5)
41private readonly ConcurrentDictionary<string, AppHostAuxiliaryBackchannel> _connectionsBySocketPath = new(StringComparers.FileSystemPath); 394if (_connectionsBySocketPath.TryRemove(removedFile, out var connection)) 561var connection = await AppHostAuxiliaryBackchannel.CreateFromSocketAsync(appHostSocket, isInScope, logger, profilingTelemetry, socket, cancellationToken).ConfigureAwait(false); 570if (_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 (27)
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)
195using var connection = await server.ConnectAsync().DefaultTimeout(); 399using var connection = await server.ConnectAsync().DefaultTimeout(); 780public async Task<AppHostAuxiliaryBackchannel> ConnectAsync() 794return await AppHostAuxiliaryBackchannel.CreateFromSocketAsync(new TestAppHostSocket("socket.hash1"), isInScope: true, NullLogger.Instance, new ProfilingTelemetry(new ConfigurationBuilder().Build()), clientSocket, CancellationToken.None).DefaultTimeout();
Mcp\AppHostConnectionSelectionLogicTests.cs (8)
25var inScope = CreateConnection("hash1", appHostPath: "C:/repo/AppHost1", isInScope: true, processId: 1); 26var outOfScope = CreateConnection("hash2", appHostPath: "C:/other/AppHost2", isInScope: false, processId: 2); 41var inScope = CreateConnection("hash1", appHostPath: "C:/repo/AppHost1", isInScope: true, processId: 1); 57var inScope = CreateConnection("hash1", appHostPath: "C:/repo/AppHost1", isInScope: true, processId: 1); 58var outOfScope = CreateConnection("hash2", appHostPath: "C:/other/AppHost2", isInScope: false, processId: 2); 83var firstConnection = CreateConnection("hash1", firstPath, isInScope: true, processId: 1); 84var secondConnection = CreateConnection("hash2", secondPath, isInScope: true, processId: 2); 98private static AppHostAuxiliaryBackchannel CreateConnection(string hash, string appHostPath, bool isInScope, int processId)
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)