Examples of org.infinispan.test.fwk.CheckPoint.triggerForever()

Class org.infinispan.test.fwk.CheckPoint

Examples of org.infinispan.test.fwk.CheckPoint.triggerForever()

org.infinispan.test.fwk.CheckPoint.triggerForever()

         cache1.put(key, key.toString());
         values.put(key, key.toString());
      }


      CheckPoint checkPoint = new CheckPoint();
      checkPoint.triggerForever("post_iterator_released");
      waitUntilDataContainerWillBeIteratedOn(cache0, checkPoint);


      final EntryRetriever<Object, String> retriever = cache2.getAdvancedCache().getComponentRegistry().getComponent(
            EntryRetriever.class);

View Full Code Here


      // Now kill the cache - we should recover and get appropriate values
      killMember(1, CACHE_NAME);


      // Now let them process the results
      checkPoint.triggerForever("pre_iterator_released");


      future.get(10, TimeUnit.SECONDS);




      ConsistentHash hash = cache0.getAdvancedCache().getComponentRegistry().getComponent(DistributionManager.class).getReadConsistentHash();

View Full Code Here

         }


         operation.perform(cache, keyToChange, value);


         // Now let the iteration complete
         checkPoint.triggerForever("pre_retrieve_entry_released");


         future.get(10, TimeUnit.SECONDS);


         verifyEvents(isClustered(listener), listener, expectedValues);
      } finally {

View Full Code Here

         }


         Object oldValue = operation.perform(cache, keyToChange, value);


         // Now let the iteration complete
         checkPoint.triggerForever("pre_close_iter_released");


         future.get(10, TimeUnit.SECONDS);


         boolean isClustered = isClustered(listener);

View Full Code Here

      try {
         checkPoint.awaitStrict("pre_complete_segment_invoked", 10, TimeUnit.SECONDS);
         Object oldValue = operation.perform(cache, keyToChange, value);


         // Now let the iteration complete
         checkPoint.triggerForever("pre_complete_segment_released");


         future.get(10, TimeUnit.SECONDS);


         boolean isClustered = isClustered(listener);

View Full Code Here

      long startTime = System.currentTimeMillis();
      TestingUtil.blockUntilViewsReceived(30000, cacheManagers);


      // unblock the REBALANCE_START command
      log.debugf("Unblocking the REBALANCE_START command on the coordinator");
      checkpoint.triggerForever("merge");


      // wait for the 4th cache to finish joining
      Cache<Object, Object> c4 = cacheFuture.get(30, TimeUnit.SECONDS);
      TestingUtil.waitForRehashToComplete(c1, c2, c3, c4);

View Full Code Here

               checkPoint.awaitStrict("pre_process_on_all_stores_invoked", 1000, TimeUnit.SECONDS);


               // Now force the entry to be moved to loader
               TestingUtil.extractComponent(cache0, PassivationManager.class).passivate(new ImmortalCacheEntry(loaderKey, loaderValue));


               checkPoint.triggerForever("pre_process_on_all_stores_released");
               return null;
            }
         });


         EntryRetriever<MagicKey, String> retriever = cache1.getAdvancedCache().getComponentRegistry().getComponent(

View Full Code Here

      assertEquals(manager(0).getAddress(), manager(0).getMembers().get(0));


      CheckPoint checkPoint = new CheckPoint();


      waitUntilRequestingListeners(cache0, checkPoint);
      checkPoint.triggerForever("post_cluster_listeners_release_" + cache0);


      // First we add the new node, but block the dist exec execution
      log.info("Adding a new node ..");
      addClusterEnabledCacheManager(builderUsed);
      log.info("Added a new node");

View Full Code Here

      log.info("Node 0 killed");


      TestingUtil.blockUntilViewsReceived(10000, false, cacheManagers);
      TestingUtil.waitForRehashToComplete(caches(CACHE_NAME));


      checkPoint.triggerForever("pre_cluster_listeners_invoked_" + cache0);


      Cache<Object, String> cache3 = future.get(10, TimeUnit.SECONDS);


      MagicKey key = new MagicKey(cache3);

View Full Code Here

      assertEquals(manager(0).getAddress(), manager(0).getMembers().get(0));


      CheckPoint checkPoint = new CheckPoint();


      waitUntilRequestingListeners(cache0, checkPoint);
      checkPoint.triggerForever("post_cluster_listeners_release_" + cache0);
      waitUntilViewChangeOccurs(manager(1), "manager1", checkPoint);


      // We let the first view change occur just fine on cache1 (this will be the addition of cache3).
      // What we want to block is the second one which is the removal of cache0
      checkPoint.trigger("pre_view_listener_release_" + "manager1");

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.