http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateStub.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateStub.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateStub.java index 0b226e0..197111a 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateStub.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateStub.java @@ -17,7 +17,7 @@ /** * File comment */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Collection; import java.util.HashMap; @@ -26,24 +26,24 @@ import java.util.Map; import java.util.Set; import java.util.concurrent.locks.ReentrantLock; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Region.Entry; -import com.gemstone.gemfire.cache.SynchronizationCommitConflictException; -import com.gemstone.gemfire.cache.TransactionDataNodeHasDepartedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.TransactionException; -import com.gemstone.gemfire.cache.TransactionId; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.ReliableReplyException; -import com.gemstone.gemfire.distributed.internal.ReliableReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.tx.TXRegionStub; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Region.Entry; +import org.apache.geode.cache.SynchronizationCommitConflictException; +import org.apache.geode.cache.TransactionDataNodeHasDepartedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.TransactionException; +import org.apache.geode.cache.TransactionId; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.ReliableReplyException; +import org.apache.geode.distributed.internal.ReliableReplyProcessor21; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.tx.TXRegionStub; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * TXStateStub lives on the accessor node when we are remoting @@ -146,7 +146,7 @@ public abstract class TXStateStub implements TXStateInterface { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#destroyExistingEntry(com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, java.lang.Object) + * @see org.apache.geode.internal.cache.TXStateInterface#destroyExistingEntry(org.apache.geode.internal.cache.EntryEventImpl, boolean, java.lang.Object) */ public void destroyExistingEntry(EntryEventImpl event, boolean cacheWrite, Object expectedOldValue) throws EntryNotFoundException { @@ -159,7 +159,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getBeginTime() + * @see org.apache.geode.internal.cache.TXStateInterface#getBeginTime() */ public long getBeginTime() { // TODO Auto-generated method stub @@ -167,14 +167,14 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getCache() + * @see org.apache.geode.internal.cache.TXStateInterface#getCache() */ public Cache getCache() { return this.proxy.getTxMgr().getCache(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getChanges() + * @see org.apache.geode.internal.cache.TXStateInterface#getChanges() */ public int getChanges() { // TODO Auto-generated method stub @@ -182,7 +182,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getDeserializedValue(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion, boolean) + * @see org.apache.geode.internal.cache.TXStateInterface#getDeserializedValue(java.lang.Object, org.apache.geode.internal.cache.LocalRegion, boolean) */ public Object getDeserializedValue(KeyInfo keyInfo, LocalRegion localRegion, @@ -203,7 +203,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getEntry(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.TXStateInterface#getEntry(java.lang.Object, org.apache.geode.internal.cache.LocalRegion) */ public Entry getEntry(KeyInfo keyInfo, LocalRegion r, boolean allowTombstones) { return getTXRegionStub(r).getEntry(keyInfo, allowTombstones); @@ -216,35 +216,35 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getEvent() + * @see org.apache.geode.internal.cache.TXStateInterface#getEvent() */ public TXEvent getEvent() { throw new UnsupportedOperationException(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getEvents() + * @see org.apache.geode.internal.cache.TXStateInterface#getEvents() */ public List getEvents() { throw new UnsupportedOperationException(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getRegions() + * @see org.apache.geode.internal.cache.TXStateInterface#getRegions() */ public Collection<LocalRegion> getRegions() { throw new UnsupportedOperationException(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getTransactionId() + * @see org.apache.geode.internal.cache.TXStateInterface#getTransactionId() */ public TransactionId getTransactionId() { return this.proxy.getTxId(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#invalidateExistingEntry(com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean) + * @see org.apache.geode.internal.cache.TXStateInterface#invalidateExistingEntry(org.apache.geode.internal.cache.EntryEventImpl, boolean, boolean) */ public void invalidateExistingEntry(EntryEventImpl event, boolean invokeCallbacks, boolean forceNewEntry) { @@ -257,21 +257,21 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#isInProgress() + * @see org.apache.geode.internal.cache.TXStateInterface#isInProgress() */ public boolean isInProgress() { return this.proxy.isInProgress(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#isInProgressAndSameAs(com.gemstone.gemfire.internal.cache.TXStateInterface) + * @see org.apache.geode.internal.cache.TXStateInterface#isInProgressAndSameAs(org.apache.geode.internal.cache.TXStateInterface) */ public boolean isInProgressAndSameAs(TXStateInterface state) { throw new UnsupportedOperationException(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#needsLargeModCount() + * @see org.apache.geode.internal.cache.TXStateInterface#needsLargeModCount() */ public boolean needsLargeModCount() { // TODO Auto-generated method stub @@ -279,7 +279,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#nextModSerialNum() + * @see org.apache.geode.internal.cache.TXStateInterface#nextModSerialNum() */ public int nextModSerialNum() { // TODO Auto-generated method stub @@ -287,14 +287,14 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#readRegion(com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.TXStateInterface#readRegion(org.apache.geode.internal.cache.LocalRegion) */ public TXRegionState readRegion(LocalRegion r) { throw new UnsupportedOperationException(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#rmRegion(com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.TXStateInterface#rmRegion(org.apache.geode.internal.cache.LocalRegion) */ public void rmRegion(LocalRegion r) { throw new UnsupportedOperationException(); @@ -315,7 +315,7 @@ public abstract class TXStateStub implements TXStateInterface { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#txPutEntry(com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean, boolean) + * @see org.apache.geode.internal.cache.TXStateInterface#txPutEntry(org.apache.geode.internal.cache.EntryEventImpl, boolean, boolean, boolean) */ public boolean txPutEntry(EntryEventImpl event, boolean ifNew, boolean requireOldValue, boolean checkResources, Object expectedOldValue) { @@ -323,7 +323,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#txReadEntry(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion, boolean) + * @see org.apache.geode.internal.cache.TXStateInterface#txReadEntry(java.lang.Object, org.apache.geode.internal.cache.LocalRegion, boolean) */ public TXEntryState txReadEntry(KeyInfo entryKey, LocalRegion localRegion, boolean rememberRead,boolean createTxEntryIfAbsent) { @@ -332,7 +332,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#txReadRegion(com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.TXStateInterface#txReadRegion(org.apache.geode.internal.cache.LocalRegion) */ public TXRegionState txReadRegion(LocalRegion localRegion) { // TODO Auto-generated method stub @@ -340,7 +340,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#txWriteRegion(com.gemstone.gemfire.internal.cache.LocalRegion, java.lang.Object) + * @see org.apache.geode.internal.cache.TXStateInterface#txWriteRegion(org.apache.geode.internal.cache.LocalRegion, java.lang.Object) */ public TXRegionState txWriteRegion(LocalRegion localRegion, KeyInfo entryKey) { // TODO Auto-generated method stub @@ -348,7 +348,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#writeRegion(com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.TXStateInterface#writeRegion(org.apache.geode.internal.cache.LocalRegion) */ public TXRegionState writeRegion(LocalRegion r) { // TODO Auto-generated method stub @@ -356,28 +356,28 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#containsKey(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#containsKey(java.lang.Object, org.apache.geode.internal.cache.LocalRegion) */ public boolean containsKey(KeyInfo keyInfo, LocalRegion localRegion) { return getTXRegionStub(localRegion).containsKey(keyInfo); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#containsValueForKey(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#containsValueForKey(java.lang.Object, org.apache.geode.internal.cache.LocalRegion) */ public boolean containsValueForKey(KeyInfo keyInfo, LocalRegion localRegion) { return getTXRegionStub(localRegion).containsValueForKey( keyInfo); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#entryCount(com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#entryCount(org.apache.geode.internal.cache.LocalRegion) */ public int entryCount(LocalRegion localRegion) { return getTXRegionStub(localRegion).entryCount(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#findObject(com.gemstone.gemfire.internal.cache.LocalRegion, java.lang.Object, java.lang.Object, boolean, boolean, java.lang.Object) + * @see org.apache.geode.internal.cache.InternalDataView#findObject(org.apache.geode.internal.cache.LocalRegion, java.lang.Object, java.lang.Object, boolean, boolean, java.lang.Object) */ public Object findObject(KeyInfo keyInfo, LocalRegion r, @@ -393,7 +393,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getAdditionalKeysForIterator(com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#getAdditionalKeysForIterator(org.apache.geode.internal.cache.LocalRegion) */ public Set getAdditionalKeysForIterator(LocalRegion currRgn) { // TODO Auto-generated method stub @@ -401,7 +401,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getEntryForIterator(com.gemstone.gemfire.internal.cache.LocalRegion, java.lang.Object, boolean) + * @see org.apache.geode.internal.cache.InternalDataView#getEntryForIterator(org.apache.geode.internal.cache.LocalRegion, java.lang.Object, boolean) */ public Object getEntryForIterator(KeyInfo keyInfo, LocalRegion currRgn, boolean rememberReads, boolean allowTombstones) { @@ -409,7 +409,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getKeyForIterator(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion, boolean) + * @see org.apache.geode.internal.cache.InternalDataView#getKeyForIterator(java.lang.Object, org.apache.geode.internal.cache.LocalRegion, boolean) */ public Object getKeyForIterator(KeyInfo keyInfo, LocalRegion currRgn, boolean rememberReads, boolean allowTombstones) { @@ -417,7 +417,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getValueInVM(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion, boolean) + * @see org.apache.geode.internal.cache.InternalDataView#getValueInVM(java.lang.Object, org.apache.geode.internal.cache.LocalRegion, boolean) */ public Object getValueInVM(KeyInfo keyInfo, LocalRegion localRegion, boolean rememberRead) { @@ -426,14 +426,14 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#isDeferredStats() + * @see org.apache.geode.internal.cache.InternalDataView#isDeferredStats() */ public boolean isDeferredStats() { return true; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#putEntry(com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean, java.lang.Object, boolean, long, boolean) + * @see org.apache.geode.internal.cache.InternalDataView#putEntry(org.apache.geode.internal.cache.EntryEventImpl, boolean, boolean, java.lang.Object, boolean, long, boolean) */ public boolean putEntry(EntryEventImpl event, boolean ifNew, boolean ifOld, Object expectedOldValue, boolean requireOldValue, long lastModified, @@ -443,7 +443,7 @@ public abstract class TXStateStub implements TXStateInterface { /* * (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getSerializedValue(com.gemstone.gemfire.internal.cache.LocalRegion, java.lang.Object, java.lang.Object) + * @see org.apache.geode.internal.cache.InternalDataView#getSerializedValue(org.apache.geode.internal.cache.LocalRegion, java.lang.Object, java.lang.Object) */ public Object getSerializedValue(LocalRegion localRegion, KeyInfo key, @@ -455,7 +455,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#putEntryOnRemote(com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean, java.lang.Object, boolean, long, boolean) + * @see org.apache.geode.internal.cache.InternalDataView#putEntryOnRemote(org.apache.geode.internal.cache.EntryEventImpl, boolean, boolean, java.lang.Object, boolean, long, boolean) */ public boolean putEntryOnRemote(EntryEventImpl event, boolean ifNew, boolean ifOld, Object expectedOldValue, boolean requireOldValue, @@ -469,7 +469,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#destroyOnRemote(java.lang.Integer, com.gemstone.gemfire.internal.cache.EntryEventImpl, java.lang.Object) + * @see org.apache.geode.internal.cache.InternalDataView#destroyOnRemote(java.lang.Integer, org.apache.geode.internal.cache.EntryEventImpl, java.lang.Object) */ public void destroyOnRemote(EntryEventImpl event, boolean cacheWrite, Object expectedOldValue) throws DataLocationException { @@ -477,7 +477,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#invalidateOnRemote(com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean) + * @see org.apache.geode.internal.cache.InternalDataView#invalidateOnRemote(org.apache.geode.internal.cache.EntryEventImpl, boolean, boolean) */ public void invalidateOnRemote(EntryEventImpl event, boolean invokeCallbacks, boolean forceNewEntry) throws DataLocationException { @@ -501,7 +501,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getBucketKeys(com.gemstone.gemfire.internal.cache.LocalRegion, int) + * @see org.apache.geode.internal.cache.InternalDataView#getBucketKeys(org.apache.geode.internal.cache.LocalRegion, int) */ public Set getBucketKeys(LocalRegion localRegion, int bucketId, boolean allowTombstones) { PartitionedRegion pr = (PartitionedRegion)localRegion; @@ -512,7 +512,7 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getEntryOnRemote(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#getEntryOnRemote(java.lang.Object, org.apache.geode.internal.cache.LocalRegion) */ public Entry getEntryOnRemote(KeyInfo key, LocalRegion localRegion, boolean allowTombstones) throws DataLocationException { @@ -520,14 +520,14 @@ public abstract class TXStateStub implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getSemaphore() + * @see org.apache.geode.internal.cache.TXStateInterface#getSemaphore() */ public ReentrantLock getLock() { return proxy.getLock(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getRegionKeysForIteration(com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#getRegionKeysForIteration(org.apache.geode.internal.cache.LocalRegion) */ public Set getRegionKeysForIteration(LocalRegion currRegion) { return getTXRegionStub(currRegion).getRegionKeysForIteration(currRegion);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXSynchronizationRunnable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXSynchronizationRunnable.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXSynchronizationRunnable.java index c353be9..5f80d5e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXSynchronizationRunnable.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXSynchronizationRunnable.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.logging.LogService; /** * TXSynchronizationThread manages beforeCompletion and afterCompletion http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TestHeapThresholdObserver.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TestHeapThresholdObserver.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TestHeapThresholdObserver.java index f8a867d..f942536 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TestHeapThresholdObserver.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TestHeapThresholdObserver.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * Test only hand back object passed to http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TimestampedEntryEventImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TimestampedEntryEventImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TimestampedEntryEventImpl.java index ce5cfab..b1138da 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TimestampedEntryEventImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TimestampedEntryEventImpl.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.util.TimestampedEntryEvent; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; +import org.apache.geode.cache.util.TimestampedEntryEvent; +import org.apache.geode.internal.offheap.annotations.Retained; /** * A subclass of EntryEventImpl used in WAN conflict resolution @@ -40,7 +40,7 @@ public class TimestampedEntryEventImpl extends EntryEventImpl implements this.oldTimestamp = oldTimestamp; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.util.TimestampedEntryEvent#getNewDistributedSystemID() + * @see org.apache.geode.internal.cache.util.TimestampedEntryEvent#getNewDistributedSystemID() */ @Override public int getNewDistributedSystemID() { @@ -48,7 +48,7 @@ public class TimestampedEntryEventImpl extends EntryEventImpl implements } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.util.TimestampedEntryEvent#getOldDistributedSystemID() + * @see org.apache.geode.internal.cache.util.TimestampedEntryEvent#getOldDistributedSystemID() */ @Override public int getOldDistributedSystemID() { @@ -56,7 +56,7 @@ public class TimestampedEntryEventImpl extends EntryEventImpl implements } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.util.TimestampedEntryEvent#getNewTimestamp() + * @see org.apache.geode.internal.cache.util.TimestampedEntryEvent#getNewTimestamp() */ @Override public long getNewTimestamp() { @@ -64,7 +64,7 @@ public class TimestampedEntryEventImpl extends EntryEventImpl implements } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.util.TimestampedEntryEvent#getOldTimestamp() + * @see org.apache.geode.internal.cache.util.TimestampedEntryEvent#getOldTimestamp() */ @Override public long getOldTimestamp() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/Token.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/Token.java b/geode-core/src/main/java/org/apache/geode/internal/cache/Token.java index 0f731e0..5be802d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/Token.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/Token.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.internal.DSCODE; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; +import org.apache.geode.internal.DSCODE; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; import java.io.DataInput; import java.io.DataOutput; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TombstoneService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TombstoneService.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TombstoneService.java index 2241b33..ede2e89 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TombstoneService.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TombstoneService.java @@ -14,24 +14,24 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.util.ObjectSizer; -import com.gemstone.gemfire.distributed.internal.CacheTime; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.cache.versions.CompactVersionHolder; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.LoggingThreadGroup; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.size.ReflectionSingleObjectSizer; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantLock; +package org.apache.geode.internal.cache; + +import org.apache.geode.CancelCriterion; +import org.apache.geode.CancelException; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.util.ObjectSizer; +import org.apache.geode.distributed.internal.CacheTime; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.cache.versions.CompactVersionHolder; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.LoggingThreadGroup; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.size.ReflectionSingleObjectSizer; +import org.apache.geode.internal.util.concurrent.StoppableReentrantLock; import org.apache.logging.log4j.Logger; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TransactionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TransactionMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TransactionMessage.java index 3c7c93a..b1ea33e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TransactionMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TransactionMessage.java @@ -17,10 +17,10 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; /** * Messages that carry transaction information will implement this interface http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TxEntryFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TxEntryFactory.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TxEntryFactory.java index db93886..f80236b 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TxEntryFactory.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TxEntryFactory.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/UnsharedImageState.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/UnsharedImageState.java b/geode-core/src/main/java/org/apache/geode/internal/cache/UnsharedImageState.java index 9920388..ca1fcc7 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/UnsharedImageState.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/UnsharedImageState.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Iterator; import java.util.Set; @@ -24,15 +24,15 @@ import java.util.concurrent.ConcurrentMap; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.concurrent.ConcurrentHashSet; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.util.concurrent.StoppableNonReentrantLock; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantReadWriteLock; +import org.apache.geode.CancelCriterion; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.concurrent.ConcurrentHashSet; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.util.concurrent.StoppableNonReentrantLock; +import org.apache.geode.internal.util.concurrent.StoppableReentrantReadWriteLock; /** * Used on distributed replicated regions to track GII and various state. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateAttributesProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateAttributesProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateAttributesProcessor.java index 9754ab9..bf543b6 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateAttributesProcessor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateAttributesProcessor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -27,25 +27,25 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisee; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.HighPriorityDistributionMessage; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.MessageWithReply; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.DSFIDFactory; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.SystemFailure; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionAdvisee; +import org.apache.geode.distributed.internal.DistributionAdvisor; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.HighPriorityDistributionMessage; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.MessageWithReply; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.DSFIDFactory; +import org.apache.geode.internal.logging.LogService; /** * This class is a bit misnamed. It really has more with pushing @@ -438,7 +438,7 @@ public class UpdateAttributesProcessor { } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.ReplyMessage#getInlineProcess() + * @see org.apache.geode.distributed.internal.ReplyMessage#getInlineProcess() * ProfileReplyMessages must be processed in-line and not in a pool to * keep partitioned region bucket profile exchange from swamping the * high priority pool and not allowing other profile exchanges through. @@ -530,7 +530,7 @@ public class UpdateAttributesProcessor { } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.ReplyMessage#getInlineProcess() + * @see org.apache.geode.distributed.internal.ReplyMessage#getInlineProcess() * ProfilesReplyMessages must be processed in-line and not in a pool to * keep partitioned region bucket profile exchange from swamping the * high priority pool and not allowing other profile exchanges through. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateEntryVersionOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateEntryVersionOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateEntryVersionOperation.java index 23fb300..984f245 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateEntryVersionOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateEntryVersionOperation.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -25,17 +25,17 @@ import java.util.List; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.distributed.internal.DirectReplyProcessor; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.internal.cache.versions.ConcurrentCacheModificationException; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.distributed.internal.DirectReplyProcessor; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.internal.cache.versions.ConcurrentCacheModificationException; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.annotations.Retained; /** * This operation updates Version stamp of an entry if entry is available and @@ -54,7 +54,7 @@ public class UpdateEntryVersionOperation extends DistributedCacheOperation { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.DistributedCacheOperation#createMessage() + * @see org.apache.geode.internal.cache.DistributedCacheOperation#createMessage() */ @Override protected CacheOperationMessage createMessage() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateOperation.java index e60cda3..90d9a1a 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/UpdateOperation.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -26,30 +26,30 @@ import java.util.List; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.InvalidDeltaException; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.distributed.internal.ConflationKey; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DirectReplyProcessor; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.cache.EntryEventImpl.NewValueImporter; -import com.gemstone.gemfire.internal.cache.EntryEventImpl.SerializedCacheValueImpl; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.MemoryAllocatorImpl; -import com.gemstone.gemfire.internal.offheap.StoredObject; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; -import com.gemstone.gemfire.internal.offheap.annotations.Unretained; -import com.gemstone.gemfire.internal.util.BlobHelper; -import com.gemstone.gemfire.internal.util.Breadcrumbs; -import static com.gemstone.gemfire.internal.offheap.annotations.OffHeapIdentifier.ENTRY_EVENT_NEW_VALUE; +import org.apache.geode.DataSerializer; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.InvalidDeltaException; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.distributed.internal.ConflationKey; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DirectReplyProcessor; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.cache.EntryEventImpl.NewValueImporter; +import org.apache.geode.internal.cache.EntryEventImpl.SerializedCacheValueImpl; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.MemoryAllocatorImpl; +import org.apache.geode.internal.offheap.StoredObject; +import org.apache.geode.internal.offheap.annotations.Retained; +import org.apache.geode.internal.offheap.annotations.Unretained; +import org.apache.geode.internal.util.BlobHelper; +import org.apache.geode.internal.util.Breadcrumbs; +import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.ENTRY_EVENT_NEW_VALUE; /** * Handles distribution messaging for updating an entry in a region. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/UserSpecifiedDiskStoreAttributes.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/UserSpecifiedDiskStoreAttributes.java b/geode-core/src/main/java/org/apache/geode/internal/cache/UserSpecifiedDiskStoreAttributes.java index ea403b0..559a97e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/UserSpecifiedDiskStoreAttributes.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/UserSpecifiedDiskStoreAttributes.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.lang.reflect.Field; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; -import com.gemstone.gemfire.internal.Assert; +import org.apache.geode.internal.Assert; /** * UserSpecifiedDiskStoreAttributes provides an way to detect departures from default attribute values. * It may be used when collecting attributes from an XML parser or from attribute changes made using the - * {@link com.gemstone.gemfire.cache.DiskStoreFactory}. Its initial usage was to validate + * {@link org.apache.geode.cache.DiskStoreFactory}. Its initial usage was to validate * when a user set a value which should not be set (for DiskStore). * * @since GemFire prPersistSprint2 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/UserSpecifiedRegionAttributes.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/UserSpecifiedRegionAttributes.java b/geode-core/src/main/java/org/apache/geode/internal/cache/UserSpecifiedRegionAttributes.java index 1a35812..0c0242b 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/UserSpecifiedRegionAttributes.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/UserSpecifiedRegionAttributes.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.lang.reflect.Field; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.util.List; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.internal.Assert; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.internal.Assert; /** * UserSpecifiedRegionAttributes provides an way to detect departures from default attribute values. * It may be used when collecting attributes from an XML parser or from attribute changes made using the - * {@link com.gemstone.gemfire.cache.AttributesFactory}. Its initial usage was to validate + * {@link org.apache.geode.cache.AttributesFactory}. Its initial usage was to validate * when a user set a value which should not be set (for PartitionedRegions). * * @since GemFire 5.1 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMCachedDeserializable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMCachedDeserializable.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMCachedDeserializable.java index 61ac6f3..c598eec 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMCachedDeserializable.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMCachedDeserializable.java @@ -15,21 +15,21 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.CopyHelper; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.lru.LRUEntry; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.lang.StringUtils; -import com.gemstone.gemfire.pdx.PdxInstance; +import org.apache.geode.CopyHelper; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.Region; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.lru.LRUEntry; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.lang.StringUtils; +import org.apache.geode.pdx.PdxInstance; /** * The first time someone asks this instance for its Object it will deserialize @@ -86,7 +86,7 @@ public final class VMCachedDeserializable implements CachedDeserializable, DataS public Object getDeserializedValue(Region r, RegionEntry re) { Object v = this.value; if (v instanceof byte[]) { -// com.gemstone.gemfire.internal.cache.GemFireCache.getInstance().getLogger().info("DEBUG getDeserializedValue r=" + r + " re=" + re, new RuntimeException("STACK")); +// org.apache.geode.internal.cache.GemFireCache.getInstance().getLogger().info("DEBUG getDeserializedValue r=" + r + " re=" + re, new RuntimeException("STACK")); LRUEntry le = null; if (re != null) { assert r != null; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMLRURegionMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMLRURegionMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMLRURegionMap.java index 8adcb06..5909eda 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMLRURegionMap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMLRURegionMap.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.internal.cache.lru.*; -//import com.gemstone.gemfire.internal.util.Sizeof; +import org.apache.geode.internal.cache.lru.*; +//import org.apache.geode.internal.util.Sizeof; /** * Internal implementation of {@link RegionMap} for regions stored http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMRegionMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMRegionMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMRegionMap.java index d5122c7..8996adf 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMRegionMap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMRegionMap.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * Internal implementation of {@link RegionMap} for regions stored http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntry.java index 817567b..1b27494 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntry.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * Implementation class of RegionEntry interface. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeap.java index cb8898d..776cb2b 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeap.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.UUID; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapIntKey.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapIntKey.java index cfd1e2b..5f1188e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapIntKey.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapIntKey.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapLongKey.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapLongKey.java index 12492ad..de85fcf 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapLongKey.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapLongKey.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapObjectKey.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapObjectKey.java index 5e2dc46..6009848 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapObjectKey.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapObjectKey.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey1.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey1.java index 99fe18a..4b23625 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey1.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey1.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey2.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey2.java index 2fa5d34..215d96b 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey2.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapStringKey2.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapUUIDKey.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapUUIDKey.java index b92166d..562ef9d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapUUIDKey.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryHeapUUIDKey.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.UUID; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeap.java index e00bcb8..0f32d0e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeap.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.UUID; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapIntKey.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapIntKey.java index d3809cf..f861a37 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapIntKey.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapIntKey.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -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; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +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; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapLongKey.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapLongKey.java index c100fbb..3e3bca9 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapLongKey.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapLongKey.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -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; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +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; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapObjectKey.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapObjectKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapObjectKey.java index ea2d9df..f83fae7 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapObjectKey.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapObjectKey.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -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; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +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; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey1.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey1.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey1.java index 84a5349..38d44a2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey1.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey1.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -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; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +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; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey2.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey2.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey2.java index 6ada0c4..039523c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey2.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapStringKey2.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -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; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +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; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapUUIDKey.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapUUIDKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapUUIDKey.java index 7013e68..333a459 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapUUIDKey.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskLRURegionEntryOffHeapUUIDKey.java @@ -14,21 +14,21 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.UUID; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -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; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +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; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntry.java index 6efa75a..4652d84 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntry.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * Implementation class of RegionEntry interface. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeap.java index 879ffb0..fb3d6f9 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeap.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.UUID; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapIntKey.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapIntKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapIntKey.java index 2a2cf72..e83284a 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapIntKey.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapIntKey.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapLongKey.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapLongKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapLongKey.java index dd883fa..23855de 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapLongKey.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/VMStatsDiskRegionEntryHeapLongKey.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; // DO NOT modify this class. It was generated from LeafRegionEntry.cpp import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; 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.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; // macros whose definition changes this class: // disk: DISK // lru: LRU
