-
Notifications
You must be signed in to change notification settings - Fork 2k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Dispose cluster & silo health monitors are disposed when host is disp…
…osed, and clean up code
- Loading branch information
1 parent
146eb7c
commit 8e88414
Showing
7 changed files
with
164 additions
and
130 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
36 changes: 15 additions & 21 deletions
36
src/Orleans.Runtime/MembershipService/RemoteSiloProber.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,31 +1,25 @@ | ||
#nullable enable | ||
using System; | ||
using System.Threading; | ||
using System.Threading.Tasks; | ||
using Microsoft.Extensions.DependencyInjection; | ||
|
||
namespace Orleans.Runtime.MembershipService | ||
namespace Orleans.Runtime.MembershipService; | ||
|
||
/// <inheritdoc /> | ||
internal class RemoteSiloProber(IServiceProvider serviceProvider) : IRemoteSiloProber | ||
{ | ||
/// <inheritdoc /> | ||
internal class RemoteSiloProber : IRemoteSiloProber | ||
public async Task Probe(SiloAddress remoteSilo, int probeNumber, CancellationToken cancellationToken) | ||
{ | ||
private readonly IServiceProvider serviceProvider; | ||
|
||
public RemoteSiloProber(IServiceProvider serviceProvider) | ||
{ | ||
this.serviceProvider = serviceProvider; | ||
} | ||
|
||
/// <inheritdoc /> | ||
public Task Probe(SiloAddress remoteSilo, int probeNumber) | ||
{ | ||
var systemTarget = this.serviceProvider.GetRequiredService<MembershipSystemTarget>(); | ||
return systemTarget.ProbeRemoteSilo(remoteSilo, probeNumber); | ||
} | ||
var systemTarget = serviceProvider.GetRequiredService<MembershipSystemTarget>(); | ||
await systemTarget.ProbeRemoteSilo(remoteSilo, probeNumber).WaitAsync(cancellationToken); | ||
} | ||
|
||
/// <inheritdoc /> | ||
public Task<IndirectProbeResponse> ProbeIndirectly(SiloAddress intermediary, SiloAddress target, TimeSpan probeTimeout, int probeNumber) | ||
{ | ||
var systemTarget = this.serviceProvider.GetRequiredService<MembershipSystemTarget>(); | ||
return systemTarget.ProbeRemoteSiloIndirectly(intermediary, target, probeTimeout, probeNumber); | ||
} | ||
/// <inheritdoc /> | ||
public async Task<IndirectProbeResponse> ProbeIndirectly(SiloAddress intermediary, SiloAddress target, TimeSpan probeTimeout, int probeNumber, CancellationToken cancellationToken) | ||
{ | ||
var systemTarget = serviceProvider.GetRequiredService<MembershipSystemTarget>(); | ||
return await systemTarget.ProbeRemoteSiloIndirectly(intermediary, target, probeTimeout, probeNumber).WaitAsync(cancellationToken); | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.