| /*========================================================================= |
| * Copyright (c) 2010-2014 Pivotal Software, Inc. All Rights Reserved. |
| * This product is protected by U.S. and international copyright |
| * and intellectual property laws. Pivotal products are covered by |
| * one or more patents listed at http://www.pivotal.io/patents. |
| *========================================================================= |
| */ |
| package com.gemstone.gemfire.internal.cache; |
| // DO NOT modify this class. It was generated from LeafRegionEntry.cpp |
| import java.util.concurrent.atomic.AtomicLongFieldUpdater; |
| import com.gemstone.gemfire.internal.cache.lru.EnableLRU; |
| import com.gemstone.gemfire.internal.cache.persistence.DiskRecoveryStore; |
| import com.gemstone.gemfire.internal.offheap.OffHeapRegionEntryHelper; |
| import com.gemstone.gemfire.internal.offheap.annotations.Released; |
| import com.gemstone.gemfire.internal.offheap.annotations.Retained; |
| import com.gemstone.gemfire.internal.offheap.annotations.Unretained; |
| import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; |
| // macros whose definition changes this class: |
| // disk: DISK |
| // lru: LRU |
| // stats: STATS |
| // versioned: VERSIONED |
| // offheap: OFFHEAP |
| // One of the following key macros must be defined: |
| // key object: KEY_OBJECT |
| // key int: KEY_INT |
| // key long: KEY_LONG |
| // key uuid: KEY_UUID |
| // key string1: KEY_STRING1 |
| // key string2: KEY_STRING2 |
| /** |
| * Do not modify this class. It was generated. |
| * Instead modify LeafRegionEntry.cpp and then run |
| * bin/generateRegionEntryClasses.sh from the directory |
| * that contains your build.xml. |
| */ |
| public class VMThinDiskRegionEntryOffHeapObjectKey extends VMThinDiskRegionEntryOffHeap { |
| public VMThinDiskRegionEntryOffHeapObjectKey (RegionEntryContext context, Object key, |
| @Retained |
| Object value |
| ) { |
| super(context, |
| (value instanceof RecoveredEntry ? null : value) |
| ); |
| // DO NOT modify this class. It was generated from LeafRegionEntry.cpp |
| initialize(context, value); |
| this.key = key; |
| } |
| // DO NOT modify this class. It was generated from LeafRegionEntry.cpp |
| // common code |
| protected int hash; |
| private HashEntry<Object, Object> next; |
| @SuppressWarnings("unused") |
| private volatile long lastModified; |
| private static final AtomicLongFieldUpdater<VMThinDiskRegionEntryOffHeapObjectKey> lastModifiedUpdater |
| = AtomicLongFieldUpdater.newUpdater(VMThinDiskRegionEntryOffHeapObjectKey.class, "lastModified"); |
| /** |
| * All access done using ohAddrUpdater so it is used even though the compiler can not tell it is. |
| */ |
| @SuppressWarnings("unused") |
| @Retained @Released private volatile long ohAddress; |
| /** |
| * I needed to add this because I wanted clear to call setValue which normally can only be called while the re is synced. |
| * But if I sync in that code it causes a lock ordering deadlock with the disk regions because they also get a rw lock in clear. |
| * Some hardware platforms do not support CAS on a long. If gemfire is run on one of those the AtomicLongFieldUpdater does a sync |
| * on the re and we will once again be deadlocked. |
| * I don't know if we support any of the hardware platforms that do not have a 64bit CAS. If we do then we can expect deadlocks |
| * on disk regions. |
| */ |
| private final static AtomicLongFieldUpdater<VMThinDiskRegionEntryOffHeapObjectKey> ohAddrUpdater = AtomicLongFieldUpdater.newUpdater(VMThinDiskRegionEntryOffHeapObjectKey.class, "ohAddress"); |
| @Override |
| public Token getValueAsToken() { |
| return OffHeapRegionEntryHelper.getValueAsToken(this); |
| } |
| @Override |
| protected Object getValueField() { |
| return OffHeapRegionEntryHelper._getValue(this); |
| } |
| // DO NOT modify this class. It was generated from LeafRegionEntry.cpp |
| @Override |
| @Unretained |
| protected void setValueField(@Unretained Object v) { |
| OffHeapRegionEntryHelper.setValue(this, v); |
| } |
| @Override |
| @Retained |
| public Object _getValueRetain(RegionEntryContext context, boolean decompress) { |
| return OffHeapRegionEntryHelper._getValueRetain(this, decompress, context); |
| } |
| @Override |
| public long getAddress() { |
| return ohAddrUpdater.get(this); |
| } |
| @Override |
| public boolean setAddress(long expectedAddr, long newAddr) { |
| return ohAddrUpdater.compareAndSet(this, expectedAddr, newAddr); |
| } |
| @Override |
| @Released |
| public void release() { |
| OffHeapRegionEntryHelper.releaseEntry(this); |
| } |
| @Override |
| public void returnToPool() { |
| // Deadcoded for now; never was working |
| // if (this instanceof VMThinRegionEntryLongKey) { |
| // factory.returnToPool((VMThinRegionEntryLongKey)this); |
| // } |
| } |
| protected long getlastModifiedField() { |
| return lastModifiedUpdater.get(this); |
| } |
| protected boolean compareAndSetLastModifiedField(long expectedValue, long newValue) { |
| return lastModifiedUpdater.compareAndSet(this, expectedValue, newValue); |
| } |
| /** |
| * @see HashEntry#getEntryHash() |
| */ |
| public final int getEntryHash() { |
| return this.hash; |
| } |
| protected void setEntryHash(int v) { |
| this.hash = v; |
| } |
| /** |
| * @see HashEntry#getNextEntry() |
| */ |
| public final HashEntry<Object, Object> getNextEntry() { |
| return this.next; |
| } |
| /** |
| * @see HashEntry#setNextEntry |
| */ |
| public final void setNextEntry(final HashEntry<Object, Object> n) { |
| this.next = n; |
| } |
| // DO NOT modify this class. It was generated from LeafRegionEntry.cpp |
| // disk code |
| protected void initialize(RegionEntryContext context, Object value) { |
| diskInitialize(context, value); |
| } |
| @Override |
| public int updateAsyncEntrySize(EnableLRU capacityController) { |
| throw new IllegalStateException("should never be called"); |
| } |
| // DO NOT modify this class. It was generated from LeafRegionEntry.cpp |
| private void diskInitialize(RegionEntryContext context, Object value) { |
| DiskRecoveryStore drs = (DiskRecoveryStore)context; |
| DiskStoreImpl ds = drs.getDiskStore(); |
| long maxOplogSize = ds.getMaxOplogSize(); |
| //get appropriate instance of DiskId implementation based on maxOplogSize |
| this.id = DiskId.createDiskId(maxOplogSize, true/* is persistence */, ds.needsLinkedList()); |
| Helper.initialize(this, drs, value); |
| } |
| /** |
| * DiskId |
| * |
| * @since 5.1 |
| */ |
| protected DiskId id;//= new DiskId(); |
| public DiskId getDiskId() { |
| return this.id; |
| } |
| @Override |
| void setDiskId(RegionEntry old) { |
| this.id = ((AbstractDiskRegionEntry)old).getDiskId(); |
| } |
| // // inlining DiskId |
| // // always have these fields |
| // /** |
| // * id consists of |
| // * most significant |
| // * 1 byte = users bits |
| // * 2-8 bytes = oplog id |
| // * least significant. |
| // * |
| // * The highest bit in the oplog id part is set to 1 if the oplog id |
| // * is negative. |
| // * @todo this field could be an int for an overflow only region |
| // */ |
| // private long id; |
| // /** |
| // * Length of the bytes on disk. |
| // * This is always set. If the value is invalid then it will be set to 0. |
| // * The most significant bit is used by overflow to mark it as needing to be written. |
| // */ |
| // protected int valueLength = 0; |
| // // have intOffset or longOffset |
| // // intOffset |
| // /** |
| // * The position in the oplog (the oplog offset) where this entry's value is |
| // * stored |
| // */ |
| // private volatile int offsetInOplog; |
| // // longOffset |
| // /** |
| // * The position in the oplog (the oplog offset) where this entry's value is |
| // * stored |
| // */ |
| // private volatile long offsetInOplog; |
| // // have overflowOnly or persistence |
| // // overflowOnly |
| // // no fields |
| // // persistent |
| // /** unique entry identifier * */ |
| // private long keyId; |
| // DO NOT modify this class. It was generated from LeafRegionEntry.cpp |
| // key code |
| private final Object key; |
| @Override |
| public final Object getKey() { |
| return this.key; |
| } |
| // DO NOT modify this class. It was generated from LeafRegionEntry.cpp |
| } |