http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXCommitMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXCommitMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXCommitMessage.java index c3ff698..4802fba 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXCommitMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXCommitMessage.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; @@ -33,49 +33,49 @@ 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.cache.Cache; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.CacheFactory; -import com.gemstone.gemfire.cache.CacheRuntimeException; -import com.gemstone.gemfire.cache.CommitDistributionException; -import com.gemstone.gemfire.cache.CommitIncompleteException; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.RegionDistributionException; -import com.gemstone.gemfire.cache.TransactionId; -import com.gemstone.gemfire.cache.TransactionListener; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.MembershipListener; -import com.gemstone.gemfire.distributed.internal.MessageWithReply; -import com.gemstone.gemfire.distributed.internal.PooledDistributionMessage; -import com.gemstone.gemfire.distributed.internal.ReliableReplyProcessor21; -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.HeapDataOutputStream; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.locks.TXLockId; -import com.gemstone.gemfire.internal.cache.locks.TXLockIdImpl; -import com.gemstone.gemfire.internal.cache.locks.TXLockService; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -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.offheap.annotations.Released; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheFactory; +import org.apache.geode.cache.CacheRuntimeException; +import org.apache.geode.cache.CommitDistributionException; +import org.apache.geode.cache.CommitIncompleteException; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.RegionDistributionException; +import org.apache.geode.cache.TransactionId; +import org.apache.geode.cache.TransactionListener; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.MembershipListener; +import org.apache.geode.distributed.internal.MessageWithReply; +import org.apache.geode.distributed.internal.PooledDistributionMessage; +import org.apache.geode.distributed.internal.ReliableReplyProcessor21; +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.HeapDataOutputStream; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.locks.TXLockId; +import org.apache.geode.internal.cache.locks.TXLockIdImpl; +import org.apache.geode.internal.cache.locks.TXLockService; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +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.offheap.annotations.Released; /** TXCommitMessage is the message that contains all the information * that needs to be distributed, on commit, to other cache members. @@ -2165,7 +2165,7 @@ public class TXCommitMessage extends PooledDistributionMessage implements Member * to bug 32999 and the recovery when the TXLock Lessor (the sending * VM) crashes/departs before or while sending the TXCommitMessage. * @see TXState#commit() - * @see com.gemstone.gemfire.internal.cache.locks.TXLockBatch#getBatchId() + * @see org.apache.geode.internal.cache.locks.TXLockBatch#getBatchId() */ private void updateLockMembers() { if (this.lockNeedsUpdate && this.lockId != null) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntry.java index 317f4e6..d6c8854 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntry.java @@ -14,18 +14,18 @@ * 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.Hashtable; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.cache.CacheStatistics; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.StatisticsDisabledException; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.offheap.annotations.Unretained; +import org.apache.geode.CancelException; +import org.apache.geode.cache.CacheStatistics; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.StatisticsDisabledException; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.offheap.annotations.Unretained; /** ******************* Class Entry ***************************************** */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryState.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryState.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryState.java index 9ae0ac3..b2af6ea 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryState.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryState.java @@ -15,26 +15,26 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.lang.StringUtils; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.OffHeapHelper; -import com.gemstone.gemfire.internal.offheap.Releasable; -import com.gemstone.gemfire.internal.offheap.StoredObject; -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.pdx.PdxSerializationException; +package org.apache.geode.internal.cache; + +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.*; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.lang.StringUtils; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.OffHeapHelper; +import org.apache.geode.internal.offheap.Releasable; +import org.apache.geode.internal.offheap.StoredObject; +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.pdx.PdxSerializationException; import org.apache.logging.log4j.Logger; import java.io.DataInput; @@ -44,7 +44,7 @@ import java.util.ArrayList; import java.util.List; import java.util.Set; -import static com.gemstone.gemfire.internal.offheap.annotations.OffHeapIdentifier.TX_ENTRY_STATE; +import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.TX_ENTRY_STATE; /** * TXEntryState is the entity that tracks transactional changes, except for http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryStateFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryStateFactory.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryStateFactory.java index 3cb5d37..c441af2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryStateFactory.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryStateFactory.java @@ -14,9 +14,9 @@ * 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.internal.cache.RegionEntry; +import org.apache.geode.internal.cache.RegionEntry; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryUserAttrState.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryUserAttrState.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryUserAttrState.java index d53fce0..aaaca24 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryUserAttrState.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEntryUserAttrState.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.cache.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.*; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * TXEntryUserAttrState is the entity that tracks transactional changes http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEvent.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEvent.java index b2bd140..e02bcf8 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXEvent.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXEvent.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; -import com.gemstone.gemfire.cache.*; +package org.apache.geode.internal.cache; +import org.apache.geode.cache.*; import java.util.*; -import com.gemstone.gemfire.internal.offheap.Releasable; +import org.apache.geode.internal.offheap.Releasable; /** <p>The internal implementation of the {@link TransactionEvent} interface * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXFarSideCMTracker.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXFarSideCMTracker.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXFarSideCMTracker.java index 90e337d..3959110 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXFarSideCMTracker.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXFarSideCMTracker.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Arrays; import java.util.Collections; import java.util.HashMap; @@ -27,14 +27,14 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.MembershipListener; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.locks.TXLockId; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.MembershipListener; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.locks.TXLockId; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * TXFarSideCMTracker tracks received and processed TXCommitMessages, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXId.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXId.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXId.java index c5e6822..eadff91 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXId.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXId.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; -import com.gemstone.gemfire.internal.ExternalizableDSFID; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.cache.TransactionId; -import com.gemstone.gemfire.internal.DSFIDFactory; +package org.apache.geode.internal.cache; +import org.apache.geode.internal.ExternalizableDSFID; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.cache.TransactionId; +import org.apache.geode.internal.DSFIDFactory; import java.io.*; -import com.gemstone.gemfire.distributed.internal.membership.*; +import org.apache.geode.distributed.internal.membership.*; /** The implementation of the {@link TransactionId} interface stored * in the transaction state and used, amoung other things, to uniquely @@ -33,7 +33,7 @@ import com.gemstone.gemfire.distributed.internal.membership.*; * @since GemFire 4.0 * * @see TXManagerImpl#begin - * @see com.gemstone.gemfire.cache.CacheTransactionManager#getTransactionId + * @see org.apache.geode.cache.CacheTransactionManager#getTransactionId */ public final class TXId extends ExternalizableDSFID http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXLockRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXLockRequest.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXLockRequest.java index 5f8283e..74d6f16 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXLockRequest.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXLockRequest.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.internal.cache.locks.*; +package org.apache.geode.internal.cache; +import org.apache.geode.cache.*; +import org.apache.geode.internal.cache.locks.*; 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/TXManagerImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXManagerImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXManagerImpl.java index ab082e0..4654a75 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXManagerImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXManagerImpl.java @@ -15,25 +15,25 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.GemFireException; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.TXManagerCancelledException; -import com.gemstone.gemfire.distributed.internal.*; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.SystemTimer.SystemTimerTask; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; -import com.gemstone.gemfire.internal.concurrent.ConcurrentHashSet; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.MapCallback; +package org.apache.geode.internal.cache; + +import org.apache.geode.DataSerializer; +import org.apache.geode.GemFireException; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.*; +import org.apache.geode.distributed.TXManagerCancelledException; +import org.apache.geode.distributed.internal.*; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.SystemTimer.SystemTimerTask; +import org.apache.geode.internal.cache.tier.sockets.Message; +import org.apache.geode.internal.concurrent.ConcurrentHashSet; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.MapCallback; import org.apache.logging.log4j.Logger; import java.io.DataInput; @@ -146,7 +146,7 @@ public class TXManagerImpl implements CacheTransactionManager, private int transactionTimeToLive; /** Constructor that implements the {@link CacheTransactionManager} - * interface. Only only one instance per {@link com.gemstone.gemfire.cache.Cache} + * interface. Only only one instance per {@link org.apache.geode.cache.Cache} * * @param cachePerfStats */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXMessage.java index 4918508..d8d2ed9 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXMessage.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.io.DataInput; import java.io.DataOutput; @@ -22,24 +22,24 @@ import java.io.IOException; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.distributed.DistributedSystemDisconnectedException; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -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.ReplySender; -import com.gemstone.gemfire.distributed.internal.SerialDistributionMessage; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.DataSerializer; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.distributed.DistributedSystemDisconnectedException; +import org.apache.geode.distributed.internal.DistributionManager; +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.ReplySender; +import org.apache.geode.distributed.internal.SerialDistributionMessage; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.partitioned.PartitionMessage; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXRegionLockRequestImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRegionLockRequestImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRegionLockRequestImpl.java index 6327ed7..d49f4b2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRegionLockRequestImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRegionLockRequestImpl.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,11 +25,11 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; /** TXRegionLockRequest represents all the locks that need to be made * for a single region. @@ -39,7 +39,7 @@ import com.gemstone.gemfire.internal.logging.log4j.LogMarker; * */ public class TXRegionLockRequestImpl - implements com.gemstone.gemfire.internal.cache.locks.TXRegionLockRequest + implements org.apache.geode.internal.cache.locks.TXRegionLockRequest { private static final long serialVersionUID = 5840033961584078082L; private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXRegionState.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRegionState.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRegionState.java index 479beb2..4026013 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRegionState.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRegionState.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.TXEntryState.DistTxThinEntryState; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +package org.apache.geode.internal.cache; +import org.apache.geode.CancelException; +import org.apache.geode.cache.*; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.TXEntryState.DistTxThinEntryState; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; import java.util.*; import java.util.Map.Entry; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteCommitMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteCommitMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteCommitMessage.java index f0eb8d1..c6d6f66 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteCommitMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteCommitMessage.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.io.DataInput; import java.io.DataOutput; @@ -24,23 +24,23 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.TransactionDataNotColocatedException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.DistributionStats; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.ReplySender; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.RemoteOperationMessage.RemoteOperationResponse; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.TransactionDataNotColocatedException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.DistributionStats; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.ReplySender; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.RemoteOperationMessage.RemoteOperationResponse; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; /** * @@ -248,7 +248,7 @@ public class TXRemoteCommitMessage extends TXMessage { /** * A processor to capture the value returned by {@link - * com.gemstone.gemfire.internal.cache.TXRemoteCommitMessage.TXRemoteCommitReplyMessage} + * org.apache.geode.internal.cache.TXRemoteCommitMessage.TXRemoteCommitReplyMessage} * * @since GemFire 6.6 */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteRollbackMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteRollbackMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteRollbackMessage.java index 96677f6..fdfd3e2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteRollbackMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRemoteRollbackMessage.java @@ -14,23 +14,23 @@ * 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.Collections; import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ReliableReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ReliableReplyProcessor21; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXReservationMgr.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXReservationMgr.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXReservationMgr.java index 2690419..80ffcc9 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXReservationMgr.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXReservationMgr.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -//import com.gemstone.gemfire.internal.cache.locks.*; +package org.apache.geode.internal.cache; +import org.apache.geode.cache.*; +import org.apache.geode.internal.i18n.LocalizedStrings; +//import org.apache.geode.internal.cache.locks.*; //import java.io.*; 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/TXRmtEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRmtEvent.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRmtEvent.java index 3de52fd..5696b19 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXRmtEvent.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXRmtEvent.java @@ -15,21 +15,21 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.ArrayList; import java.util.Collections; import java.util.Iterator; import java.util.List; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.TransactionEvent; -import com.gemstone.gemfire.cache.TransactionId; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.internal.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.TransactionEvent; +import org.apache.geode.cache.TransactionId; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; /** * <p> http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXState.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXState.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXState.java index 3223f12..fa63bcd 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXState.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXState.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.ArrayList; import java.util.Collection; @@ -33,38 +33,38 @@ import javax.transaction.Status; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.Region.Entry; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.SynchronizationCommitConflictException; -import com.gemstone.gemfire.cache.TransactionDataRebalancedException; -import com.gemstone.gemfire.cache.TransactionId; -import com.gemstone.gemfire.cache.TransactionWriter; -import com.gemstone.gemfire.cache.TransactionWriterException; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.TXManagerCancelledException; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.control.MemoryThresholds; -import com.gemstone.gemfire.internal.cache.partitioned.PutAllPRMessage; -import com.gemstone.gemfire.internal.cache.partitioned.RemoveAllPRMessage; -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.TransactionalOperation.ServerRegionOperation; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; +import org.apache.geode.CancelException; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.Region.Entry; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.SynchronizationCommitConflictException; +import org.apache.geode.cache.TransactionDataRebalancedException; +import org.apache.geode.cache.TransactionId; +import org.apache.geode.cache.TransactionWriter; +import org.apache.geode.cache.TransactionWriterException; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.cache.client.internal.ServerRegionDataAccess; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.TXManagerCancelledException; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.control.MemoryThresholds; +import org.apache.geode.internal.cache.partitioned.PutAllPRMessage; +import org.apache.geode.internal.cache.partitioned.RemoveAllPRMessage; +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.TransactionalOperation.ServerRegionOperation; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; /** TXState is the entity that tracks the transaction state on a per * thread basis, noting changes to Region entries on a per operation @@ -199,7 +199,7 @@ public class TXState implements TXStateInterface { } /* (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(); @@ -231,7 +231,7 @@ public class TXState 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) { return this.regions.get(r); @@ -243,7 +243,7 @@ public class TXState 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) { TXRegionState result = readRegion(r); @@ -262,13 +262,13 @@ public class TXState implements TXStateInterface { return result; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getBeginTime() + * @see org.apache.geode.internal.cache.TXStateInterface#getBeginTime() */ public long getBeginTime() { return this.beginTime; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getChanges() + * @see org.apache.geode.internal.cache.TXStateInterface#getChanges() */ public int getChanges() { int changes = 0; @@ -280,21 +280,21 @@ public class TXState implements TXStateInterface { return changes; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#isInProgress() + * @see org.apache.geode.internal.cache.TXStateInterface#isInProgress() */ public boolean isInProgress() { return !this.closed; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#nextModSerialNum() + * @see org.apache.geode.internal.cache.TXStateInterface#nextModSerialNum() */ public int nextModSerialNum() { this.modSerialNum += 1; return this.modSerialNum; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#needsLargeModCount() + * @see org.apache.geode.internal.cache.TXStateInterface#needsLargeModCount() */ public boolean needsLargeModCount() { return this.modSerialNum > Byte.MAX_VALUE; @@ -341,7 +341,7 @@ public class TXState implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#commit() + * @see org.apache.geode.internal.cache.TXStateInterface#commit() */ public void commit() throws CommitConflictException { if (this.closed) { @@ -520,7 +520,7 @@ public class TXState implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#rollback() + * @see org.apache.geode.internal.cache.TXStateInterface#rollback() */ public void rollback() { if (this.closed) { @@ -835,7 +835,7 @@ public class TXState implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getEvents() + * @see org.apache.geode.internal.cache.TXStateInterface#getEvents() */ public List getEvents() { ArrayList events = new ArrayList(); @@ -909,7 +909,7 @@ public class TXState implements TXStateInterface { // JTA Synchronization implementation // ////////////////////////////////////////////////////////////////// /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#beforeCompletion() + * @see org.apache.geode.internal.cache.TXStateInterface#beforeCompletion() */ public void beforeCompletion() throws SynchronizationCommitConflictException { if (this.closed) { @@ -967,7 +967,7 @@ public class TXState implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#afterCompletion(int) + * @see org.apache.geode.internal.cache.TXStateInterface#afterCompletion(int) */ public void afterCompletion(int status) { // System.err.println("start afterCompletion"); @@ -1091,14 +1091,14 @@ public class TXState 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#getRegions() + * @see org.apache.geode.internal.cache.TXStateInterface#getRegions() */ public Collection<LocalRegion> getRegions() { return this.regions.keySet(); @@ -1218,7 +1218,7 @@ public class TXState implements TXStateInterface { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#containsValueForKey(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.TXStateInterface#containsValueForKey(java.lang.Object, org.apache.geode.internal.cache.LocalRegion) */ public boolean containsValueForKey(KeyInfo keyInfo, LocalRegion region) { TXEntryState tx = txReadEntry(keyInfo, region, true, true/*create txEntry is absent*/); @@ -1236,7 +1236,7 @@ public class TXState 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(final EntryEventImpl event, final boolean cacheWrite, Object expectedOldValue) { if(bridgeContext==null) { @@ -1255,7 +1255,7 @@ public class TXState implements TXStateInterface { } } /* (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(final EntryEventImpl event, boolean invokeCallbacks, boolean forceNewEntry) { if(bridgeContext==null) { @@ -1311,7 +1311,7 @@ public class TXState implements TXStateInterface { return tx; } /* (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(final KeyInfo keyInfo, final LocalRegion region, boolean allowTombstones) { TXEntryState tx = txReadEntry(keyInfo, region, true, true/*create txEntry is absent*/); @@ -1401,7 +1401,7 @@ public class TXState 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, @@ -1426,7 +1426,7 @@ public class TXState 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) */ @Retained public Object getSerializedValue(LocalRegion localRegion, @@ -1454,7 +1454,7 @@ public class TXState implements TXStateInterface { } /* (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) { int result = localRegion.getRegionSize(); @@ -1472,7 +1472,7 @@ public class TXState implements TXStateInterface { } } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#containsKey(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.TXStateInterface#containsKey(java.lang.Object, org.apache.geode.internal.cache.LocalRegion) */ public boolean containsKey(KeyInfo keyInfo, LocalRegion localRegion) { TXEntryState tx = txReadEntry(keyInfo, localRegion, true,true/*create txEntry is absent*/); @@ -1483,7 +1483,7 @@ public class TXState implements TXStateInterface { } } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getValueInVM(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion, boolean) + * @see org.apache.geode.internal.cache.TXStateInterface#getValueInVM(java.lang.Object, org.apache.geode.internal.cache.LocalRegion, boolean) */ @Retained public Object getValueInVM(KeyInfo keyInfo, LocalRegion localRegion, @@ -1496,7 +1496,7 @@ public class TXState implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#putEntry(com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean, java.lang.Object, boolean, long, boolean) + * @see org.apache.geode.internal.cache.TXStateInterface#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, @@ -1519,13 +1519,13 @@ public class TXState implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#isStatsDeferred() + * @see org.apache.geode.internal.cache.InternalDataView#isStatsDeferred() */ public boolean isDeferredStats() { return true; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#findObject(com.gemstone.gemfire.internal.cache.LocalRegion, java.lang.Object, java.lang.Object, boolean, boolean, java.lang.Object) + * @see org.apache.geode.internal.cache.TXStateInterface#findObject(org.apache.geode.internal.cache.LocalRegion, java.lang.Object, java.lang.Object, boolean, boolean, java.lang.Object) */ public Object findObject(KeyInfo key, LocalRegion r, @@ -1554,7 +1554,7 @@ public class TXState implements TXStateInterface { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getEntryForIterator(com.gemstone.gemfire.internal.cache.LocalRegion, java.lang.Object, boolean) + * @see org.apache.geode.internal.cache.TXStateInterface#getEntryForIterator(org.apache.geode.internal.cache.LocalRegion, java.lang.Object, boolean) */ public Object getEntryForIterator(KeyInfo curr, LocalRegion currRgn, boolean rememberReads, boolean allowTombstones) { @@ -1582,7 +1582,7 @@ public class TXState 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 curr, LocalRegion currRgn, boolean rememberReads, boolean allowTombstones) { @@ -1594,7 +1594,7 @@ public class TXState 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) { if (currRgn instanceof PartitionedRegion) { @@ -1622,7 +1622,7 @@ public class TXState implements TXStateInterface { /* (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 otherState) { return isInProgress() && otherState == this; @@ -1630,7 +1630,7 @@ public class TXState 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, @@ -1682,7 +1682,7 @@ public class TXState 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; @@ -1690,7 +1690,7 @@ public class TXState 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 { @@ -1707,14 +1707,14 @@ public class TXState 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 currRegion.getRegionKeysForIteration(); @@ -1748,7 +1748,7 @@ public class TXState implements TXStateInterface { /* * For TX this needs to be a PR passed in as region * - * @see com.gemstone.gemfire.internal.cache.InternalDataView#postPutAll(com.gemstone.gemfire.internal.cache.DistributedPutAllOperation, java.util.Map, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#postPutAll(org.apache.geode.internal.cache.DistributedPutAllOperation, java.util.Map, org.apache.geode.internal.cache.LocalRegion) */ public void postPutAll(final DistributedPutAllOperation putallOp, final VersionedObjectList successfulPuts,LocalRegion reg) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateInterface.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateInterface.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateInterface.java index 865ebd5..d1ce3a8 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateInterface.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateInterface.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.List; @@ -25,14 +25,14 @@ import java.util.concurrent.locks.ReentrantLock; import javax.transaction.Synchronization; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.cache.TransactionId; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.cache.Region.Entry; -import com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.tx.TransactionalOperation.ServerRegionOperation; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.cache.TransactionId; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.cache.Region.Entry; +import org.apache.geode.cache.client.internal.ServerRegionDataAccess; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.tx.TransactionalOperation.ServerRegionOperation; /** * An entity that tracks transactions must 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/TXStateProxy.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateProxy.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateProxy.java index 8f8d1cd..9edf1db 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateProxy.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateProxy.java @@ -17,12 +17,12 @@ /** * File comment */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.tx.TransactionalOperation.ServerRegionOperation; +import org.apache.geode.cache.client.internal.ServerRegionDataAccess; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.tx.TransactionalOperation.ServerRegionOperation; /** * This interface extends {@link TXStateInterface} providing for a proxy for the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateProxyImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateProxyImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateProxyImpl.java index c4ebadd..412ce09 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateProxyImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/TXStateProxyImpl.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; @@ -29,26 +29,26 @@ import java.util.concurrent.locks.ReentrantLock; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.GemFireException; -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.TransactionDataNotColocatedException; -import com.gemstone.gemfire.cache.TransactionDataRebalancedException; -import com.gemstone.gemfire.cache.TransactionException; -import com.gemstone.gemfire.cache.TransactionId; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -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.ClientTXStateStub; -import com.gemstone.gemfire.internal.cache.tx.TransactionalOperation.ServerRegionOperation; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.GemFireException; +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.TransactionDataNotColocatedException; +import org.apache.geode.cache.TransactionDataRebalancedException; +import org.apache.geode.cache.TransactionException; +import org.apache.geode.cache.TransactionId; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.cache.client.internal.ServerRegionDataAccess; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +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.ClientTXStateStub; +import org.apache.geode.internal.cache.tx.TransactionalOperation.ServerRegionOperation; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * @@ -93,7 +93,7 @@ public class TXStateProxyImpl implements TXStateProxy { /* * (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getSemaphore() + * @see org.apache.geode.internal.cache.TXStateInterface#getSemaphore() */ public ReentrantLock getLock() { return this.lock; @@ -220,10 +220,10 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#checkJTA(java.lang.String) + * @see org.apache.geode.internal.cache.TXStateInterface#checkJTA(java.lang.String) */ /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateProxyInterface#checkJTA(java.lang.String) + * @see org.apache.geode.internal.cache.TXStateProxyInterface#checkJTA(java.lang.String) */ public void checkJTA(String errmsg) throws IllegalStateException { if (isJTA()) { @@ -240,7 +240,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#commit() + * @see org.apache.geode.internal.cache.TXStateInterface#commit() */ public void commit() throws CommitConflictException { boolean preserveTx = false; @@ -277,7 +277,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#containsValueForKey(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.TXStateInterface#containsValueForKey(java.lang.Object, org.apache.geode.internal.cache.LocalRegion) */ public boolean containsValueForKey(KeyInfo keyInfo, LocalRegion region) { try { @@ -303,7 +303,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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 { @@ -317,21 +317,21 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getBeginTime() + * @see org.apache.geode.internal.cache.TXStateInterface#getBeginTime() */ public long getBeginTime() { return getRealDeal(null, null).getBeginTime(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getCache() + * @see org.apache.geode.internal.cache.TXStateInterface#getCache() */ public Cache getCache() { return txMgr.getCache(); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getChanges() + * @see org.apache.geode.internal.cache.TXStateInterface#getChanges() */ public int getChanges() { assertBootstrapped(); @@ -339,7 +339,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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, @@ -360,7 +360,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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 region, boolean allowTombstones) { try { @@ -374,7 +374,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getEvent() + * @see org.apache.geode.internal.cache.TXStateInterface#getEvent() */ public TXEvent getEvent() { assertBootstrapped(); @@ -382,7 +382,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getEvents() + * @see org.apache.geode.internal.cache.TXStateInterface#getEvents() */ public List getEvents() { assertBootstrapped(); @@ -390,7 +390,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getRegions() + * @see org.apache.geode.internal.cache.TXStateInterface#getRegions() */ public Collection<LocalRegion> getRegions() { assertBootstrapped(); @@ -398,14 +398,14 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#getTransactionId() + * @see org.apache.geode.internal.cache.TXStateInterface#getTransactionId() */ public TransactionId getTransactionId() { return txId; } /* (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) { @@ -419,7 +419,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#isInProgress() + * @see org.apache.geode.internal.cache.TXStateInterface#isInProgress() */ public boolean isInProgress() { return inProgress; @@ -431,7 +431,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#needsLargeModCount() + * @see org.apache.geode.internal.cache.TXStateInterface#needsLargeModCount() */ public boolean needsLargeModCount() { assertBootstrapped(); @@ -439,7 +439,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#nextModSerialNum() + * @see org.apache.geode.internal.cache.TXStateInterface#nextModSerialNum() */ public int nextModSerialNum() { assertBootstrapped(); @@ -447,7 +447,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) { assertBootstrapped(); @@ -455,7 +455,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) { assertBootstrapped(); @@ -463,7 +463,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#rollback() + * @see org.apache.geode.internal.cache.TXStateInterface#rollback() */ public void rollback() { try { @@ -477,7 +477,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) { @@ -492,7 +492,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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 keyInfo, LocalRegion localRegion, boolean rememberRead,boolean createTxEntryIfAbsent) { @@ -508,7 +508,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) { assertBootstrapped(); @@ -516,14 +516,14 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) { return getRealDeal(entryKey, localRegion).txWriteRegion(localRegion, entryKey); } /* (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) { assertBootstrapped(); @@ -558,7 +558,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) { try { @@ -572,7 +572,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) */ @edu.umd.cs.findbugs.annotations.SuppressWarnings(value="UL_UNRELEASED_LOCK", justification="This method unlocks and then conditionally undoes the unlock in the finally-block. Review again at later time.") public int entryCount(LocalRegion localRegion) { @@ -603,7 +603,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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 key, LocalRegion r, boolean isCreate, boolean generateCallbacks, Object value, boolean disableCopyOnRead, @@ -621,7 +621,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) { if (this.realDeal == null) { @@ -631,7 +631,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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 key, LocalRegion currRgn, boolean rememberReads, boolean allowTombstones) { @@ -654,7 +654,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) { @@ -676,7 +676,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) { @@ -685,7 +685,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#isDeferredStats() + * @see org.apache.geode.internal.cache.InternalDataView#isDeferredStats() */ public boolean isDeferredStats() { assertBootstrapped(); @@ -693,7 +693,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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, @@ -710,14 +710,14 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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 otherState) { return isInProgress() && otherState == this; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateProxy#setLocalTXState(com.gemstone.gemfire.internal.cache.TXState) + * @see org.apache.geode.internal.cache.TXStateProxy#setLocalTXState(org.apache.geode.internal.cache.TXState) */ public void setLocalTXState(TXStateInterface state) { this.realDeal = state; @@ -725,7 +725,7 @@ public class TXStateProxyImpl implements TXStateProxy { /* * (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, @@ -738,7 +738,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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, @@ -755,7 +755,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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 { @@ -766,7 +766,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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 { @@ -793,7 +793,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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) { //if this the first operation in a transaction, reset txState @@ -815,7 +815,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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 keyInfo, LocalRegion localRegion, boolean allowTombstones) throws DataLocationException { @@ -830,14 +830,14 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateProxy#getTarget() + * @see org.apache.geode.internal.cache.TXStateProxy#getTarget() */ public DistributedMember getTarget() { return this.target; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateProxy#setTarget(com.gemstone.gemfire.distributed.DistributedMember) + * @see org.apache.geode.internal.cache.TXStateProxy#setTarget(org.apache.geode.distributed.DistributedMember) */ public void setTarget(DistributedMember target) { assert this.target == null; @@ -845,7 +845,7 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (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 Collection<?> getRegionKeysForIteration(LocalRegion currRegion) { if (currRegion.isUsedForPartitionedRegionBucket()) { @@ -856,14 +856,14 @@ public class TXStateProxyImpl implements TXStateProxy { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateProxy#isCommitRequestedByOwner() + * @see org.apache.geode.internal.cache.TXStateProxy#isCommitRequestedByOwner() */ public boolean isCommitOnBehalfOfRemoteStub() { return this.commitRequestedByOwner; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateProxy#setCommitRequestedByOwner() + * @see org.apache.geode.internal.cache.TXStateProxy#setCommitRequestedByOwner() */ public boolean setCommitOnBehalfOfRemoteStub(boolean requestedByOwner) { return this.commitRequestedByOwner = requestedByOwner;