logos-storage/logos-storage-nim-cs-dist-tests
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim-cs-dist-tests.git synced 2026-01-08 00:13:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixes issue with frozen docker commands

Browse Source
This commit is contained in:
Ben 2025-04-22 09:59:53 +02:00
parent 779897521d
commit c9fe841bb5
No known key found for this signature in database
GPG Key ID: 0F16E812E736C24B
1 changed files with 29 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
ProjectPlugins/CodexContractsPlugin/VersionRegistry.cs
View File

@ -11,7 +11,8 @@ namespace CodexContractsPlugin
public class VersionRegistry
{
private ICodexDockerImageProvider provider = new ExceptionProvider();
private readonly Dictionary<string, string> cache = new Dictionary<string, string>();
private static readonly Dictionary<string, string> cache = new Dictionary<string, string>();
private static readonly object cacheLock = new object();
private readonly ILog log;
public VersionRegistry(ILog log)
@ -38,6 +39,8 @@ namespace CodexContractsPlugin
}
private string GetContractsDockerImage(string codexImage)
{
lock (cacheLock)
{
if (cache.TryGetValue(codexImage, out string? value))
{
@ -47,6 +50,7 @@ namespace CodexContractsPlugin
cache.Add(codexImage, result);
return result;
}
}
private string GetContractsImage(string codexImage)
{
@ -82,14 +86,32 @@ namespace CodexContractsPlugin
startInfo.RedirectStandardError = true;
var process = Process.Start(startInfo);
if (process == null || process.HasExited)
if (process == null)
{
throw new Exception("Failed to start: " + cmd + args);
}
KillAfterTimeout(process);
process.WaitForExit();
return process.StandardOutput.ReadToEnd();
}
private void KillAfterTimeout(Process process)
{
// There's a known issue that some docker commands on some platforms
// will fail to stop on their own. This has been known since 2019 and it's not fixed.
// So we will issue a kill to the process ourselves if it exceeds a timeout.
Task.Run(() =>
{
Thread.Sleep(TimeSpan.FromSeconds(30.0));
if (process != null && !process.HasExited)
{
process.Kill();
}
});
}
}
internal class ExceptionProvider : ICodexDockerImageProvider