Fix test scripts and inactivity timeout test (#2893)

zeroc-ice · Oct 14, 2024 · 462dee3 · 462dee3
1 parent 9663bc8
commit 462dee3
Show file tree

Hide file tree

Showing 9 changed files with 33 additions and 22 deletions.
diff --git a/cpp/test/Ice/inactivityTimeout/Test.ice b/cpp/test/Ice/inactivityTimeout/Test.ice
@@ -8,6 +8,7 @@ module Test
 {
     interface TestIntf
     {
+        ["amd"]
         void sleep(int ms);
 
         void shutdown();

diff --git a/cpp/test/Ice/inactivityTimeout/TestI.cpp b/cpp/test/Ice/inactivityTimeout/TestI.cpp
@@ -9,9 +9,15 @@
 using namespace std;
 
 void
-TestIntfI::sleep(int32_t ms, const Ice::Current&)
+TestIntfI::sleepAsync(int32_t ms, function<void()> response, function<void(exception_ptr)>, const Ice::Current&)
 {
-    this_thread::sleep_for(chrono::milliseconds(ms));
+    _sleepFuture = std::async(
+        std::launch::async,
+        [ms, response]
+        {
+            this_thread::sleep_for(chrono::milliseconds(ms));
+            response();
+        });
 }
 
 void

diff --git a/cpp/test/Ice/inactivityTimeout/TestI.h b/cpp/test/Ice/inactivityTimeout/TestI.h
@@ -10,8 +10,16 @@
 class TestIntfI final : public Test::TestIntf
 {
 public:
-    void sleep(std::int32_t, const Ice::Current&) final;
+    void sleepAsync(
+        std::int32_t ms,
+        std::function<void()> response,
+        std::function<void(std::exception_ptr)> exception,
+        const Ice::Current& current) final;
 
     void shutdown(const Ice::Current&) final;
+
+private:
+    // has a blocking destructor
+    std::future<void> _sleepFuture;
 };
 #endif
diff --git a/csharp/test/Ice/inactivityTimeout/Test.ice b/csharp/test/Ice/inactivityTimeout/Test.ice
@@ -9,7 +9,9 @@ module Test
 {
     interface TestIntf
     {
+        ["amd"]
         void sleep(int ms);
+
         void shutdown();
     }
 }
diff --git a/csharp/test/Ice/inactivityTimeout/TestI.cs b/csharp/test/Ice/inactivityTimeout/TestI.cs
@@ -4,7 +4,7 @@ namespace Ice.inactivityTimeout;
 
 internal sealed class TestIntfI : Test.TestIntfDisp_
 {
-    public override void sleep(int ms, Current current) => Thread.Sleep(ms);
+    public override Task sleepAsync(int ms, Current current) => Task.Delay(ms);
 
     public override void shutdown(Current current) => current.adapter.getCommunicator().shutdown();
 }
diff --git a/java/test/src/main/java/test/Ice/inactivityTimeout/Test.ice b/java/test/src/main/java/test/Ice/inactivityTimeout/Test.ice
@@ -8,7 +8,9 @@ module Test
 {
     interface TestIntf
     {
+        ["amd"]
         void sleep(int ms);
+
         void shutdown();
     }
 }
diff --git a/java/test/src/main/java/test/Ice/inactivityTimeout/TestIntfI.java b/java/test/src/main/java/test/Ice/inactivityTimeout/TestIntfI.java
@@ -7,12 +7,15 @@
 
 class TestIntfI implements TestIntf {
     @Override
-    public void sleep(int ms, Current current) {
-        try {
-            Thread.sleep(ms);
-        } catch (InterruptedException ex) {
-            // ignored
-        }
+    public java.util.concurrent.CompletionStage<Void> sleepAsync(int ms, Current current) {
+        return java.util.concurrent.CompletableFuture.runAsync(
+                () -> {
+                    try {
+                        Thread.sleep(ms);
+                    } catch (InterruptedException ex) {
+                        // ignored
+                    }
+                });
     }
 
     @Override

diff --git a/scripts/tests/Ice/inactivityTimeout.py b/scripts/tests/Ice/inactivityTimeout.py
diff --git a/scripts/tests/Ice/maxConnections.py b/scripts/tests/Ice/maxConnections.py
@@ -14,6 +14,6 @@
 TestSuite(
     __name__,
     testcases,
-    options={"compress": [False], "protocol": ["ssl", "ws", "tcp"]},
+    options={"compress": [False]},
     multihost=False,
 )