diff --git a/src/main/java/org/opensearch/performanceanalyzer/commons/event_process/EventLogFileHandler.java b/src/main/java/org/opensearch/performanceanalyzer/commons/event_process/EventLogFileHandler.java index 943f1bb..0b5b12f 100644 --- a/src/main/java/org/opensearch/performanceanalyzer/commons/event_process/EventLogFileHandler.java +++ b/src/main/java/org/opensearch/performanceanalyzer/commons/event_process/EventLogFileHandler.java @@ -44,7 +44,7 @@ public EventLogFileHandler(EventLog eventLog, String metricsLocation) { } public void writeTmpFile(List dataEntries, long epoch) { - Util.invokePrivileged(() -> writeTmpFileWithPrivilege(dataEntries, epoch)); + Util.invokePrivilegedAndLogError(() -> writeTmpFileWithPrivilege(dataEntries, epoch)); } /** @@ -93,7 +93,7 @@ public void writeTmpFileWithPrivilege(List dataEntries, long epoch) { } public void renameFromTmp(long epoch) { - Util.invokePrivileged(() -> renameFromTmpWithPrivilege(epoch)); + Util.invokePrivilegedAndLogError(() -> renameFromTmpWithPrivilege(epoch)); } public void renameFromTmpWithPrivilege(long epoch) { @@ -161,7 +161,7 @@ private void readInternal(Path pathToFile, int bufferSize, EventDispatcher proce } public void deleteAllFiles() { - Util.invokePrivileged(this::deleteAllFilesWithPrivilege); + Util.invokePrivilegedAndLogError(this::deleteAllFilesWithPrivilege); } public void deleteAllFilesWithPrivilege() { @@ -197,6 +197,6 @@ public void deleteFiles(List filesToDelete) { } public void removeFilesWithPrivilege(File file) { - Util.invokePrivileged(() -> PerformanceAnalyzerMetrics.removeMetrics(file)); + Util.invokePrivilegedAndLogError(() -> PerformanceAnalyzerMetrics.removeMetrics(file)); } } diff --git a/src/main/java/org/opensearch/performanceanalyzer/commons/hwnet/Disks.java b/src/main/java/org/opensearch/performanceanalyzer/commons/hwnet/Disks.java index 73fc46f..65a6802 100644 --- a/src/main/java/org/opensearch/performanceanalyzer/commons/hwnet/Disks.java +++ b/src/main/java/org/opensearch/performanceanalyzer/commons/hwnet/Disks.java @@ -61,7 +61,7 @@ public class Disks { }; static { - Util.invokePrivileged(() -> listDisks()); + Util.invokePrivilegedAndLogError(() -> listDisks()); oldkvTimestamp = System.currentTimeMillis(); kvTimestamp = oldkvTimestamp; }