summaryrefslogtreecommitdiffstats
path: root/node-maintainer/src/main/java/com/yahoo/vespa/hosted/node/verification/hardware/benchmarks/DiskBenchmark.java
diff options
context:
space:
mode:
Diffstat (limited to 'node-maintainer/src/main/java/com/yahoo/vespa/hosted/node/verification/hardware/benchmarks/DiskBenchmark.java')
-rw-r--r--node-maintainer/src/main/java/com/yahoo/vespa/hosted/node/verification/hardware/benchmarks/DiskBenchmark.java10
1 files changed, 5 insertions, 5 deletions
diff --git a/node-maintainer/src/main/java/com/yahoo/vespa/hosted/node/verification/hardware/benchmarks/DiskBenchmark.java b/node-maintainer/src/main/java/com/yahoo/vespa/hosted/node/verification/hardware/benchmarks/DiskBenchmark.java
index 7d2082f5027..a7fc5809058 100644
--- a/node-maintainer/src/main/java/com/yahoo/vespa/hosted/node/verification/hardware/benchmarks/DiskBenchmark.java
+++ b/node-maintainer/src/main/java/com/yahoo/vespa/hosted/node/verification/hardware/benchmarks/DiskBenchmark.java
@@ -10,6 +10,7 @@ import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
+import java.util.Optional;
import java.util.logging.Level;
import java.util.logging.Logger;
@@ -42,22 +43,21 @@ public class DiskBenchmark implements Benchmark {
public void doBenchmark() {
try {
List<String> commandOutput = commandExecutor.executeCommand(DISK_BENCHMARK_COMMAND);
- ParseResult parseResult = parseDiskSpeed(commandOutput);
+ Optional<ParseResult> parseResult = parseDiskSpeed(commandOutput);
setDiskSpeed(parseResult);
} catch (IOException e) {
logger.log(Level.WARNING, "Failed to perform disk benchmark", e);
}
}
- ParseResult parseDiskSpeed(List<String> commandOutput) {
+ Optional<ParseResult> parseDiskSpeed(List<String> commandOutput) {
List<String> searchWords = new ArrayList<>(Arrays.asList(KILO_BYTE_SEARCH_WORD, MEGA_BYTE_SEARCH_WORD, GIGA_BYTE_SEARCH_WORD));
ParseInstructions parseInstructions = new ParseInstructions(SEARCH_ELEMENT_INDEX, RETURN_ELEMENT_INDEX, SPLIT_REGEX_STRING, searchWords);
return OutputParser.parseSingleOutput(parseInstructions, commandOutput);
}
- void setDiskSpeed(ParseResult parseResult) {
- double diskSpeedMBs = getDiskSpeedInMBs(parseResult);
- benchmarkResults.setDiskSpeedMbs(diskSpeedMBs);
+ void setDiskSpeed(Optional<ParseResult> parseResult) {
+ benchmarkResults.setDiskSpeedMbs(parseResult.map(this::getDiskSpeedInMBs).orElse(0.0d));
}
double getDiskSpeedInMBs(ParseResult parseResult) {