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

Prevents multiple continuous tests from running interleaved.

This commit is contained in:
benbierens 2023-10-02 11:18:27 +02:00
parent 73c49b42c6
commit 3dcbb78204
No known key found for this signature in database
GPG Key ID: FE44815D96D0A1AA
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
Tests/CodexContinuousTests/TestLoop.cs
View File

@ -13,6 +13,7 @@ namespace ContinuousTests
private readonly StartupChecker startupChecker; private readonly StartupChecker startupChecker;
private readonly CancellationToken cancelToken; private readonly CancellationToken cancelToken;
private readonly EventWaitHandle runFinishedHandle = new EventWaitHandle(true, EventResetMode.ManualReset); private readonly EventWaitHandle runFinishedHandle = new EventWaitHandle(true, EventResetMode.ManualReset);
private static object testLock = new object();
public TestLoop(EntryPointFactory entryPointFactory, TaskFactory taskFactory, Configuration config, ILog overviewLog, Type testType, TimeSpan runsEvery, StartupChecker startupChecker, CancellationToken cancelToken) public TestLoop(EntryPointFactory entryPointFactory, TaskFactory taskFactory, Configuration config, ILog overviewLog, Type testType, TimeSpan runsEvery, StartupChecker startupChecker, CancellationToken cancelToken)
{ {
@ -41,13 +42,19 @@ namespace ContinuousTests
NumberOfFailures = 0; NumberOfFailures = 0;
while (!cancelToken.IsCancellationRequested) while (!cancelToken.IsCancellationRequested)
{ {
WaitHandle.WaitAny(new[] { runFinishedHandle, cancelToken.WaitHandle }); lock (testLock)
// In the original design, multiple tests are allowed to interleave their test-moments, increasing test through-put.
// Since we're still stabilizing some of the basics, this lock limits us to 1 test run at a time.
{
WaitHandle.WaitAny(new[] { runFinishedHandle, cancelToken.WaitHandle });
cancelToken.ThrowIfCancellationRequested(); cancelToken.ThrowIfCancellationRequested();
StartTest(); StartTest();
cancelToken.WaitHandle.WaitOne(runsEvery); cancelToken.WaitHandle.WaitOne(runsEvery);
}
Thread.Sleep(100);
} }
} }
catch (OperationCanceledException) catch (OperationCanceledException)