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

[Galder Zamarreño (JIRA)]

     [ https://issues.jboss.org/browse/ISPN-1702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Galder Zamarreño reopened ISPN-1702:
------------------------------------


    
> 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
>          Components: Transactions
>    Affects Versions: 5.0.1.FINAL
>            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