status-im
/
cs-codex-dist-tests
mirror of
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

stops autoclient after 5 failures

This commit is contained in:
benbierens 2024-11-11 13:41:02 +01:00
parent 365032978b
commit d48caa44d6
No known key found for this signature in database
GPG Key ID: 877D2C2E09A22F3A
1 changed files with 24 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
Tools/AutoClient/Modes/FolderStoreMode.cs
View File

@ -40,10 +40,14 @@ namespace AutoClient.Modes
var i = 0; var i = 0;
while (!cts.IsCancellationRequested) while (!cts.IsCancellationRequested)
{ {
if (app.FolderWorkDispatcher.Revisiting) Thread.Sleep(500); if (app.FolderWorkDispatcher.Revisiting) Thread.Sleep(2000);
else Thread.Sleep(2000); else Thread.Sleep(5000);
await ProcessWorkItem(instance); var worker = await ProcessWorkItem(instance);
if (worker.FailureCounter > 5)
{
throw new Exception("Worker has failure count > 5. Stopping AutoClient...");
}
i++; i++;
if (i > 5) if (i > 5)
@ -55,7 +59,7 @@ namespace AutoClient.Modes
} }
} }
private async Task ProcessWorkItem(ICodexInstance instance) private async Task<FileWorker> ProcessWorkItem(ICodexInstance instance)
{ {
var file = app.FolderWorkDispatcher.GetFileToCheck(); var file = app.FolderWorkDispatcher.GetFileToCheck();
var worker = new FileWorker(app, purchaseInfo, folder, file); var worker = new FileWorker(app, purchaseInfo, folder, file);
@ -63,6 +67,8 @@ namespace AutoClient.Modes
{ {
app.FolderWorkDispatcher.RevisitSoon(file); app.FolderWorkDispatcher.RevisitSoon(file);
}); });
return worker;
} }
public void Stop() public void Stop()
@ -92,6 +98,8 @@ namespace AutoClient.Modes
sourceFilename = filename; sourceFilename = filename;
} }
public int FailureCounter => State.FailureCounter;
public async Task Update(ICodexInstance instance, Action shouldRevisitSoon) public async Task Update(ICodexInstance instance, Action shouldRevisitSoon)
{ {
try try
@ -122,9 +130,18 @@ namespace AutoClient.Modes
await UpdatePurchase(recent, instance, codex); await UpdatePurchase(recent, instance, codex);
if (recent.Expiry.HasValue || recent.Finish.HasValue) if (recent.Expiry.HasValue)
{ {
app.Log.Log($"Purchase for '{sourceFilename}' has expired or finished."); app.Log.Log($"Purchase for '{sourceFilename}' has failed or expired.");
await MakeNewPurchase(instance, codex);
shouldRevisitSoon();
State.FailureCounter++;
return;
}
if (recent.Finish.HasValue)
{
app.Log.Log($"Purchase for '{sourceFilename}' has finished.");
await MakeNewPurchase(instance, codex); await MakeNewPurchase(instance, codex);
shouldRevisitSoon(); shouldRevisitSoon();
return; return;
@ -299,6 +316,7 @@ namespace AutoClient.Modes
public class WorkerStatus public class WorkerStatus
{ {
public string Cid { get; set; } = string.Empty; public string Cid { get; set; } = string.Empty;
public int FailureCounter { get; set; } = 0;
public WorkerPurchase[] Purchases { get; set; } = Array.Empty<WorkerPurchase>(); public WorkerPurchase[] Purchases { get; set; } = Array.Empty<WorkerPurchase>();
} }