From cc66520fee95ceea13e3bdde375ac421d8dee158 Mon Sep 17 00:00:00 2001
From: ahmed <ahmed@esiur.com>
Date: Wed, 8 Apr 2026 02:14:28 +0300
Subject: [PATCH] 400ms test

---
 Tests/Distribution/NodeFanout/Client/Program.cs | 6 +++---
 Tests/Serialization/Gvwie/Program.cs            | 3 +++
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/Tests/Distribution/NodeFanout/Client/Program.cs b/Tests/Distribution/NodeFanout/Client/Program.cs
index 84ea0ff..9eb93a8 100644
--- a/Tests/Distribution/NodeFanout/Client/Program.cs
+++ b/Tests/Distribution/NodeFanout/Client/Program.cs
@@ -23,7 +23,7 @@ Console.WriteLine($"[Client {clientId}] Connecting to {host}:{port}, resources={
 
 // Counters
 long   totalReceived    = 0;
-long   lateCount        = 0;     // notifications arriving > 500ms after the previous
+long   lateCount        = 0;     // notifications arriving > 400ms after the previous
 double sumLatencyMs     = 0;
 long   latencySamples   = 0;
 
@@ -64,7 +64,7 @@ try
             {
                 sumLatencyMs += elapsedMs;
                 latencySamples++;
-                if (elapsedMs > 500) lateCount++;
+                if (elapsedMs > 400) lateCount++;
             }
         };
     }
@@ -112,7 +112,7 @@ string csv = $"time_s,received_per_5s,rate_per_s,avg_interval_ms\n" +
 string outFile = $"client_{clientId}_results.csv";
 await File.WriteAllTextAsync(outFile, csv);
 Console.WriteLine($"[Client {clientId}] Results written to {outFile}");
-Console.WriteLine($"[Client {clientId}] Total received={totalReceived}  late(>500ms)={lateCount}");
+Console.WriteLine($"[Client {clientId}] Total received={totalReceived}  late(>400ms)={lateCount}");
 
 
 static string GetArg(string[] args, string key, string def)
diff --git a/Tests/Serialization/Gvwie/Program.cs b/Tests/Serialization/Gvwie/Program.cs
index 62e4d0c..7f87a61 100644
--- a/Tests/Serialization/Gvwie/Program.cs
+++ b/Tests/Serialization/Gvwie/Program.cs
@@ -1,7 +1,10 @@
 
+using Esiur.Data.Gvwie;
 using Esiur.Tests.Gvwie;
 using MessagePack;
 
+var e = GroupInt32Codec.Encode(new int[] {-12000, 15000, -1, 32760 });
+
 MessagePack.MessagePackSerializer.DefaultOptions = MessagePackSerializerOptions.Standard
     .WithCompression(MessagePackCompression.None); // optional; remove if you want raw size