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-05-05 17:09:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

found delay in transport layer

Browse Source
This commit is contained in:
benbierens 2025-01-08 15:44:08 +01:00
parent ed8f2d1f00
commit e7a451671c
No known key found for this signature in database
GPG Key ID: 877D2C2E09A22F3A
3 changed files with 41 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
SeeTimeline/LogToEvents.cs
View File

@ -55,7 +55,7 @@ namespace SeeTimeline
var keys = events.Keys.ToArray();
foreach (var key in keys)
{
if (key != NoAddress && key != MiscAddress && !addresses.Contains(key))
if (key != NoAddress && !key.StartsWith(MiscAddress) && !addresses.Contains(key))
{
events.Remove(key);
}
@ -113,6 +113,21 @@ namespace SeeTimeline
public void Parse()
{
var colormap = new Dictionary<string, Color>
{
{ "0", Colors.Black },
{ "1", Colors.Red },
{ "2", Colors.Green },
{ "3", Colors.Blue },
{ "4", Colors.Red },
{ "5", Colors.Green },
{ "6", Colors.Blue },
{ "7", Colors.Red },
{ "8", Colors.Green },
{ "9", Colors.Blue },
{ "10", Colors.Black }
};
//if (!line.Attributes.Any(a => a.Value.ToLowerInvariant().Contains("index: 5"))) return;
//AddJobs(result, "Created", Colors.Red, req.Created);
@ -232,6 +247,15 @@ namespace SeeTimeline
//// waiting for data
//else if (line.Message == "waiting for data") AddEvent(EventSet.MiscAddress, "wait", Colors.Black);
// MsgReceived
// MsgSending
// MsgSent
else if (line.Message == "MsgSending") AddEvent(EventSet.MiscAddress + "snd", line.Attributes["num"], colormap[line.Attributes["num"]]);
else if (line.Message == "MsgSent") AddEvent(EventSet.MiscAddress + "snt", line.Attributes["num"], colormap[line.Attributes["num"]]);
else if (line.Message == "MsgReceived") AddEvent(EventSet.MiscAddress + "rcv", line.Attributes["num"], colormap[line.Attributes["num"]]);
}
private void AddMultiple(string addresses, string name, Color color)

14
SeeTimeline/MainWindow.xaml.cs
View File

@ -29,12 +29,12 @@ namespace SeeTimeline
private void Button_Click(object sender, RoutedEventArgs e)
{
//var path = "d:\\Projects\\cs-codex-dist-tests\\Tests\\CodexReleaseTests\\bin\\Debug\\net8.0\\CodexTestLogs\\2024-12\\20\\09-57-01Z_TwoClientTests\\";
var path = "c:\\Projects\\cs-codex-dist-tests\\Tests\\CodexReleaseTests\\bin\\Debug\\net8.0\\CodexTestLogs\\2025-01\\07\\14-09-39Z_TwoClientTests\\";
var file1 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-18-f]_000001_Downloader1.log");
var file2 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-18-f]_000000_Uploader0.log");
var file3 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-18-s]_000001_Downloader1.log");
var file4 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-18-s]_000000_Uploader0.log");
var path = "d:\\Projects\\cs-codex-dist-tests\\Tests\\CodexReleaseTests\\bin\\Debug\\net8.0\\CodexTestLogs\\2025-01\\08\\13-56-44Z_TwoClientTests\\";
//var path = "c:\\Projects\\cs-codex-dist-tests\\Tests\\CodexReleaseTests\\bin\\Debug\\net8.0\\CodexTestLogs\\2025-01\\07\\14-09-39Z_TwoClientTests\\";
var file1 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-20-f]_000001_Downloader1.log");
var file2 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-20-f]_000000_Uploader0.log");
var file3 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-20-s]_000001_Downloader1.log");
var file4 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-20-s]_000000_Uploader0.log");
Line1Name.Text = file1;
Line2Name.Text = file2;
@ -110,7 +110,7 @@ namespace SeeTimeline
set.Iterate((addr, events) =>
{
if (addr == EventSet.NoAddress || addr == EventSet.MiscAddress)
if (addr == EventSet.NoAddress || addr.StartsWith(EventSet.MiscAddress))
{
result.Add(CreateItem(addr, events));
}

12
Tests/CodexReleaseTests/DataTests/TwoClientTest.cs
View File

@ -48,14 +48,20 @@ namespace CodexReleaseTests.DataTests
"thatbenbierens/nim-codex:blkex-cancelpresence-17-s", // S same but slow
"thatbenbierens/nim-codex:blkex-cancelpresence-18-f", // F "tick" every 10 milliseconds
"thatbenbierens/nim-codex:blkex-cancelpresence-18-s" // S same but slow
"thatbenbierens/nim-codex:blkex-cancelpresence-18-s", // S same but slow
"thatbenbierens/nim-codex:blkex-cancelpresence-19-f", // F sending/sent/received logs
"thatbenbierens/nim-codex:blkex-cancelpresence-19-s", // S same but slow
"thatbenbierens/nim-codex:blkex-cancelpresence-20-f", // F sending/sent/received logs + number
"thatbenbierens/nim-codex:blkex-cancelpresence-20-s" // S? same but slow
)] string img
)
{
CodexContainerRecipe.DockerImageOverride = img;
var uploader = StartCodex(s => s.WithName("Uploader").WithLogLevel(CodexLogLevel.Trace, new CodexLogCustomTopics(CodexLogLevel.Trace, CodexLogLevel.Trace, CodexLogLevel.Trace)));
var downloader = StartCodex(s => s.WithName("Downloader").WithLogLevel(CodexLogLevel.Trace, new CodexLogCustomTopics(CodexLogLevel.Trace, CodexLogLevel.Trace, CodexLogLevel.Trace)).WithBootstrapNode(uploader));
var uploader = StartCodex(s => s.WithName("Uploader"));
var downloader = StartCodex(s => s.WithName("Downloader").WithBootstrapNode(uploader));
PerformTwoClientTest(uploader, downloader);
}