[infinispan-issues] [JBoss JIRA] (ISPN-1702) If a key written by a transaction cannot be invalidated the transaction should fail

[Mircea Markus (Created) (JIRA)]

If a key written by a transaction cannot be invalidated the transaction should fail
-----------------------------------------------------------------------------------

                 Key: ISPN-1702
                 URL: https://issues.jboss.org/browse/ISPN-1702
             Project: Infinispan
          Issue Type: Bug
            Reporter: Mircea Markus
            Assignee: Mircea Markus
            Priority: Critical


UT below:

{code}
package org.infinispan.invalidation;

import org.infinispan.configuration.cache.CacheMode;
import org.infinispan.configuration.cache.ConfigurationBuilder;
import org.infinispan.container.DataContainer;
import org.infinispan.context.Flag;
import org.infinispan.test.MultipleCacheManagersTest;
import org.infinispan.test.TestingUtil;
import org.testng.annotations.Test;

import static org.testng.Assert.assertEquals;

/**
 * @author Mircea Markus <mircea.markus at jboss.com> (C) 2011 Red Hat Inc.
 * @since 5.1
 */
@Test (groups = "functional", testName = "invalidation.InvalidationTxTest")
public class InvalidationTxTest extends MultipleCacheManagersTest {
   
   @Override
   protected void createCacheManagers() throws Throwable {
      ConfigurationBuilder config = getDefaultClusteredCacheConfig(CacheMode.INVALIDATION_SYNC, true);
      createCluster(config, 2);
      waitForClusterToForm();
   }
   
   
   public void testInvalidationFailsDuringPrepare() throws Exception {
      cache(0).put("k","v0");

      DataContainer dc0 = getDataContainer(0);
      assert dc0.get("k").getValue().equals("v0");

      DataContainer dc1 = getDataContainer(1);
      assert dc1.get("k") == null;

      advancedCache(1).withFlags(Flag.CACHE_MODE_LOCAL).put("k", "v1");


      assert dc0.get("k").getValue().equals("v0");
      assertEquals(dc1.get("k").getValue(), "v1");
      
      tm(1).begin();
      cache(1).put("k", "v");
      tm(1).suspend();
      lockManager(1).isLocked("k");

      tm(0).begin();
      cache(0).put("k", "v2");
      try {
        tm(0).commit(); 
        assert false : "this fails";
      } catch (Exception t) {
        //expected
      }

   }

   private DataContainer getDataContainer(int index) {
      return TestingUtil.extractComponent(cache(index), DataContainer.class);
   }
}
{code}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira