@@ -135,7 +135,7 @@ func prepareHeaders(ctx context.Context, s *url.URL) (string, http.Header) {
135135
136136// formatMessage reports a WireMeasurement in a human readable format.
137137func formatMessage (prefix string , stream int , m WireMeasurement ) {
138- log .Printf ("%s #%d - rate %0.2f Mbps, rtt %5.2fms, elapsed %0.4fs, application r/w: %d/%d, network r/w: %d/%d kernel* r/w: %d/%d\n " ,
138+ log .Printf ("%s #%d rate: %0.2f Mbps, rtt %5.2fms, elapsed %0.4fs, application r/w: %d/%d, network r/w: %d/%d kernel* r/w: %d/%d\n " ,
139139 prefix , stream ,
140140 8 * float64 (m .TCPInfo ["BytesAcked" ])/ (float64 (m .ElapsedTime )), // to mbps.
141141 float64 (m .TCPInfo ["RTT" ])/ 1000.0 , // to ms.
@@ -312,7 +312,7 @@ outer:
312312 case streamCount > 1 && stream == 0 :
313313 // Only do this for one stream.
314314 elapsed := time .Since (s .firstStartTime )
315- log .Printf ("Download client #1 - Avg %0.2f Mbps, MinRTT %5.2fms, elapsed %0.4fs, application r/w: %d/%d\n " ,
315+ log .Printf ("Download stream #1 rate: %0.2f Mbps, MinRTT %5.2fms, elapsed %0.4fs, application r/w: %d/%d\n " ,
316316 8 * float64 (s .bytesTotal .Load ())/ 1e6 / elapsed .Seconds (), // as mbps.
317317 float64 (s .minRTT .Load ())/ 1000.0 , // as ms.
318318 elapsed .Seconds (), 0 , s .bytesTotal .Load ())
@@ -345,9 +345,16 @@ func main() {
345345 wg .Wait ()
346346
347347 log .Println ("------" )
348+ elapsedTotal := s .lastStopTime .Sub (s .firstStartTime )
349+ bytesTotal := s .bytesTotal .Load ()
350+ log .Printf ("Download total average: %0.2f Mbps, MinRTT %5.2fms, elapsed %0.4fs, application r/w: %d/%d\n " ,
351+ 8 * float64 (bytesTotal )/ 1e6 / elapsedTotal .Seconds (), // as mbps.
352+ float64 (s .minRTT .Load ())/ 1000.0 , // as ms.
353+ elapsedTotal .Seconds (), 0 , bytesTotal )
354+
348355 elapsedAvg := s .firstStopTime .Sub (s .firstStartTime )
349356 bytesAvg := s .bytesAtFirstStop .Load () // like msak-client, bytes during first-start to first-stop.
350- log .Printf ("Download client #1 - Avg %0.2f Mbps, MinRTT %5.2fms, elapsed %0.4fs, application r/w: %d/%d\n " ,
357+ log .Printf ("Download first average: %0.2f Mbps, MinRTT %5.2fms, elapsed %0.4fs, application r/w: %d/%d\n " ,
351358 8 * float64 (bytesAvg )/ 1e6 / elapsedAvg .Seconds (), // as mbps.
352359 float64 (s .minRTT .Load ())/ 1000.0 , // as ms.
353360 elapsedAvg .Seconds (), 0 , bytesAvg )
@@ -356,7 +363,7 @@ func main() {
356363 elapsedPeak := s .firstStopTime .Sub (s .lastStartTime )
357364 bytesPeak := s .bytesAtFirstStop .Load () - s .bytesAtLastStart .Load () // bytes during of peak period.
358365 if * flagStreams > 1 && bytesPeak > 0 && elapsedPeak > 0 {
359- log .Printf ("Download client #1 - Peak %0.2f Mbps, MinRTT %5.2fms, elapsed %0.4fs, application r/w: %d/%d\n " ,
366+ log .Printf ("Download center average: %0.2f Mbps, MinRTT %5.2fms, elapsed %0.4fs, application r/w: %d/%d\n " ,
360367 8 * float64 (bytesPeak )/ 1e6 / elapsedPeak .Seconds (), // as mbps.
361368 float64 (s .minRTT .Load ())/ 1000.0 , // as ms.
362369 elapsedPeak .Seconds (), 0 , bytesPeak )
0 commit comments