|
|
|
@ -44,19 +44,20 @@ namespace Squidex.Infrastructure.Orleans |
|
|
|
|
|
|
|
try |
|
|
|
{ |
|
|
|
var grain = cluster.GrainFactory.GetGrain<IAsyncLocalGrain>(SingleGrain.Id); |
|
|
|
var grain = cluster.GrainFactory.GetGrain<IAsyncLocalGrain>(SingleGrain.Id); |
|
|
|
|
|
|
|
var result1 = await grain.GetValueAsync(); |
|
|
|
var result2 = await grain.GetValueAsync(); |
|
|
|
var result1 = await grain.GetValueAsync(); |
|
|
|
var result2 = await grain.GetValueAsync(); |
|
|
|
|
|
|
|
await cluster.KillSiloAsync(cluster.Silos[0]); |
|
|
|
await cluster.StartAdditionalSiloAsync(); |
|
|
|
await cluster.KillSiloAsync(cluster.Silos[0]); |
|
|
|
await cluster.StartAdditionalSiloAsync(); |
|
|
|
|
|
|
|
var result3 = await grain.GetValueAsync(); |
|
|
|
var result3 = await grain.GetValueAsync(); |
|
|
|
|
|
|
|
Assert.Equal(1, result1); |
|
|
|
Assert.Equal(1, result2); |
|
|
|
Assert.Equal(1, result3); |
|
|
|
Assert.Equal(1, result1); |
|
|
|
Assert.Equal(1, result2); |
|
|
|
Assert.Equal(1, result3); |
|
|
|
} |
|
|
|
finally |
|
|
|
{ |
|
|
|
await Task.WhenAny(Task.Delay(2000), cluster.StopAllSilosAsync()); |
|
|
|
|