Skip to content

Commit d241f7e

Browse files
feat(throughput): include missed P2P event count and coordinated omission event count in output metrics
1 parent c54d9c8 commit d241f7e

File tree

1 file changed

+6
-0
lines changed
  • pkg/coordinator/tasks/tx_pool_throughput_analysis

1 file changed

+6
-0
lines changed

pkg/coordinator/tasks/tx_pool_throughput_analysis/task.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -168,6 +168,12 @@ func (t *Task) Execute(ctx context.Context) error {
168168
// Set the throughput measures in the task context outputs
169169
// from this plot we can compute the Maximum Sustainable Throughput or Capacity limit
170170
t.ctx.Outputs.SetVar("throughput_measures", throughoutMeasures) // log coordinated_omission_event_count and missed_p2p_event_count?
171+
t.ctx.Outputs.SetVar("missed_p2p_event_count", missedP2PEventCount)
172+
t.ctx.Outputs.SetVar("coordinated_omission_event_count", totalCoordinatedOmissionEventCount)
173+
t.ctx.Outputs.SetVar("starting_tps", t.config.StartingTPS)
174+
t.ctx.Outputs.SetVar("ending_tps", t.config.EndingTPS)
175+
t.ctx.Outputs.SetVar("increment_tps", t.config.IncrementTPS)
176+
t.ctx.Outputs.SetVar("duration_s", t.config.DurationS)
171177

172178
outputs := map[string]interface{}{
173179
"throughput_measures": throughoutMeasures,

0 commit comments

Comments
 (0)