Applies mutex in codex CidChecker

benbierens · benbierens · commit 33153a2b761d · 2024-12-03T08:50:50.000+01:00
diff --git a/Tools/BiblioTech/CodexCidChecker.cs b/Tools/BiblioTech/CodexCidChecker.cs
@@ -10,6 +10,7 @@ public class CodexCidChecker
         private static readonly string nl = Environment.NewLine;
         private readonly Configuration config;
         private readonly ILog log;
+        private readonly Mutex checkMutex = new Mutex();
         private CodexApi? currentCodexNode;
 
         public CodexCidChecker(Configuration config, ILog log)
@@ -27,6 +28,7 @@ public async Task<CheckResponse> PerformCheck(string cid)
 
             try
             {
+                checkMutex.WaitOne();
                 var codex = GetCodex();
                 var nodeCheck = await CheckCodex(codex);
                 if (!nodeCheck) return new CheckResponse(false, "Codex node is not available. Cannot perform check.", $"Codex node at '{config.CodexEndpoint}' did not respond correctly to debug/info.");
@@ -37,6 +39,10 @@ public async Task<CheckResponse> PerformCheck(string cid)
             {
                 return new CheckResponse(false, "Internal server error", ex.ToString());
             }
+            finally
+            {
+                checkMutex.ReleaseMutex();
+            }
         }
 
         private async Task<CheckResponse> PerformCheck(CodexApi codex, string cid)

Original file line number	Diff line number	Diff line change
`@@ -10,6 +10,7 @@ public class CodexCidChecker`
`10`	`10`	`private static readonly string nl = Environment.NewLine;`
`11`	`11`	`private readonly Configuration config;`
`12`	`12`	`private readonly ILog log;`
	`13`	`+ private readonly Mutex checkMutex = new Mutex();`
`13`	`14`	`private CodexApi? currentCodexNode;`
`14`	`15`
`15`	`16`	`public CodexCidChecker(Configuration config, ILog log)`
`@@ -27,6 +28,7 @@ public async Task<CheckResponse> PerformCheck(string cid)`
`27`	`28`
`28`	`29`	`try`
`29`	`30`	`{`
	`31`	`+ checkMutex.WaitOne();`
`30`	`32`	`var codex = GetCodex();`
`31`	`33`	`var nodeCheck = await CheckCodex(codex);`
`32`	`34`	`if (!nodeCheck) return new CheckResponse(false, "Codex node is not available. Cannot perform check.", $"Codex node at '{config.CodexEndpoint}' did not respond correctly to debug/info.");`
`@@ -37,6 +39,10 @@ public async Task<CheckResponse> PerformCheck(string cid)`
`37`	`39`	`{`
`38`	`40`	`return new CheckResponse(false, "Internal server error", ex.ToString());`
`39`	`41`	`}`
	`42`	`+ finally`
	`43`	`+ {`
	`44`	`+ checkMutex.ReleaseMutex();`
	`45`	`+ }`
`40`	`46`	`}`
`41`	`47`
`42`	`48`	`private async Task<CheckResponse> PerformCheck(CodexApi codex, string cid)`