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-03-17 00:53:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

chronos streams reads and writes

Browse Source
This commit is contained in:
Ben 2025-01-09 11:53:04 +01:00
parent e7a451671c
commit fdecbfe754
No known key found for this signature in database
GPG Key ID: 0F16E812E736C24B
3 changed files with 32 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
SeeTimeline/LogToEvents.cs
View File

@ -253,9 +253,15 @@ namespace SeeTimeline
// 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"]]);
//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"]]);
//else if (line.Message == "lpc-write-fast") AddEvent(EventSet.MiscAddress + "f", "F", Colors.Black);
//else if (line.Message == "lpc-write-prepare") AddEvent(EventSet.MiscAddress + "p", "P", Colors.Black);
else if (line.Message == "chronoswrite") AddEvent(EventSet.MiscAddress + "chronos-write", line.Attributes["ticks"], Colors.Black);
else if (line.Message == "chronosread") AddEvent(EventSet.MiscAddress + "chronos-read", line.Attributes["ticks"], Colors.Black);
}
private void AddMultiple(string addresses, string name, Color color)

12
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\\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");
//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\\09\\10-45-20Z_TwoClientTests\\";
var file1 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-25-f]_000001_Downloader1.log");
var file2 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-25-f]_000000_Uploader0.log");
var file3 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-25-s]_000001_Downloader1.log");
var file4 = Path.Combine(path, "TwoClientTest[thatbenbierens_nim-codex_blkex-cancelpresence-25-s]_000000_Uploader0.log");
Line1Name.Text = file1;
Line2Name.Text = file2;

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

@ -42,19 +42,31 @@ namespace CodexReleaseTests.DataTests
"thatbenbierens/nim-codex:blkex-cancelpresence-15", // S new logging
"thatbenbierens/nim-codex:blkex-cancelpresence-16-f", // F more logging
"thatbenbierens/nim-codex:blkex-cancelpresence-16-s", // S more logging
"thatbenbierens/nim-codex:blkex-cancelpresence-16-s", // S more logging
"thatbenbierens/nim-codex:blkex-cancelpresence-17-f", // F "tick" every 100 milliseconds
"thatbenbierens/nim-codex:blkex-cancelpresence-17-s", // S same but slow
"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-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
"thatbenbierens/nim-codex:blkex-cancelpresence-20-s", // S same but slow
"thatbenbierens/nim-codex:blkex-cancelpresence-21-f", // F libp2p lpchannel.write logs
"thatbenbierens/nim-codex:blkex-cancelpresence-21-s", // S same but slow
"thatbenbierens/nim-codex:blkex-cancelpresence-22-f", // F chronos stream write logs
"thatbenbierens/nim-codex:blkex-cancelpresence-22-s", // S same but slow
"thatbenbierens/nim-codex:blkex-cancelpresence-23-f", // F chronos stream write logs in libp2p hand-off
"thatbenbierens/nim-codex:blkex-cancelpresence-23-s", // S same but slow
"thatbenbierens/nim-codex:blkex-cancelpresence-25-f", // F chronos stream write logs in libp2p hand-off with ticks
"thatbenbierens/nim-codex:blkex-cancelpresence-25-s" // S same but slow
)] string img
)
{