Examples of AtomicHashMap

org.infinispan.atomic.AtomicHashMap
The default implementation of {@link AtomicMap}. Note that this map cannot be constructed directly, and callers should obtain references to AtomicHashMaps via the {@link AtomicMapLookup} helper. This helper will ensure properconcurrent construction and registration of AtomicMaps in Infinispan's data container. E.g.:

AtomicMap<String, Integer> map = AtomicMapLookup.getAtomicMap(cache, "my_atomic_map_key");

Note that for replication to work properly, AtomicHashMap updates must always take place within the scope of an ongoing JTA transaction or batch (see {@link Cache#startBatch()}).
@author (various) @param < K> the type of keys maintained by this map @param < V> the type of mapped values @see AtomicMap @see AtomicMapLookup @since 4.0
org.infinispan.atomic.impl.AtomicHashMap
The default implementation of {@link AtomicMap}. Note that this map cannot be constructed directly, and callers should obtain references to AtomicHashMaps via the {@link AtomicMapLookup} helper. This helper will ensure properconcurrent construction and registration of AtomicMaps in Infinispan's data container. E.g.:

AtomicMap<String, Integer> map = AtomicMapLookup.getAtomicMap(cache, "my_atomic_map_key");

Note that for replication to work properly, AtomicHashMap updates must always take place within the scope of an ongoing JTA transaction or batch (see {@link Cache#startBatch()}).
@author (various) @param < K> the type of keys maintained by this map @param < V> the type of mapped values @see AtomicMap @see AtomicMapLookup @since 4.0

Examples of org.infinispan.atomic.AtomicHashMap

   public DeltaAwareCacheEntry(Object key, DeltaAware value, CacheEntry wrappedEntry) {
      setValid(true);
      this.key = key;
      this.value = value;
      this.wrappedEntry = wrappedEntry;
      this.uncommittedChanges = new AtomicHashMap();
      this.deltas = new ArrayList<Delta>();
   }

View Full Code Here

Examples of org.infinispan.atomic.AtomicHashMap

      public void setCreator() {creator = Thread.currentThread();}


      public DeltaAware merge(DeltaAware d) {
         if (creator != Thread.currentThread())
            throw new RuntimeException("Induced!");
         return new AtomicHashMap();
      }

View Full Code Here

Examples of org.infinispan.atomic.AtomicHashMap

   public DeltaAwareCacheEntry(Object key, DeltaAware value, CacheEntry wrappedEntry) {
      setValid(true);
      this.key = key;
      this.value = value;
      this.wrappedEntry = wrappedEntry;
      this.uncommittedChanges = new AtomicHashMap();
      this.deltas = new ArrayList<Delta>();
   }

View Full Code Here

Examples of org.infinispan.atomic.AtomicHashMap

            log.tracef("Updating entry (key=%s removed=%s valid=%s changed=%s created=%s value=%s]", getKey(),
                      isRemoved(), isValid(), isChanged(), isCreated(), value);


         // Ugh!
         if (value instanceof AtomicHashMap) {
            AtomicHashMap ahm = (AtomicHashMap) value;
            ahm.commit();
            if (isRemoved() && !isEvicted()) ahm.markRemoved(true);
         }


         if (isRemoved()) {
            container.remove(key);
         } else if (value != null) {

View Full Code Here

Examples of org.infinispan.atomic.AtomicHashMap

      public void setCreator() {creator = Thread.currentThread();}


      public DeltaAware merge(DeltaAware d) {
         if (creator != Thread.currentThread())
            throw new RuntimeException("Induced!");
         return new AtomicHashMap();
      }

View Full Code Here

Examples of org.infinispan.atomic.impl.AtomicHashMap

import org.testng.annotations.Test;


@Test(groups = "unit", testName = "atomic.AtomicHashMapTest")
public class AtomicHashMapTest extends AbstractInfinispanTest {
   public void testDeltasWithEmptyMap() {
      AtomicHashMap m = new AtomicHashMap();
      Delta d = m.delta();
      assert d instanceof NullDelta;


      AtomicHashMap newMap = new AtomicHashMap();
      newMap.initForWriting();
      newMap.put("k", "v");
      newMap = (AtomicHashMap) d.merge(newMap);
      assert newMap.containsKey("k");
      assert newMap.size() == 1;


      newMap = (AtomicHashMap) d.merge(null);
      assert newMap.isEmpty();
   }

View Full Code Here

Examples of org.infinispan.atomic.impl.AtomicHashMap

      newMap = (AtomicHashMap) d.merge(null);
      assert newMap.isEmpty();
   }


   public void testDeltasWithNoChanges() {
      AtomicHashMap m = new AtomicHashMap();
      m.initForWriting();
      m.put("k1", "v1");
      m.commit();
      assert m.size() == 1;
      Delta d = m.delta();
      assert d instanceof NullDelta;


      AtomicHashMap newMap = new AtomicHashMap();
      newMap.initForWriting();
      newMap.put("k", "v");
      newMap = (AtomicHashMap) d.merge(newMap);
      assert newMap.containsKey("k");
      assert newMap.size() == 1;


      newMap = (AtomicHashMap) d.merge(null);
      assert newMap.isEmpty();
   }

View Full Code Here

Examples of org.infinispan.atomic.impl.AtomicHashMap

      newMap = (AtomicHashMap) d.merge(null);
      assert newMap.isEmpty();
   }


   public void testDeltasWithRepeatedChanges() {
      AtomicHashMap m = new AtomicHashMap();
      m.initForWriting();
      m.put("k1", "v1");
      m.put("k1", "v2");
      m.put("k1", "v3");
      assert m.size() == 1;
      AtomicHashMapDelta d = (AtomicHashMapDelta) m.delta();
      assert d.getChangeLogSize() != 0;


      AtomicHashMap newMap = new AtomicHashMap();
      newMap.initForWriting();
      newMap.put("k1", "v4");
      newMap = (AtomicHashMap) d.merge(newMap);
      assert newMap.containsKey("k1");
      assert newMap.get("k1").equals("v3");
      assert newMap.size() == 1;


      newMap = (AtomicHashMap) d.merge(null);
      assert newMap.containsKey("k1");
      assert newMap.get("k1").equals("v3");
      assert newMap.size() == 1;
   }

View Full Code Here

Examples of org.infinispan.atomic.impl.AtomicHashMap

      public void setCreator() {creator = Thread.currentThread();}


      public DeltaAware merge(DeltaAware d) {
         if (creator != Thread.currentThread())
            throw new RuntimeException("Induced!");
         return new AtomicHashMap();
      }

View Full Code Here

0 1

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.