Skip to content

Commit 8da42f2

Browse files
feat(tx_pool_throughput_analysis): log throughput measurement details during execution
1 parent 1d0fe08 commit 8da42f2

File tree

1 file changed

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

1 file changed

+2
-0
lines changed

pkg/coordinator/tasks/tx_pool_throughput_analysis/task.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -147,6 +147,8 @@ func (t *Task) Execute(ctx context.Context) error {
147147

148148
for sendingTps := t.config.StartingTPS; sendingTps <= t.config.EndingTPS; sendingTps += t.config.IncrementTPS {
149149
// measure the throughput with the current sendingTps
150+
t.logger.Infof("Measuring throughput with sendingTps=%d, duration=%d", sendingTps, t.config.DurationS)
151+
150152
processedTps, notReceivedP2PEventCount, coordinatedOmissionEventCount, err := t.measureTpsWithLoad(loadTarget, sendingTps, t.config.DurationS, singleMeasureDeadline, percentile)
151153
if err != nil {
152154
t.logger.Errorf("Error during throughput measurement with sendingTps=%d, duration=%d: %v", sendingTps, t.config.DurationS, err)

0 commit comments

Comments
 (0)