Skip to content

Commit f514819

Browse files
committed
Test fixes
1 parent f40867c commit f514819

File tree

3 files changed

+4
-8
lines changed

3 files changed

+4
-8
lines changed

src/Orleans.Runtime/GrainDirectory/DhtGrainLocator.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ public DhtGrainLocator(
2828

2929
public async ValueTask<GrainAddress> Lookup(GrainId grainId) => (await _localGrainDirectory.LookupAsync(grainId)).Address;
3030

31-
public async Task<GrainAddress> Register(GrainAddress address, GrainAddress previousAddress) => (await _localGrainDirectory.RegisterAsync(address, currentRegistration: previousAddress)).Address;
31+
public async Task<GrainAddress> Register(GrainAddress address, GrainAddress previousAddress) => (await _localGrainDirectory.RegisterAsync(address, previousAddress, hopCount: 0)).Address;
3232

3333
public Task Unregister(GrainAddress address, UnregistrationCause cause)
3434
{
@@ -132,7 +132,7 @@ private async Task ProcessDeregistrationQueue()
132132

133133
if (operations.Count > 0)
134134
{
135-
await _localGrainDirectory.UnregisterManyAsync(addresses, _cause);
135+
await _localGrainDirectory.UnregisterManyAsync(addresses, _cause, hopCount: 0);
136136
foreach (var op in operations)
137137
{
138138
op.TrySetResult(true);

src/Orleans.Runtime/GrainDirectory/ILocalGrainDirectory.cs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,6 @@ internal interface ILocalGrainDirectory : IDhtGrainDirectory
1818
/// </summary>
1919
Task StopAsync();
2020

21-
RemoteGrainDirectory RemoteGrainDirectory { get; }
22-
RemoteGrainDirectory CacheValidator { get; }
23-
2421
/// <summary>
2522
/// Removes the record for an non-existing activation from the directory service.
2623
/// This is used when a request is received for an activation that cannot be found,

test/Grains/TestInternalGrains/TestGrain.cs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,6 @@ internal class OneWayGrain : Grain, IOneWayGrain, ISimpleGrainObserver
218218

219219
public OneWayGrain(GrainLocator grainLocator) => this.grainLocator = grainLocator;
220220

221-
private ILocalGrainDirectory LocalGrainDirectory => this.ServiceProvider.GetRequiredService<ILocalGrainDirectory>();
222221
private ILocalSiloDetails LocalSiloDetails => this.ServiceProvider.GetRequiredService<ILocalSiloDetails>();
223222

224223
public Task Notify()
@@ -325,8 +324,8 @@ public Task<SiloAddress> GetSiloAddress()
325324

326325
public Task<SiloAddress> GetPrimaryForGrain()
327326
{
328-
var grainId = (GrainId)this.GrainId;
329-
var primaryForGrain = this.LocalGrainDirectory.GetPrimaryForGrain(grainId);
327+
var directory = (DistributedGrainDirectory.ITestHooks)ServiceProvider.GetRequiredService<DistributedGrainDirectory>();
328+
var primaryForGrain = directory.GetPrimaryForGrain(GrainId);
330329
return Task.FromResult(primaryForGrain);
331330
}
332331

0 commit comments

Comments
 (0)