move uses of invokePrivileged to invokePrivilegedAndLogError

opensearch-project · Nov 29, 2023 · 89de19a · 89de19a
1 parent 4773f4e
commit 89de19a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/...in/java/org/opensearch/performanceanalyzer/commons/event_process/EventLogFileHandler.java b/...in/java/org/opensearch/performanceanalyzer/commons/event_process/EventLogFileHandler.java
@@ -44,7 +44,7 @@ public EventLogFileHandler(EventLog eventLog, String metricsLocation) {
     }
 
     public void writeTmpFile(List<Event> dataEntries, long epoch) {
-        Util.invokePrivileged(() -> writeTmpFileWithPrivilege(dataEntries, epoch));
+        Util.invokePrivilegedAndLogError(() -> writeTmpFileWithPrivilege(dataEntries, epoch));
     }
 
     /**
@@ -93,7 +93,7 @@ public void writeTmpFileWithPrivilege(List<Event> 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<String> 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
@@ -61,7 +61,7 @@ public class Disks {
     };
 
     static {
-        Util.invokePrivileged(() -> listDisks());
+        Util.invokePrivilegedAndLogError(() -> listDisks());
         oldkvTimestamp = System.currentTimeMillis();
         kvTimestamp = oldkvTimestamp;
     }