From 64762a67ddacb677d43cc5a81b42a571b04faed5 Mon Sep 17 00:00:00 2001 From: Will Hawkins Date: Wed, 17 Aug 2022 22:19:38 -0400 Subject: Update code format to meet 80-column requirement. --- rpm/rpm.go | 18 +++++++++++++----- 1 file changed, 13 insertions(+), 5 deletions(-) (limited to 'rpm') diff --git a/rpm/rpm.go b/rpm/rpm.go index fe8184e..607cffa 100644 --- a/rpm/rpm.go +++ b/rpm/rpm.go @@ -62,10 +62,10 @@ type ProbeConfiguration struct { } type ProbeDataPoint struct { - Time time.Time `Description:"Time of the generation of the data point." Formatter:"Format" FormatterArgument:"01-02-2006-15-04-05.000"` + Time time.Time `Description:"Time of the generation of the data point." Formatter:"Format" FormatterArgument:"01-02-2006-15-04-05.000"` RoundTripCount uint64 `Description:"The number of round trips measured by this data point."` - Duration time.Duration `Description:"The duration for this measurement." Formatter:"Seconds"` - TCPRtt time.Duration `Description:"The underlying connection's RTT at probe time." Formatter:"Seconds"` + Duration time.Duration `Description:"The duration for this measurement." Formatter:"Seconds"` + TCPRtt time.Duration `Description:"The underlying connection's RTT at probe time." Formatter:"Seconds"` TCPCwnd uint32 `Description:"The underlying connection's congestion window at probe time."` } @@ -200,7 +200,13 @@ func Probe( fmt.Printf("Warning: Could not fetch the extended stats for a probe: %v\n", err) } } - dataPoint := ProbeDataPoint{Time: time_before_probe, RoundTripCount: roundTripCount, Duration: totalDelay, TCPRtt: tcpRtt, TCPCwnd: tcpCwnd} + dataPoint := ProbeDataPoint{ + Time: time_before_probe, + RoundTripCount: roundTripCount, + Duration: totalDelay, + TCPRtt: tcpRtt, + TCPCwnd: tcpCwnd, + } if !utilities.IsInterfaceNil(logger) { logger.LogRecord(dataPoint) } @@ -458,7 +464,9 @@ func LGCollectData( ) if !utilities.IsInterfaceNil(throughputDataLogger) { - throughputDataLogger.LogRecord(ThroughputDataPoint{time.Now(), currentMovingAverage}) + throughputDataLogger.LogRecord( + ThroughputDataPoint{time.Now(), currentMovingAverage}, + ) } if debug.IsDebug(debugging.Level) { -- cgit v1.2.3