increased delay to 2500, renamed method
This commit is contained in:
parent
22d03005a1
commit
f70ff5c053
3 changed files with 4 additions and 4 deletions
|
@ -62,9 +62,9 @@ public partial class Administration
|
||||||
if (!response)
|
if (!response)
|
||||||
return;
|
return;
|
||||||
|
|
||||||
for (var i = startShardId; i < _creds.GetCreds().TotalShards; i++)
|
for (var shardId = startShardId; shardId < _creds.GetCreds().TotalShards; shardId++)
|
||||||
{
|
{
|
||||||
await _svc.LeaveUnkeptServers(i);
|
await _svc.StartLeavingUnkeptServers(shardId);
|
||||||
await Task.Delay(2250 * 1000);
|
await Task.Delay(2250 * 1000);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -237,7 +237,7 @@ public sealed class CleanupService : ICleanupService, IReadyExecutor, IEService
|
||||||
return await table.CountAsync();
|
return await table.CountAsync();
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task LeaveUnkeptServers(int shardId)
|
public async Task StartLeavingUnkeptServers(int shardId)
|
||||||
=> await _pubSub.Pub(_keepTriggerKey, shardId);
|
=> await _pubSub.Pub(_keepTriggerKey, shardId);
|
||||||
|
|
||||||
private ValueTask OnKeepReport(KeepReport report)
|
private ValueTask OnKeepReport(KeepReport report)
|
||||||
|
|
|
@ -5,5 +5,5 @@ public interface ICleanupService
|
||||||
Task<KeepResult?> DeleteMissingGuildDataAsync();
|
Task<KeepResult?> DeleteMissingGuildDataAsync();
|
||||||
Task<bool> KeepGuild(ulong guildId);
|
Task<bool> KeepGuild(ulong guildId);
|
||||||
Task<int> GetKeptGuildCount();
|
Task<int> GetKeptGuildCount();
|
||||||
Task LeaveUnkeptServers(int shardId);
|
Task StartLeavingUnkeptServers(int shardId);
|
||||||
}
|
}
|
Loading…
Reference in a new issue