spring/spring-boot
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-boot.git synced 2026-09-17 12:09:16 +00:00
Code Issues Projects Releases Wiki Activity

Polish "Improve Docker Compose ProcessRunner's handling of failure cases"

Browse Source 
See gh-50963

Signed-off-by: Andy Wilkinson <andy.wilkinson@broadcom.com>
This commit is contained in:
Andy Wilkinson
2026-09-02 09:11:53 +01:00
parent 27e96308ed
commit bf8731693b
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/spring-boot-docker-compose/src/test/java/org/springframework/boot/docker/compose/core/ProcessRunnerTests.java
+3 -5
View File
@@ -17,10 +17,12 @@
package org.springframework.boot.docker.compose.core; package org.springframework.boot.docker.compose.core;
import java.nio.file.Files; import java.nio.file.Files;
import java.nio.file.LinkOption;
import java.nio.file.Path; import java.nio.file.Path;
import java.time.Duration; import java.time.Duration;
import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReference;
import org.awaitility.Awaitility;
import org.junit.jupiter.api.Nested; import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.DisabledOnOs; import org.junit.jupiter.api.condition.DisabledOnOs;
@@ -75,11 +77,7 @@ class ProcessRunnerTests {
} }
}, "process-runner-interrupt-test"); }, "process-runner-interrupt-test");
runner.start(); runner.start();
long deadline = System.currentTimeMillis() + 5000; Awaitility.await().until(() -> Files.exists(pidFile, LinkOption.NOFOLLOW_LINKS));
while (!Files.exists(pidFile) && System.currentTimeMillis() < deadline) {
Thread.sleep(50);
}
assertThat(pidFile).exists();
long pid = Long.parseLong(Files.readString(pidFile).trim()); long pid = Long.parseLong(Files.readString(pidFile).trim());
assertThat(ProcessHandle.of(pid)).isPresent().get().matches(ProcessHandle::isAlive); assertThat(ProcessHandle.of(pid)).isPresent().get().matches(ProcessHandle::isAlive);
runner.interrupt(); runner.interrupt();