http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java index 4cbcbd0..a6951de 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java @@ -15,9 +15,9 @@ * 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.*; +import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.*; import java.io.DataInputStream; import java.io.DataOutputStream; @@ -54,164 +54,164 @@ import java.util.regex.Pattern; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.CopyHelper; -import com.gemstone.gemfire.DataSerializable; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.DeltaSerializationException; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.LogWriter; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.admin.internal.SystemMemberCacheEventProcessor; -import com.gemstone.gemfire.cache.AttributesMutator; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.CacheListener; -import com.gemstone.gemfire.cache.CacheLoader; -import com.gemstone.gemfire.cache.CacheLoaderException; -import com.gemstone.gemfire.cache.CacheRuntimeException; -import com.gemstone.gemfire.cache.CacheStatistics; -import com.gemstone.gemfire.cache.CacheWriter; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.CustomExpiry; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.cache.DiskStoreFactory; -import com.gemstone.gemfire.cache.DiskWriteAttributes; -import com.gemstone.gemfire.cache.DiskWriteAttributesFactory; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.EntryExistsException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.EvictionAttributes; -import com.gemstone.gemfire.cache.ExpirationAttributes; -import com.gemstone.gemfire.cache.FailedSynchronizationException; -import com.gemstone.gemfire.cache.InterestRegistrationEvent; -import com.gemstone.gemfire.cache.InterestResultPolicy; -import com.gemstone.gemfire.cache.LoaderHelper; -import com.gemstone.gemfire.cache.LowMemoryException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.PartitionedRegionStorageException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.RegionEvent; -import com.gemstone.gemfire.cache.RegionExistsException; -import com.gemstone.gemfire.cache.RegionMembershipListener; -import com.gemstone.gemfire.cache.RegionReinitializedException; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.cache.StatisticsDisabledException; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.cache.TransactionException; -import com.gemstone.gemfire.cache.TransactionId; -import com.gemstone.gemfire.cache.client.PoolManager; -import com.gemstone.gemfire.cache.client.ServerOperationException; -import com.gemstone.gemfire.cache.client.SubscriptionNotEnabledException; -import com.gemstone.gemfire.cache.client.internal.Connection; -import com.gemstone.gemfire.cache.client.internal.Endpoint; -import com.gemstone.gemfire.cache.client.internal.PoolImpl; -import com.gemstone.gemfire.cache.client.internal.ServerRegionProxy; -import com.gemstone.gemfire.cache.control.ResourceManager; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.cache.partition.PartitionRegionHelper; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.Index; -import com.gemstone.gemfire.cache.query.IndexMaintenanceException; -import com.gemstone.gemfire.cache.query.IndexType; -import com.gemstone.gemfire.cache.query.MultiIndexCreationException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.TypeMismatchException; -import com.gemstone.gemfire.cache.query.internal.DefaultQuery; -import com.gemstone.gemfire.cache.query.internal.DefaultQueryService; -import com.gemstone.gemfire.cache.query.internal.ExecutionContext; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.cache.query.internal.index.IndexCreationData; -import com.gemstone.gemfire.cache.query.internal.index.IndexManager; -import com.gemstone.gemfire.cache.query.internal.index.IndexProtocol; -import com.gemstone.gemfire.cache.query.internal.index.IndexUtils; -import com.gemstone.gemfire.cache.util.ObjectSizer; -import com.gemstone.gemfire.cache.wan.GatewaySender; -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.DistributionAdvisor; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.DistributionStats; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ResourceEvent; -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.ClassLoadUtil; -import com.gemstone.gemfire.internal.HeapDataOutputStream; -import com.gemstone.gemfire.internal.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.NanoTimer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.admin.ClientHealthMonitoringRegion; -import com.gemstone.gemfire.internal.cache.AbstractRegionMap.ARMLockTestHook; -import com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.CacheProfile; -import com.gemstone.gemfire.internal.cache.DiskInitFile.DiskRegionFlag; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo.FilterInfo; -import com.gemstone.gemfire.internal.cache.InitialImageOperation.GIIStatus; -import com.gemstone.gemfire.internal.cache.PutAllPartialResultException.PutAllPartialResult; -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.control.ResourceListener; -import com.gemstone.gemfire.internal.cache.execute.DistributedRegionFunctionExecutor; -import com.gemstone.gemfire.internal.cache.execute.DistributedRegionFunctionResultSender; -import com.gemstone.gemfire.internal.cache.execute.LocalResultCollector; -import com.gemstone.gemfire.internal.cache.execute.RegionFunctionContextImpl; -import com.gemstone.gemfire.internal.cache.execute.ServerToClientFunctionResultSender; -import com.gemstone.gemfire.internal.cache.ha.ThreadIdentifier; -import com.gemstone.gemfire.internal.cache.lru.LRUEntry; -import com.gemstone.gemfire.internal.cache.partitioned.RedundancyAlreadyMetException; -import com.gemstone.gemfire.internal.cache.persistence.DiskExceptionHandler; -import com.gemstone.gemfire.internal.cache.persistence.DiskRecoveryStore; -import com.gemstone.gemfire.internal.cache.persistence.DiskRegionView; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.cache.persistence.query.IndexMap; -import com.gemstone.gemfire.internal.cache.persistence.query.mock.IndexMapImpl; -import com.gemstone.gemfire.internal.cache.tier.InterestType; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientNotifier; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientHealthMonitor; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientTombstoneMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientUpdateMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.HandShake; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.versions.ConcurrentCacheModificationException; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionHolder; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -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.cache.wan.AbstractGatewaySender; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderEventCallbackArgument; -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.offheap.OffHeapHelper; -import com.gemstone.gemfire.internal.offheap.ReferenceCountHelper; -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.internal.sequencelog.EntryLogger; -import com.gemstone.gemfire.internal.util.concurrent.FutureResult; -import com.gemstone.gemfire.internal.util.concurrent.StoppableCountDownLatch; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReadWriteLock; +import org.apache.geode.CancelCriterion; +import org.apache.geode.CancelException; +import org.apache.geode.CopyHelper; +import org.apache.geode.DataSerializable; +import org.apache.geode.DataSerializer; +import org.apache.geode.DeltaSerializationException; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.LogWriter; +import org.apache.geode.SystemFailure; +import org.apache.geode.admin.internal.SystemMemberCacheEventProcessor; +import org.apache.geode.cache.AttributesMutator; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.CacheListener; +import org.apache.geode.cache.CacheLoader; +import org.apache.geode.cache.CacheLoaderException; +import org.apache.geode.cache.CacheRuntimeException; +import org.apache.geode.cache.CacheStatistics; +import org.apache.geode.cache.CacheWriter; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.CustomExpiry; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.cache.DiskStoreFactory; +import org.apache.geode.cache.DiskWriteAttributes; +import org.apache.geode.cache.DiskWriteAttributesFactory; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.EntryExistsException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.EvictionAttributes; +import org.apache.geode.cache.ExpirationAttributes; +import org.apache.geode.cache.FailedSynchronizationException; +import org.apache.geode.cache.InterestRegistrationEvent; +import org.apache.geode.cache.InterestResultPolicy; +import org.apache.geode.cache.LoaderHelper; +import org.apache.geode.cache.LowMemoryException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.PartitionedRegionStorageException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.RegionEvent; +import org.apache.geode.cache.RegionExistsException; +import org.apache.geode.cache.RegionMembershipListener; +import org.apache.geode.cache.RegionReinitializedException; +import org.apache.geode.cache.Scope; +import org.apache.geode.cache.StatisticsDisabledException; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.cache.TransactionException; +import org.apache.geode.cache.TransactionId; +import org.apache.geode.cache.client.PoolManager; +import org.apache.geode.cache.client.ServerOperationException; +import org.apache.geode.cache.client.SubscriptionNotEnabledException; +import org.apache.geode.cache.client.internal.Connection; +import org.apache.geode.cache.client.internal.Endpoint; +import org.apache.geode.cache.client.internal.PoolImpl; +import org.apache.geode.cache.client.internal.ServerRegionProxy; +import org.apache.geode.cache.control.ResourceManager; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.cache.partition.PartitionRegionHelper; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.Index; +import org.apache.geode.cache.query.IndexMaintenanceException; +import org.apache.geode.cache.query.IndexType; +import org.apache.geode.cache.query.MultiIndexCreationException; +import org.apache.geode.cache.query.NameResolutionException; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.TypeMismatchException; +import org.apache.geode.cache.query.internal.DefaultQuery; +import org.apache.geode.cache.query.internal.DefaultQueryService; +import org.apache.geode.cache.query.internal.ExecutionContext; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.cache.query.internal.index.IndexCreationData; +import org.apache.geode.cache.query.internal.index.IndexManager; +import org.apache.geode.cache.query.internal.index.IndexProtocol; +import org.apache.geode.cache.query.internal.index.IndexUtils; +import org.apache.geode.cache.util.ObjectSizer; +import org.apache.geode.cache.wan.GatewaySender; +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.DistributionAdvisor; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.DistributionStats; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ResourceEvent; +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.ClassLoadUtil; +import org.apache.geode.internal.HeapDataOutputStream; +import org.apache.geode.internal.InternalStatisticsDisabledException; +import org.apache.geode.internal.NanoTimer; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.admin.ClientHealthMonitoringRegion; +import org.apache.geode.internal.cache.AbstractRegionMap.ARMLockTestHook; +import org.apache.geode.internal.cache.CacheDistributionAdvisor.CacheProfile; +import org.apache.geode.internal.cache.DiskInitFile.DiskRegionFlag; +import org.apache.geode.internal.cache.FilterRoutingInfo.FilterInfo; +import org.apache.geode.internal.cache.InitialImageOperation.GIIStatus; +import org.apache.geode.internal.cache.PutAllPartialResultException.PutAllPartialResult; +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.control.ResourceListener; +import org.apache.geode.internal.cache.execute.DistributedRegionFunctionExecutor; +import org.apache.geode.internal.cache.execute.DistributedRegionFunctionResultSender; +import org.apache.geode.internal.cache.execute.LocalResultCollector; +import org.apache.geode.internal.cache.execute.RegionFunctionContextImpl; +import org.apache.geode.internal.cache.execute.ServerToClientFunctionResultSender; +import org.apache.geode.internal.cache.ha.ThreadIdentifier; +import org.apache.geode.internal.cache.lru.LRUEntry; +import org.apache.geode.internal.cache.partitioned.RedundancyAlreadyMetException; +import org.apache.geode.internal.cache.persistence.DiskExceptionHandler; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.cache.persistence.DiskRegionView; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.cache.persistence.query.IndexMap; +import org.apache.geode.internal.cache.persistence.query.mock.IndexMapImpl; +import org.apache.geode.internal.cache.tier.InterestType; +import org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier; +import org.apache.geode.internal.cache.tier.sockets.ClientHealthMonitor; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.ClientTombstoneMessage; +import org.apache.geode.internal.cache.tier.sockets.ClientUpdateMessage; +import org.apache.geode.internal.cache.tier.sockets.HandShake; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.versions.ConcurrentCacheModificationException; +import org.apache.geode.internal.cache.versions.RegionVersionHolder; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +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.cache.wan.AbstractGatewaySender; +import org.apache.geode.internal.cache.wan.GatewaySenderEventCallbackArgument; +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.offheap.OffHeapHelper; +import org.apache.geode.internal.offheap.ReferenceCountHelper; +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.internal.sequencelog.EntryLogger; +import org.apache.geode.internal.util.concurrent.FutureResult; +import org.apache.geode.internal.util.concurrent.StoppableCountDownLatch; +import org.apache.geode.internal.util.concurrent.StoppableReadWriteLock; /** * Implementation of a local scoped-region. Note that this class has a different @@ -359,7 +359,7 @@ public class LocalRegion extends AbstractRegion * Prevents access to this region until it is done initializing, except for * some special initializing operations such as replying to create region * messages In JDK 1.5 we will use java.util.concurrent.CountDownLatch instead - * of com.gemstone.gemfire.internal.util.CountDownLatch. + * of org.apache.geode.internal.util.CountDownLatch. */ protected final StoppableCountDownLatch initializationLatchBeforeGetInitialImage; @@ -397,7 +397,7 @@ public class LocalRegion extends AbstractRegion /* * Asif: This boolean needs to be made true if the test needs to receive a * synchronous callback just after clear on map is done. Its visibility is - * default so that only tests present in com.gemstone.gemfire.internal.cache + * default so that only tests present in org.apache.geode.internal.cache * will be able to see it */ public static boolean ISSUE_CALLBACKS_TO_CACHE_OBSERVER = false; @@ -486,7 +486,7 @@ public class LocalRegion extends AbstractRegion } /* (non-Javadoc) - * @see com.gemstone.gemfire.CancelCriterion#generateCancelledException(java.lang.Throwable) + * @see org.apache.geode.CancelCriterion#generateCancelledException(java.lang.Throwable) */ @Override public RuntimeException generateCancelledException(Throwable e) { @@ -1717,7 +1717,7 @@ public class LocalRegion extends AbstractRegion // 3. Check if it has server region proxy. // We do not have a handle to event in PutOpImpl to check if we have // delta bytes calculated already. So no need to calculate it here. - // 4. Check if value is instanceof com.gemstone.gemfire.Delta + // 4. Check if value is instanceof org.apache.geode.Delta // 5. Check if Region in PR with redundantCopies > 0. Set extractDelta. // 6. Check if Region has peers. Set extractDelta. // 7. Check if it has any delta proxies attached to it. Set extractDelta. @@ -1729,7 +1729,7 @@ public class LocalRegion extends AbstractRegion boolean extractDelta = false; // How costly is this if check? if (this.getSystem().getConfig().getDeltaPropagation() - && value instanceof com.gemstone.gemfire.Delta) { + && value instanceof org.apache.geode.Delta) { if (!this.hasServerProxy()) { if ((this instanceof PartitionedRegion)) { if (((PartitionedRegion)this).getRedundantCopies() > 0) { @@ -1760,11 +1760,11 @@ public class LocalRegion extends AbstractRegion // This is a client region extractDelta = true; } - if (extractDelta && ((com.gemstone.gemfire.Delta)value).hasDelta()) { + if (extractDelta && ((org.apache.geode.Delta)value).hasDelta()) { HeapDataOutputStream hdos = new HeapDataOutputStream(Version.CURRENT); long start = DistributionStats.getStatTime(); try { - ((com.gemstone.gemfire.Delta)value).toDelta(hdos); + ((org.apache.geode.Delta)value).toDelta(hdos); } catch (RuntimeException re) { throw re; } catch (Exception e) { @@ -11357,7 +11357,7 @@ public class LocalRegion extends AbstractRegion } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.control.ResourceListener#onEvent(java.lang.Object) + * @see org.apache.geode.cache.control.ResourceListener#onEvent(java.lang.Object) */ public final void onEvent(MemoryEvent event) { if (logger.isDebugEnabled()) { @@ -12624,7 +12624,7 @@ public class LocalRegion extends AbstractRegion } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.DiskRecoveryStore#getVersionForMember(com.gemstone.gemfire.internal.cache.versions.VersionSource) + * @see org.apache.geode.internal.cache.DiskRecoveryStore#getVersionForMember(org.apache.geode.internal.cache.versions.VersionSource) */ @Override public long getVersionForMember(VersionSource member) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegionDataView.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegionDataView.java b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegionDataView.java index ae4789d..1f4faa4 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegionDataView.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegionDataView.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.Collection; 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.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.versions.ConcurrentCacheModificationException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.Region.Entry; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.versions.ConcurrentCacheModificationException; /** * @@ -33,7 +33,7 @@ import com.gemstone.gemfire.internal.cache.versions.ConcurrentCacheModificationE */ public class LocalRegionDataView implements InternalDataView { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getDeserializedValue(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion, boolean) + * @see org.apache.geode.internal.cache.InternalDataView#getDeserializedValue(java.lang.Object, org.apache.geode.internal.cache.LocalRegion, boolean) */ public Object getDeserializedValue(KeyInfo keyInfo, LocalRegion localRegion, @@ -48,7 +48,7 @@ public class LocalRegionDataView implements InternalDataView { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#txDestroyExistingEntry(com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean) + * @see org.apache.geode.internal.cache.InternalDataView#txDestroyExistingEntry(org.apache.geode.internal.cache.EntryEventImpl, boolean) */ public void destroyExistingEntry(EntryEventImpl event, boolean cacheWrite, Object expectedOldValue) { LocalRegion lr = event.getLocalRegion(); @@ -59,7 +59,7 @@ public class LocalRegionDataView implements InternalDataView { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#txInvalidateExistingEntry(com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean) + * @see org.apache.geode.internal.cache.InternalDataView#txInvalidateExistingEntry(org.apache.geode.internal.cache.EntryEventImpl, boolean, boolean) */ public void invalidateExistingEntry(EntryEventImpl event, boolean invokeCallbacks, boolean forceNewEntry) { @@ -83,14 +83,14 @@ public class LocalRegionDataView implements InternalDataView { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#entryCount(com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#entryCount(org.apache.geode.internal.cache.LocalRegion) */ public int entryCount(LocalRegion localRegion) { return localRegion.getRegionSize(); } /* (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) { @@ -98,21 +98,21 @@ public class LocalRegionDataView implements InternalDataView { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#containsKey(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#containsKey(java.lang.Object, org.apache.geode.internal.cache.LocalRegion) */ public boolean containsKey(KeyInfo keyInfo, LocalRegion localRegion) { return localRegion.nonTXContainsKey(keyInfo); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#containsValueForKey(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#containsValueForKey(java.lang.Object, org.apache.geode.internal.cache.LocalRegion) */ public boolean containsValueForKey(KeyInfo keyInfo, LocalRegion localRegion) { return localRegion.nonTXContainsValueForKey(keyInfo); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getEntry(java.lang.Object, com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.InternalDataView#getEntry(java.lang.Object, org.apache.geode.internal.cache.LocalRegion) */ public Entry getEntry(KeyInfo keyInfo, LocalRegion localRegion, boolean allowTombstones) { return localRegion.nonTXGetEntry(keyInfo, false, allowTombstones); @@ -124,7 +124,7 @@ public class LocalRegionDataView implements InternalDataView { /* (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, @@ -133,14 +133,14 @@ public class LocalRegionDataView implements InternalDataView { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#isStatsDeferred() + * @see org.apache.geode.internal.cache.InternalDataView#isStatsDeferred() */ public boolean isDeferredStats() { return false; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#findObject(com.gemstone.gemfire.internal.cache.LocalRegion, java.lang.Object, java.lang.Object, boolean, boolean, java.lang.Object) + * @see org.apache.geode.internal.cache.InternalDataView#findObject(org.apache.geode.internal.cache.LocalRegion, java.lang.Object, java.lang.Object, boolean, boolean, java.lang.Object) */ public Object findObject(KeyInfo keyInfo, LocalRegion r, @@ -156,7 +156,7 @@ public class LocalRegionDataView implements InternalDataView { } /* (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 Region.Entry<?, ?> getEntryForIterator(final KeyInfo keyInfo, final LocalRegion currRgn, boolean rememberReads, boolean allowTombstones) { @@ -169,7 +169,7 @@ public class LocalRegionDataView implements InternalDataView { } /* (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(final KeyInfo keyInfo, final LocalRegion currRgn, boolean rememberReads, boolean allowTombstones) { @@ -184,7 +184,7 @@ public class LocalRegionDataView implements InternalDataView { } /* (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) { return null; @@ -192,7 +192,7 @@ public class LocalRegionDataView implements InternalDataView { /* * (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getSerializedValue(com.gemstone.gemfire.internal.cache.BucketRegion, java.lang.Object, java.lang.Object) + * @see org.apache.geode.internal.cache.InternalDataView#getSerializedValue(org.apache.geode.internal.cache.BucketRegion, java.lang.Object, java.lang.Object) */ public Object getSerializedValue(LocalRegion localRegion, KeyInfo key, @@ -216,7 +216,7 @@ public class LocalRegionDataView implements InternalDataView { } /* (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 { @@ -224,14 +224,14 @@ public class LocalRegionDataView implements InternalDataView { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.InternalDataView#getBucketKeys(int) + * @see org.apache.geode.internal.cache.InternalDataView#getBucketKeys(int) */ public Set getBucketKeys(LocalRegion localRegion, int bucketId, boolean allowTombstones) { throw new IllegalStateException(); } /* (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 { throw new IllegalStateException(); @@ -254,7 +254,7 @@ public class LocalRegionDataView implements InternalDataView { } /* (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) { //return currRegion.getRegionKeysForIteration(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/MemberFunctionStreamingMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/MemberFunctionStreamingMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/MemberFunctionStreamingMessage.java index a28d0f6..b86e707 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/MemberFunctionStreamingMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/MemberFunctionStreamingMessage.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,33 +24,33 @@ 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.CacheClosedException; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.execute.FunctionInvocationTargetException; -import com.gemstone.gemfire.cache.execute.FunctionService; -import com.gemstone.gemfire.cache.execute.ResultSender; -import com.gemstone.gemfire.cache.query.QueryException; -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.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.MessageWithReply; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.execute.FunctionContextImpl; -import com.gemstone.gemfire.internal.cache.execute.FunctionStats; -import com.gemstone.gemfire.internal.cache.execute.MemberFunctionResultSender; -import com.gemstone.gemfire.internal.cache.execute.MultiRegionFunctionContextImpl; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.FunctionInvocationTargetException; +import org.apache.geode.cache.execute.FunctionService; +import org.apache.geode.cache.execute.ResultSender; +import org.apache.geode.cache.query.QueryException; +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.InternalDistributedSystem; +import org.apache.geode.distributed.internal.MessageWithReply; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.execute.FunctionContextImpl; +import org.apache.geode.internal.cache.execute.FunctionStats; +import org.apache.geode.internal.cache.execute.MemberFunctionResultSender; +import org.apache.geode.internal.cache.execute.MultiRegionFunctionContextImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; /** * @@ -378,13 +378,13 @@ public class MemberFunctionStreamingMessage extends DistributionMessage implemen return (ds == null || ds.isDisconnecting()); } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TransactionMessage#canStartRemoteTransaction() + * @see org.apache.geode.internal.cache.TransactionMessage#canStartRemoteTransaction() */ public boolean canStartRemoteTransaction() { return true; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TransactionMessage#getTXUniqId() + * @see org.apache.geode.internal.cache.TransactionMessage#getTXUniqId() */ public int getTXUniqId() { return this.txUniqId; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/MinimumSystemRequirements.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/MinimumSystemRequirements.java b/geode-core/src/main/java/org/apache/geode/internal/cache/MinimumSystemRequirements.java index 775b4ba..c470ab3 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/MinimumSystemRequirements.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/MinimumSystemRequirements.java @@ -15,14 +15,14 @@ * 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.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.lang.SystemUtils; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.lang.SystemUtils; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * Checks that minimum system requirements are met. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/NetSearchExpirationCalculator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/NetSearchExpirationCalculator.java b/geode-core/src/main/java/org/apache/geode/internal/cache/NetSearchExpirationCalculator.java index c1909b8..6810a4b 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/NetSearchExpirationCalculator.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/NetSearchExpirationCalculator.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.*; /** * EntryExpiryTask already implements the algorithm for figuring out http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/Node.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/Node.java b/geode-core/src/main/java/org/apache/geode/internal/cache/Node.java index d94540c..9441e57 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/Node.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/Node.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.*; -import com.gemstone.gemfire.internal.ExternalizableDSFID; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.ExternalizableDSFID; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.DataSerializer; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; /** * Stores information about a PartitionedRegion singleton instance running http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/NonLocalRegionEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/NonLocalRegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/NonLocalRegionEntry.java index 4c1fa7f..ff1ba72 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/NonLocalRegionEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/NonLocalRegionEntry.java @@ -17,30 +17,30 @@ /** * */ -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.CacheWriterException; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.EntryEvent; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.StatisticsDisabledException; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.ByteArrayDataInput; -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.i18n.LocalizedStrings; +import org.apache.geode.DataSerializer; +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.Region; +import org.apache.geode.cache.StatisticsDisabledException; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.ByteArrayDataInput; +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.i18n.LocalizedStrings; public class NonLocalRegionEntry implements RegionEntry, VersionStamp { private long lastModified; @@ -306,14 +306,14 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { /* * (non-Javadoc) * - * @see com.gemstone.gemfire.internal.cache.RegionEntry#getValueOnDiskOrBuffer(com.gemstone.gemfire.internal.cache.LocalRegion) + * @see org.apache.geode.internal.cache.RegionEntry#getValueOnDiskOrBuffer(org.apache.geode.internal.cache.LocalRegion) */ public Object getValueOnDiskOrBuffer(LocalRegion r) throws EntryNotFoundException { throw new UnsupportedOperationException(LocalizedStrings.PartitionedRegion_NOT_APPROPRIATE_FOR_PARTITIONEDREGIONNONLOCALREGIONENTRY.toLocalizedString()); } /* (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.PartitionedRegion_NOT_APPROPRIATE_FOR_PARTITIONEDREGIONNONLOCALREGIONENTRY.toLocalizedString()); @@ -339,7 +339,7 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { // VersionStamp methods ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.RegionEntry#generateVersionTag(com.gemstone.gemfire.distributed.DistributedMember, boolean) + * @see org.apache.geode.internal.cache.RegionEntry#generateVersionTag(org.apache.geode.distributed.DistributedMember, boolean) */ public VersionTag generateVersionTag(VersionSource member, boolean withDelta, LocalRegion region, EntryEventImpl event) { @@ -348,7 +348,7 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { /* (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) { @@ -357,7 +357,7 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.versions.VersionStamp#getEntryVersion() + * @see org.apache.geode.internal.cache.versions.VersionStamp#getEntryVersion() */ public int getEntryVersion() { if (this.versionTag != null) { @@ -374,7 +374,7 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.versions.VersionStamp#getMemberID() + * @see org.apache.geode.internal.cache.versions.VersionStamp#getMemberID() */ public VersionSource getMemberID() { if (this.versionTag != null) { @@ -392,7 +392,7 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.versions.VersionStamp#setEntryVersion(int) + * @see org.apache.geode.internal.cache.versions.VersionStamp#setEntryVersion(int) */ public void setVersions(VersionTag tag) { throw new UnsupportedOperationException(); @@ -400,7 +400,7 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.versions.VersionStamp#setMemberID(com.gemstone.gemfire.distributed.DistributedMember) + * @see org.apache.geode.internal.cache.versions.VersionStamp#setMemberID(org.apache.geode.distributed.DistributedMember) */ public void setMemberID(VersionSource memberID) { throw new UnsupportedOperationException(); @@ -408,7 +408,7 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.versions.VersionStamp#setPreviousMemberID(com.gemstone.gemfire.distributed.DistributedMember) + * @see org.apache.geode.internal.cache.versions.VersionStamp#setPreviousMemberID(org.apache.geode.distributed.DistributedMember) */ public void setPreviousMemberID(DistributedMember previousMemberID) { throw new UnsupportedOperationException(); @@ -416,7 +416,7 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.versions.VersionStamp#asVersionTag() + * @see org.apache.geode.internal.cache.versions.VersionStamp#asVersionTag() */ public VersionTag asVersionTag() { return this.versionTag; @@ -424,7 +424,7 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.versions.VersionStamp#processVersionTag(com.gemstone.gemfire.internal.cache.LocalRegion, com.gemstone.gemfire.internal.cache.versions.VersionTag, boolean, com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember, com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember) + * @see org.apache.geode.internal.cache.versions.VersionStamp#processVersionTag(org.apache.geode.internal.cache.LocalRegion, org.apache.geode.internal.cache.versions.VersionTag, boolean, org.apache.geode.distributed.internal.membership.InternalDistributedMember, org.apache.geode.distributed.internal.membership.InternalDistributedMember) */ public void processVersionTag(LocalRegion r, VersionTag tag, boolean isTombstoneFromGII, boolean hasDelta, @@ -433,7 +433,7 @@ public class NonLocalRegionEntry implements RegionEntry, VersionStamp { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.versions.VersionStamp#getVersionTimeStamp() + * @see org.apache.geode.internal.cache.versions.VersionStamp#getVersionTimeStamp() */ @Override public long getVersionTimeStamp() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/NonLocalRegionEntryWithStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/NonLocalRegionEntryWithStats.java b/geode-core/src/main/java/org/apache/geode/internal/cache/NonLocalRegionEntryWithStats.java index 91ae3f0..70d61a5 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/NonLocalRegionEntryWithStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/NonLocalRegionEntryWithStats.java @@ -17,15 +17,15 @@ /** * */ -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.cache.StatisticsDisabledException; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.InternalStatisticsDisabledException; +import org.apache.geode.cache.StatisticsDisabledException; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.InternalStatisticsDisabledException; public class NonLocalRegionEntryWithStats extends NonLocalRegionEntry { private long hitCount; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/OffHeapRegionEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/OffHeapRegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/OffHeapRegionEntry.java index acd1e63..20d4ae3 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/OffHeapRegionEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/OffHeapRegionEntry.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.internal.offheap.Releasable; +import org.apache.geode.internal.offheap.Releasable; /** * Any RegionEntry that is stored off heap must http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/OfflineCompactionDiskRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/OfflineCompactionDiskRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/OfflineCompactionDiskRegion.java index 516edbe..e71fa7f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/OfflineCompactionDiskRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/OfflineCompactionDiskRegion.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.CancelCriterion; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.internal.cache.persistence.DiskExceptionHandler; -import com.gemstone.gemfire.internal.cache.persistence.DiskRecoveryStore; -import com.gemstone.gemfire.internal.cache.persistence.DiskRegionView; +import org.apache.geode.CancelCriterion; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.internal.cache.persistence.DiskExceptionHandler; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.cache.persistence.DiskRegionView; /** * A disk region that is created when doing offline compaction. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/OpType.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/OpType.java b/geode-core/src/main/java/org/apache/geode/internal/cache/OpType.java index f4a49d6..ca51312 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/OpType.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/OpType.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; /** * Enumerated type for an event operation. * * * - * @see com.gemstone.gemfire.cache.Operation + * @see org.apache.geode.cache.Operation * * @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/Oplog.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java b/geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java index 59b0893..004fc4a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/Oplog.java @@ -14,41 +14,41 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.SerializationException; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.OplogCancelledException; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.*; -import com.gemstone.gemfire.internal.cache.DiskEntry.Helper.Flushable; -import com.gemstone.gemfire.internal.cache.DiskEntry.Helper.ValueWrapper; -import com.gemstone.gemfire.internal.cache.DiskInitFile.DiskRegionFlag; -import com.gemstone.gemfire.internal.cache.DiskStoreImpl.OplogCompactor; -import com.gemstone.gemfire.internal.cache.DiskStoreImpl.OplogEntryIdSet; -import com.gemstone.gemfire.internal.cache.DistributedRegion.DiskPosition; -import com.gemstone.gemfire.internal.cache.lru.EnableLRU; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.cache.persistence.*; -import com.gemstone.gemfire.internal.cache.versions.*; -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.offheap.OffHeapHelper; -import com.gemstone.gemfire.internal.offheap.ReferenceCountHelper; -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.sequencelog.EntryLogger; -import com.gemstone.gemfire.internal.shared.NativeCalls; -import com.gemstone.gemfire.internal.util.BlobHelper; -import com.gemstone.gemfire.internal.util.IOUtils; -import com.gemstone.gemfire.internal.util.TransformUtils; -import com.gemstone.gemfire.pdx.internal.PdxWriterImpl; +package org.apache.geode.internal.cache; + +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.SerializationException; +import org.apache.geode.cache.*; +import org.apache.geode.distributed.OplogCancelledException; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.*; +import org.apache.geode.internal.cache.DiskEntry.Helper.Flushable; +import org.apache.geode.internal.cache.DiskEntry.Helper.ValueWrapper; +import org.apache.geode.internal.cache.DiskInitFile.DiskRegionFlag; +import org.apache.geode.internal.cache.DiskStoreImpl.OplogCompactor; +import org.apache.geode.internal.cache.DiskStoreImpl.OplogEntryIdSet; +import org.apache.geode.internal.cache.DistributedRegion.DiskPosition; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.cache.persistence.*; +import org.apache.geode.internal.cache.versions.*; +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.offheap.OffHeapHelper; +import org.apache.geode.internal.offheap.ReferenceCountHelper; +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.sequencelog.EntryLogger; +import org.apache.geode.internal.shared.NativeCalls; +import org.apache.geode.internal.util.BlobHelper; +import org.apache.geode.internal.util.IOUtils; +import org.apache.geode.internal.util.TransformUtils; +import org.apache.geode.pdx.internal.PdxWriterImpl; import it.unimi.dsi.fastutil.ints.Int2ObjectMap; import it.unimi.dsi.fastutil.ints.Int2ObjectOpenHashMap; import it.unimi.dsi.fastutil.longs.Long2ObjectMap; @@ -1006,9 +1006,9 @@ public final class Oplog implements CompactableOplog, Flushable { // at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:104) // at sun.nio.ch.IOUtil.write(IOUtil.java:60) // at sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:206) - // at com.gemstone.gemfire.internal.cache.Oplog.flush(Oplog.java:3377) + // at org.apache.geode.internal.cache.Oplog.flush(Oplog.java:3377) // at - // com.gemstone.gemfire.internal.cache.Oplog.flushAll(Oplog.java:3419) + // org.apache.geode.internal.cache.Oplog.flushAll(Oplog.java:3419) /* * { String os = System.getProperty("os.name"); if (os != null) { if * (os.indexOf("Windows") != -1) { olf.raf.close(); olf.RAFClosed = @@ -7100,7 +7100,7 @@ public final class Oplog implements CompactableOplog, Flushable { /* * (non-Javadoc) * - * @see com.gemstone.gemfire.internal.cache.DiskEntry#getVersionStamp() + * @see org.apache.geode.internal.cache.DiskEntry#getVersionStamp() */ @Override public VersionStamp getVersionStamp() { @@ -7203,7 +7203,7 @@ public final class Oplog implements CompactableOplog, Flushable { } @Override - public boolean fillInValue(LocalRegion r, com.gemstone.gemfire.internal.cache.InitialImageOperation.Entry entry, + public boolean fillInValue(LocalRegion r, org.apache.geode.internal.cache.InitialImageOperation.Entry entry, ByteArrayDataInput in, DM mgr) { // TODO Auto-generated method stub return false; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/OplogSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/OplogSet.java b/geode-core/src/main/java/org/apache/geode/internal/cache/OplogSet.java index d7f2423..bb7076d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/OplogSet.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/OplogSet.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.DiskEntry.Helper.ValueWrapper; +import org.apache.geode.internal.cache.DiskEntry.Helper.ValueWrapper; public interface OplogSet { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/OrderedTombstoneMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/OrderedTombstoneMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/OrderedTombstoneMap.java index 09d5309..df87ee9 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/OrderedTombstoneMap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/OrderedTombstoneMap.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.Comparator; import java.util.HashMap; @@ -22,9 +22,9 @@ import java.util.Map; import java.util.Map.Entry; import java.util.TreeMap; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.versions.VersionTag; /** * This class is used for sorting tombstones by region version number. Because http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/OverflowOplog.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/OverflowOplog.java b/geode-core/src/main/java/org/apache/geode/internal/cache/OverflowOplog.java index bb792a8..846325c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/OverflowOplog.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/OverflowOplog.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.File; import java.io.IOException; @@ -31,20 +31,20 @@ import java.util.concurrent.locks.ReentrantLock; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.distributed.OplogCancelledException; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.DiskEntry.Helper.Flushable; -import com.gemstone.gemfire.internal.cache.DiskEntry.Helper.ValueWrapper; -import com.gemstone.gemfire.internal.cache.DiskStoreImpl.OplogCompactor; -import com.gemstone.gemfire.internal.cache.Oplog.OplogDiskEntry; -import com.gemstone.gemfire.internal.cache.persistence.BytesAndBits; -import com.gemstone.gemfire.internal.cache.persistence.DiskRegionView; -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 org.apache.geode.cache.DiskAccessException; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.distributed.OplogCancelledException; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.DiskEntry.Helper.Flushable; +import org.apache.geode.internal.cache.DiskEntry.Helper.ValueWrapper; +import org.apache.geode.internal.cache.DiskStoreImpl.OplogCompactor; +import org.apache.geode.internal.cache.Oplog.OplogDiskEntry; +import org.apache.geode.internal.cache.persistence.BytesAndBits; +import org.apache.geode.internal.cache.persistence.DiskRegionView; +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; /** * An oplog used for overflow-only regions. @@ -901,7 +901,7 @@ class OverflowOplog implements CompactableOplog, Flushable { myRAF.readFully(valueBytes); // if (EntryBits.isSerialized(userBits)) { // try { -// com.gemstone.gemfire.internal.util.BlobHelper.deserializeBlob(valueBytes); +// org.apache.geode.internal.util.BlobHelper.deserializeBlob(valueBytes); // } catch (IOException ex) { // throw new RuntimeException("DEBUG readPos=" + readPosition + " len=" + valueLength + "doneApp=" + doneAppending + " userBits=" + userBits, ex); // } catch (ClassNotFoundException ex2) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/OverflowOplogSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/OverflowOplogSet.java b/geode-core/src/main/java/org/apache/geode/internal/cache/OverflowOplogSet.java index 62da419..b98d5fc 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/OverflowOplogSet.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/OverflowOplogSet.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.IOException; import java.nio.channels.FileChannel; @@ -29,11 +29,11 @@ import java.util.concurrent.atomic.AtomicInteger; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.internal.cache.DiskEntry.Helper.ValueWrapper; -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.DiskAccessException; +import org.apache.geode.internal.cache.DiskEntry.Helper.ValueWrapper; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; public class OverflowOplogSet 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/PRContainsValueFunction.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PRContainsValueFunction.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PRContainsValueFunction.java index 5768c99..9f956b0 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PRContainsValueFunction.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PRContainsValueFunction.java @@ -14,15 +14,15 @@ * 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.Iterator; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.execute.FunctionAdapter; -import com.gemstone.gemfire.cache.execute.FunctionContext; -import com.gemstone.gemfire.cache.execute.RegionFunctionContext; -import com.gemstone.gemfire.internal.InternalEntity; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.execute.FunctionAdapter; +import org.apache.geode.cache.execute.FunctionContext; +import org.apache.geode.cache.execute.RegionFunctionContext; +import org.apache.geode.internal.InternalEntity; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java index 9e01c1c..cfedb67 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PRHARedundancyProvider.java @@ -15,41 +15,41 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.PartitionedRegionStorageException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.persistence.PartitionOfflineException; -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.LonerDistributionManager; -import com.gemstone.gemfire.distributed.internal.MembershipListener; -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.NanoTimer; -import com.gemstone.gemfire.internal.OneTaskOnlyExecutor; -import com.gemstone.gemfire.internal.cache.PartitionedRegion.RetryTimeKeeper; -import com.gemstone.gemfire.internal.cache.PartitionedRegionDataStore.CreateBucketResult; -import com.gemstone.gemfire.internal.cache.control.InternalResourceManager; -import com.gemstone.gemfire.internal.cache.partitioned.*; -import com.gemstone.gemfire.internal.cache.partitioned.FetchPartitionDetailsMessage.FetchPartitionDetailsResponse; -import com.gemstone.gemfire.internal.cache.partitioned.ManageBucketMessage.NodeResponse; -import com.gemstone.gemfire.internal.cache.partitioned.RegionAdvisor.PartitionProfile; -import com.gemstone.gemfire.internal.cache.partitioned.rebalance.CompositeDirector; -import com.gemstone.gemfire.internal.cache.partitioned.rebalance.FPRDirector; -import com.gemstone.gemfire.internal.cache.partitioned.rebalance.RebalanceDirector; -import com.gemstone.gemfire.internal.cache.persistence.MembershipFlushRequest; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.cache.persistence.PersistentStateListener; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +package org.apache.geode.internal.cache; + +import org.apache.geode.CancelException; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.PartitionedRegionStorageException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.persistence.PartitionOfflineException; +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.LonerDistributionManager; +import org.apache.geode.distributed.internal.MembershipListener; +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.NanoTimer; +import org.apache.geode.internal.OneTaskOnlyExecutor; +import org.apache.geode.internal.cache.PartitionedRegion.RetryTimeKeeper; +import org.apache.geode.internal.cache.PartitionedRegionDataStore.CreateBucketResult; +import org.apache.geode.internal.cache.control.InternalResourceManager; +import org.apache.geode.internal.cache.partitioned.*; +import org.apache.geode.internal.cache.partitioned.FetchPartitionDetailsMessage.FetchPartitionDetailsResponse; +import org.apache.geode.internal.cache.partitioned.ManageBucketMessage.NodeResponse; +import org.apache.geode.internal.cache.partitioned.RegionAdvisor.PartitionProfile; +import org.apache.geode.internal.cache.partitioned.rebalance.CompositeDirector; +import org.apache.geode.internal.cache.partitioned.rebalance.FPRDirector; +import org.apache.geode.internal.cache.partitioned.rebalance.RebalanceDirector; +import org.apache.geode.internal.cache.persistence.MembershipFlushRequest; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.cache.persistence.PersistentStateListener; +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.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java index 967a39d..02a5ce8 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PRQueryProcessor.java @@ -14,24 +14,24 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.cache.CacheRuntimeException; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.QueryInvocationTargetException; -import com.gemstone.gemfire.cache.query.SelectResults; -import com.gemstone.gemfire.cache.query.internal.*; -import com.gemstone.gemfire.cache.query.types.ObjectType; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.PartitionedRegionQueryEvaluator.PRQueryResultCollector; -import com.gemstone.gemfire.internal.cache.execute.BucketMovedException; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.cache.CacheRuntimeException; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.cache.query.QueryInvocationTargetException; +import org.apache.geode.cache.query.SelectResults; +import org.apache.geode.cache.query.internal.*; +import org.apache.geode.cache.query.types.ObjectType; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.PartitionedRegionQueryEvaluator.PRQueryResultCollector; +import org.apache.geode.internal.cache.execute.BucketMovedException; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; 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/PRSystemPropertyGetter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PRSystemPropertyGetter.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PRSystemPropertyGetter.java index 868a3e9..f141257 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PRSystemPropertyGetter.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PRSystemPropertyGetter.java @@ -18,7 +18,7 @@ * Created on Dec 22, 2005 * */ -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/PartitionAttributesImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionAttributesImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionAttributesImpl.java index dd90a62..243c7a1 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionAttributesImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionAttributesImpl.java @@ -17,7 +17,7 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -31,22 +31,22 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializable; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.FixedPartitionAttributes; -import com.gemstone.gemfire.cache.PartitionAttributes; -import com.gemstone.gemfire.cache.PartitionAttributesFactory; -import com.gemstone.gemfire.cache.PartitionResolver; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.partition.PartitionListener; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.offheap.OffHeapStorage; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.DataSerializable; +import org.apache.geode.DataSerializer; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.FixedPartitionAttributes; +import org.apache.geode.cache.PartitionAttributes; +import org.apache.geode.cache.PartitionAttributesFactory; +import org.apache.geode.cache.PartitionResolver; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.partition.PartitionListener; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.offheap.OffHeapStorage; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * Internal implementation of PartitionAttributes. New attributes existing http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionRegionConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionRegionConfig.java b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionRegionConfig.java index 926c47a..44f6888 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionRegionConfig.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/PartitionRegionConfig.java @@ -18,25 +18,25 @@ /* * Created on Dec 1, 2005 */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.*; import java.io.*; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.internal.ExternalizableDSFID; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.cache.EvictionAttributes; -import com.gemstone.gemfire.cache.ExpirationAttributes; -import com.gemstone.gemfire.cache.FixedPartitionAttributes; -import com.gemstone.gemfire.cache.PartitionAttributes; -import com.gemstone.gemfire.internal.cache.PartitionAttributesImpl; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.cache.partition.PartitionListener; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.util.Versionable; -import com.gemstone.gemfire.internal.util.VersionedArrayList; +import org.apache.geode.DataSerializer; +import org.apache.geode.internal.ExternalizableDSFID; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.cache.EvictionAttributes; +import org.apache.geode.cache.ExpirationAttributes; +import org.apache.geode.cache.FixedPartitionAttributes; +import org.apache.geode.cache.PartitionAttributes; +import org.apache.geode.internal.cache.PartitionAttributesImpl; +import org.apache.geode.cache.Scope; +import org.apache.geode.cache.partition.PartitionListener; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.util.Versionable; +import org.apache.geode.internal.util.VersionedArrayList; /** * Maintains configuration information for a PartitionedRegion. Instances are