List of triggerForever() Examples

Examples of triggerForever()

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

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

               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

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

      ClusterListener clusterListener = listener();
      cache0.addListener(clusterListener);


      CheckPoint checkPoint = new CheckPoint();
      waitUntilNotificationRaised(cache1, checkPoint);
      checkPoint.triggerForever("pre_raise_notification_release");


      final MagicKey key = new MagicKey(cache1, cache2);
      Future<String> future = fork(new Callable<String>() {
         @Override
         public String call() throws Exception {

View Full Code Here

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

      checkPoint.awaitStrict("before-second-chunk", 30, TimeUnit.SECONDS);


      final Future<Void> topologyEventFuture = triggerTopologyChange(LON, testCaches.removeIndex);


      topologyEventFuture.get();
      checkPoint.triggerForever("second-chunk");


      awaitLocalStateTransfer(LON);
      awaitXSiteStateSent(LON);


      assertData();

View Full Code Here

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


      checkPoint.awaitStrict("before-block", 30, TimeUnit.SECONDS);


      Future<?> topologyChangeFuture = triggerTopologyChange(NYC, testCaches.removeIndex);
      discard.set(false);
      checkPoint.triggerForever("blocked");
      topologyChangeFuture.get();


      awaitXSiteStateSent(LON);
      awaitLocalStateTransfer(NYC);
      awaitXSiteStateReceived(NYC);

View Full Code Here

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

      checkPoint.awaitStrict("pre_topology_installed_invoked_" + c2, 10, TimeUnit.SECONDS);


      barrier.await(10, TimeUnit.SECONDS);
      assertEquals(startValue, future.get(10, TimeUnit.SECONDS));


      checkPoint.triggerForever("post_topology_installed_released_" + c3);
      checkPoint.triggerForever("pre_topology_installed_released_" + c1);
      checkPoint.triggerForever("pre_topology_installed_released_" + c2);


      join.get(10, TimeUnit.SECONDS);

View Full Code Here

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


      barrier.await(10, TimeUnit.SECONDS);
      assertEquals(startValue, future.get(10, TimeUnit.SECONDS));


      checkPoint.triggerForever("post_topology_installed_released_" + c3);
      checkPoint.triggerForever("pre_topology_installed_released_" + c1);
      checkPoint.triggerForever("pre_topology_installed_released_" + c2);


      join.get(10, TimeUnit.SECONDS);


      assertIsInContainerImmortal(c1, key);

View Full Code Here

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

      barrier.await(10, TimeUnit.SECONDS);
      assertEquals(startValue, future.get(10, TimeUnit.SECONDS));


      checkPoint.triggerForever("post_topology_installed_released_" + c3);
      checkPoint.triggerForever("pre_topology_installed_released_" + c1);
      checkPoint.triggerForever("pre_topology_installed_released_" + c2);


      join.get(10, TimeUnit.SECONDS);


      assertIsInContainerImmortal(c1, key);
      assertIsNotInL1(c2, key);

View Full Code Here

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

         fail("Should have thrown a TimeoutException");
      } catch (TimeoutException e) {
      }


      // Let the get complete finally
      checkPoint.triggerForever("pre_acquire_shared_topology_lock_released");


      Assert.assertEquals(firstValue, getFuture.get(10, TimeUnit.SECONDS));


      Assert.assertEquals(firstValue, putFuture.get(10, TimeUnit.SECONDS));

View Full Code Here

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

            fail("Should have thrown a TimeoutException");
         } catch (TimeoutException e) {
         }


         // Let the get complete finally
         checkPoint.triggerForever("pre_acquire_shared_topology_lock_released");


         Assert.assertEquals(firstValue, getFuture.get(10, TimeUnit.SECONDS));


         Assert.assertEquals(firstValue, getFuture2.get(10, TimeUnit.SECONDS));

View Full Code Here

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

            fail("Should have thrown a TimeoutException");
         } catch (TimeoutException e) {
         }


         // Let the get complete finally
         checkPoint.triggerForever("pre_acquire_shared_topology_lock_released");


         Assert.assertNull(getFuture.get(10, TimeUnit.SECONDS));


         Assert.assertNull(getFuture2.get(10, TimeUnit.SECONDS));
      } finally {

View Full Code Here

0 1 2 3 4 5

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.