summaryrefslogtreecommitdiff
path: root/networkQuality.go
diff options
context:
space:
mode:
authorWill Hawkins <[email protected]>2022-07-16 04:11:13 -0400
committerWill Hawkins <[email protected]>2022-07-16 04:13:21 -0400
commit72c8de6ac0cf85f395ee89db3e8363b2376ec7cd (patch)
tree2c1778dac104a3464d963dfdcafe39ead9e97ff0 /networkQuality.go
parent23d16686f2320f9a5fe35aebbaa2e036b27421ca (diff)
[Formatting] Cleanup long lines.
Diffstat (limited to 'networkQuality.go')
-rw-r--r--networkQuality.go54
1 files changed, 43 insertions, 11 deletions
diff --git a/networkQuality.go b/networkQuality.go
index e875e97..731f755 100644
--- a/networkQuality.go
+++ b/networkQuality.go
@@ -9,7 +9,7 @@
* PARTICULAR PURPOSE. See the GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License along
- * with Foobar. If not, see <https://www.gnu.org/licenses/>.
+ * with Go Responsiveness. If not, see <https://www.gnu.org/licenses/>.
*/
package main
@@ -86,7 +86,11 @@ var (
false,
"Enable the collection and display of extended statistics -- may not be available on certain platforms.",
)
- dataLoggerBaseFileName = flag.String("logger-filename", "", "Store information about the results of each probe in files with this basename. Time and probe type will be appended (before the first .) to create two separate log files. Disabled by default.")
+ dataLoggerBaseFileName = flag.String(
+ "logger-filename",
+ "",
+ "Store information about the results of each probe in files with this basename. Time and probe type will be appended (before the first .) to create two separate log files. Disabled by default.",
+ )
)
func main() {
@@ -191,15 +195,26 @@ func main() {
var err error = nil
unique := time.Now().UTC().Format("01-02-2006-15-04-05")
dataLoggerSelfFilename := utilities.FilenameAppend(*dataLoggerBaseFileName, "-self-"+unique)
- dataLoggerForeignFilename := utilities.FilenameAppend(*dataLoggerBaseFileName, "-foreign-"+unique)
+ dataLoggerForeignFilename := utilities.FilenameAppend(
+ *dataLoggerBaseFileName,
+ "-foreign-"+unique,
+ )
selfDataLogger, err = datalogger.CreateCSVDataLogger[rpm.DataPoint](dataLoggerSelfFilename)
if err != nil {
- fmt.Printf("Warning: Could not create the file for storing self probe results (%s). Disabling functionality.\n", dataLoggerSelfFilename)
+ fmt.Printf(
+ "Warning: Could not create the file for storing self probe results (%s). Disabling functionality.\n",
+ dataLoggerSelfFilename,
+ )
selfDataLogger = nil
}
- foreignDataLogger, err = datalogger.CreateCSVDataLogger[rpm.DataPoint](dataLoggerForeignFilename)
+ foreignDataLogger, err = datalogger.CreateCSVDataLogger[rpm.DataPoint](
+ dataLoggerForeignFilename,
+ )
if err != nil {
- fmt.Printf("Warning: Could not create the file for storing foreign probe results (%s). Disabling functionality.\n", dataLoggerForeignFilename)
+ fmt.Printf(
+ "Warning: Could not create the file for storing foreign probe results (%s). Disabling functionality.\n",
+ dataLoggerForeignFilename,
+ )
foreignDataLogger = nil
}
}
@@ -222,11 +237,19 @@ func main() {
}
generateSelfProbeConfiguration := func() rpm.ProbeConfiguration {
- return rpm.ProbeConfiguration{URL: config.Urls.SmallUrl, DataLogger: selfDataLogger, Interval: 100 * time.Millisecond}
+ return rpm.ProbeConfiguration{
+ URL: config.Urls.SmallUrl,
+ DataLogger: selfDataLogger,
+ Interval: 100 * time.Millisecond,
+ }
}
generateForeignProbeConfiguration := func() rpm.ProbeConfiguration {
- return rpm.ProbeConfiguration{URL: config.Urls.SmallUrl, DataLogger: foreignDataLogger, Interval: 100 * time.Millisecond}
+ return rpm.ProbeConfiguration{
+ URL: config.Urls.SmallUrl,
+ DataLogger: foreignDataLogger,
+ Interval: 100 * time.Millisecond,
+ }
}
var downloadDebugging *debug.DebugWithPrefix = debug.NewDebugWithPrefix(debugLevel, "download")
@@ -378,11 +401,20 @@ func main() {
foreignProbeDataPoints := utilities.ChannelToSlice(foreignProbeDataPointsChannel)
totalForeignRoundTrips := len(foreignProbeDataPoints)
- foreignProbeRoundTripTimes := utilities.Fmap(foreignProbeDataPoints, func(dp rpm.DataPoint) float64 { return dp.Duration.Seconds() })
+ foreignProbeRoundTripTimes := utilities.Fmap(
+ foreignProbeDataPoints,
+ func(dp rpm.DataPoint) float64 { return dp.Duration.Seconds() },
+ )
foreignProbeRoundTripTimeP90 := utilities.CalculatePercentile(foreignProbeRoundTripTimes, 90)
- downloadRoundTripTimes := utilities.Fmap(downloadDataCollectionResult.DataPoints, func(dcr rpm.DataPoint) float64 { return dcr.Duration.Seconds() })
- uploadRoundTripTimes := utilities.Fmap(uploadDataCollectionResult.DataPoints, func(dcr rpm.DataPoint) float64 { return dcr.Duration.Seconds() })
+ downloadRoundTripTimes := utilities.Fmap(
+ downloadDataCollectionResult.DataPoints,
+ func(dcr rpm.DataPoint) float64 { return dcr.Duration.Seconds() },
+ )
+ uploadRoundTripTimes := utilities.Fmap(
+ uploadDataCollectionResult.DataPoints,
+ func(dcr rpm.DataPoint) float64 { return dcr.Duration.Seconds() },
+ )
selfProbeRoundTripTimes := append(downloadRoundTripTimes, uploadRoundTripTimes...)
totalSelfRoundTrips := len(selfProbeRoundTripTimes)
selfProbeRoundTripTimeP90 := utilities.CalculatePercentile(selfProbeRoundTripTimes, 90)