commit 64530e1098e9bb11e69e90c55ac0fb9e360d57ca
author Clebert Suconic <clebertsuconic@apache.org> Thu Jun 11 21:53:39 2020 -0400
committer Clebert Suconic <clebertsuconic@apache.org> Thu Jun 11 21:55:17 2020 -0400
tree 795befda349a54d0b4dde2e1a5ff27b51952941d
parent 2e23377d91059472742a6de4433a26b261b1c7be

NO-JIRA improving test

src/main/c/org_apache_activemq_artemis_nativo_jlibaio_LibaioContext.c

diff --git a/src/main/c/org_apache_activemq_artemis_nativo_jlibaio_LibaioContext.c b/src/main/c/org_apache_activemq_artemis_nativo_jlibaio_LibaioContext.c
index d495eb4..7d49380 100644
--- a/src/main/c/org_apache_activemq_artemis_nativo_jlibaio_LibaioContext.c
+++ b/src/main/c/org_apache_activemq_artemis_nativo_jlibaio_LibaioContext.c
@@ -151,6 +151,7 @@
             }
 
             if (available >= max) {
+               fprintf (stderr, "Forcing a syscall\n"); fflush(stderr);
                // This is to trap a possible bug from the kernel:
                //       https://bugzilla.redhat.com/show_bug.cgi?id=1845326
                //       https://issues.apache.org/jira/browse/ARTEMIS-2800

src/test/java/org/apache/activemq/artemis/nativo/jlibaio/test/LibaioStressTest.java

diff --git a/src/test/java/org/apache/activemq/artemis/nativo/jlibaio/test/LibaioStressTest.java b/src/test/java/org/apache/activemq/artemis/nativo/jlibaio/test/LibaioStressTest.java
index e4e55b8..5930c64 100644
--- a/src/test/java/org/apache/activemq/artemis/nativo/jlibaio/test/LibaioStressTest.java
+++ b/src/test/java/org/apache/activemq/artemis/nativo/jlibaio/test/LibaioStressTest.java
@@ -42,6 +42,10 @@
 
     private static final int STRESS_TIME = Integer.parseInt(System.getProperty("test.stress.time", "5000"));
 
+    static {
+        System.out.println("LibaioStressTest:: -Dtest.stress.time=" + STRESS_TIME);
+    }
+
     /**
      * This is just an arbitrary number for a number of elements you need to pass to the libaio init method
      * Some of the tests are using half of this number, so if anyone decide to change this please use an even number.
@@ -124,7 +128,16 @@
     }
 
     @Test
+    public void testStressWritesNoSleeps() throws Exception {
+        testStressWrites(false);
+    }
+
+    @Test
     public void testStressWrites() throws Exception {
+        testStressWrites(true);
+    }
+
+    private void testStressWrites(boolean sleeps) throws Exception {
         Assume.assumeFalse(LibaioContext.isForceSyscall());
 
         Thread t = new Thread() {
@@ -150,8 +163,8 @@
 
         t2.start();
 
-        Thread test1 = startThread("test1.bin");
-        Thread test2 = startThread("test2.bin");
+        Thread test1 = startThread("test1.bin", sleeps);
+        Thread test2 = startThread("test2.bin", sleeps);
         Thread.sleep(STRESS_TIME); // Configured timeout on the test
         running = false;
         test2.join();
@@ -162,10 +175,10 @@
         return;
     }
 
-    private Thread startThread(String name) {
+    private Thread startThread(String name, boolean sleeps) {
         Thread t_test = new Thread(() -> {
             try {
-                doFile(name);
+                doFile(name, sleeps);
             } catch (IOException e) {
                 e.printStackTrace();
             } catch (InterruptedException e) {
@@ -177,7 +190,7 @@
         return t_test;
     }
 
-    private void doFile(String fileName) throws IOException, InterruptedException {
+    private void doFile(String fileName, boolean sleeps) throws IOException, InterruptedException {
         ReusableLatch latchWrites = new ReusableLatch(0);
 
         File file = temporaryFolder.newFile(fileName);
@@ -230,8 +243,10 @@
             myClass.reusableLatch.countUp();
 
 
-            if (count % 100 == 0) {
-                Thread.sleep(100);
+            if (sleeps) {
+                if (count % 100 == 0) {
+                    Thread.sleep(100);
+                }
             }
             fileDescriptor.write(pos, 4096, buffer, myClass);
             pos += 4096;