1 write to CircuitId
Microsoft.AspNetCore.Components.Server (1)
Circuits\CircuitHost.cs (1)
60
CircuitId
= circuitId;
83 references to CircuitId
Microsoft.AspNetCore.Components.Server (56)
Circuits\Circuit.cs (1)
21
public string Id => _circuitHost.
CircuitId
.Id;
Circuits\CircuitFactory.cs (1)
133
CreatedCircuit(logger, circuitHost.
CircuitId
.Id, circuitHost.Client.ConnectionId);
Circuits\CircuitHost.cs (24)
61
if (
CircuitId
.Secret is null)
64
throw new ArgumentException($"Property '{nameof(
CircuitId
.Secret)}' cannot be null.", nameof(circuitId));
132
activityHandle = _circuitActivitySource.StartCircuitActivity(
CircuitId
.Id, httpActivityContext);
198
Log.DisposeStarted(_logger,
CircuitId
);
240
Log.DisposeSucceeded(_logger,
CircuitId
);
244
Log.DisposeFailed(_logger,
CircuitId
, ex);
253
Log.CircuitOpened(_logger,
CircuitId
);
284
Log.ConnectionUp(_logger,
CircuitId
, Client.ConnectionId);
320
Log.ConnectionDown(_logger,
CircuitId
, Client.ConnectionId);
350
Log.CircuitClosed(_logger,
CircuitId
);
392
Log.OnRenderCompletedFailed(_logger, renderId,
CircuitId
, e);
569
Log.LocationChange(_logger, uri,
CircuitId
);
571
Log.LocationChangeSucceeded(_logger, uri,
CircuitId
);
588
Log.LocationChangeFailedInCircuit(_logger, uri,
CircuitId
, nex);
596
Log.LocationChangeFailed(_logger, uri,
CircuitId
, ex);
611
Log.LocationChanging(_logger, uri,
CircuitId
);
621
Log.LocationChangeFailed(_logger, uri,
CircuitId
, ex);
717
Log.CircuitUnhandledException(_logger,
CircuitId
, exception);
744
CircuitId
,
751
Log.CircuitTransmittingClientError(_logger,
CircuitId
);
753
Log.CircuitTransmittedClientErrorSuccess(_logger,
CircuitId
);
757
Log.CircuitTransmitErrorFailed(_logger,
CircuitId
, ex);
953
CircuitId
.Secret,
961
Log.FailedToSaveStateToClient(_logger,
CircuitId
, ex);
Circuits\CircuitPersistenceManager.cs (2)
42
circuit.
CircuitId
,
57
circuit.
CircuitId
,
Circuits\CircuitRegistry.cs (17)
79
if (!ConnectedCircuits.TryAdd(circuitHost.
CircuitId
, circuitHost))
82
throw new ArgumentException($"Circuit with identity {circuitHost.
CircuitId
} is already registered.");
92
Log.CircuitDisconnectStarted(_logger, circuitHost.
CircuitId
, connectionId);
116
var circuitId = circuitHost.
CircuitId
;
160
DisconnectedCircuits.Set(circuitHost.
CircuitId
.Secret, entry, entryOptions);
218
Log.ReconnectionSucceeded(_logger, circuitHost.
CircuitId
);
223
Log.FailedToReconnectToCircuit(_logger, circuitHost.
CircuitId
, ex);
235
Log.ConnectingToActiveCircuit(_logger, connectedCircuitHost.
CircuitId
, connectionId);
245
Log.ConnectingToDisconnectedCircuit(_logger, disconnectedEntry.CircuitHost.
CircuitId
, connectionId);
270
Log.CircuitEvicted(_logger, disconnectedEntry.CircuitHost.
CircuitId
, reason);
299
Log.PersistedCircuitStateDiscarded(_logger, entry.CircuitHost.
CircuitId
);
324
Log.CircuitPauseStarted(_logger, circuitHost.
CircuitId
, connectionId);
335
Log.CircuitPauseFailed(_logger, circuitHost.
CircuitId
, connectionId);
341
var circuitId = circuitHost.
CircuitId
;
391
Log.CircuitDisconnectedPermanently(_logger, circuitHost.
CircuitId
);
414
await TerminateAsync(circuitHost.
CircuitId
);
419
Log.CircuitExceptionHandlerFailed(_logger, circuitHost.
CircuitId
, ex);
ComponentHub.cs (11)
94
Log.CircuitAlreadyInitialized(_logger, circuitHost.
CircuitId
);
95
await NotifyClientError(Clients.Caller, $"The circuit host '{circuitHost.
CircuitId
}' has already been initialized.");
155
Log.CreatedCircuit(_logger, circuitHost.
CircuitId
, circuitHost.
CircuitId
.Secret, Context.ConnectionId);
156
return circuitHost.
CircuitId
.Secret;
196
await _circuitRegistry.TerminateAsync(circuitHost.
CircuitId
);
291
Log.CircuitAlreadyInitialized(_logger, circuitHost.
CircuitId
);
292
await NotifyClientError(Clients.Caller, $"The circuit host '{circuitHost.
CircuitId
}' has already been initialized.");
381
Log.CreatedCircuit(_logger, circuitHost.
CircuitId
, circuitHost.
CircuitId
.Secret, Context.ConnectionId);
383
return circuitHost.
CircuitId
.Secret;
Microsoft.AspNetCore.Components.Server.Tests (27)
Circuits\CircuitHostTest.cs (1)
442
It.Is<object[]>(args => args[0].Equals(circuitHost.
CircuitId
.Secret) &&
Circuits\CircuitRegistryTest.cs (26)
49
var result = await registry.ConnectAsync(circuitHost.
CircuitId
, newClient, newConnectionId, default);
74
var result = await registry.ConnectAsync(circuitHost.
CircuitId
, newClient, newConnectionId, default);
83
Assert.False(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
, out _));
100
var result = await registry.ConnectAsync(circuitHost.
CircuitId
, newClient, newConnectionId, default);
124
var result = await registry.ConnectAsync(circuitHost.
CircuitId
, newClient, newConnectionId, default);
149
var result = await registry.ConnectAsync(circuitHost.
CircuitId
, newClient, newConnectionId, default);
164
registry.DisconnectedCircuits.Set(circuitHost.
CircuitId
.Secret, circuitHost, new MemoryCacheEntryOptions { Size = 1 });
171
Assert.True(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
.Secret, out _));
256
await registry.ConnectAsync(circuitHost.
CircuitId
, client, newId, default);
268
Assert.False(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
.Secret, out _));
311
var connectCore = registry.ConnectAsync(circuitHost.
CircuitId
, client, newId, default);
324
Assert.False(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
.Secret, out _));
364
var connectCore = registry.ConnectAsync(circuitHost.
CircuitId
, client, newId, default);
377
Assert.False(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
.Secret, out _));
395
var connect = Task.Run(() => registry.ConnectAsync(circuitHost.
CircuitId
, client, newId, default));
407
Assert.False(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
.Secret, out _));
432
Assert.True(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
.Secret, out var _));
434
Assert.False(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
.Secret, out var _));
456
await registry.ConnectAsync(circuitHost.
CircuitId
, Mock.Of<ISingleClientProxy>(), "new-connection", default);
462
Assert.True(registry.ConnectedCircuits.TryGetValue(circuitHost.
CircuitId
, out var cacheValue));
465
Assert.False(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
.Secret, out var _));
483
Assert.True(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
.Secret, out _));
526
var connectResultAttempt = registry.ConnectAsync(circuitHost.
CircuitId
, newClient, newConnectionId, default);
540
Assert.False(registry.ConnectedCircuits.ContainsKey(circuitHost.
CircuitId
), "Circuit should not be in connected circuits.");
541
Assert.False(registry.DisconnectedCircuits.TryGetValue(circuitHost.
CircuitId
.Secret, out _), "Circuit should be evicted from disconnected circuits.");
559
Assert.True(registry.ConnectedCircuits.TryGetValue(circuitHost.
CircuitId
, out var connectedCircuit));