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

I accidentally filled up my harddrive with random numbers last night.

This commit is contained in:
benbierens 2023-08-21 07:58:58 +02:00
parent 1682dfc08f
commit ce3850b0b0
No known key found for this signature in database
GPG Key ID: FE44815D96D0A1AA
1 changed files with 40 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

75
Tests/BasicTests/ContinuousSubstitute.cs
View File

@ -63,8 +63,8 @@ namespace Tests.BasicTests
public void HoldMyBeerTest() public void HoldMyBeerTest()
{ {
var blockExpirationTime = TimeSpan.FromMinutes(3); var blockExpirationTime = TimeSpan.FromMinutes(3);
var group = SetupCodexNodes(1, o => o var group = SetupCodexNodes(3, o => o
.EnableMetrics() //.EnableMetrics()
.WithBlockTTL(blockExpirationTime) .WithBlockTTL(blockExpirationTime)
.WithBlockMaintenanceInterval(TimeSpan.FromMinutes(1)) .WithBlockMaintenanceInterval(TimeSpan.FromMinutes(1))
.WithBlockMaintenanceNumber(10000) .WithBlockMaintenanceNumber(10000)
@ -72,7 +72,7 @@ namespace Tests.BasicTests
var nodes = group.Cast<OnlineCodexNode>().ToArray(); var nodes = group.Cast<OnlineCodexNode>().ToArray();
var endTime = DateTime.UtcNow + TimeSpan.FromHours(1); var endTime = DateTime.UtcNow + TimeSpan.FromHours(24);
var filesize = 80.MB(); var filesize = 80.MB();
double codexDefaultBlockSize = 31 * 64 * 33; double codexDefaultBlockSize = 31 * 64 * 33;
@ -90,43 +90,48 @@ namespace Tests.BasicTests
{ {
try try
{ {
var uploadStartTime = DateTime.UtcNow; Thread.Sleep(TimeSpan.FromSeconds(5));
var file = GenerateTestFile(filesize);
var cid = node.UploadFile(file);
var cidTag = cid.Id.Substring(cid.Id.Length - 6); ScopedTestFiles(() =>
Stopwatch.Measure(Get().Log, "upload-log-asserts", () =>
{ {
var uploadLog = node.DownloadLog(tailLines: 50000); var uploadStartTime = DateTime.UtcNow;
var file = GenerateTestFile(filesize);
var cid = node.UploadFile(file);
var storeLines = uploadLog.FindLinesThatContain("Stored data", "topics=\"codex node\""); var cidTag = cid.Id.Substring(cid.Id.Length - 6);
uploadLog.DeleteFile(); Stopwatch.Measure(Get().Log, "upload-log-asserts", () =>
{
var uploadLog = node.DownloadLog(tailLines: 50000);
var storeLine = GetLineForCidTag(storeLines, cidTag); var storeLines = uploadLog.FindLinesThatContain("Stored data", "topics=\"codex node\"");
AssertStoreLineContains(storeLine, numberOfBlocks, sizeInBytes); uploadLog.DeleteFile();
var storeLine = GetLineForCidTag(storeLines, cidTag);
AssertStoreLineContains(storeLine, numberOfBlocks, sizeInBytes);
});
successfulUploads++;
var uploadTimeTaken = DateTime.UtcNow - uploadStartTime;
if (uploadTimeTaken >= blockExpirationTime.Subtract(TimeSpan.FromSeconds(10)))
{
Assert.Fail("Upload took too long. Blocks already expired.");
}
var dl = node.DownloadContent(cid);
file.AssertIsEqual(dl);
Stopwatch.Measure(Get().Log, "download-log-asserts", () =>
{
var downloadLog = node.DownloadLog(tailLines: 50000);
var sentLines = downloadLog.FindLinesThatContain("Sent bytes", "topics=\"codex restapi\"");
downloadLog.DeleteFile();
var sentLine = GetLineForCidTag(sentLines, cidTag);
AssertSentLineContains(sentLine, sizeInBytes);
});
successfulDownloads++;
}); });
successfulUploads++;
var uploadTimeTaken = DateTime.UtcNow - uploadStartTime;
if (uploadTimeTaken >= blockExpirationTime.Subtract(TimeSpan.FromSeconds(10)))
{
Assert.Fail("Upload took too long. Blocks already expired.");
}
var dl = node.DownloadContent(cid);
file.AssertIsEqual(dl);
Stopwatch.Measure(Get().Log, "download-log-asserts", () =>
{
var downloadLog = node.DownloadLog(tailLines: 50000);
var sentLines = downloadLog.FindLinesThatContain("Sent bytes", "topics=\"codex restapi\"");
downloadLog.DeleteFile();
var sentLine = GetLineForCidTag(sentLines, cidTag);
AssertSentLineContains(sentLine, sizeInBytes);
});
successfulDownloads++;
} }
catch catch
{ {