From b626fd14884b6e565c63d71eea3dc50ff0f5eda4 Mon Sep 17 00:00:00 2001 From: arriven Date: Wed, 9 Mar 2022 20:17:13 +0200 Subject: [PATCH] track successfull tcp deliveries --- src/jobs/rawnet.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/jobs/rawnet.go b/src/jobs/rawnet.go index 59270b86..e797eac8 100644 --- a/src/jobs/rawnet.go +++ b/src/jobs/rawnet.go @@ -49,6 +49,8 @@ func tcpJob(ctx context.Context, globalConfig GlobalConfig, args Args, debug boo trafficMonitor := metrics.Default.NewWriter(metrics.Traffic, uuid.New().String()) go trafficMonitor.Update(ctx, time.Second) + processedTrafficMonitor := metrics.Default.NewWriter(metrics.ProcessedTraffic, uuid.NewString()) + go processedTrafficMonitor.Update(ctx, time.Second) for jobConfig.Next(ctx) { if debug { @@ -78,6 +80,7 @@ func tcpJob(ctx context.Context, globalConfig GlobalConfig, args Args, debug boo if debug { log.Printf("%s finished at %d", jobConfig.Address, time.Now().Unix()) } + processedTrafficMonitor.Add(len(body)) metrics.IncRawnetTCP(tcpAddr.String(), metrics.StatusSuccess) } }