Merge branch 'main' into jdk-base-watcher

Author: sungshik

src/test/java/engineering/swat/watch/DeleteLockTests.java

@@ -62,7 +62,6 @@ static void setupEverything() {
         Awaitility.setDefaultTimeout(TestHelper.NORMAL_WAIT);
     }
 
-
     @FunctionalInterface
     private interface Deleter {
         void run(Path target) throws IOException;

src/test/java/engineering/swat/watch/RecursiveWatchTests.java

@@ -66,7 +66,6 @@ static void setupEverything() {
         Awaitility.setDefaultTimeout(TestHelper.NORMAL_WAIT);
     }
 
-
     @Test
     void newDirectoryWithFilesChangesDetected() throws IOException {
         var target = new AtomicReference<Path>();

src/test/java/engineering/swat/watch/SmokeTests.java

@@ -112,6 +112,4 @@ void watchSingleFile() throws IOException {
             await("Single file change").untilTrue(changed);
         }
     }
-
-
 }

src/test/java/engineering/swat/watch/TestHelper.java

@@ -37,7 +37,7 @@ public class TestHelper {
     static {
         var delayFactorConfig = System.getenv("DELAY_FACTOR");
         int delayFactor = delayFactorConfig == null ? 1 : Integer.parseInt(delayFactorConfig);
-        var os = System.getProperty("os", "?").toLowerCase();
+        var os = System.getProperty("os.name", "?").toLowerCase();
         if (os.contains("mac")) {
             // OSX is SLOW on it's watches
             delayFactor *= 2;

src/test/java/engineering/swat/watch/TortureTests.java

@@ -49,7 +49,9 @@
 
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.awaitility.Awaitility;
 import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.RepeatedTest;
 import org.junit.jupiter.api.Test;
@@ -61,6 +63,11 @@ class TortureTests {
 
     private TestDirectory testDir;
 
+    @BeforeAll
+    static void setupEverything() {
+        Awaitility.setDefaultTimeout(TestHelper.LONG_WAIT.getSeconds(), TimeUnit.SECONDS);
+    }
+
     @BeforeEach
     void setup() throws IOException {
         testDir = new TestDirectory();
@@ -236,7 +243,6 @@ void manyRegistrationsForSamePath() throws InterruptedException, IOException {
             done.acquire(TORTURE_REGISTRATION_THREADS - 1);
             assertTrue(seen.isEmpty(), "No events should have been sent");
             var target = testDir.getTestDirectory().resolve("test124.txt");
-            //logger.info("Writing: {}", target);
             Files.writeString(target, "Hello World");
             var expected = Collections.singleton(target);
             await("We should see only one event")
@@ -321,8 +327,6 @@ void manyRegisterAndUnregisterSameTime() throws InterruptedException, IOExceptio
 
     }
 
-
-
     @Test
     //Deletes can race the filesystem, so you might miss a few files in a dir, if that dir is already deleted
     @EnabledIfEnvironmentVariable(named="TORTURE_DELETE", matches="true")
@@ -360,7 +364,7 @@ void pressureOnFSShouldNotMissDeletes() throws InterruptedException, IOException
                 });
 
             try (var activeWatch = watchConfig.start() ) {
-                logger.info("Deleting files now", THREADS);
+                logger.info("Deleting files now ({} threads)", THREADS);
                 testDir.deleteAllFiles();
                 logger.info("Waiting for the events processing to stabilize");
                 waitForStable(events, happened);

src/test/java/engineering/swat/watch/impl/BundlingTests.java

@@ -54,7 +54,7 @@
 import engineering.swat.watch.impl.util.BundledSubscription;
 import engineering.swat.watch.impl.util.ISubscribable;
 
-public class BundlingTests {
+class BundlingTests {
 
     private final Logger logger = LogManager.getLogger();
     private BundledSubscription<Long, Boolean> target;
@@ -77,8 +77,7 @@ void publish(Long x) {
                 s.accept(true);
             }
         }
-    };
-
+    }
 
     @BeforeEach
     void setup() {
@@ -134,7 +133,7 @@ void manySubscriptions() throws IOException {
     }
 
     @RepeatedTest(failureThreshold = 1, value=50)
-    void parallelSubscriptions() throws IOException, InterruptedException {
+    void parallelSubscriptions() throws InterruptedException {
         var hits = new AtomicInteger();
         var endPointReached = new Semaphore(0);
         var waitingForClose = new Semaphore(0);
@@ -171,5 +170,4 @@ void parallelSubscriptions() throws IOException, InterruptedException {
             .untilAtomic(hits, IsEqual.equalTo(active));
         waitingForClose.release(active);
     }
-
 }