3 instantiations of AppHostAuxiliaryBackchannel
aspire (1)
Backchannel\AppHostAuxiliaryBackchannel.cs (1)
165return new AppHostAuxiliaryBackchannel(hash, socketPath, rpc, mcpInfo, appHostInfo, isInScope, capabilitiesSet, logger);
Aspire.Cli.Tests (2)
Mcp\AppHostConnectionSelectionLogicTests.cs (1)
70return new AppHostAuxiliaryBackchannel(
Mcp\ListAppHostsToolTests.cs (1)
178return new AppHostAuxiliaryBackchannel(hash, socketPath, rpc, mcpInfo: null, appHostInfo, isInScope);
23 references to AppHostAuxiliaryBackchannel
aspire (12)
Backchannel\AppHostAuxiliaryBackchannel.cs (2)
112public static Task<AppHostAuxiliaryBackchannel> ConnectAsync( 133internal static async Task<AppHostAuxiliaryBackchannel> CreateFromSocketAsync(
Backchannel\AppHostConnectionResolver.cs (2)
67var connection = await AppHostAuxiliaryBackchannel.ConnectAsync(
Backchannel\AuxiliaryBackchannelMonitor.cs (6)
29private readonly ConcurrentDictionary<string, ConcurrentDictionary<string, AppHostAuxiliaryBackchannel>> _connectionsByHash = new(); 234connectionsForHash.TryRemove(removedFile, out var connection)) 409var connection = await AppHostAuxiliaryBackchannel.CreateFromSocketAsync(hash, socketPath, isInScope, socket, logger, cancellationToken).ConfigureAwait(false); 419connectionsForHash.TryRemove(socketPath, out var conn)) 432var connectionsDict = _connectionsByHash.GetOrAdd(hash, _ => new ConcurrentDictionary<string, AppHostAuxiliaryBackchannel>());
Projects\RunningInstanceManager.cs (2)
48using var backchannel = await AppHostAuxiliaryBackchannel.ConnectAsync(socketPath, _logger, cancellationToken).ConfigureAwait(false);
Aspire.Cli.Tests (11)
Mcp\AppHostConnectionSelectionLogicTests.cs (6)
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); 66private 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); 174private static AppHostAuxiliaryBackchannel CreateAppHostConnection(string hash, string socketPath, AppHostInformation appHostInfo, bool isInScope)