core/src/test/java/org/infinispan/util/CountingCARD.java
/**
    * Prohibit staggered calls started before call to this happen to execute, and wait until we get responses
    * for all already invoked RPCs.
    */
Prohibit staggered calls started before call to this happen to execute, and wait until we get responses
for all already invoked RPCs.
Prohibit staggered calls started before call to this happen to execute and wait until we get responses for all already invoked RPCs .
public void advanceGenerationAndAwait(long timeout, TimeUnit timeUnit) throws InterruptedException {
      timeoutExecutor.advanceGeneration();
      long now = System.currentTimeMillis();
      long deadline = now + timeUnit.toMillis(timeout);
      synchronized (this) {
         while (awaitingReponses > 0) {
            this.wait(deadline - now);
            now = System.currentTimeMillis();
         }
      }
   }
public void advanceGenerationAndAwait ( long timeout , TimeUnit timeUnit ) throws InterruptedException { timeoutExecutor . advanceGeneration ( ) ; long now = System . currentTimeMillis ( ) ; long deadline = now + timeUnit . toMillis ( timeout ) ; synchronized ( this ) { while ( awaitingReponses > 0 ) { this . wait ( deadline - now ) ; now = System . currentTimeMillis ( ) ; } } }
Prohibit staggered calls started before call to this happen to execute, and wait until we get responses
 for all already invoked RPCs.
Prohibit staggered calls started before call to this happen to execute and wait until we get responses for all already invoked RPCs .