[exo-jcr-commits] exo-jcr SVN: r3601 - kernel/trunk/exo.kernel.component.common/src/test/java/org/exoplatform/services/rpc/impl.

[do-not-reply at jboss.org]

Author: areshetnyak
Date: 2010-12-06 04:33:20 -0500 (Mon, 06 Dec 2010)
New Revision: 3601

Modified:
   kernel/trunk/exo.kernel.component.common/src/test/java/org/exoplatform/services/rpc/impl/TestRPCServiceImpl.java
Log:
EXOJCR-1073 : The problem with TestRPCServiceImpl was fixed.

Modified: kernel/trunk/exo.kernel.component.common/src/test/java/org/exoplatform/services/rpc/impl/TestRPCServiceImpl.java
===================================================================
--- kernel/trunk/exo.kernel.component.common/src/test/java/org/exoplatform/services/rpc/impl/TestRPCServiceImpl.java	2010-12-06 07:57:47 UTC (rev 3600)
+++ kernel/trunk/exo.kernel.component.common/src/test/java/org/exoplatform/services/rpc/impl/TestRPCServiceImpl.java	2010-12-06 09:33:20 UTC (rev 3601)
@@ -833,7 +833,7 @@
          };
          t.start();
          service1.stop();
-         Thread.sleep(5000);
+         listener2.waitTopologyChange();
          assertFalse(listener1.coordinatorHasChanged);
          assertTrue(listener1.isCoordinator);
          assertEquals(2, listener1.count);
@@ -1188,6 +1188,8 @@
       private boolean coordinatorHasChanged;
       private boolean isCoordinator;
       private int count;
+
+      private CountDownLatch lock;
       
       /**
        * @see org.exoplatform.services.rpc.TopologyChangeListener#onChange(org.exoplatform.services.rpc.TopologyChangeEvent)
@@ -1197,6 +1199,17 @@
          this.coordinatorHasChanged = event.isCoordinatorHasChanged();
          this.isCoordinator = event.isCoordinator();
          count++;
+         
+         if (lock != null)
+         {
+            lock.countDown();
+         }
       }
+
+      public void waitTopologyChange() throws InterruptedException
+      {
+         lock = new CountDownLatch(1);
+         lock.await();
+      }
    }
 }