http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionRegionConfigValidator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionRegionConfigValidator.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionRegionConfigValidator.java index b3ca5e5..bb14576 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionRegionConfigValidator.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionRegionConfigValidator.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.ArrayList; import java.util.HashSet; @@ -24,18 +24,18 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.AttributesFactory; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.DuplicatePrimaryPartitionException; -import com.gemstone.gemfire.cache.EvictionAttributes; -import com.gemstone.gemfire.cache.FixedPartitionAttributes; -import com.gemstone.gemfire.cache.PartitionAttributes; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.internal.Assert; -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.cache.AttributesFactory; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.DuplicatePrimaryPartitionException; +import org.apache.geode.cache.EvictionAttributes; +import org.apache.geode.cache.FixedPartitionAttributes; +import org.apache.geode.cache.PartitionAttributes; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.Scope; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** *
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java index 175a284..6e4fcd5 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegion.java @@ -15,98 +15,98 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.cache.asyncqueue.internal.AsyncEventQueueImpl; -import com.gemstone.gemfire.cache.client.internal.*; -import com.gemstone.gemfire.cache.execute.*; -import com.gemstone.gemfire.cache.partition.PartitionListener; -import com.gemstone.gemfire.cache.partition.PartitionNotAvailableException; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.*; -import com.gemstone.gemfire.cache.query.internal.index.*; -import com.gemstone.gemfire.cache.query.internal.types.ObjectTypeImpl; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.wan.GatewaySender; -import com.gemstone.gemfire.distributed.DistributedLockService; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.LockServiceDestroyedException; -import com.gemstone.gemfire.distributed.internal.*; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem.DisconnectListener; -import com.gemstone.gemfire.distributed.internal.locks.DLockRemoteToken; -import com.gemstone.gemfire.distributed.internal.locks.DLockService; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.MemberAttributes; -import com.gemstone.gemfire.i18n.StringId; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.NanoTimer; -import com.gemstone.gemfire.internal.SetUtils; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.BucketAdvisor.ServerBucketProfile; -import com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.CacheProfile; -import com.gemstone.gemfire.internal.cache.DestroyPartitionedRegionMessage.DestroyPartitionedRegionResponse; -import com.gemstone.gemfire.internal.cache.PutAllPartialResultException.PutAllPartialResult; -import com.gemstone.gemfire.internal.cache.control.HeapMemoryMonitor; -import com.gemstone.gemfire.internal.cache.control.InternalResourceManager; -import com.gemstone.gemfire.internal.cache.control.InternalResourceManager.ResourceType; -import com.gemstone.gemfire.internal.cache.control.MemoryEvent; -import com.gemstone.gemfire.internal.cache.control.MemoryThresholds; -import com.gemstone.gemfire.internal.cache.execute.*; -import com.gemstone.gemfire.internal.cache.ha.ThreadIdentifier; -import com.gemstone.gemfire.internal.cache.lru.HeapEvictor; -import com.gemstone.gemfire.internal.cache.lru.LRUStatistics; -import com.gemstone.gemfire.internal.cache.partitioned.*; -import com.gemstone.gemfire.internal.cache.partitioned.ContainsKeyValueMessage.ContainsKeyValueResponse; -import com.gemstone.gemfire.internal.cache.partitioned.DestroyMessage.DestroyResponse; -import com.gemstone.gemfire.internal.cache.partitioned.DumpB2NRegion.DumpB2NResponse; -import com.gemstone.gemfire.internal.cache.partitioned.FetchBulkEntriesMessage.FetchBulkEntriesResponse; -import com.gemstone.gemfire.internal.cache.partitioned.FetchEntriesMessage.FetchEntriesResponse; -import com.gemstone.gemfire.internal.cache.partitioned.FetchEntryMessage.FetchEntryResponse; -import com.gemstone.gemfire.internal.cache.partitioned.FetchKeysMessage.FetchKeysResponse; -import com.gemstone.gemfire.internal.cache.partitioned.GetMessage.GetResponse; -import com.gemstone.gemfire.internal.cache.partitioned.IdentityRequestMessage.IdentityResponse; -import com.gemstone.gemfire.internal.cache.partitioned.IdentityUpdateMessage.IdentityUpdateResponse; -import com.gemstone.gemfire.internal.cache.partitioned.InterestEventMessage.InterestEventResponse; -import com.gemstone.gemfire.internal.cache.partitioned.InvalidateMessage.InvalidateResponse; -import com.gemstone.gemfire.internal.cache.partitioned.PRUpdateEntryVersionMessage.UpdateEntryVersionResponse; -import com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage.PartitionResponse; -import com.gemstone.gemfire.internal.cache.partitioned.PutMessage.PutResult; -import com.gemstone.gemfire.internal.cache.partitioned.RegionAdvisor.PartitionProfile; -import com.gemstone.gemfire.internal.cache.partitioned.SizeMessage.SizeResponse; -import com.gemstone.gemfire.internal.cache.persistence.PRPersistentConfig; -import com.gemstone.gemfire.internal.cache.tier.InterestType; -import com.gemstone.gemfire.internal.cache.tier.sockets.BaseCommand; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.tier.sockets.command.Get70; -import com.gemstone.gemfire.internal.cache.versions.ConcurrentCacheModificationException; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionStamp; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySender; -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySenderEventProcessor; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderConfigurationException; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderException; -import com.gemstone.gemfire.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue; -import com.gemstone.gemfire.internal.cache.wan.parallel.ParallelGatewaySenderQueue; -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.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Unretained; -import com.gemstone.gemfire.internal.sequencelog.RegionLogger; -import com.gemstone.gemfire.internal.util.TransformUtils; -import com.gemstone.gemfire.internal.util.concurrent.StoppableCountDownLatch; +package org.apache.geode.internal.cache; + +import org.apache.geode.CancelException; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.*; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.cache.asyncqueue.internal.AsyncEventQueueImpl; +import org.apache.geode.cache.client.internal.*; +import org.apache.geode.cache.execute.*; +import org.apache.geode.cache.partition.PartitionListener; +import org.apache.geode.cache.partition.PartitionNotAvailableException; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.*; +import org.apache.geode.cache.query.internal.index.*; +import org.apache.geode.cache.query.internal.types.ObjectTypeImpl; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.wan.GatewaySender; +import org.apache.geode.distributed.DistributedLockService; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.LockServiceDestroyedException; +import org.apache.geode.distributed.internal.*; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.distributed.internal.InternalDistributedSystem.DisconnectListener; +import org.apache.geode.distributed.internal.locks.DLockRemoteToken; +import org.apache.geode.distributed.internal.locks.DLockService; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.distributed.internal.membership.MemberAttributes; +import org.apache.geode.i18n.StringId; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.NanoTimer; +import org.apache.geode.internal.SetUtils; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.BucketAdvisor.ServerBucketProfile; +import org.apache.geode.internal.cache.CacheDistributionAdvisor.CacheProfile; +import org.apache.geode.internal.cache.DestroyPartitionedRegionMessage.DestroyPartitionedRegionResponse; +import org.apache.geode.internal.cache.PutAllPartialResultException.PutAllPartialResult; +import org.apache.geode.internal.cache.control.HeapMemoryMonitor; +import org.apache.geode.internal.cache.control.InternalResourceManager; +import org.apache.geode.internal.cache.control.InternalResourceManager.ResourceType; +import org.apache.geode.internal.cache.control.MemoryEvent; +import org.apache.geode.internal.cache.control.MemoryThresholds; +import org.apache.geode.internal.cache.execute.*; +import org.apache.geode.internal.cache.ha.ThreadIdentifier; +import org.apache.geode.internal.cache.lru.HeapEvictor; +import org.apache.geode.internal.cache.lru.LRUStatistics; +import org.apache.geode.internal.cache.partitioned.*; +import org.apache.geode.internal.cache.partitioned.ContainsKeyValueMessage.ContainsKeyValueResponse; +import org.apache.geode.internal.cache.partitioned.DestroyMessage.DestroyResponse; +import org.apache.geode.internal.cache.partitioned.DumpB2NRegion.DumpB2NResponse; +import org.apache.geode.internal.cache.partitioned.FetchBulkEntriesMessage.FetchBulkEntriesResponse; +import org.apache.geode.internal.cache.partitioned.FetchEntriesMessage.FetchEntriesResponse; +import org.apache.geode.internal.cache.partitioned.FetchEntryMessage.FetchEntryResponse; +import org.apache.geode.internal.cache.partitioned.FetchKeysMessage.FetchKeysResponse; +import org.apache.geode.internal.cache.partitioned.GetMessage.GetResponse; +import org.apache.geode.internal.cache.partitioned.IdentityRequestMessage.IdentityResponse; +import org.apache.geode.internal.cache.partitioned.IdentityUpdateMessage.IdentityUpdateResponse; +import org.apache.geode.internal.cache.partitioned.InterestEventMessage.InterestEventResponse; +import org.apache.geode.internal.cache.partitioned.InvalidateMessage.InvalidateResponse; +import org.apache.geode.internal.cache.partitioned.PRUpdateEntryVersionMessage.UpdateEntryVersionResponse; +import org.apache.geode.internal.cache.partitioned.PartitionMessage.PartitionResponse; +import org.apache.geode.internal.cache.partitioned.PutMessage.PutResult; +import org.apache.geode.internal.cache.partitioned.RegionAdvisor.PartitionProfile; +import org.apache.geode.internal.cache.partitioned.SizeMessage.SizeResponse; +import org.apache.geode.internal.cache.persistence.PRPersistentConfig; +import org.apache.geode.internal.cache.tier.InterestType; +import org.apache.geode.internal.cache.tier.sockets.BaseCommand; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.ServerConnection; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.tier.sockets.command.Get70; +import org.apache.geode.internal.cache.versions.ConcurrentCacheModificationException; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionStamp; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.cache.wan.AbstractGatewaySender; +import org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor; +import org.apache.geode.internal.cache.wan.GatewaySenderConfigurationException; +import org.apache.geode.internal.cache.wan.GatewaySenderException; +import org.apache.geode.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue; +import org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue; +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.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Unretained; +import org.apache.geode.internal.sequencelog.RegionLogger; +import org.apache.geode.internal.util.TransformUtils; +import org.apache.geode.internal.util.concurrent.StoppableCountDownLatch; import org.apache.logging.log4j.Logger; import java.io.IOException; @@ -2051,7 +2051,7 @@ public class PartitionedRegion extends LocalRegion implements } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.LocalRegion#checkIfAboveThreshold(com.gemstone.gemfire.internal.cache.EntryEventImpl) + * @see org.apache.geode.internal.cache.LocalRegion#checkIfAboveThreshold(org.apache.geode.internal.cache.EntryEventImpl) */ @Override public void checkIfAboveThreshold(EntryEventImpl evi) @@ -5951,7 +5951,7 @@ public class PartitionedRegion extends LocalRegion implements /* * We yet don't have any stats for this operation. * (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.LocalRegion#basicUpdateEntryVersion(com.gemstone.gemfire.internal.cache.EntryEventImpl) + * @see org.apache.geode.internal.cache.LocalRegion#basicUpdateEntryVersion(org.apache.geode.internal.cache.EntryEventImpl) */ @Override void basicUpdateEntryVersion(EntryEventImpl event) @@ -8357,7 +8357,7 @@ public class PartitionedRegion extends LocalRegion implements } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.LocalRegion#dumpBackingMap() + * @see org.apache.geode.internal.cache.LocalRegion#dumpBackingMap() */ @Override public void dumpBackingMap() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionBucketMgmtHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionBucketMgmtHelper.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionBucketMgmtHelper.java index 2d1ae19..79a397d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionBucketMgmtHelper.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionBucketMgmtHelper.java @@ -14,13 +14,13 @@ * 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.*; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.SetUtils; -import com.gemstone.gemfire.internal.cache.partitioned.Bucket; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.SetUtils; +import org.apache.geode.internal.cache.partitioned.Bucket; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java index 494c288..76de6ae 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataStore.java @@ -14,49 +14,49 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.Region.Entry; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.execute.ResultSender; -import com.gemstone.gemfire.cache.query.QueryInvalidException; -import com.gemstone.gemfire.cache.query.internal.QCompiler; -import com.gemstone.gemfire.cache.query.internal.index.IndexCreationData; -import com.gemstone.gemfire.cache.query.internal.index.PartitionedIndex; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.i18n.StringId; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.BucketRegion.RawValue; -import com.gemstone.gemfire.internal.cache.LocalRegion.RegionPerfStats; -import com.gemstone.gemfire.internal.cache.PartitionedRegion.BucketLock; -import com.gemstone.gemfire.internal.cache.PartitionedRegion.SizeEntry; -import com.gemstone.gemfire.internal.cache.execute.BucketMovedException; -import com.gemstone.gemfire.internal.cache.execute.FunctionStats; -import com.gemstone.gemfire.internal.cache.execute.PartitionedRegionFunctionResultSender; -import com.gemstone.gemfire.internal.cache.execute.RegionFunctionContextImpl; -import com.gemstone.gemfire.internal.cache.partitioned.*; -import com.gemstone.gemfire.internal.cache.partitioned.RemoveBucketMessage.RemoveBucketResponse; -import com.gemstone.gemfire.internal.cache.persistence.BackupManager; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySender; -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySenderEventProcessor; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderEventImpl; -import com.gemstone.gemfire.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue; -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.StoppableReentrantReadWriteLock; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantReadWriteLock.StoppableReadLock; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantReadWriteLock.StoppableWriteLock; +package org.apache.geode.internal.cache; + +import org.apache.geode.InternalGemFireError; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.cache.*; +import org.apache.geode.cache.Region.Entry; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.ResultSender; +import org.apache.geode.cache.query.QueryInvalidException; +import org.apache.geode.cache.query.internal.QCompiler; +import org.apache.geode.cache.query.internal.index.IndexCreationData; +import org.apache.geode.cache.query.internal.index.PartitionedIndex; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.i18n.StringId; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.BucketRegion.RawValue; +import org.apache.geode.internal.cache.LocalRegion.RegionPerfStats; +import org.apache.geode.internal.cache.PartitionedRegion.BucketLock; +import org.apache.geode.internal.cache.PartitionedRegion.SizeEntry; +import org.apache.geode.internal.cache.execute.BucketMovedException; +import org.apache.geode.internal.cache.execute.FunctionStats; +import org.apache.geode.internal.cache.execute.PartitionedRegionFunctionResultSender; +import org.apache.geode.internal.cache.execute.RegionFunctionContextImpl; +import org.apache.geode.internal.cache.partitioned.*; +import org.apache.geode.internal.cache.partitioned.RemoveBucketMessage.RemoveBucketResponse; +import org.apache.geode.internal.cache.persistence.BackupManager; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.ServerConnection; +import org.apache.geode.internal.cache.wan.AbstractGatewaySender; +import org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor; +import org.apache.geode.internal.cache.wan.GatewaySenderEventImpl; +import org.apache.geode.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue; +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.StoppableReentrantReadWriteLock; +import org.apache.geode.internal.util.concurrent.StoppableReentrantReadWriteLock.StoppableReadLock; +import org.apache.geode.internal.util.concurrent.StoppableReentrantReadWriteLock.StoppableWriteLock; import org.apache.logging.log4j.Logger; import java.io.IOException; @@ -70,10 +70,10 @@ import java.util.concurrent.locks.Lock; /** * Implementation of DataStore (DS) for a PartitionedRegion (PR). This will be -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySenderEventProcessor; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderEventImpl; -import com.gemstone.gemfire.internal.cache.wan.parallel.ParallelGatewaySenderImpl; -import com.gemstone.gemfire.internal.cache.wan.parallel.ParallelGatewaySenderQueue; +import org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor; +import org.apache.geode.internal.cache.wan.GatewaySenderEventImpl; +import org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderImpl; +import org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue; * accessed via accessor of PartitionedRegion or PartionService thread which * will handle remote calls to this DataStore from other nodes participating in * this PartitionedRegion. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataView.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataView.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataView.java index 02a84ee..e73f059 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataView.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionDataView.java @@ -17,14 +17,14 @@ /** * File comment */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Set; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.Region.Entry; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.Region.Entry; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionException.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionException.java index 6cb7ca0..1cbc932 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionException.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.cache.CacheRuntimeException; +import org.apache.geode.cache.CacheRuntimeException; /** * RuntimeException propagated to invoking code to signal problem with remote http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionHelper.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionHelper.java index 397f35f..d185187 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionHelper.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionHelper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.IOException; import java.util.ArrayList; @@ -29,41 +29,41 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.cache.AttributesFactory; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.EntryEvent; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.EntryOperation; -import com.gemstone.gemfire.cache.FixedPartitionAttributes; -import com.gemstone.gemfire.cache.FixedPartitionResolver; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.PartitionResolver; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.RegionExistsException; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.cache.partition.PartitionNotAvailableException; -import com.gemstone.gemfire.cache.util.CacheListenerAdapter; -import com.gemstone.gemfire.cache.util.CacheWriterAdapter; -import com.gemstone.gemfire.distributed.DistributedLockService; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -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.partitioned.Bucket; -import com.gemstone.gemfire.internal.cache.partitioned.PRLocallyDestroyedException; -import com.gemstone.gemfire.internal.cache.partitioned.RegionAdvisor; -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.CancelException; +import org.apache.geode.cache.AttributesFactory; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.EntryEvent; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.EntryOperation; +import org.apache.geode.cache.FixedPartitionAttributes; +import org.apache.geode.cache.FixedPartitionResolver; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.PartitionResolver; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.RegionExistsException; +import org.apache.geode.cache.Scope; +import org.apache.geode.cache.partition.PartitionNotAvailableException; +import org.apache.geode.cache.util.CacheListenerAdapter; +import org.apache.geode.cache.util.CacheWriterAdapter; +import org.apache.geode.distributed.DistributedLockService; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +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.partitioned.Bucket; +import org.apache.geode.internal.cache.partitioned.PRLocallyDestroyedException; +import org.apache.geode.internal.cache.partitioned.RegionAdvisor; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionQueryEvaluator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionQueryEvaluator.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionQueryEvaluator.java index 987d8a0..7f12cc5 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionQueryEvaluator.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionQueryEvaluator.java @@ -14,26 +14,26 @@ * 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.CopyHelper; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.*; -import com.gemstone.gemfire.cache.query.internal.IndexTrackingQueryObserver.IndexInfo; -import com.gemstone.gemfire.cache.query.internal.utils.PDXUtils; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.cache.query.types.StructType; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.*; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.NanoTimer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.partitioned.QueryMessage; -import com.gemstone.gemfire.internal.cache.partitioned.StreamingPartitionOperation; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.CopyHelper; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.*; +import org.apache.geode.cache.query.internal.IndexTrackingQueryObserver.IndexInfo; +import org.apache.geode.cache.query.internal.utils.PDXUtils; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.cache.query.types.StructType; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.*; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.NanoTimer; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.partitioned.QueryMessage; +import org.apache.geode.internal.cache.partitioned.StreamingPartitionOperation; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; import it.unimi.dsi.fastutil.ints.IntOpenHashSet; import it.unimi.dsi.fastutil.objects.Object2ObjectOpenHashMap; import org.apache.logging.log4j.Logger; @@ -346,7 +346,7 @@ public class PartitionedRegionQueryEvaluator extends StreamingPartitionOperation if (isDebugEnabled) { logger.debug("Following remote members failed {} and retry flag is set to: {}", failedMembers, requiresRetry); } - } catch (com.gemstone.gemfire.cache.TimeoutException e) { //Shobhit: Swallow remote exception if + } catch (org.apache.geode.cache.TimeoutException e) { //Shobhit: Swallow remote exception if // local exception is there. if (localFault == null) { throw new QueryException(e); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionStats.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionStats.java index c6f1243..558176a 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionStats.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Collections; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; -import com.gemstone.gemfire.StatisticDescriptor; -import com.gemstone.gemfire.Statistics; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.StatisticsType; -import com.gemstone.gemfire.StatisticsTypeFactory; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.StatisticDescriptor; +import org.apache.geode.Statistics; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.StatisticsType; +import org.apache.geode.StatisticsTypeFactory; +import org.apache.geode.cache.Region; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; /** * Represents a statistics type that can be archived to vsd. Loading of this http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionStatus.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionStatus.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionStatus.java index 193d7ba..2f7dc38 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionStatus.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionedRegionStatus.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * Class <code>PartitionedRegionStatus</code> provides information about http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PeerTXStateStub.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PeerTXStateStub.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PeerTXStateStub.java index a600a44..4ffbd0e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PeerTXStateStub.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PeerTXStateStub.java @@ -14,28 +14,28 @@ * 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.CancelException; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.cache.TransactionDataRebalancedException; -import com.gemstone.gemfire.cache.TransactionException; -import com.gemstone.gemfire.cache.TransactionInDoubtException; -import com.gemstone.gemfire.cache.client.internal.ServerRegionDataAccess; -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.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.TXRemoteCommitMessage.RemoteCommitResponse; -import com.gemstone.gemfire.internal.cache.tx.DistributedTXRegionStub; -import com.gemstone.gemfire.internal.cache.tx.PartitionedTXRegionStub; -import com.gemstone.gemfire.internal.cache.tx.TXRegionStub; -import com.gemstone.gemfire.internal.cache.tx.TransactionalOperation.ServerRegionOperation; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.CancelException; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.cache.TransactionDataRebalancedException; +import org.apache.geode.cache.TransactionException; +import org.apache.geode.cache.TransactionInDoubtException; +import org.apache.geode.cache.client.internal.ServerRegionDataAccess; +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.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.TXRemoteCommitMessage.RemoteCommitResponse; +import org.apache.geode.internal.cache.tx.DistributedTXRegionStub; +import org.apache.geode.internal.cache.tx.PartitionedTXRegionStub; +import org.apache.geode.internal.cache.tx.TXRegionStub; +import org.apache.geode.internal.cache.tx.TransactionalOperation.ServerRegionOperation; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; public class PeerTXStateStub extends TXStateStub { @@ -50,7 +50,7 @@ public class PeerTXStateStub extends TXStateStub { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#rollback() + * @see org.apache.geode.internal.cache.TXStateInterface#rollback() */ @Override public void rollback() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PersistentOplogSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PersistentOplogSet.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PersistentOplogSet.java index af84423..747f49d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PersistentOplogSet.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PersistentOplogSet.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 it.unimi.dsi.fastutil.longs.LongOpenHashSet; @@ -36,20 +36,20 @@ import java.util.concurrent.atomic.AtomicLong; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.internal.FileUtil; -import com.gemstone.gemfire.internal.cache.DiskEntry.Helper.ValueWrapper; -import com.gemstone.gemfire.internal.cache.DiskStoreImpl.OplogEntryIdSet; -import com.gemstone.gemfire.internal.cache.persistence.DiskRecoveryStore; -import com.gemstone.gemfire.internal.cache.persistence.DiskRegionView; -import com.gemstone.gemfire.internal.cache.persistence.DiskStoreFilter; -import com.gemstone.gemfire.internal.cache.persistence.OplogType; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -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.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.sequencelog.EntryLogger; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.internal.FileUtil; +import org.apache.geode.internal.cache.DiskEntry.Helper.ValueWrapper; +import org.apache.geode.internal.cache.DiskStoreImpl.OplogEntryIdSet; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.cache.persistence.DiskRegionView; +import org.apache.geode.internal.cache.persistence.DiskStoreFilter; +import org.apache.geode.internal.cache.persistence.OplogType; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +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.logging.log4j.LogMarker; +import org.apache.geode.internal.sequencelog.EntryLogger; public class PersistentOplogSet implements OplogSet { 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/PlaceHolderDiskRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PlaceHolderDiskRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PlaceHolderDiskRegion.java index df858f6..b78f7b5 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PlaceHolderDiskRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PlaceHolderDiskRegion.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; - -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.internal.cache.lru.LRUStatistics; -import com.gemstone.gemfire.internal.cache.persistence.DiskRecoveryStore; -import com.gemstone.gemfire.internal.cache.persistence.DiskRegionView; -import com.gemstone.gemfire.internal.cache.persistence.DiskStoreID; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +package org.apache.geode.internal.cache; + +import org.apache.geode.CancelCriterion; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.internal.cache.lru.LRUStatistics; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.cache.persistence.DiskRegionView; +import org.apache.geode.internal.cache.persistence.DiskStoreID; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * Used to represent a recovered disk region. Once the region actually exists http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PoolFactoryImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PoolFactoryImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PoolFactoryImpl.java index 1b6ce7a..fea9e5c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PoolFactoryImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PoolFactoryImpl.java @@ -14,22 +14,22 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.DataSerializable; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.RegionService; -import com.gemstone.gemfire.cache.client.Pool; -import com.gemstone.gemfire.cache.client.PoolFactory; -import com.gemstone.gemfire.cache.client.internal.LocatorDiscoveryCallback; -import com.gemstone.gemfire.cache.client.internal.PoolImpl; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.wan.GatewaySender; -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.pdx.internal.TypeRegistry; +package org.apache.geode.internal.cache; + +import org.apache.geode.DataSerializable; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.RegionService; +import org.apache.geode.cache.client.Pool; +import org.apache.geode.cache.client.PoolFactory; +import org.apache.geode.cache.client.internal.LocatorDiscoveryCallback; +import org.apache.geode.cache.client.internal.PoolImpl; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.wan.GatewaySender; +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.pdx.internal.TypeRegistry; import org.apache.logging.log4j.Logger; import java.io.DataInput; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PoolManagerImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PoolManagerImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PoolManagerImpl.java index bc5441b..97b926c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PoolManagerImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PoolManagerImpl.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Collections; import java.util.HashMap; @@ -25,25 +25,25 @@ import java.util.Map.Entry; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.Instantiator; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.client.Pool; -import com.gemstone.gemfire.cache.client.PoolFactory; -import com.gemstone.gemfire.cache.client.PoolManager; -import com.gemstone.gemfire.cache.client.internal.PoolImpl; -import com.gemstone.gemfire.cache.client.internal.RegisterDataSerializersOp; -import com.gemstone.gemfire.cache.client.internal.RegisterInstantiatorsOp; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.InternalDataSerializer.SerializerAttributesHolder; -import com.gemstone.gemfire.internal.InternalInstantiator; -import com.gemstone.gemfire.internal.InternalInstantiator.InstantiatorAttributesHolder; -import com.gemstone.gemfire.internal.cache.tier.sockets.ServerConnection; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheCreation; -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.DataSerializer; +import org.apache.geode.Instantiator; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.client.Pool; +import org.apache.geode.cache.client.PoolFactory; +import org.apache.geode.cache.client.PoolManager; +import org.apache.geode.cache.client.internal.PoolImpl; +import org.apache.geode.cache.client.internal.RegisterDataSerializersOp; +import org.apache.geode.cache.client.internal.RegisterInstantiatorsOp; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.InternalDataSerializer.SerializerAttributesHolder; +import org.apache.geode.internal.InternalInstantiator; +import org.apache.geode.internal.InternalInstantiator.InstantiatorAttributesHolder; +import org.apache.geode.internal.cache.tier.sockets.ServerConnection; +import org.apache.geode.internal.cache.xmlcache.CacheCreation; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * Implementation used by PoolManager. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PoolStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PoolStats.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PoolStats.java index e53b61c..fcb8a2e 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PoolStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PoolStats.java @@ -14,13 +14,13 @@ * 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.*; -import com.gemstone.gemfire.distributed.internal.DistributionStats; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.*; +import org.apache.geode.distributed.internal.DistributionStats; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.LOCATORS; +import static org.apache.geode.distributed.ConfigurationProperties.LOCATORS; /** * GemFire statistics about a Pool http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PreferBytesCachedDeserializable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PreferBytesCachedDeserializable.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PreferBytesCachedDeserializable.java index 3a582ab..a58fd10 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PreferBytesCachedDeserializable.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PreferBytesCachedDeserializable.java @@ -15,18 +15,18 @@ * 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.DataSerializer; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.lang.StringUtils; +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.i18n.LocalizedStrings; +import org.apache.geode.internal.lang.StringUtils; /** * This cache deserializable always keeps its byte[] in serialized form. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PrimaryBucketException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PrimaryBucketException.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PrimaryBucketException.java index 4a5696b..2bc7ad1 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PrimaryBucketException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PrimaryBucketException.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.GemFireException; +import org.apache.geode.GemFireException; /** * An exception thrown if a bucket instance is not primary yet was requested http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ProfileExchangeProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ProfileExchangeProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ProfileExchangeProcessor.java index fe0e6b0..ea82e84 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ProfileExchangeProcessor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ProfileExchangeProcessor.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 java.util.HashSet; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.InitialImageAdvice; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.CacheDistributionAdvisor.InitialImageAdvice; /** * Used to exchange profiles during region initialization and determine the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyBucketRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyBucketRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyBucketRegion.java index 7078fe2..b8aad7a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyBucketRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyBucketRegion.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.Collections; import java.util.EnumSet; @@ -26,32 +26,32 @@ import java.util.concurrent.atomic.AtomicBoolean; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.EvictionAttributes; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.RegionService; -import com.gemstone.gemfire.cache.persistence.PartitionOfflineException; -import com.gemstone.gemfire.distributed.DistributedLockService; -import com.gemstone.gemfire.distributed.DistributedMember; -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.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.CacheProfile; -import com.gemstone.gemfire.internal.cache.DiskInitFile.DiskRegionFlag; -import com.gemstone.gemfire.internal.cache.PartitionedRegion.BucketLock; -import com.gemstone.gemfire.internal.cache.PartitionedRegionDataStore.CreateBucketResult; -import com.gemstone.gemfire.internal.cache.partitioned.Bucket; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberManager; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMembershipView; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.CancelCriterion; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.EvictionAttributes; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.RegionService; +import org.apache.geode.cache.persistence.PartitionOfflineException; +import org.apache.geode.distributed.DistributedLockService; +import org.apache.geode.distributed.DistributedMember; +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.InternalDistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.CacheDistributionAdvisor.CacheProfile; +import org.apache.geode.internal.cache.DiskInitFile.DiskRegionFlag; +import org.apache.geode.internal.cache.PartitionedRegion.BucketLock; +import org.apache.geode.internal.cache.PartitionedRegionDataStore.CreateBucketResult; +import org.apache.geode.internal.cache.partitioned.Bucket; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.cache.persistence.PersistentMemberManager; +import org.apache.geode.internal.cache.persistence.PersistentMembershipView; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; /** * Empty shell for {@link BucketRegion} which exists only to maintain metadata http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyRegionMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyRegionMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyRegionMap.java index 99d96ab..2e1ba3e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyRegionMap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ProxyRegionMap.java @@ -15,36 +15,36 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.Set; -import com.gemstone.gemfire.cache.CacheWriter; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.EntryEvent; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.cache.TransactionId; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.ByteArrayDataInput; -import com.gemstone.gemfire.internal.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.AbstractRegionMap.ARMLockTestHook; -import com.gemstone.gemfire.internal.cache.lru.LRUEntry; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionHolder; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.versions.VersionStamp; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.offheap.annotations.Released; +import org.apache.geode.cache.CacheWriter; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.EntryEvent; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.cache.TransactionId; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.ByteArrayDataInput; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.AbstractRegionMap.ARMLockTestHook; +import org.apache.geode.internal.cache.lru.LRUEntry; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionHolder; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.versions.VersionStamp; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.offheap.annotations.Released; /** * Internal implementation of {@link RegionMap}for regions whose DataPolicy is @@ -532,7 +532,7 @@ final class ProxyRegionMap implements RegionMap { throw new UnsupportedOperationException(LocalizedStrings.ProxyRegionMap_NO_ENTRY_SUPPORT_ON_REGIONS_WITH_DATAPOLICY_0.toLocalizedString(DataPolicy.EMPTY)); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.RegionEntry#getSerializedValueOnDisk(com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.RegionEntry#getSerializedValueOnDisk(org.apache.geode.internal.cache.LocalRegion) */ public Object getSerializedValueOnDisk(LocalRegion localRegion) { throw new UnsupportedOperationException(LocalizedStrings.ProxyRegionMap_NO_ENTRY_SUPPORT_ON_REGIONS_WITH_DATAPOLICY_0.toLocalizedString(DataPolicy.EMPTY)); @@ -588,7 +588,7 @@ final class ProxyRegionMap implements RegionMap { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.RegionEntry#concurrencyCheck(com.gemstone.gemfire.internal.cache.LocalRegion, com.gemstone.gemfire.internal.cache.versions.VersionTag, com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember, com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember) + * @see org.apache.geode.internal.cache.RegionEntry#concurrencyCheck(org.apache.geode.internal.cache.LocalRegion, org.apache.geode.internal.cache.versions.VersionTag, org.apache.geode.distributed.internal.membership.InternalDistributedMember, org.apache.geode.distributed.internal.membership.InternalDistributedMember) */ public void processVersionTag(LocalRegion r, VersionTag tag, InternalDistributedMember thisVM, InternalDistributedMember sender) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PutAllPartialResultException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PutAllPartialResultException.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PutAllPartialResultException.java index 39e1a02..42b0f0c 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PutAllPartialResultException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PutAllPartialResultException.java @@ -14,11 +14,11 @@ * 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.CancelException; -import com.gemstone.gemfire.GemFireException; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.CancelException; +import org.apache.geode.GemFireException; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; import java.io.Serializable; 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/QueuedOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/QueuedOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/QueuedOperation.java index 7be2bb9..40fcd3c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/QueuedOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/QueuedOperation.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; -import com.gemstone.gemfire.internal.cache.versions.ConcurrentCacheModificationException; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.offheap.annotations.Released; -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.DistributedMember; +import org.apache.geode.internal.cache.versions.ConcurrentCacheModificationException; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.*; +import org.apache.geode.cache.*; +import org.apache.geode.distributed.DistributedMember; import java.io.*; /** @@ -42,7 +42,7 @@ public class QueuedOperation /** * Deserialization policies defined in AbstractUpdateOperation - * @see com.gemstone.gemfire.internal.cache.AbstractUpdateOperation + * @see org.apache.geode.internal.cache.AbstractUpdateOperation */ private final byte deserializationPolicy; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/RegionClearedException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionClearedException.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionClearedException.java index 03d6759..088a51f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionClearedException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionClearedException.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; /** * Indicates that a Clear Operation happened while an entry operation http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntry.java index 48ed5db..bee123d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntry.java @@ -15,26 +15,26 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import static com.gemstone.gemfire.internal.offheap.annotations.OffHeapIdentifier.ABSTRACT_REGION_ENTRY_FILL_IN_VALUE; -import static com.gemstone.gemfire.internal.offheap.annotations.OffHeapIdentifier.ABSTRACT_REGION_ENTRY_PREPARE_VALUE_FOR_CACHE; +import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.ABSTRACT_REGION_ENTRY_FILL_IN_VALUE; +import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.ABSTRACT_REGION_ENTRY_PREPARE_VALUE_FOR_CACHE; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.EntryEvent; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.internal.ByteArrayDataInput; -import com.gemstone.gemfire.internal.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.versions.VersionStamp; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -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 org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.EntryEvent; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.internal.ByteArrayDataInput; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.versions.VersionStamp; +import org.apache.geode.internal.cache.versions.VersionTag; +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; /** * Internal interface for a region entry. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntryContext.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntryContext.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntryContext.java index 064c8f2..7d83586 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntryContext.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntryContext.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.compression.Compressor; +import org.apache.geode.compression.Compressor; /** * Provides important contextual information that allows a {@link RegionEntry} to manage its state. * @since GemFire 8.0 */ public interface RegionEntryContext extends HasCachePerfStats { - public static final String DEFAULT_COMPRESSION_PROVIDER="com.gemstone.gemfire.compression.SnappyCompressor"; + public static final String DEFAULT_COMPRESSION_PROVIDER="org.apache.geode.compression.SnappyCompressor"; /** * Returns the compressor to be used by this region entry when storing the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntryFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntryFactory.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntryFactory.java index a5d9d79..330c198 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntryFactory.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEntryFactory.java @@ -15,7 +15,7 @@ * 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/RegionEventImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEventImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEventImpl.java index 333dfd2..dad8be0 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEventImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEventImpl.java @@ -15,25 +15,25 @@ * 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 java.lang.ClassNotFoundException; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.internal.*; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo.FilterInfo; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.*; +import org.apache.geode.internal.*; +import org.apache.geode.internal.cache.FilterRoutingInfo.FilterInfo; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; /** * Implementation of a region event @@ -126,7 +126,7 @@ public class RegionEventImpl /** * (non-Javadoc) * - * @see com.gemstone.gemfire.cache.CacheEvent#getRegion() + * @see org.apache.geode.cache.CacheEvent#getRegion() */ public Region getRegion() { @@ -152,7 +152,7 @@ public class RegionEventImpl } /** - * @see com.gemstone.gemfire.cache.CacheEvent#getCallbackArgument() + * @see org.apache.geode.cache.CacheEvent#getCallbackArgument() */ public Object getCallbackArgument() { @@ -181,7 +181,7 @@ public class RegionEventImpl } /** - * @see com.gemstone.gemfire.cache.CacheEvent#isOriginRemote() + * @see org.apache.geode.cache.CacheEvent#isOriginRemote() */ public boolean isOriginRemote() { @@ -199,7 +199,7 @@ public class RegionEventImpl } /** - * @see com.gemstone.gemfire.cache.CacheEvent#isExpiration() + * @see org.apache.geode.cache.CacheEvent#isExpiration() */ public boolean isExpiration() { @@ -207,7 +207,7 @@ public class RegionEventImpl } /** - * @see com.gemstone.gemfire.cache.CacheEvent#isDistributed() + * @see org.apache.geode.cache.CacheEvent#isDistributed() */ public boolean isDistributed() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEvictorTask.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEvictorTask.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEvictorTask.java index e47ae91..444cb4e 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEvictorTask.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionEvictorTask.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; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.cache.lru.HeapEvictor; -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.cache.RegionDestroyedException; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.cache.lru.HeapEvictor; +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.logging.log4j.Logger; import java.util.Iterator; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/RegionExpiryTask.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionExpiryTask.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionExpiryTask.java index 2e97065..0fbe869 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionExpiryTask.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionExpiryTask.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * RegionExpiryTask represents a timeout event for region expiration */ -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.ExpirationAttributes; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.TimeoutException; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.ExpirationAttributes; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.TimeoutException; abstract class RegionExpiryTask extends ExpiryTask { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/RegionFactoryImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionFactoryImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionFactoryImpl.java index 254d37d..536cbca 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionFactoryImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionFactoryImpl.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; import java.io.File; import java.util.Properties; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.client.ClientNotReadyException; +import org.apache.geode.CancelException; +import org.apache.geode.cache.*; +import org.apache.geode.cache.client.ClientNotReadyException; /** * <code>RegionFactoryImpl</code> extends RegionFactory http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/RegionIdleExpiryTask.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionIdleExpiryTask.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionIdleExpiryTask.java index ca98f5f..8d6ff61 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionIdleExpiryTask.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionIdleExpiryTask.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.*; +import org.apache.geode.cache.*; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/RegionListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionListener.java b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionListener.java index dd66301..08721cf 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/RegionListener.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/RegionListener.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.Region; -import com.gemstone.gemfire.cache.RegionAttributes; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; /** * Callback on a cache that receives notifications about region creates.
