blob: 83304ca7b8656c6698d0a45ebe30743d450a268e [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one or more contributor license
* agreements. See the NOTICE file distributed with this work for additional information regarding
* copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance with the License. You may obtain a
* copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software distributed under the License
* is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
* or implied. See the License for the specific language governing permissions and limitations under
* the License.
*/
package org.apache.geode.internal.cache.entries;
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
#if defined(KEY_OBJECT)
#define KEY_TYPE Object
#elif defined(KEY_INT)
#define KEY_TYPE int
#elif defined(KEY_LONG)
#define KEY_TYPE long
#elif defined(KEY_UUID)
#define KEY_TYPE UUID
#elif defined(KEY_STRING1) || defined(KEY_STRING2)
#define KEY_TYPE String
#else
#error the KEY_TYPE macro must be defined
#endif
#ifdef KEY_UUID
import java.util.UUID;
#endif
#if defined(STATS) || defined(LRU)
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
#endif
import java.util.concurrent.atomic.AtomicLongFieldUpdater;
#if defined(VERSIONED)
import org.apache.geode.cache.EntryEvent;
import org.apache.geode.internal.cache.InternalRegion;
#endif
import org.apache.geode.internal.cache.RegionEntryContext;
#if defined(DISK) || defined(LRU)
import org.apache.geode.internal.cache.eviction.EvictionController;
import org.apache.geode.internal.cache.persistence.DiskRecoveryStore;
#endif
#ifdef DISK
import org.apache.geode.internal.cache.DiskId;
import org.apache.geode.internal.cache.DiskStoreImpl;
import org.apache.geode.internal.cache.PlaceHolderDiskRegion;
import org.apache.geode.internal.cache.RegionEntry;
#endif
#ifdef STATS
import org.apache.geode.internal.InternalStatisticsDisabledException;
#endif
#ifdef LRU
import org.apache.geode.internal.cache.InternalRegion;
import org.apache.geode.internal.cache.eviction.EvictionNode;
#endif
#ifdef VERSIONED
import org.apache.geode.distributed.internal.membership.InternalDistributedMember;
import org.apache.geode.internal.cache.versions.VersionSource;
import org.apache.geode.internal.cache.versions.VersionStamp;
import org.apache.geode.internal.cache.versions.VersionTag;
#endif
#ifdef OFFHEAP
import org.apache.geode.internal.cache.Token;
import org.apache.geode.internal.offheap.OffHeapRegionEntryHelper;
import org.apache.geode.internal.offheap.annotations.Released;
import org.apache.geode.internal.offheap.annotations.Retained;
import org.apache.geode.internal.offheap.annotations.Unretained;
#endif
import org.apache.geode.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
* ./dev-tools/generateRegionEntryClasses.sh (it must be run from the top level directory).
*/
public class LEAF_CLASS extends PARENT_CLASS {
// --------------------------------------- common fields ----------------------------------------
private static final AtomicLongFieldUpdater<LEAF_CLASS> LAST_MODIFIED_UPDATER
= AtomicLongFieldUpdater.newUpdater(LEAF_CLASS.class, "lastModified");
protected int hash;
private HashEntry<Object, Object> nextEntry;
@SuppressWarnings("unused")
private volatile long lastModified;
#ifdef OFFHEAP
#else
private volatile Object value;
#endif
#ifdef OFFHEAP
// --------------------------------------- offheap fields ---------------------------------------
/**
* All access done using OFF_HEAP_ADDRESS_UPDATER so it is used even though the compiler can not
* tell it is.
*/
@SuppressWarnings("unused")
@Retained @Released private volatile long offHeapAddress;
/**
* 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
* RegionEntry 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 static final AtomicLongFieldUpdater<LEAF_CLASS> OFF_HEAP_ADDRESS_UPDATER =
AtomicLongFieldUpdater.newUpdater(LEAF_CLASS.class, "offHeapAddress");
#endif
#ifdef DISK
// ---------------------------------------- disk fields -----------------------------------------
/**
* @since GemFire 5.1
*/
protected DiskId id;
#endif
#ifdef STATS
// --------------------------------------- stats fields -----------------------------------------
private volatile long lastAccessed;
private volatile int hitCount;
private volatile int missCount;
private static final AtomicIntegerFieldUpdater<LEAF_CLASS> HIT_COUNT_UPDATER
= AtomicIntegerFieldUpdater.newUpdater(LEAF_CLASS.class, "hitCount");
private static final AtomicIntegerFieldUpdater<LEAF_CLASS> MISS_COUNT_UPDATER
= AtomicIntegerFieldUpdater.newUpdater(LEAF_CLASS.class, "missCount");
#endif
#ifdef VERSIONED
// ------------------------------------- versioned fields ---------------------------------------
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
private VersionSource memberId;
private short entryVersionLowBytes;
private short regionVersionHighBytes;
private int regionVersionLowBytes;
private byte entryVersionHighByte;
private byte distributedSystemId;
#endif
// --------------------------------------- key fields -------------------------------------------
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
#ifdef KEY_OBJECT
private final Object key;
#elif defined(KEY_INT)
private final int key;
#elif defined(KEY_LONG)
private final long key;
#elif defined(KEY_LONG)
private final long key;
#elif defined(KEY_UUID)
private final long keyMostSigBits;
private final long keyLeastSigBits;
#elif defined(KEY_STRING1)
private final long bits1;
#elif defined(KEY_STRING2)
/**
* strlen is encoded in lowest 6 bits (max strlen is 63)<br>
* character encoding info is in bits 7 and 8<br>
* The other bits are used to encoded character data.
*/
private final long bits1;
/**
* bits2 encodes character data
*/
private final long bits2;
#endif
public LEAF_CLASS (final RegionEntryContext context, final KEY_TYPE key,
#ifdef OFFHEAP
@Retained
#endif
final Object value
#if defined(KEY_STRING1) || defined(KEY_STRING2)
, final boolean byteEncode
#endif
) {
super(context,
#ifdef DISK
(value instanceof RecoveredEntry ? null : value)
#else
value
#endif
);
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
#ifdef DISK
initialize(context, value);
#endif
#if defined(KEY_OBJECT)
this.key = key;
#elif defined(KEY_INT)
this.key = key;
#elif defined(KEY_LONG)
this.key = key;
#elif defined(KEY_UUID)
this.keyMostSigBits = key.getMostSignificantBits();
this.keyLeastSigBits = key.getLeastSignificantBits();
#elif defined(KEY_STRING1)
// caller has already confirmed that key.length <= MAX_INLINE_STRING_KEY
long tempBits1 = 0L;
if (byteEncode) {
for (int i = key.length() - 1; i >= 0; i--) {
// Note: we know each byte is <= 0x7f so the "& 0xff" is not needed. But I added it in to
// keep findbugs happy.
tempBits1 |= (byte) key.charAt(i) & 0xff;
tempBits1 <<= 8;
}
tempBits1 |= 1<<6;
} else {
for (int i = key.length() - 1; i >= 0; i--) {
tempBits1 |= key.charAt(i);
tempBits1 <<= 16;
}
}
tempBits1 |= key.length();
this.bits1 = tempBits1;
#elif defined(KEY_STRING2)
// caller has already confirmed that key.length <= MAX_INLINE_STRING_KEY
long tempBits1 = 0L;
long tempBits2 = 0L;
if (byteEncode) {
for (int i = key.length() - 1; i >= 0; i--) {
// Note: we know each byte is <= 0x7f so the "& 0xff" is not needed. But I added it in to
// keep findbugs happy.
if (i < 7) {
tempBits1 |= (byte)key.charAt(i) & 0xff;
tempBits1 <<= 8;
} else {
tempBits2 <<= 8;
tempBits2 |= (byte)key.charAt(i) & 0xff;
}
}
tempBits1 |= 1<<6;
} else {
for (int i = key.length() - 1; i >= 0; i--) {
if (i < 3) {
tempBits1 |= key.charAt(i);
tempBits1 <<= 16;
} else {
tempBits2 <<= 16;
tempBits2 |= key.charAt(i);
}
}
}
tempBits1 |= key.length();
this.bits1 = tempBits1;
this.bits2 = tempBits2;
#endif
}
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
#ifdef OFFHEAP
@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
#ifdef OFFHEAP
@Unretained
protected void setValueField(@Unretained final Object value) {
#else
protected void setValueField(final Object value) {
#endif
OffHeapRegionEntryHelper.setValue(this, value);
}
@Override
#ifdef OFFHEAP
@Retained
#endif
public Object getValueRetain(final RegionEntryContext context, final boolean decompress) {
return OffHeapRegionEntryHelper._getValueRetain(this, decompress, context);
}
@Override
public long getAddress() {
return OFF_HEAP_ADDRESS_UPDATER.get(this);
}
@Override
public boolean setAddress(final long expectedAddress, long newAddress) {
return OFF_HEAP_ADDRESS_UPDATER.compareAndSet(this, expectedAddress, newAddress);
}
@Override
#ifdef OFFHEAP
@Released
#endif
public void release() {
OffHeapRegionEntryHelper.releaseEntry(this);
}
@Override
public void returnToPool() {
// never implemented
}
#else
@Override
protected Object getValueField() {
return this.value;
}
@Override
protected void setValueField(final Object value) {
this.value = value;
}
#endif
@Override
protected long getLastModifiedField() {
return LAST_MODIFIED_UPDATER.get(this);
}
@Override
protected boolean compareAndSetLastModifiedField(final long expectedValue, final long newValue) {
return LAST_MODIFIED_UPDATER.compareAndSet(this, expectedValue, newValue);
}
@Override
public int getEntryHash() {
return this.hash;
}
@Override
protected void setEntryHash(final int hash) {
this.hash = hash;
}
@Override
public HashEntry<Object, Object> getNextEntry() {
return this.nextEntry;
}
@Override
public void setNextEntry(final HashEntry<Object, Object> nextEntry) {
this.nextEntry = nextEntry;
}
#ifdef DISK
// ----------------------------------------- disk code ------------------------------------------
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
#ifdef LRU
protected void initialize(final RegionEntryContext context, final Object value) {
boolean isBackup;
if (context instanceof InternalRegion) {
isBackup = ((InternalRegion) context).getDiskRegion().isBackup();
} else if (context instanceof PlaceHolderDiskRegion) {
isBackup = true;
} else {
throw new IllegalArgumentException("expected a InternalRegion or PlaceHolderDiskRegion");
}
// Delay the initialization of DiskID if overflow only
if (isBackup) {
diskInitialize(context, value);
}
}
@Override
public synchronized int updateAsyncEntrySize(final EvictionController evictionController) {
int oldSize = getEntrySize();
int newSize = evictionController.entrySize(getKeyForSizing(), null);
setEntrySize(newSize);
int delta = newSize - oldSize;
return delta;
}
#else
protected void initialize(final RegionEntryContext context, final Object value) {
diskInitialize(context, value);
}
@Override
public int updateAsyncEntrySize(final EvictionController evictionController) {
throw new IllegalStateException("should never be called");
}
#endif
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public DiskId getDiskId() {
return this.id;
}
@Override
public void setDiskId(final RegionEntry oldEntry) {
this.id = ((DiskEntry) oldEntry).getDiskId();
}
private void diskInitialize(final RegionEntryContext context, final Object value) {
DiskRecoveryStore diskRecoveryStore = (DiskRecoveryStore) context;
DiskStoreImpl diskStore = diskRecoveryStore.getDiskStore();
long maxOplogSize = diskStore.getMaxOplogSize();
// get appropriate instance of DiskId implementation based on maxOplogSize
this.id = DiskId.createDiskId(maxOplogSize, true, diskStore.needsLinkedList());
Helper.initialize(this, diskRecoveryStore, value);
}
#endif
#ifdef LRU
// --------------------------------------- eviction code ----------------------------------------
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public void setDelayedDiskId(final DiskRecoveryStore diskRecoveryStore) {
#ifdef DISK
DiskStoreImpl diskStore = diskRecoveryStore.getDiskStore();
long maxOplogSize = diskStore.getMaxOplogSize();
this.id = DiskId.createDiskId(maxOplogSize, false, diskStore.needsLinkedList());
#else
// nothing needed for LRUs with no disk
#endif
}
@Override
public synchronized int updateEntrySize(final EvictionController evictionController) {
// OFFHEAP: getValue ok w/o incing refcount because we are synced and only getting the size
return updateEntrySize(evictionController, getValue());
}
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public synchronized int updateEntrySize(final EvictionController evictionController, final Object value) {
int oldSize = getEntrySize();
int newSize = evictionController.entrySize(getKeyForSizing(), value);
setEntrySize(newSize);
int delta = newSize - oldSize;
return delta;
}
@Override
public boolean isRecentlyUsed() {
return areAnyBitsSet(RECENTLY_USED);
}
@Override
public void setRecentlyUsed(RegionEntryContext context) {
if (!isRecentlyUsed()) {
setBits(RECENTLY_USED);
context.incRecentlyUsed();
}
}
@Override
public void unsetRecentlyUsed() {
clearBits(~RECENTLY_USED);
}
@Override
public boolean isEvicted() {
return areAnyBitsSet(EVICTED);
}
@Override
public void setEvicted() {
setBits(EVICTED);
}
@Override
public void unsetEvicted() {
clearBits(~EVICTED);
}
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
private EvictionNode nextEvictionNode;
private EvictionNode previousEvictionNode;
private int size;
@Override
public void setNext(final EvictionNode nextEvictionNode) {
this.nextEvictionNode = nextEvictionNode;
}
@Override
public EvictionNode next() {
return this.nextEvictionNode;
}
@Override
public void setPrevious(final EvictionNode previousEvictionNode) {
this.previousEvictionNode = previousEvictionNode;
}
@Override
public EvictionNode previous() {
return this.previousEvictionNode;
}
@Override
public int getEntrySize() {
return this.size;
}
protected void setEntrySize(final int size) {
this.size = size;
}
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public Object getKeyForSizing() {
#ifdef KEY_OBJECT
// default implementation.
return getKey();
#else
// inline keys always report null for sizing since the size comes from the entry size
return null;
#endif
}
#endif
#ifdef STATS
// ---------------------------------------- stats code ------------------------------------------
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public void updateStatsForGet(final boolean isHit, final long time) {
setLastAccessed(time);
if (isHit) {
incrementHitCount();
} else {
incrementMissCount();
}
}
@Override
protected void setLastModifiedAndAccessedTimes(final long lastModified, final long lastAccessed) {
_setLastModified(lastModified);
if (!DISABLE_ACCESS_TIME_UPDATE_ON_PUT) {
setLastAccessed(lastAccessed);
}
}
@Override
public long getLastAccessed() throws InternalStatisticsDisabledException {
return this.lastAccessed;
}
@Override
public void setLastAccessed(final long lastAccessed) {
this.lastAccessed = lastAccessed;
}
@Override
public long getHitCount() throws InternalStatisticsDisabledException {
return this.hitCount & 0xFFFFFFFFL;
}
@Override
public long getMissCount() throws InternalStatisticsDisabledException {
return this.missCount & 0xFFFFFFFFL;
}
private void incrementHitCount() {
HIT_COUNT_UPDATER.incrementAndGet(this);
}
private void incrementMissCount() {
MISS_COUNT_UPDATER.incrementAndGet(this);
}
@Override
public void resetCounts() throws InternalStatisticsDisabledException {
HIT_COUNT_UPDATER.set(this,0);
MISS_COUNT_UPDATER.set(this,0);
}
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public void txDidDestroy(long timeStamp) {
setLastModified(timeStamp);
setLastAccessed(timeStamp);
this.hitCount = 0;
this.missCount = 0;
}
@Override
public boolean hasStats() {
return true;
}
#endif
#ifdef VERSIONED
// -------------------------------------- versioned code ----------------------------------------
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public int getEntryVersion() {
return ((entryVersionHighByte << 16) & 0xFF0000) | (entryVersionLowBytes & 0xFFFF);
}
@Override
public long getRegionVersion() {
return (((long)regionVersionHighBytes) << 32) | (regionVersionLowBytes & 0x00000000FFFFFFFFL);
}
@Override
public long getVersionTimeStamp() {
return getLastModified();
}
@Override
public void setVersionTimeStamp(final long timeStamp) {
setLastModified(timeStamp);
}
@Override
public VersionSource getMemberID() {
return this.memberId;
}
@Override
public int getDistributedSystemId() {
return this.distributedSystemId;
}
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public void setVersions(final VersionTag versionTag) {
this.memberId = versionTag.getMemberID();
int eVersion = versionTag.getEntryVersion();
this.entryVersionLowBytes = (short) (eVersion & 0xffff);
this.entryVersionHighByte = (byte) ((eVersion & 0xff0000) >> 16);
this.regionVersionHighBytes = versionTag.getRegionVersionHighBytes();
this.regionVersionLowBytes = versionTag.getRegionVersionLowBytes();
if (!versionTag.isGatewayTag() && this.distributedSystemId == versionTag.getDistributedSystemId()) {
if (getVersionTimeStamp() <= versionTag.getVersionTimeStamp()) {
setVersionTimeStamp(versionTag.getVersionTimeStamp());
} else {
versionTag.setVersionTimeStamp(getVersionTimeStamp());
}
} else {
setVersionTimeStamp(versionTag.getVersionTimeStamp());
}
this.distributedSystemId = (byte) (versionTag.getDistributedSystemId() & 0xff);
}
@Override
public void setMemberID(final VersionSource memberId) {
this.memberId = memberId;
}
@Override
public VersionStamp getVersionStamp() {
return this;
}
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public VersionTag asVersionTag() {
VersionTag tag = VersionTag.create(memberId);
tag.setEntryVersion(getEntryVersion());
tag.setRegionVersion(this.regionVersionHighBytes, this.regionVersionLowBytes);
tag.setVersionTimeStamp(getVersionTimeStamp());
tag.setDistributedSystemId(this.distributedSystemId);
return tag;
}
@Override
public void processVersionTag(final InternalRegion region, final VersionTag versionTag,
final boolean isTombstoneFromGII, final boolean hasDelta, final VersionSource versionSource,
final InternalDistributedMember sender, final boolean checkForConflicts) {
basicProcessVersionTag(region, versionTag, isTombstoneFromGII, hasDelta, versionSource, sender, checkForConflicts);
}
@Override
public void processVersionTag(final EntryEvent cacheEvent) {
// this keeps IDE happy. without it the sender chain becomes confused while browsing this code
super.processVersionTag(cacheEvent);
}
/** get rvv internal high byte. Used by region entries for transferring to storage */
@Override
public short getRegionVersionHighBytes() {
return this.regionVersionHighBytes;
}
/** get rvv internal low bytes. Used by region entries for transferring to storage */
@Override
public int getRegionVersionLowBytes() {
return this.regionVersionLowBytes;
}
#endif
// ----------------------------------------- key code -------------------------------------------
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
#ifdef KEY_OBJECT
@Override
public Object getKey() {
return this.key;
}
#elif defined(KEY_INT)
@Override
public Object getKey() {
return this.key;
}
@Override
public boolean isKeyEqual(final Object key) {
if (key instanceof Integer) {
return ((Integer) key).intValue() == this.key;
}
return false;
}
#elif defined(KEY_LONG)
@Override
public Object getKey() {
return this.key;
}
@Override
public boolean isKeyEqual(final Object key) {
if (key instanceof Long) {
return ((Long) key).longValue() == this.key;
}
return false;
}
#elif defined(KEY_UUID)
@Override
public Object getKey() {
return new UUID(this.keyMostSigBits, this.keyLeastSigBits);
}
@Override
public boolean isKeyEqual(final Object key) {
if (key instanceof UUID) {
UUID uuid = (UUID) key;
return uuid.getLeastSignificantBits() == this.keyLeastSigBits
&& uuid.getMostSignificantBits() == this.keyMostSigBits;
}
return false;
}
#elif defined(KEY_STRING1)
private int getKeyLength() {
return (int) (this.bits1 & 0x003fL);
}
private int getEncoding() {
// 0 means encoded as char
// 1 means encoded as bytes that are all <= 0x7f;
return (int) (this.bits1 >> 6) & 0x03;
}
@Override
public Object getKey() {
int keyLength = getKeyLength();
char[] chars = new char[keyLength];
long tempBits1 = this.bits1;
if (getEncoding() == 1) {
for (int i=0; i < keyLength; i++) {
tempBits1 >>= 8;
chars[i] = (char) (tempBits1 & 0x00ff);
}
} else {
for (int i=0; i < keyLength; i++) {
tempBits1 >>= 16;
chars[i] = (char) (tempBits1 & 0x00FFff);
}
}
return new String(chars);
}
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public boolean isKeyEqual(final Object key) {
if (key instanceof String) {
String stringKey = (String) key;
int keyLength = getKeyLength();
if (stringKey.length() == keyLength) {
long tempBits1 = this.bits1;
if (getEncoding() == 1) {
for (int i = 0; i < keyLength; i++) {
tempBits1 >>= 8;
char character = (char) (tempBits1 & 0x00ff);
if (stringKey.charAt(i) != character) {
return false;
}
}
} else {
for (int i = 0; i < keyLength; i++) {
tempBits1 >>= 16;
char character = (char) (tempBits1 & 0x00FFff);
if (stringKey.charAt(i) != character) {
return false;
}
}
}
return true;
}
}
return false;
}
#elif defined(KEY_STRING2)
private int getKeyLength() {
return (int) (this.bits1 & 0x003fL);
}
private int getEncoding() {
// 0 means encoded as char
// 1 means encoded as bytes that are all <= 0x7f;
return (int) (this.bits1 >> 6) & 0x03;
}
@Override
public Object getKey() {
int keyLength = getKeyLength();
char[] chars = new char[keyLength];
long tempBits1 = this.bits1;
long tempBits2 = this.bits2;
if (getEncoding() == 1) {
for (int i = 0; i < keyLength; i++) {
if (i < 7) {
tempBits1 >>= 8;
chars[i] = (char) (tempBits1 & 0x00ff);
} else {
chars[i] = (char) (tempBits2 & 0x00ff);
tempBits2 >>= 8;
}
}
} else {
for (int i = 0; i < keyLength; i++) {
if (i < 3) {
tempBits1 >>= 16;
chars[i] = (char) (tempBits1 & 0x00FFff);
} else {
chars[i] = (char) (tempBits2 & 0x00FFff);
tempBits2 >>= 16;
}
}
}
return new String(chars);
}
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
@Override
public boolean isKeyEqual(final Object key) {
if (key instanceof String) {
String stringKey = (String)key;
int keyLength = getKeyLength();
if (stringKey.length() == keyLength) {
long tempBits1 = this.bits1;
long tempBits2 = this.bits2;
if (getEncoding() == 1) {
for (int i = 0; i < keyLength; i++) {
char character;
if (i < 7) {
tempBits1 >>= 8;
character = (char) (tempBits1 & 0x00ff);
} else {
character = (char) (tempBits2 & 0x00ff);
tempBits2 >>= 8;
}
if (stringKey.charAt(i) != character) {
return false;
}
}
} else {
for (int i = 0; i < keyLength; i++) {
char character;
if (i < 3) {
tempBits1 >>= 16;
character = (char) (tempBits1 & 0x00FFff);
} else {
character = (char) (tempBits2 & 0x00FFff);
tempBits2 >>= 16;
}
if (stringKey.charAt(i) != character) {
return false;
}
}
}
return true;
}
}
return false;
}
#endif
// DO NOT modify this class. It was generated from LeafRegionEntry.cpp
}