Verify object detachment.

cojen · Oct 5, 2024 · 3ce1780 · 3ce1780
1 parent 575ed2c
commit 3ce1780
Showing 1 changed file with 17 additions and 1 deletion.
diff --git a/src/test/java/org/cojen/dirmi/AutoDisposeTest.java b/src/test/java/org/cojen/dirmi/AutoDisposeTest.java
@@ -99,6 +99,8 @@ public void basic() throws Exception {
 
     @Test
     public void noReply() throws Exception {
+        R2Server.mDetached = 0;
+
         R1 root = mSession.root();
         R2 r2 = root.r2();
 
@@ -120,6 +122,8 @@ public void noReply() throws Exception {
 
         int sleep = 100;
 
+        assertEquals(0, R2Server.mDetached);
+
         while (true) {
             System.gc();
 
@@ -130,6 +134,7 @@ public void noReply() throws Exception {
 
             if (newId != id) {
                 // Original remote object was disposed and a new one was created.
+                assertEquals(1, R2Server.mDetached);
                 break;
             }
 
@@ -207,7 +212,9 @@ public R2 r2() {
         }
     }
 
-    private static class R2Server implements R2 {
+    private static class R2Server implements R2, SessionAware {
+        static volatile int mDetached;
+
         private volatile String mMessage;
 
         @Override
@@ -219,5 +226,14 @@ public void update(String msg) {
         public String getMessage() {
             return mMessage;
         }
+
+        @Override
+        public void attached(Session<?> s) {
+        }
+
+        @Override
+        public void detached(Session<?> s) {
+            mDetached++;
+        }
     }
 }