add: elapse metric on ActionEvaluationPublisher

planetarium · Sep 22, 2023 · 5c17083 · 5c17083
1 parent 2c361ea
commit 5c17083
Showing 1 changed file with 19 additions and 1 deletion.
diff --git a/NineChronicles.Headless/ActionEvaluationPublisher.cs b/NineChronicles.Headless/ActionEvaluationPublisher.cs
@@ -3,6 +3,7 @@
 using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Collections.Immutable;
+using System.Diagnostics;
 using System.Diagnostics.Metrics;
 using System.IO;
 using System.IO.Compression;
@@ -296,6 +297,8 @@ await _hub.BroadcastRenderBlockAsync(
                         {
                             try
                             {
+                                Stopwatch stopwatch = new Stopwatch();
+                                stopwatch.Start();
                                 ActionBase? pa = ev.Action is RewardGold
                                     ? null
                                     : ev.Action;
@@ -361,8 +364,23 @@ await _hub.BroadcastRenderBlockAsync(
                                     ev.Action.GetType(),
                                     compressed.LongLength
                                 );
-
+
+                                var encodeElapsedMilliseconds = stopwatch.ElapsedMilliseconds;
                                 await _hub.BroadcastRenderAsync(compressed);
+                                stopwatch.Stop();
+                                var broadcastElapsedMilliseconds = stopwatch.ElapsedMilliseconds - encodeElapsedMilliseconds;
+                                Log
+                                    .ForContext("tag", "Metric")
+                                    .ForContext("subtag", "ActionEvaluationPublisherElapse")
+                                    .Information(
+                                        "[{ClientAddress}], #{BlockIndex}, {Action}," +
+                                        " {EncodeElapsedMilliseconds}, {BroadcastElapsedMilliseconds}, {TotalElapsedMilliseconds}",
+                                        _clientAddress,
+                                        ev.BlockIndex,
+                                        ev.Action.GetType(),
+                                        encodeElapsedMilliseconds,
+                                        broadcastElapsedMilliseconds,
+                                        encodeElapsedMilliseconds + broadcastElapsedMilliseconds);
                             }
                             catch (SerializationException se)
                             {