3 instantiations of AppHostAuxiliaryBackchannel
aspire (1)
Backchannel\AppHostAuxiliaryBackchannel.cs (1)
201
return new
AppHostAuxiliaryBackchannel
(hash, socketPath, rpc, appHostInfo, isInScope, capabilitiesSet, logger, profilingTelemetry);
Aspire.Cli.Tests (2)
Mcp\AppHostConnectionSelectionLogicTests.cs (1)
70
return new
AppHostAuxiliaryBackchannel
(
Mcp\ListAppHostsToolTests.cs (1)
176
return new
AppHostAuxiliaryBackchannel
(hash, socketPath, rpc, appHostInfo, isInScope);
34 references to AppHostAuxiliaryBackchannel
aspire (12)
Backchannel\AppHostAuxiliaryBackchannel.cs (2)
134
public static Task<
AppHostAuxiliaryBackchannel
> ConnectAsync(
159
internal static async Task<
AppHostAuxiliaryBackchannel
> CreateFromSocketAsync(
Backchannel\AppHostConnectionResolver.cs (2)
156
var
connection = await
AppHostAuxiliaryBackchannel
.ConnectAsync(
Backchannel\AuxiliaryBackchannelMonitor.cs (6)
42
private readonly ConcurrentDictionary<string, ConcurrentDictionary<string,
AppHostAuxiliaryBackchannel
>> _connectionsByHash = new();
330
connectionsForHash.TryRemove(removedFile, out
var
connection))
505
var
connection = await
AppHostAuxiliaryBackchannel
.CreateFromSocketAsync(hash, socketPath, isInScope, logger, profilingTelemetry, socket, cancellationToken).ConfigureAwait(false);
515
connectionsForHash.TryRemove(socketPath, out
var
conn))
530
var connectionsDict = _connectionsByHash.GetOrAdd(hash, _ => new ConcurrentDictionary<string,
AppHostAuxiliaryBackchannel
>());
Projects\RunningInstanceManager.cs (2)
53
using
var
backchannel = await
AppHostAuxiliaryBackchannel
.ConnectAsync(socketPath, _logger, _profilingTelemetry, cancellationToken).ConfigureAwait(false);
Aspire.Cli.Tests (22)
Backchannel\AppHostAuxiliaryBackchannelTests.cs (7)
22
using
var
backchannel = await server.ConnectAsync().DefaultTimeout();
37
using
var
backchannel = await server.ConnectAsync().DefaultTimeout();
56
using
var
backchannel = await server.ConnectAsync().DefaultTimeout();
70
using
var
backchannel = await server.ConnectAsync().DefaultTimeout();
86
using
var
backchannel = await server.ConnectAsync().DefaultTimeout();
115
public async Task<
AppHostAuxiliaryBackchannel
> ConnectAsync()
129
return await
AppHostAuxiliaryBackchannel
.CreateFromSocketAsync("hash1", "socket.hash1", isInScope: true, NullLogger.Instance, new ProfilingTelemetry(new ConfigurationBuilder().Build()), clientSocket, CancellationToken.None).DefaultTimeout();
Commands\PsCommandTests.cs (4)
196
using
var
connection = await server.ConnectAsync().DefaultTimeout();
400
using
var
connection = await server.ConnectAsync().DefaultTimeout();
781
public async Task<
AppHostAuxiliaryBackchannel
> ConnectAsync()
795
return await
AppHostAuxiliaryBackchannel
.CreateFromSocketAsync("hash1", "socket.hash1", isInScope: true, NullLogger.Instance, new ProfilingTelemetry(new ConfigurationBuilder().Build()), clientSocket, CancellationToken.None).DefaultTimeout();
Mcp\AppHostConnectionSelectionLogicTests.cs (6)
25
var
inScope = CreateConnection("hash1", appHostPath: "C:/repo/AppHost1", isInScope: true, processId: 1);
26
var
outOfScope = CreateConnection("hash2", appHostPath: "C:/other/AppHost2", isInScope: false, processId: 2);
41
var
inScope = CreateConnection("hash1", appHostPath: "C:/repo/AppHost1", isInScope: true, processId: 1);
57
var
inScope = CreateConnection("hash1", appHostPath: "C:/repo/AppHost1", isInScope: true, processId: 1);
58
var
outOfScope = CreateConnection("hash2", appHostPath: "C:/other/AppHost2", isInScope: false, processId: 2);
66
private static
AppHostAuxiliaryBackchannel
CreateConnection(string hash, string appHostPath, bool isInScope, int processId)
Mcp\ListAppHostsToolTests.cs (5)
54
var
connection = CreateAppHostConnection("hash1", "/tmp/socket1", appHostInfo, isInScope: true);
86
var
connection = CreateAppHostConnection("hash2", "/tmp/socket2", appHostInfo, isInScope: false);
118
var
inScopeConnection = CreateAppHostConnection("hash1", "/tmp/socket1", inScopeAppHostInfo, isInScope: true);
129
var
outOfScopeConnection = CreateAppHostConnection("hash2", "/tmp/socket2", outOfScopeAppHostInfo, isInScope: false);
172
private static
AppHostAuxiliaryBackchannel
CreateAppHostConnection(string hash, string socketPath, AppHostInformation appHostInfo, bool isInScope)