http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/GemFireCacheImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/GemFireCacheImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/GemFireCacheImpl.java index 1364b3e..93a9c3b 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/GemFireCacheImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/GemFireCacheImpl.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.BufferedReader; import java.io.ByteArrayInputStream; @@ -76,161 +76,161 @@ import com.sun.jna.Platform; import org.apache.geode.redis.GeodeRedisServer; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.ForcedDisconnectException; -import com.gemstone.gemfire.GemFireCacheException; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.LogWriter; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.admin.internal.SystemMemberCacheEventProcessor; -import com.gemstone.gemfire.cache.AttributesFactory; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.CacheExistsException; -import com.gemstone.gemfire.cache.CacheRuntimeException; -import com.gemstone.gemfire.cache.CacheTransactionManager; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.CacheXmlException; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.Declarable; -import com.gemstone.gemfire.cache.DiskStore; -import com.gemstone.gemfire.cache.DiskStoreFactory; -import com.gemstone.gemfire.cache.DynamicRegionFactory; -import com.gemstone.gemfire.cache.EvictionAction; -import com.gemstone.gemfire.cache.EvictionAttributes; -import com.gemstone.gemfire.cache.GatewayException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.PartitionAttributesFactory; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.RegionExistsException; -import com.gemstone.gemfire.cache.RegionFactory; -import com.gemstone.gemfire.cache.RegionService; -import com.gemstone.gemfire.cache.RegionShortcut; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue; -import com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueueFactory; -import com.gemstone.gemfire.cache.asyncqueue.internal.AsyncEventQueueFactoryImpl; -import com.gemstone.gemfire.cache.asyncqueue.internal.AsyncEventQueueImpl; -import com.gemstone.gemfire.cache.client.ClientCache; -import com.gemstone.gemfire.cache.client.ClientRegionFactory; -import com.gemstone.gemfire.cache.client.ClientRegionShortcut; -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.ClientMetadataService; -import com.gemstone.gemfire.cache.client.internal.ClientRegionFactoryImpl; -import com.gemstone.gemfire.cache.client.internal.PoolImpl; -import com.gemstone.gemfire.cache.execute.FunctionService; -import com.gemstone.gemfire.cache.query.QueryService; -import com.gemstone.gemfire.cache.query.internal.DefaultQuery; -import com.gemstone.gemfire.cache.query.internal.DefaultQueryService; -import com.gemstone.gemfire.cache.query.internal.QueryMonitor; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.cache.query.internal.cq.CqServiceProvider; -import com.gemstone.gemfire.cache.server.CacheServer; -import com.gemstone.gemfire.cache.snapshot.CacheSnapshotService; -import com.gemstone.gemfire.cache.util.GatewayConflictResolver; -import com.gemstone.gemfire.cache.wan.GatewayReceiver; -import com.gemstone.gemfire.cache.wan.GatewayReceiverFactory; -import com.gemstone.gemfire.cache.wan.GatewaySender; -import com.gemstone.gemfire.cache.wan.GatewaySenderFactory; -import com.gemstone.gemfire.distributed.DistributedLockService; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.DistributedSystemDisconnectedException; -import com.gemstone.gemfire.distributed.Locator; -import com.gemstone.gemfire.distributed.internal.CacheTime; -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.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.InternalLocator; -import com.gemstone.gemfire.distributed.internal.PooledExecutorWithDMStats; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.ResourceEvent; -import com.gemstone.gemfire.distributed.internal.ResourceEventsListener; -import com.gemstone.gemfire.distributed.internal.ServerLocation; -import com.gemstone.gemfire.distributed.internal.locks.DLockService; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.i18n.LogWriterI18n; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.ClassPathLoader; -import com.gemstone.gemfire.internal.JarDeployer; -import com.gemstone.gemfire.internal.net.SocketCreator; -import com.gemstone.gemfire.internal.SystemTimer; -import com.gemstone.gemfire.internal.cache.control.InternalResourceManager; -import com.gemstone.gemfire.internal.cache.control.InternalResourceManager.ResourceType; -import com.gemstone.gemfire.internal.cache.control.ResourceAdvisor; -import com.gemstone.gemfire.internal.cache.execute.util.FindRestEnabledServersFunction; -import com.gemstone.gemfire.internal.cache.extension.Extensible; -import com.gemstone.gemfire.internal.cache.extension.ExtensionPoint; -import com.gemstone.gemfire.internal.cache.extension.SimpleExtensionPoint; -import com.gemstone.gemfire.internal.cache.ha.HARegionQueue; -import com.gemstone.gemfire.internal.cache.locks.TXLockService; -import com.gemstone.gemfire.internal.cache.lru.HeapEvictor; -import com.gemstone.gemfire.internal.cache.lru.OffHeapEvictor; -import com.gemstone.gemfire.internal.cache.partitioned.RedundancyAlreadyMetException; -import com.gemstone.gemfire.internal.cache.persistence.BackupManager; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberManager; -import com.gemstone.gemfire.internal.cache.persistence.query.TemporaryResultSetFactory; -import com.gemstone.gemfire.internal.cache.snapshot.CacheSnapshotServiceImpl; -import com.gemstone.gemfire.internal.cache.tier.sockets.AcceptorImpl; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientNotifier; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientProxy; -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.ServerConnection; -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySender; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderAdvisor; -import com.gemstone.gemfire.internal.cache.wan.WANServiceProvider; -import com.gemstone.gemfire.internal.cache.wan.parallel.ParallelGatewaySenderQueue; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheXmlParser; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheXmlPropertyResolver; -import com.gemstone.gemfire.internal.cache.xmlcache.PropertyResolver; -import com.gemstone.gemfire.internal.concurrent.ConcurrentHashSet; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.jndi.JNDIInvoker; -import com.gemstone.gemfire.internal.jta.TransactionManagerImpl; -import com.gemstone.gemfire.internal.logging.InternalLogWriter; -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.net.SocketCreator; -import com.gemstone.gemfire.internal.offheap.MemoryAllocator; -import com.gemstone.gemfire.internal.process.ClusterConfigurationNotAvailableException; -import com.gemstone.gemfire.internal.sequencelog.SequenceLoggerImpl; -import com.gemstone.gemfire.internal.tcp.ConnectionTable; -import com.gemstone.gemfire.internal.util.concurrent.FutureResult; -import com.gemstone.gemfire.lang.Identifiable; -import com.gemstone.gemfire.management.internal.JmxManagerAdvisee; -import com.gemstone.gemfire.management.internal.JmxManagerAdvisor; -import com.gemstone.gemfire.management.internal.RestAgent; -import com.gemstone.gemfire.management.internal.beans.ManagementListener; -import com.gemstone.gemfire.management.internal.configuration.messages.ConfigurationResponse; -import com.gemstone.gemfire.memcached.GemFireMemcachedServer; -import com.gemstone.gemfire.memcached.GemFireMemcachedServer.Protocol; -import com.gemstone.gemfire.pdx.PdxInstance; -import com.gemstone.gemfire.pdx.PdxInstanceFactory; -import com.gemstone.gemfire.pdx.PdxSerializer; -import com.gemstone.gemfire.pdx.ReflectionBasedAutoSerializer; -import com.gemstone.gemfire.pdx.internal.AutoSerializableManager; -import com.gemstone.gemfire.pdx.internal.PdxInstanceFactoryImpl; -import com.gemstone.gemfire.pdx.internal.PdxInstanceImpl; -import com.gemstone.gemfire.pdx.internal.TypeRegistry; +import org.apache.geode.CancelCriterion; +import org.apache.geode.CancelException; +import org.apache.geode.ForcedDisconnectException; +import org.apache.geode.GemFireCacheException; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.LogWriter; +import org.apache.geode.SystemFailure; +import org.apache.geode.admin.internal.SystemMemberCacheEventProcessor; +import org.apache.geode.cache.AttributesFactory; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.CacheExistsException; +import org.apache.geode.cache.CacheRuntimeException; +import org.apache.geode.cache.CacheTransactionManager; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.CacheXmlException; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.Declarable; +import org.apache.geode.cache.DiskStore; +import org.apache.geode.cache.DiskStoreFactory; +import org.apache.geode.cache.DynamicRegionFactory; +import org.apache.geode.cache.EvictionAction; +import org.apache.geode.cache.EvictionAttributes; +import org.apache.geode.cache.GatewayException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.PartitionAttributesFactory; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.RegionExistsException; +import org.apache.geode.cache.RegionFactory; +import org.apache.geode.cache.RegionService; +import org.apache.geode.cache.RegionShortcut; +import org.apache.geode.cache.Scope; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.cache.asyncqueue.AsyncEventQueue; +import org.apache.geode.cache.asyncqueue.AsyncEventQueueFactory; +import org.apache.geode.cache.asyncqueue.internal.AsyncEventQueueFactoryImpl; +import org.apache.geode.cache.asyncqueue.internal.AsyncEventQueueImpl; +import org.apache.geode.cache.client.ClientCache; +import org.apache.geode.cache.client.ClientRegionFactory; +import org.apache.geode.cache.client.ClientRegionShortcut; +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.ClientMetadataService; +import org.apache.geode.cache.client.internal.ClientRegionFactoryImpl; +import org.apache.geode.cache.client.internal.PoolImpl; +import org.apache.geode.cache.execute.FunctionService; +import org.apache.geode.cache.query.QueryService; +import org.apache.geode.cache.query.internal.DefaultQuery; +import org.apache.geode.cache.query.internal.DefaultQueryService; +import org.apache.geode.cache.query.internal.QueryMonitor; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.cache.query.internal.cq.CqServiceProvider; +import org.apache.geode.cache.server.CacheServer; +import org.apache.geode.cache.snapshot.CacheSnapshotService; +import org.apache.geode.cache.util.GatewayConflictResolver; +import org.apache.geode.cache.wan.GatewayReceiver; +import org.apache.geode.cache.wan.GatewayReceiverFactory; +import org.apache.geode.cache.wan.GatewaySender; +import org.apache.geode.cache.wan.GatewaySenderFactory; +import org.apache.geode.distributed.DistributedLockService; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.DistributedSystemDisconnectedException; +import org.apache.geode.distributed.Locator; +import org.apache.geode.distributed.internal.CacheTime; +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.DistributionConfig; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.InternalLocator; +import org.apache.geode.distributed.internal.PooledExecutorWithDMStats; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.ResourceEvent; +import org.apache.geode.distributed.internal.ResourceEventsListener; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.distributed.internal.locks.DLockService; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.i18n.LogWriterI18n; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.ClassPathLoader; +import org.apache.geode.internal.JarDeployer; +import org.apache.geode.internal.net.SocketCreator; +import org.apache.geode.internal.SystemTimer; +import org.apache.geode.internal.cache.control.InternalResourceManager; +import org.apache.geode.internal.cache.control.InternalResourceManager.ResourceType; +import org.apache.geode.internal.cache.control.ResourceAdvisor; +import org.apache.geode.internal.cache.execute.util.FindRestEnabledServersFunction; +import org.apache.geode.internal.cache.extension.Extensible; +import org.apache.geode.internal.cache.extension.ExtensionPoint; +import org.apache.geode.internal.cache.extension.SimpleExtensionPoint; +import org.apache.geode.internal.cache.ha.HARegionQueue; +import org.apache.geode.internal.cache.locks.TXLockService; +import org.apache.geode.internal.cache.lru.HeapEvictor; +import org.apache.geode.internal.cache.lru.OffHeapEvictor; +import org.apache.geode.internal.cache.partitioned.RedundancyAlreadyMetException; +import org.apache.geode.internal.cache.persistence.BackupManager; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.cache.persistence.PersistentMemberManager; +import org.apache.geode.internal.cache.persistence.query.TemporaryResultSetFactory; +import org.apache.geode.internal.cache.snapshot.CacheSnapshotServiceImpl; +import org.apache.geode.internal.cache.tier.sockets.AcceptorImpl; +import org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier; +import org.apache.geode.internal.cache.tier.sockets.CacheClientProxy; +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.ServerConnection; +import org.apache.geode.internal.cache.wan.AbstractGatewaySender; +import org.apache.geode.internal.cache.wan.GatewaySenderAdvisor; +import org.apache.geode.internal.cache.wan.WANServiceProvider; +import org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue; +import org.apache.geode.internal.cache.xmlcache.CacheXmlParser; +import org.apache.geode.internal.cache.xmlcache.CacheXmlPropertyResolver; +import org.apache.geode.internal.cache.xmlcache.PropertyResolver; +import org.apache.geode.internal.concurrent.ConcurrentHashSet; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.jndi.JNDIInvoker; +import org.apache.geode.internal.jta.TransactionManagerImpl; +import org.apache.geode.internal.logging.InternalLogWriter; +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.net.SocketCreator; +import org.apache.geode.internal.offheap.MemoryAllocator; +import org.apache.geode.internal.process.ClusterConfigurationNotAvailableException; +import org.apache.geode.internal.sequencelog.SequenceLoggerImpl; +import org.apache.geode.internal.tcp.ConnectionTable; +import org.apache.geode.internal.util.concurrent.FutureResult; +import org.apache.geode.lang.Identifiable; +import org.apache.geode.management.internal.JmxManagerAdvisee; +import org.apache.geode.management.internal.JmxManagerAdvisor; +import org.apache.geode.management.internal.RestAgent; +import org.apache.geode.management.internal.beans.ManagementListener; +import org.apache.geode.management.internal.configuration.messages.ConfigurationResponse; +import org.apache.geode.memcached.GemFireMemcachedServer; +import org.apache.geode.memcached.GemFireMemcachedServer.Protocol; +import org.apache.geode.pdx.PdxInstance; +import org.apache.geode.pdx.PdxInstanceFactory; +import org.apache.geode.pdx.PdxSerializer; +import org.apache.geode.pdx.ReflectionBasedAutoSerializer; +import org.apache.geode.pdx.internal.AutoSerializableManager; +import org.apache.geode.pdx.internal.PdxInstanceFactoryImpl; +import org.apache.geode.pdx.internal.PdxInstanceImpl; +import org.apache.geode.pdx.internal.TypeRegistry; // @todo somebody Come up with more reasonable values for {@link #DEFAULT_LOCK_TIMEOUT}, etc. /** - * GemFire's implementation of a distributed {@link com.gemstone.gemfire.cache.Cache}. + * GemFire's implementation of a distributed {@link org.apache.geode.cache.Cache}. * */ @SuppressWarnings("deprecation") @@ -628,7 +628,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer } /** - * This is for debugging cache-open issues (esp. {@link com.gemstone.gemfire.cache.CacheExistsException}) + * This is for debugging cache-open issues (esp. {@link org.apache.geode.cache.CacheExistsException}) */ @Override public String toString() { @@ -1275,7 +1275,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer * @throws CacheXmlException * If something goes wrong while parsing the declarative caching XML file. * @throws TimeoutException - * If a {@link com.gemstone.gemfire.cache.Region#put(Object, Object)}times out while initializing the cache. + * If a {@link org.apache.geode.cache.Region#put(Object, Object)}times out while initializing the cache. * @throws CacheWriterException * If a <code>CacheWriterException</code> is thrown while initializing the cache. * @throws RegionExistsException @@ -1400,7 +1400,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer /* * (non-Javadoc) * - * @see com.gemstone.gemfire.CancelCriterion#cancelInProgress() + * @see org.apache.geode.CancelCriterion#cancelInProgress() */ @Override public String cancelInProgress() { @@ -1420,7 +1420,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer /* * (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) { @@ -2701,7 +2701,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer /* * (non-Javadoc) * - * @see com.gemstone.gemfire.cache.Cache#getMembers() + * @see org.apache.geode.cache.Cache#getMembers() */ public Set<DistributedMember> getMembers() { return Collections.unmodifiableSet(this.dm.getOtherNormalDistributionManagerIds()); @@ -2710,7 +2710,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer /* * (non-Javadoc) * - * @see com.gemstone.gemfire.cache.Cache#getAdminMembers() + * @see org.apache.geode.cache.Cache#getAdminMembers() */ public Set<DistributedMember> getAdminMembers() { return this.dm.getAdminMemberSet(); @@ -2719,7 +2719,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer /* * (non-Javadoc) * - * @see com.gemstone.gemfire.cache.Cache#getMembers(com.gemstone.gemfire.cache.Region) + * @see org.apache.geode.cache.Cache#getMembers(org.apache.geode.cache.Region) */ public Set<DistributedMember> getMembers(Region r) { if (r instanceof DistributedRegion) { @@ -2736,7 +2736,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer /* * (non-Javadoc) * - * @see com.gemstone.gemfire.cache.client.ClientCache#getCurrentServers() + * @see org.apache.geode.cache.client.ClientCache#getCurrentServers() */ public Set<InetSocketAddress> getCurrentServers() { Map<String, Pool> pools = PoolManager.getAll(); @@ -3617,7 +3617,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer } /** - * Implementation of {@link com.gemstone.gemfire.cache.Cache#setCopyOnRead} + * Implementation of {@link org.apache.geode.cache.Cache#setCopyOnRead} * * @since GemFire 4.0 */ @@ -3626,7 +3626,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer } /** - * Implementation of {@link com.gemstone.gemfire.cache.Cache#getCopyOnRead} + * Implementation of {@link org.apache.geode.cache.Cache#getCopyOnRead} * * @since GemFire 4.0 */ @@ -4525,7 +4525,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer */ public QueryMonitor getQueryMonitor() { //Check to see if monitor is required if ResourceManager critical heap percentage is set - //@see com.gemstone.gemfire.cache.control.ResourceManager#setCriticalHeapPercentage(int) + //@see org.apache.geode.cache.control.ResourceManager#setCriticalHeapPercentage(int) //or whether we override it with the system variable; boolean monitorRequired = !QUERY_MONITOR_DISABLED_FOR_LOW_MEM && QUERY_MONITOR_REQUIRED_FOR_RESOURCE_MANAGER; // Added for DUnit test purpose, which turns-on and off the this.TEST_MAX_QUERY_EXECUTION_TIME.
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/GemfireCacheHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/GemfireCacheHelper.java b/geode-core/src/main/java/org/apache/geode/internal/cache/GemfireCacheHelper.java index 19fd3fa..45cba65 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/GemfireCacheHelper.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/GemfireCacheHelper.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.concurrent.FutureTask; import java.util.concurrent.ThreadFactory; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/GridAdvisor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/GridAdvisor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/GridAdvisor.java index ff7dea1..c6ae9a2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/GridAdvisor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/GridAdvisor.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.*; import java.io.*; -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.distributed.DistributedSystemDisconnectedException; -import com.gemstone.gemfire.distributed.Locator; -import com.gemstone.gemfire.distributed.internal.*; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -import com.gemstone.gemfire.distributed.internal.membership.*; +import org.apache.geode.*; +import org.apache.geode.distributed.DistributedSystemDisconnectedException; +import org.apache.geode.distributed.Locator; +import org.apache.geode.distributed.internal.*; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.distributed.internal.membership.*; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/HARegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/HARegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/HARegion.java index d79cb72..772c20b 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/HARegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/HARegion.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -25,29 +25,29 @@ import java.util.Map; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializable; -import com.gemstone.gemfire.cache.CacheLoader; -import com.gemstone.gemfire.cache.CacheLoaderException; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.ExpirationAction; -import com.gemstone.gemfire.cache.ExpirationAttributes; -import com.gemstone.gemfire.cache.LoaderHelper; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.RegionExistsException; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.ha.HARegionQueue; -import com.gemstone.gemfire.internal.cache.ha.ThreadIdentifier; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.HAEventWrapper; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.annotations.Released; +import org.apache.geode.DataSerializable; +import org.apache.geode.cache.CacheLoader; +import org.apache.geode.cache.CacheLoaderException; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.ExpirationAction; +import org.apache.geode.cache.ExpirationAttributes; +import org.apache.geode.cache.LoaderHelper; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.RegionExistsException; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.ha.HARegionQueue; +import org.apache.geode.internal.cache.ha.ThreadIdentifier; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.HAEventWrapper; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.annotations.Released; /** * This region is being implemented to suppress distribution of puts and to @@ -335,7 +335,7 @@ public final class HARegion extends DistributedRegion * This method is overriden so as to make isOriginRemote true always so that * the operation is never propagated to other nodes * - * @see com.gemstone.gemfire.internal.cache.AbstractRegion#destroyRegion() + * @see org.apache.geode.internal.cache.AbstractRegion#destroyRegion() */ @Override public void destroyRegion(Object aCallbackArgument) @@ -481,7 +481,7 @@ public final class HARegion extends DistributedRegion } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.LocalRegion#getEventState() + * @see org.apache.geode.internal.cache.LocalRegion#getEventState() */ @Override public Map<? extends DataSerializable, ? extends DataSerializable> getEventState() { @@ -537,7 +537,7 @@ public final class HARegion extends DistributedRegion } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor#adviseInitialImage(com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.InitialImageAdvice) + * @see org.apache.geode.internal.cache.CacheDistributionAdvisor#adviseInitialImage(org.apache.geode.internal.cache.CacheDistributionAdvisor.InitialImageAdvice) */ @Override public InitialImageAdvice adviseInitialImage( @@ -582,7 +582,7 @@ public final class HARegion extends DistributedRegion } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.CacheProfile#fromData(java.io.DataInput) + * @see org.apache.geode.internal.cache.CacheDistributionAdvisor.CacheProfile#fromData(java.io.DataInput) */ @Override public void fromData(DataInput in) throws IOException, @@ -594,7 +594,7 @@ public final class HARegion extends DistributedRegion } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.CacheProfile#toData(java.io.DataOutput) + * @see org.apache.geode.internal.cache.CacheDistributionAdvisor.CacheProfile#toData(java.io.DataOutput) */ @Override public void toData(DataOutput out) throws IOException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/HasCachePerfStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/HasCachePerfStats.java b/geode-core/src/main/java/org/apache/geode/internal/cache/HasCachePerfStats.java index 70aaa97..7d52f57 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/HasCachePerfStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/HasCachePerfStats.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; public interface HasCachePerfStats { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/IdentityArrayList.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/IdentityArrayList.java b/geode-core/src/main/java/org/apache/geode/internal/cache/IdentityArrayList.java index 736f6bf..1640fa9 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/IdentityArrayList.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/IdentityArrayList.java @@ -18,7 +18,7 @@ * This is a modified version of the fastutil ObjectArrayList. It is modified * to use identity checks rather than equality checks for higher performance. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Arrays; import java.util.Collection; 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/ImageState.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ImageState.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ImageState.java index da3873c..05378ed 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ImageState.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ImageState.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Collection; import java.util.Iterator; import java.util.Set; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.versions.VersionTag; /** * State object used during getInitialImage Locked during clean up of destroyed http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InMemoryPersistentMemberView.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InMemoryPersistentMemberView.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InMemoryPersistentMemberView.java index aa55634..65f7349 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InMemoryPersistentMemberView.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InMemoryPersistentMemberView.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.HashSet; import java.util.Map; @@ -22,11 +22,11 @@ import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.Collections; -import com.gemstone.gemfire.internal.cache.persistence.DiskStoreID; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberPattern; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberState; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberView; +import org.apache.geode.internal.cache.persistence.DiskStoreID; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.cache.persistence.PersistentMemberPattern; +import org.apache.geode.internal.cache.persistence.PersistentMemberState; +import org.apache.geode.internal.cache.persistence.PersistentMemberView; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/IncomingGatewayStatus.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/IncomingGatewayStatus.java b/geode-core/src/main/java/org/apache/geode/internal/cache/IncomingGatewayStatus.java index abcbcf1..a35b9bc 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/IncomingGatewayStatus.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/IncomingGatewayStatus.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.Serializable; import java.net.InetAddress; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageFlowControl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageFlowControl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageFlowControl.java index 613d040..8c4ae0c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageFlowControl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageFlowControl.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; @@ -27,17 +27,17 @@ import java.util.concurrent.atomic.AtomicBoolean; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.MembershipListener; -import com.gemstone.gemfire.distributed.internal.ProcessorKeeper21; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -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.i18n.StringId; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.MembershipListener; +import org.apache.geode.distributed.internal.ProcessorKeeper21; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.DataSerializableFixedID; +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.i18n.StringId; /** * This class keeps track of how many InitialImageMessages are in flight between the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageOperation.java index 7ee5c74..df4746d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InitialImageOperation.java @@ -15,41 +15,41 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.query.internal.CqStateImpl; -import com.gemstone.gemfire.cache.query.internal.DefaultQueryService; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.cache.query.internal.cq.ServerCQ; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.*; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.*; -import com.gemstone.gemfire.internal.cache.InitialImageFlowControl.FlowControlPermitMessage; -import com.gemstone.gemfire.internal.cache.ha.HAContainerWrapper; -import com.gemstone.gemfire.internal.cache.persistence.DiskStoreID; -import com.gemstone.gemfire.internal.cache.persistence.PersistenceAdvisor; -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.CacheClientProxy; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.versions.*; -import com.gemstone.gemfire.internal.cache.vmotion.VMotionObserverHolder; -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySender; -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.sequencelog.EntryLogger; -import com.gemstone.gemfire.internal.sequencelog.RegionLogger; -import com.gemstone.gemfire.internal.util.ObjectIntProcedure; +package org.apache.geode.internal.cache; + +import org.apache.geode.*; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.query.internal.CqStateImpl; +import org.apache.geode.cache.query.internal.DefaultQueryService; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.cache.query.internal.cq.ServerCQ; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.*; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.*; +import org.apache.geode.internal.cache.InitialImageFlowControl.FlowControlPermitMessage; +import org.apache.geode.internal.cache.ha.HAContainerWrapper; +import org.apache.geode.internal.cache.persistence.DiskStoreID; +import org.apache.geode.internal.cache.persistence.PersistenceAdvisor; +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.CacheClientProxy; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.versions.*; +import org.apache.geode.internal.cache.vmotion.VMotionObserverHolder; +import org.apache.geode.internal.cache.wan.AbstractGatewaySender; +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.sequencelog.EntryLogger; +import org.apache.geode.internal.sequencelog.RegionLogger; +import org.apache.geode.internal.util.ObjectIntProcedure; import org.apache.logging.log4j.Logger; import java.io.*; @@ -200,14 +200,14 @@ public class InitialImageOperation { * @param advice * @param recoveredRVV recovered rvv * @return true if succeeded to get image - * @throws com.gemstone.gemfire.cache.TimeoutException + * @throws org.apache.geode.cache.TimeoutException */ GIIStatus getFromOne( Set recipientSet, boolean targetReinitialized, CacheDistributionAdvisor.InitialImageAdvice advice, boolean recoveredFromDisk, RegionVersionVector recoveredRVV) - throws com.gemstone.gemfire.cache.TimeoutException + throws org.apache.geode.cache.TimeoutException { final boolean isDebugEnabled = logger.isDebugEnabled(); @@ -485,8 +485,8 @@ public class InitialImageOperation { continue; } catch (InternalGemFireException ex) { Throwable cause = ex.getCause(); - if (cause instanceof com.gemstone.gemfire.cache.TimeoutException) { - throw (com.gemstone.gemfire.cache.TimeoutException)cause; + if (cause instanceof org.apache.geode.cache.TimeoutException) { + throw (org.apache.geode.cache.TimeoutException)cause; } throw ex; } catch (ReplyException e) { @@ -597,8 +597,8 @@ public class InitialImageOperation { } } catch (InternalGemFireException ex) { Throwable cause = ex.getCause(); - if (cause instanceof com.gemstone.gemfire.cache.TimeoutException) { - throw (com.gemstone.gemfire.cache.TimeoutException)cause; + if (cause instanceof org.apache.geode.cache.TimeoutException) { + throw (org.apache.geode.cache.TimeoutException)cause; } throw ex; } catch (ReplyException e) { @@ -720,8 +720,8 @@ public class InitialImageOperation { return processor.filtersReceived; } catch (InternalGemFireException ex) { Throwable cause = ex.getCause(); - if (cause instanceof com.gemstone.gemfire.cache.TimeoutException) { - throw (com.gemstone.gemfire.cache.TimeoutException)cause; + if (cause instanceof org.apache.geode.cache.TimeoutException) { + throw (org.apache.geode.cache.TimeoutException)cause; } throw ex; } catch (ReplyException e) { @@ -966,8 +966,8 @@ public class InitialImageOperation { received_rvv = rvv_processor.received_rvv; } catch (InternalGemFireException ex) { Throwable cause = ex.getCause(); - if (cause instanceof com.gemstone.gemfire.cache.TimeoutException) { - throw (com.gemstone.gemfire.cache.TimeoutException)cause; + if (cause instanceof org.apache.geode.cache.TimeoutException) { + throw (org.apache.geode.cache.TimeoutException)cause; } throw ex; } catch (ReplyException e) { @@ -1189,7 +1189,7 @@ public class InitialImageOperation { /* * (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.ReplyProcessor21#process(com.gemstone.gemfire.distributed.internal.DistributionMessage) + * @see org.apache.geode.distributed.internal.ReplyProcessor21#process(org.apache.geode.distributed.internal.DistributionMessage) */ @Override public void process(DistributionMessage msg) { @@ -2358,7 +2358,7 @@ public class InitialImageOperation { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.DataSerializableFixedID#getDSFID() + * @see org.apache.geode.internal.DataSerializableFixedID#getDSFID() */ @Override public int getDSFID() { @@ -3350,7 +3350,7 @@ public class InitialImageOperation { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.DataSerializableFixedID#getDSFID() + * @see org.apache.geode.internal.DataSerializableFixedID#getDSFID() */ @Override public int getDSFID() { @@ -3858,7 +3858,7 @@ public class InitialImageOperation { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.DataSerializableFixedID#getDSFID() + * @see org.apache.geode.internal.DataSerializableFixedID#getDSFID() */ @Override public int getDSFID() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InlineKeyHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InlineKeyHelper.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InlineKeyHelper.java index aa98fa6..6ea9729 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InlineKeyHelper.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InlineKeyHelper.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.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.DistributionConfig; /** * No instances of this class. Just some static method having to do with inline keys. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InterestEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InterestEvent.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InterestEvent.java index 77412be..330b05e 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InterestEvent.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InterestEvent.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.internal.cache.tier.sockets.CacheServerHelper; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.cache.tier.sockets.CacheServerHelper; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InterestFilter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InterestFilter.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InterestFilter.java index e4419a3..1d2be4c 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InterestFilter.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InterestFilter.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.CacheCallback; +import org.apache.geode.cache.CacheCallback; public interface InterestFilter extends CacheCallback { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InterestRegistrationEventImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InterestRegistrationEventImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InterestRegistrationEventImpl.java index 41d3abd..cf0f078 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InterestRegistrationEventImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InterestRegistrationEventImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -22,14 +22,14 @@ import java.io.IOException; import java.util.HashSet; import java.util.Set; -import com.gemstone.gemfire.DataSerializable; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.ClientSession; -import com.gemstone.gemfire.cache.InterestRegistrationEvent; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.cache.tier.InterestType; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientProxy; +import org.apache.geode.DataSerializable; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.ClientSession; +import org.apache.geode.cache.InterestRegistrationEvent; +import org.apache.geode.cache.Region; +import org.apache.geode.internal.cache.tier.InterestType; +import org.apache.geode.internal.cache.tier.sockets.CacheClientProxy; public class InterestRegistrationEventImpl implements InterestRegistrationEvent, DataSerializable { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InternalCache.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalCache.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalCache.java index 20f5f49..0f9a87f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalCache.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalCache.java @@ -15,20 +15,20 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Collection; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.internal.cache.extension.Extensible; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.internal.cache.extension.Extensible; /** * The InternalCache interface is contract for implementing classes for defining internal cache operations that should * not be part of the "public" API of the implementing class. * </p> - * @see com.gemstone.gemfire.cache.Cache + * @see org.apache.geode.cache.Cache * @since GemFire 7.0 */ public interface InternalCache extends Cache, Extensible<Cache> { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InternalCacheEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalCacheEvent.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalCacheEvent.java index da2d385..3bacd0a 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalCacheEvent.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalCacheEvent.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 com.gemstone.gemfire.cache.CacheEvent; -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 org.apache.geode.cache.CacheEvent; +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; /** * A CacheEvent, but the isGenerateCallbacks() is hidden from public consumption http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InternalDataView.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalDataView.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalDataView.java index 2452804..334fb3e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalDataView.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalDataView.java @@ -17,18 +17,18 @@ /** * File comment */ -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.offheap.annotations.Retained; +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.offheap.annotations.Retained; /** * @since GemFire 6.0tx http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegionArguments.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegionArguments.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegionArguments.java index 54c9194..ad50dd3 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegionArguments.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InternalRegionArguments.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.io.InputStream; import java.util.HashMap; import java.util.List; import java.util.Map; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.LocalRegion.TestCallable; -import com.gemstone.gemfire.internal.cache.partitioned.RegionAdvisor; -import com.gemstone.gemfire.internal.cache.persistence.PersistenceAdvisor; -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySender; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.LocalRegion.TestCallable; +import org.apache.geode.internal.cache.partitioned.RegionAdvisor; +import org.apache.geode.internal.cache.persistence.PersistenceAdvisor; +import org.apache.geode.internal.cache.wan.AbstractGatewaySender; /** * An internal version of Region Attributes that allows for additional information http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateOperation.java index 1742ad3..9f09e97 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateOperation.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -25,16 +25,16 @@ import java.util.List; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.distributed.internal.ConflationKey; -import com.gemstone.gemfire.distributed.internal.DirectReplyProcessor; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.versions.ConcurrentCacheModificationException; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.distributed.internal.ConflationKey; +import org.apache.geode.distributed.internal.DirectReplyProcessor; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.versions.ConcurrentCacheModificationException; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.annotations.Retained; /** * Handles distribution messaging for invalidating an entry in a region. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidatePartitionedRegionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidatePartitionedRegionMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidatePartitionedRegionMessage.java index 97346d3..f604a80 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidatePartitionedRegionMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidatePartitionedRegionMessage.java @@ -17,15 +17,15 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.internal.cache.partitioned.PartitionMessage; import java.io.DataInput; import java.io.DataOutput; @@ -61,7 +61,7 @@ public class InvalidatePartitionedRegionMessage extends PartitionMessage { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage#operateOnPartitionedRegion(com.gemstone.gemfire.distributed.internal.DistributionManager, com.gemstone.gemfire.internal.cache.PartitionedRegion, long) + * @see org.apache.geode.internal.cache.partitioned.PartitionMessage#operateOnPartitionedRegion(org.apache.geode.distributed.internal.DistributionManager, org.apache.geode.internal.cache.PartitionedRegion, long) */ @Override protected boolean operateOnPartitionedRegion(DistributionManager dm, @@ -75,14 +75,14 @@ public class InvalidatePartitionedRegionMessage extends PartitionMessage { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.DataSerializableFixedID#getDSFID() + * @see org.apache.geode.internal.DataSerializableFixedID#getDSFID() */ public int getDSFID() { return INVALIDATE_PARTITIONED_REGION_MESSAGE; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage#fromData(java.io.DataInput) + * @see org.apache.geode.internal.cache.partitioned.PartitionMessage#fromData(java.io.DataInput) */ @Override public void fromData(DataInput in) throws IOException, ClassNotFoundException { @@ -91,7 +91,7 @@ public class InvalidatePartitionedRegionMessage extends PartitionMessage { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage#toData(java.io.DataOutput) + * @see org.apache.geode.internal.cache.partitioned.PartitionMessage#toData(java.io.DataOutput) */ @Override public void toData(DataOutput out) throws IOException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateRegionOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateRegionOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateRegionOperation.java index e36234e..c1cbbcb 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateRegionOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/InvalidateRegionOperation.java @@ -15,16 +15,16 @@ * 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.util.*; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.DataSerializer; +import org.apache.geode.cache.*; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.DataSerializer; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/JtaAfterCompletionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/JtaAfterCompletionMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/JtaAfterCompletionMessage.java index f20cb9e..f173de8 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/JtaAfterCompletionMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/JtaAfterCompletionMessage.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; @@ -27,15 +27,15 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.TXRemoteCommitMessage.RemoteCommitResponse; -import com.gemstone.gemfire.internal.cache.TXRemoteCommitMessage.TXRemoteCommitReplyMessage; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.Cache; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.TXRemoteCommitMessage.RemoteCommitResponse; +import org.apache.geode.internal.cache.TXRemoteCommitMessage.TXRemoteCommitReplyMessage; +import org.apache.geode.internal.logging.LogService; /** * @@ -80,7 +80,7 @@ public class JtaAfterCompletionMessage extends TXMessage { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXMessage#operateOnTx(com.gemstone.gemfire.internal.cache.TXId) + * @see org.apache.geode.internal.cache.TXMessage#operateOnTx(org.apache.geode.internal.cache.TXId) */ @Override protected boolean operateOnTx(TXId txId,DistributionManager dm) throws RemoteOperationException { @@ -98,14 +98,14 @@ public class JtaAfterCompletionMessage extends TXMessage { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.DataSerializableFixedID#getDSFID() + * @see org.apache.geode.internal.DataSerializableFixedID#getDSFID() */ public int getDSFID() { return JTA_AFTER_COMPLETION_MESSAGE; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXMessage#toData(java.io.DataOutput) + * @see org.apache.geode.internal.cache.TXMessage#toData(java.io.DataOutput) */ @Override public void toData(DataOutput out) throws IOException { @@ -115,7 +115,7 @@ public class JtaAfterCompletionMessage extends TXMessage { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXMessage#fromData(java.io.DataInput) + * @see org.apache.geode.internal.cache.TXMessage#fromData(java.io.DataInput) */ @Override public void fromData(DataInput in) throws IOException, ClassNotFoundException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/JtaBeforeCompletionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/JtaBeforeCompletionMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/JtaBeforeCompletionMessage.java index 079fd89..1c7a449 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/JtaBeforeCompletionMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/JtaBeforeCompletionMessage.java @@ -17,21 +17,21 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Collections; import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ReliableReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.Cache; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ReliableReplyProcessor21; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.logging.LogService; /** * @@ -59,7 +59,7 @@ public class JtaBeforeCompletionMessage extends TXMessage { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TXMessage#operateOnTx(com.gemstone.gemfire.internal.cache.TXId) + * @see org.apache.geode.internal.cache.TXMessage#operateOnTx(org.apache.geode.internal.cache.TXId) */ @Override protected boolean operateOnTx(TXId txId,DistributionManager dm) { @@ -73,7 +73,7 @@ public class JtaBeforeCompletionMessage extends TXMessage { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.DataSerializableFixedID#getDSFID() + * @see org.apache.geode.internal.DataSerializableFixedID#getDSFID() */ public int getDSFID() { return JTA_BEFORE_COMPLETION_MESSAGE; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/KeyInfo.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/KeyInfo.java b/geode-core/src/main/java/org/apache/geode/internal/cache/KeyInfo.java index 3065b47..1010054 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/KeyInfo.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/KeyInfo.java @@ -17,14 +17,14 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import static com.gemstone.gemfire.internal.offheap.annotations.OffHeapIdentifier.ENTRY_EVENT_NEW_VALUE; +import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.ENTRY_EVENT_NEW_VALUE; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; -import com.gemstone.gemfire.internal.offheap.annotations.Unretained; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.offheap.annotations.Retained; +import org.apache.geode.internal.offheap.annotations.Unretained; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/LoaderHelperFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LoaderHelperFactory.java b/geode-core/src/main/java/org/apache/geode/internal/cache/LoaderHelperFactory.java index 707ee2d..8ca3c32 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/LoaderHelperFactory.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LoaderHelperFactory.java @@ -20,13 +20,13 @@ * outside the context of the Region the loader invoked from. * @since GemFire 5.0 */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.LoaderHelper; +import org.apache.geode.cache.LoaderHelper; /** * The LoaderHelperFactory creates a LoaderHelper class which is used by a - * {@link com.gemstone.gemfire.cache.CacheLoader}. + * {@link org.apache.geode.cache.CacheLoader}. * * @since GemFire 5.0 */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/LoaderHelperImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LoaderHelperImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/LoaderHelperImpl.java index 55a10b5..15eb988 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/LoaderHelperImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LoaderHelperImpl.java @@ -15,14 +15,14 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -//import com.gemstone.gemfire.*; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +//import org.apache.geode.*; +import org.apache.geode.cache.*; +import org.apache.geode.internal.i18n.LocalizedStrings; //import java.io.*; //import java.util.Set; -import com.gemstone.gemfire.i18n.StringId; +import org.apache.geode.i18n.StringId; /** Provides a set of APIs to help the * implementation of the <code>CacheLoader</code> load method. An instance of <code>LoaderHelper</code> http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/LocalDataSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalDataSet.java b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalDataSet.java index 62c95e1..0883581 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/LocalDataSet.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/LocalDataSet.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.io.InputStream; @@ -31,41 +31,41 @@ import java.util.concurrent.locks.Lock; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.AttributesMutator; -import com.gemstone.gemfire.cache.CacheLoaderException; -import com.gemstone.gemfire.cache.CacheStatistics; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.EntryExistsException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.InterestResultPolicy; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.RegionExistsException; -import com.gemstone.gemfire.cache.RegionService; -import com.gemstone.gemfire.cache.StatisticsDisabledException; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.cache.query.FunctionDomainException; -import com.gemstone.gemfire.cache.query.NameResolutionException; -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.QueryExecutor; -import com.gemstone.gemfire.cache.query.internal.QueryObserver; -import com.gemstone.gemfire.cache.snapshot.RegionSnapshotService; -import com.gemstone.gemfire.internal.NanoTimer; -import com.gemstone.gemfire.internal.cache.LocalRegion.IteratorType; -import com.gemstone.gemfire.internal.cache.LocalRegion.NonTXEntry; -import com.gemstone.gemfire.internal.cache.execute.BucketMovedException; -import com.gemstone.gemfire.internal.cache.execute.InternalRegionFunctionContext; -import com.gemstone.gemfire.internal.cache.snapshot.RegionSnapshotServiceImpl; -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.AttributesMutator; +import org.apache.geode.cache.CacheLoaderException; +import org.apache.geode.cache.CacheStatistics; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.EntryExistsException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.InterestResultPolicy; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.RegionExistsException; +import org.apache.geode.cache.RegionService; +import org.apache.geode.cache.StatisticsDisabledException; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.cache.query.FunctionDomainException; +import org.apache.geode.cache.query.NameResolutionException; +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.QueryExecutor; +import org.apache.geode.cache.query.internal.QueryObserver; +import org.apache.geode.cache.snapshot.RegionSnapshotService; +import org.apache.geode.internal.NanoTimer; +import org.apache.geode.internal.cache.LocalRegion.IteratorType; +import org.apache.geode.internal.cache.LocalRegion.NonTXEntry; +import org.apache.geode.internal.cache.execute.BucketMovedException; +import org.apache.geode.internal.cache.execute.InternalRegionFunctionContext; +import org.apache.geode.internal.cache.snapshot.RegionSnapshotServiceImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /**
