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

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 Fix For: 5.1.0.FINAL 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(a)jboss.com&gt; (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}