aboutsummaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/logging
diff options
context:
space:
mode:
authorbjormel <bjormel@yahooinc.com>2023-10-01 12:23:12 +0000
committerbjormel <bjormel@yahooinc.com>2023-10-01 12:23:12 +0000
commite9058b555d4dfea2f6c872d9a677e8678b569569 (patch)
treefa1b67c6e39712c1e0d9f308b0dd55573b43f913 /container-search/src/main/java/com/yahoo/search/logging
parent0ad931fa86658904fe9212b014d810236b0e00e4 (diff)
parent16030193ec04ee41e98779a3d7ee6a6c1d0d0d6f (diff)
Merge branch 'master' into bjormel/aws-main-controller
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/logging')
-rw-r--r--container-search/src/main/java/com/yahoo/search/logging/LoggerEntry.java2
-rw-r--r--container-search/src/main/java/com/yahoo/search/logging/Spooler.java10
2 files changed, 6 insertions, 6 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/logging/LoggerEntry.java b/container-search/src/main/java/com/yahoo/search/logging/LoggerEntry.java
index 80ff967f779..d8e656d1b2b 100644
--- a/container-search/src/main/java/com/yahoo/search/logging/LoggerEntry.java
+++ b/container-search/src/main/java/com/yahoo/search/logging/LoggerEntry.java
@@ -135,7 +135,7 @@ public class LoggerEntry {
return logger.send(new LoggerEntry(this));
}
- LoggerEntry build() {
+ public LoggerEntry build() {
return new LoggerEntry(this);
}
diff --git a/container-search/src/main/java/com/yahoo/search/logging/Spooler.java b/container-search/src/main/java/com/yahoo/search/logging/Spooler.java
index 921b8f444f1..cf750fd9d8a 100644
--- a/container-search/src/main/java/com/yahoo/search/logging/Spooler.java
+++ b/container-search/src/main/java/com/yahoo/search/logging/Spooler.java
@@ -85,10 +85,10 @@ public class Spooler {
public void processFiles(Function<LoggerEntry, Boolean> transport) throws IOException {
List<Path> files = listFilesInPath(readyPath);
if (files.size() == 0) {
- log.log(Level.FINEST, "No files in ready path " + readyPath.toFile().getAbsolutePath());
+ log.log(Level.FINEST, () -> "No files in ready path " + readyPath.toFile().getAbsolutePath());
return;
}
- log.log(Level.FINE, "Files in ready path: " + files.size());
+ log.log(Level.FINE, () -> "Files in ready path: " + files.size());
List<File> fileList = getFiles(files);
if ( ! fileList.isEmpty()) {
@@ -116,7 +116,7 @@ public class Spooler {
List<String> lines = Files.readAllLines(f.toPath());
for (String line : lines) {
LoggerEntry entry = LoggerEntry.deserialize(line);
- log.log(Level.FINE, "Read entry " + entry + " from " + f);
+ log.log(Level.FINE, () -> "Read entry " + entry + " from " + f);
success = transport.apply(entry);
if (! success) {
throw new RuntimeException("Unable to process file " + f + ": unsuccessful call to transport() for " + entry);
@@ -190,7 +190,7 @@ public class Spooler {
String fileName = currentFileName();
Path file = spoolPath.resolve(processingPath).resolve(fileName);
try {
- log.log(Level.FINE, "Writing entry " + entryCounter.get() + " (" + entry.serialize() + ") to file " + fileName);
+ log.log(Level.FINE, () -> "Writing entry " + entryCounter.get() + " (" + entry.serialize() + ") to file " + fileName);
Files.writeString(file, entry.serialize() + "\n", StandardOpenOption.WRITE, StandardOpenOption.APPEND, StandardOpenOption.CREATE);
firstWriteTimestamp.compareAndExchange(Instant.EPOCH, clock.instant());
entryCounter.incrementAndGet();
@@ -242,7 +242,7 @@ public class Spooler {
if (file.exists() && file.canRead() && file.canWrite()) {
log.log(Level.INFO, "Directory " + path + " already exists");
} else if (file.mkdirs()) {
- log.log(Level.FINE, "Created " + path);
+ log.log(Level.FINE, () -> "Created " + path);
} else {
log.log(Level.WARNING, "Could not create " + path + ", please check permissions");
}