From 2a66d72baf84795af2400da8e3861733306ce1c5 Mon Sep 17 00:00:00 2001 From: Alva Swanson Date: Mon, 15 Apr 2024 20:59:27 +0200 Subject: [PATCH] NativeTorProcess: Remove log file monitoring --- .../bisq/tor/process/NativeTorProcess.java | 36 ------------------- 1 file changed, 36 deletions(-) diff --git a/network/tor/tor/src/main/java/bisq/tor/process/NativeTorProcess.java b/network/tor/tor/src/main/java/bisq/tor/process/NativeTorProcess.java index a5c08d2834..670170e36e 100644 --- a/network/tor/tor/src/main/java/bisq/tor/process/NativeTorProcess.java +++ b/network/tor/tor/src/main/java/bisq/tor/process/NativeTorProcess.java @@ -17,8 +17,6 @@ package bisq.tor.process; -import bisq.common.FileCreationWatcher; -import bisq.common.scanner.FileScanner; import lombok.extern.slf4j.Slf4j; import java.io.File; @@ -26,11 +24,7 @@ import java.nio.file.Path; import java.util.Map; import java.util.Optional; -import java.util.Set; -import java.util.concurrent.ExecutionException; -import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; -import java.util.concurrent.TimeoutException; @Slf4j public class NativeTorProcess { @@ -41,7 +35,6 @@ public class NativeTorProcess { private final Path torBinaryPath; private final Path torrcPath; private Optional process = Optional.empty(); - private Optional> logFileCreationWaiter = Optional.empty(); public NativeTorProcess(Path torDataDirPath) { this.torDataDirPath = torDataDirPath; @@ -66,8 +59,6 @@ public void start() { processBuilder.redirectError(ProcessBuilder.Redirect.DISCARD); processBuilder.redirectOutput(ProcessBuilder.Redirect.DISCARD); - logFileCreationWaiter = Optional.of(createLogFileCreationWaiter()); - try { Process torProcess = processBuilder.start(); process = Optional.of(torProcess); @@ -76,24 +67,6 @@ public void start() { } } - public void waitUntilControlPortReady() { - try { - if (logFileCreationWaiter.isPresent()) { - Future pathFuture = logFileCreationWaiter.get(); - - FileScanner fileScanner = new FileScanner( - Set.of("[notice] Opened Control listener connection (ready) on "), - pathFuture - ); - fileScanner.waitUntilLogContainsLines(); - } - - } catch (ExecutionException | IOException | InterruptedException | TimeoutException e) { - log.error("Couldn't wait for log file creation.", e); - throw new IllegalStateException("Couldn't wait for log file creation."); - } - } - public void waitUntilExited() { log.info("Wait until tor process has exited"); process.ifPresent(process -> { @@ -119,13 +92,4 @@ private void createTorControlDirectory() { } } } - - private Future createLogFileCreationWaiter() { - Path dataDir = torrcPath.getParent(); - Path logFilePath = torrcPath.getParent().resolve("debug.log"); - - FileCreationWatcher fileCreationWatcher = new FileCreationWatcher(dataDir); - return fileCreationWatcher.waitForFile(logFilePath); - } - }