Remove possible vertx thread blocking.

prebid · Nov 7, 2024 · a6cacbf · a6cacbf
1 parent e7745d4
commit a6cacbf
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/org/prebid/server/execution/file/syncer/FileSyncer.java b/src/main/java/org/prebid/server/execution/file/syncer/FileSyncer.java
@@ -45,7 +45,7 @@ private void sync(RetryPolicy currentRetryPolicy) {
 
     private Future<?> processFile(String filePath) {
         return filePath != null
-                ? fileProcessor.setDataPath(filePath)
+                ? vertx.executeBlocking(() -> fileProcessor.setDataPath(filePath))
                 .onFailure(error -> logger.error("Can't process saved file: " + filePath))
                 : Future.succeededFuture();
     }

diff --git a/src/main/java/org/prebid/server/execution/file/syncer/RemoteFileSyncer.java b/src/main/java/org/prebid/server/execution/file/syncer/RemoteFileSyncer.java
@@ -85,7 +85,7 @@ public void sync() {
     }
 
     private Future<Void> processSavedFile() {
-        return processor.setDataPath(saveFilePath)
+        return vertx.executeBlocking(() -> processor.setDataPath(saveFilePath))
                 .onFailure(error -> logger.error("Can't process saved file: " + saveFilePath))
                 .recover(ignored -> deleteFile(saveFilePath).mapEmpty())
                 .mapEmpty();