summaryrefslogtreecommitdiffstats
path: root/container-core/src/main/java/com/yahoo/container/jdisc/state/CoredumpGatherer.java
diff options
context:
space:
mode:
Diffstat (limited to 'container-core/src/main/java/com/yahoo/container/jdisc/state/CoredumpGatherer.java')
-rw-r--r--container-core/src/main/java/com/yahoo/container/jdisc/state/CoredumpGatherer.java12
1 files changed, 6 insertions, 6 deletions
diff --git a/container-core/src/main/java/com/yahoo/container/jdisc/state/CoredumpGatherer.java b/container-core/src/main/java/com/yahoo/container/jdisc/state/CoredumpGatherer.java
index 915cced842b..b0175c49f63 100644
--- a/container-core/src/main/java/com/yahoo/container/jdisc/state/CoredumpGatherer.java
+++ b/container-core/src/main/java/com/yahoo/container/jdisc/state/CoredumpGatherer.java
@@ -20,13 +20,13 @@ public class CoredumpGatherer {
private static final Path COREDUMP_PATH = Path.of(Defaults.getDefaults().underVespaHome("var/crash/processing"));
- protected static JSONObject gatherCoredumpMetrics() {
- int coredumps = getNumberOfCoredumps();
+ public static JSONObject gatherCoredumpMetrics(FileWrapper fileWrapper) {
+ int coredumps = getNumberOfCoredumps(fileWrapper);
JSONObject packet = new JSONObject();
try {
packet.put("status_code", coredumps == 0 ? 0 : 1);
- packet.put("status_msg", coredumps == 0 ? "OK" : String.format("Found %d coredumps", coredumps));
+ packet.put("status_msg", coredumps == 0 ? "OK" : String.format("Found %d coredump(s)", coredumps));
packet.put("timestamp", Instant.now().getEpochSecond());
packet.put("application", "system-coredumps-processing");
@@ -34,10 +34,10 @@ public class CoredumpGatherer {
return packet;
}
- private static int getNumberOfCoredumps() {
+ private static int getNumberOfCoredumps(FileWrapper fileWrapper) {
try {
- return (int) Files.walk(COREDUMP_PATH)
- .filter(Files::isRegularFile)
+ return (int) fileWrapper.walkTree(COREDUMP_PATH)
+ .filter(fileWrapper::isRegularFile)
.count();
} catch (NoSuchFileException e) {
return 0;