diff options
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.java | 10 |
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) { |