http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheClientStatus.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheClientStatus.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheClientStatus.java index 44e17f1..c73f1f0 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheClientStatus.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheClientStatus.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.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; import java.io.Serializable; import java.util.List;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheConfig.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheConfig.java index 4035645..60034ff 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheConfig.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheConfig.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.List; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheServerCreation; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.PdxSerializer; -import com.gemstone.gemfire.pdx.ReflectionBasedAutoSerializer; -import com.gemstone.gemfire.pdx.internal.AutoSerializableManager; +import org.apache.geode.internal.cache.xmlcache.CacheServerCreation; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.PdxSerializer; +import org.apache.geode.pdx.ReflectionBasedAutoSerializer; +import org.apache.geode.pdx.internal.AutoSerializableManager; /** * This is helper class used by CacheFactory to pass the cache configuration http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisee.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisee.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisee.java index 3163c32..0975421 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisee.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisee.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.Cache; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisee; -import com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.CacheProfile; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.distributed.internal.DistributionAdvisee; +import org.apache.geode.internal.cache.CacheDistributionAdvisor.CacheProfile; /** * Distributed cache object (typically a <code>Region</code>) which uses http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisor.java index fff9bab..6370aed 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheDistributionAdvisor.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; @@ -31,27 +31,27 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.InterestPolicy; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.cache.SubscriptionAttributes; -import com.gemstone.gemfire.distributed.Role; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.MembershipListener; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.DSCODE; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.cache.partitioned.PRLocallyDestroyedException; -import com.gemstone.gemfire.internal.cache.persistence.DiskStoreID; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.InterestPolicy; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.Scope; +import org.apache.geode.cache.SubscriptionAttributes; +import org.apache.geode.distributed.Role; +import org.apache.geode.distributed.internal.DistributionAdvisor; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.MembershipListener; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.DSCODE; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.cache.partitioned.PRLocallyDestroyedException; +import org.apache.geode.internal.cache.persistence.DiskStoreID; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; /** * Adds bookkeeping info and cache-specific behavior to DistributionAdvisor. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheLifecycleListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheLifecycleListener.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheLifecycleListener.java index e21f3bc..7838cb1 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheLifecycleListener.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheLifecycleListener.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; /** * Defines callbacks that are invoked when a <code>GemFireCache</code> is http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserver.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserver.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserver.java index ae3a40b..3e76fef 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserver.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserver.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.nio.ByteBuffer; -import com.gemstone.gemfire.cache.RegionEvent; +import org.apache.geode.cache.RegionEvent; /** * This interface is used by testing/debugging code to be notified of query * events. See the documentation for class CacheObserverHolder for details. Also * the callback is issed only if the boolean ISSUE_CALLBACKS_TO_CACHE_OBSERVER - * present in com.gemstone.gemfire.internal.cache.LocalRegion is made true + * present in org.apache.geode.internal.cache.LocalRegion is made true * */ public interface CacheObserver http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserverAdapter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserverAdapter.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserverAdapter.java index e6ac989..4ac8359 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserverAdapter.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserverAdapter.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.nio.ByteBuffer; -import com.gemstone.gemfire.cache.RegionEvent; +import org.apache.geode.cache.RegionEvent; /** * This class provides 'do-nothing' implementations of all of the methods of * interface CacheObserver. See the documentation for class CacheObserverHolder * for details. Also the callback is issed only if the boolean * ISSUE_CALLBACKS_TO_CACHE_OBSERVER present in - * com.gemstone.gemfire.internal.cache.LocalRegion is made true + * org.apache.geode.internal.cache.LocalRegion is made true * */ public class CacheObserverAdapter implements CacheObserver { @@ -71,7 +71,7 @@ public class CacheObserverAdapter implements CacheObserver { /* * (non-Javadoc) * - * @see com.gemstone.gemfire.internal.cache.CacheObserver#afterConflation(java.nio.ByteBuffer, + * @see org.apache.geode.internal.cache.CacheObserver#afterConflation(java.nio.ByteBuffer, * java.nio.ByteBuffer) */ public void afterConflation(ByteBuffer origBB, ByteBuffer conflatedBB) @@ -80,7 +80,7 @@ public class CacheObserverAdapter implements CacheObserver { } /* * (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.CacheObserver#afterSettingOplogOffSet() + * @see org.apache.geode.internal.cache.CacheObserver#afterSettingOplogOffSet() */ public void afterSettingOplogOffSet(long offset) { // TODO Auto-generated method stub @@ -99,7 +99,7 @@ public class CacheObserverAdapter implements CacheObserver { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.CacheObserver#beforeStoppingCompacter() + * @see org.apache.geode.internal.cache.CacheObserver#beforeStoppingCompacter() */ public void beforeStoppingCompactor() { @@ -125,7 +125,7 @@ public class CacheObserverAdapter implements CacheObserver { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.CacheObserver#afterSwitchingWriteAndFlushMaps() + * @see org.apache.geode.internal.cache.CacheObserver#afterSwitchingWriteAndFlushMaps() */ public void afterSwitchingWriteAndFlushMaps() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserverHolder.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserverHolder.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserverHolder.java index 8bc77f8..4c0fc04 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserverHolder.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheObserverHolder.java @@ -19,7 +19,7 @@ * * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * This class is intended to hold a single 'observer' which will receive @@ -35,7 +35,7 @@ package com.gemstone.gemfire.internal.cache; * of interest ... } * * CacheObserver old = CacheObserverHolder.setInstance(new MyCacheObserver()); - * com.gemstone.gemfire.internal.cache.LocalRegion.ISSUE_CALLBACKS_TO_CACHE_OBSERVER=true; + * org.apache.geode.internal.cache.LocalRegion.ISSUE_CALLBACKS_TO_CACHE_OBSERVER=true; * * try { Call region methods here } finally { // reset to the original * CacheObserver. CacheObserverHolder.setInstance(old); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CachePerfStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CachePerfStats.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CachePerfStats.java index 7fa2183..9bbd2a6 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CachePerfStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CachePerfStats.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.internal.*; -import com.gemstone.gemfire.distributed.internal.PoolStatHelper; -import com.gemstone.gemfire.distributed.internal.QueueStatHelper; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.*; +import org.apache.geode.internal.*; +import org.apache.geode.distributed.internal.PoolStatHelper; +import org.apache.geode.distributed.internal.QueueStatHelper; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; /** * CachePerfStats tracks statistics about GemFire cache performance. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerAdvisor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerAdvisor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerAdvisor.java index 01e8210..8becf16 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerAdvisor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerAdvisor.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; @@ -23,12 +23,12 @@ import java.io.IOException; import java.util.Arrays; import java.util.List; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.server.ServerLoad; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisee; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.InternalDataSerializer; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.server.ServerLoad; +import org.apache.geode.distributed.internal.DistributionAdvisee; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.InternalDataSerializer; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerImpl.java index 37c05eb..aa0a60c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerImpl.java @@ -14,36 +14,36 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.GemFireIOException; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.InvalidValueException; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.server.CacheServer; -import com.gemstone.gemfire.cache.server.ClientSubscriptionConfig; -import com.gemstone.gemfire.cache.server.ServerLoadProbe; -import com.gemstone.gemfire.cache.server.internal.LoadMonitor; -import com.gemstone.gemfire.cache.wan.GatewayTransportFilter; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.*; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -import com.gemstone.gemfire.distributed.internal.membership.MemberAttributes; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.OSProcess; -import com.gemstone.gemfire.internal.admin.ClientHealthMonitoringRegion; -import com.gemstone.gemfire.internal.cache.CacheServerAdvisor.CacheServerProfile; -import com.gemstone.gemfire.internal.cache.ha.HARegionQueue; -import com.gemstone.gemfire.internal.cache.tier.Acceptor; -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.ClientProxyMembershipID; -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.management.membership.ClientMembership; -import com.gemstone.gemfire.management.membership.ClientMembershipListener; +package org.apache.geode.internal.cache; + +import org.apache.geode.CancelCriterion; +import org.apache.geode.GemFireIOException; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.InvalidValueException; +import org.apache.geode.cache.*; +import org.apache.geode.cache.server.CacheServer; +import org.apache.geode.cache.server.ClientSubscriptionConfig; +import org.apache.geode.cache.server.ServerLoadProbe; +import org.apache.geode.cache.server.internal.LoadMonitor; +import org.apache.geode.cache.wan.GatewayTransportFilter; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.*; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.distributed.internal.membership.MemberAttributes; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.OSProcess; +import org.apache.geode.internal.admin.ClientHealthMonitoringRegion; +import org.apache.geode.internal.cache.CacheServerAdvisor.CacheServerProfile; +import org.apache.geode.internal.cache.ha.HARegionQueue; +import org.apache.geode.internal.cache.tier.Acceptor; +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.ClientProxyMembershipID; +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.management.membership.ClientMembership; +import org.apache.geode.management.membership.ClientMembershipListener; import org.apache.logging.log4j.Logger; import java.io.File; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerLauncher.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerLauncher.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerLauncher.java index e2e7af8..20cc5a7 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerLauncher.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServerLauncher.java @@ -15,36 +15,36 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheFactory; -import com.gemstone.gemfire.cache.partition.PartitionRegionHelper; -import com.gemstone.gemfire.cache.server.CacheServer; -import com.gemstone.gemfire.distributed.ConfigurationProperties; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.DistributionConfigImpl; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.i18n.LogWriterI18n; -import com.gemstone.gemfire.internal.OSProcess; -import com.gemstone.gemfire.internal.PureJavaMode; -import com.gemstone.gemfire.internal.net.SocketCreator; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheServerHelper; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.process.StartupStatus; -import com.gemstone.gemfire.internal.process.StartupStatusListener; -import com.gemstone.gemfire.internal.util.IOUtils; -import com.gemstone.gemfire.internal.util.JavaCommandBuilder; +package org.apache.geode.internal.cache; + +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheFactory; +import org.apache.geode.cache.partition.PartitionRegionHelper; +import org.apache.geode.cache.server.CacheServer; +import org.apache.geode.distributed.ConfigurationProperties; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.DistributionConfigImpl; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.i18n.LogWriterI18n; +import org.apache.geode.internal.OSProcess; +import org.apache.geode.internal.PureJavaMode; +import org.apache.geode.internal.net.SocketCreator; +import org.apache.geode.internal.cache.tier.sockets.CacheServerHelper; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.process.StartupStatus; +import org.apache.geode.internal.process.StartupStatusListener; +import org.apache.geode.internal.util.IOUtils; +import org.apache.geode.internal.util.JavaCommandBuilder; import java.io.*; import java.net.URL; import java.util.*; import java.util.concurrent.TimeUnit; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.LOG_FILE; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.SERVER_BIND_ADDRESS; +import static org.apache.geode.distributed.ConfigurationProperties.LOG_FILE; +import static org.apache.geode.distributed.ConfigurationProperties.SERVER_BIND_ADDRESS; /** * Launcher program to start a cache server. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheService.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheService.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheService.java index b1d3b62..22465ee 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheService.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheService.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.management.internal.beans.CacheServiceMBeanBase; +import org.apache.geode.cache.Cache; +import org.apache.geode.management.internal.beans.CacheServiceMBeanBase; /** * Interface for a service that is linked to a cache. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServiceProfile.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServiceProfile.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServiceProfile.java index d25e92a..043ab60 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServiceProfile.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheServiceProfile.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.Region; +import org.apache.geode.cache.Region; /** * CacheServiceProfiles track additions to a {@link Region} made by a {@link CacheService}. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CacheStatisticsImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheStatisticsImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheStatisticsImpl.java index 9fd56c7..26104ef 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CacheStatisticsImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CacheStatisticsImpl.java @@ -15,13 +15,13 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.internal.InternalStatisticsDisabledException; -//import com.gemstone.gemfire.InternalGemFireException; -//import com.gemstone.gemfire.internal.util.Callable; -//import com.gemstone.gemfire.util.concurrent.locks.Lock; +import org.apache.geode.cache.*; +import org.apache.geode.internal.InternalStatisticsDisabledException; +//import org.apache.geode.InternalGemFireException; +//import org.apache.geode.internal.util.Callable; +//import org.apache.geode.util.concurrent.locks.Lock; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CachedDeserializable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CachedDeserializable.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CachedDeserializable.java index 472b9ff..8833c44 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CachedDeserializable.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CachedDeserializable.java @@ -15,16 +15,16 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.cache.lru.Sizeable; -import com.gemstone.gemfire.internal.util.BlobHelper; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.Region; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.cache.lru.Sizeable; +import org.apache.geode.internal.util.BlobHelper; /** * Provides protocol for getting the deserialized value from a potentially http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CachedDeserializableFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CachedDeserializableFactory.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CachedDeserializableFactory.java index ae60056..ee749b7 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CachedDeserializableFactory.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CachedDeserializableFactory.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.util.ObjectSizer; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.DSCODE; -import com.gemstone.gemfire.internal.HeapDataOutputStream; -import com.gemstone.gemfire.internal.NullDataOutputStream; -import com.gemstone.gemfire.internal.cache.lru.Sizeable; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.PdxInstance; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.util.ObjectSizer; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.DSCODE; +import org.apache.geode.internal.HeapDataOutputStream; +import org.apache.geode.internal.NullDataOutputStream; +import org.apache.geode.internal.cache.lru.Sizeable; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.PdxInstance; 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/ClientRegionEventImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ClientRegionEventImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ClientRegionEventImpl.java index 15d02cd..f61d2a6 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ClientRegionEventImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ClientRegionEventImpl.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.Operation; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; -//import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +//import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; /** * Class <code>ClientRegionEventImpl</code> is a http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserver.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserver.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserver.java index 92578a0..5101378 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserver.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserver.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.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.tier.sockets.Message; /** * This interface is used by testing/debugging code to be notified of different http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserverAdapter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserverAdapter.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserverAdapter.java index 6069297..0fe6a23 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserverAdapter.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserverAdapter.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.distributed.internal.ServerLocation; -import com.gemstone.gemfire.internal.cache.tier.sockets.Message; +import org.apache.geode.distributed.internal.ServerLocation; +import org.apache.geode.internal.cache.tier.sockets.Message; /** * This class provides 'do-nothing' implementations of all of the methods of http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserverHolder.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserverHolder.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserverHolder.java index ec81a2f..f59a3f7 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserverHolder.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ClientServerObserverHolder.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.query.internal.Support; +import org.apache.geode.cache.query.internal.Support; /** * This class is intended to hold a single 'observer' which will receive http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ClientSubscriptionConfigImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ClientSubscriptionConfigImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ClientSubscriptionConfigImpl.java index a4a8882..fe49e54 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ClientSubscriptionConfigImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ClientSubscriptionConfigImpl.java @@ -17,10 +17,10 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.server.ClientSubscriptionConfig; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.server.ClientSubscriptionConfig; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * * Configuration parameters for client subscription http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CloseCacheMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CloseCacheMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CloseCacheMessage.java index 5067d92..cd7ae17 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CloseCacheMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CloseCacheMessage.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; @@ -23,12 +23,12 @@ import java.io.IOException; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.HighPriorityDistributionMessage; -import com.gemstone.gemfire.distributed.internal.MessageWithReply; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.SystemFailure; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.HighPriorityDistributionMessage; +import org.apache.geode.distributed.internal.MessageWithReply; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.internal.logging.LogService; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ClusterConfigurationLoader.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ClusterConfigurationLoader.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ClusterConfigurationLoader.java index be9cfbe..5281e11 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ClusterConfigurationLoader.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ClusterConfigurationLoader.java @@ -14,25 +14,25 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.UnmodifiableException; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.SharedConfiguration; -import com.gemstone.gemfire.distributed.internal.tcpserver.TcpClient; -import com.gemstone.gemfire.internal.ConfigSource; -import com.gemstone.gemfire.internal.JarClassLoader; -import com.gemstone.gemfire.internal.JarDeployer; -import com.gemstone.gemfire.internal.admin.remote.DistributionLocatorId; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.lang.StringUtils; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.net.*; -import com.gemstone.gemfire.internal.process.ClusterConfigurationNotAvailableException; -import com.gemstone.gemfire.management.internal.configuration.domain.Configuration; -import com.gemstone.gemfire.management.internal.configuration.messages.ConfigurationRequest; -import com.gemstone.gemfire.management.internal.configuration.messages.ConfigurationResponse; +package org.apache.geode.internal.cache; + +import org.apache.geode.UnmodifiableException; +import org.apache.geode.cache.Cache; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.SharedConfiguration; +import org.apache.geode.distributed.internal.tcpserver.TcpClient; +import org.apache.geode.internal.ConfigSource; +import org.apache.geode.internal.JarClassLoader; +import org.apache.geode.internal.JarDeployer; +import org.apache.geode.internal.admin.remote.DistributionLocatorId; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.lang.StringUtils; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.net.*; +import org.apache.geode.internal.process.ClusterConfigurationNotAvailableException; +import org.apache.geode.management.internal.configuration.domain.Configuration; +import org.apache.geode.management.internal.configuration.messages.ConfigurationRequest; +import org.apache.geode.management.internal.configuration.messages.ConfigurationResponse; import org.apache.logging.log4j.Logger; import java.io.ByteArrayInputStream; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ColocationHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ColocationHelper.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ColocationHelper.java index aec8ef8..12ce85a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ColocationHelper.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ColocationHelper.java @@ -15,23 +15,23 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionService; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.execute.InternalRegionFunctionContext; -import com.gemstone.gemfire.internal.cache.partitioned.PRLocallyDestroyedException; -import com.gemstone.gemfire.internal.cache.persistence.PRPersistentConfig; -import com.gemstone.gemfire.internal.cache.wan.parallel.ParallelGatewaySenderQueue; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionService; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.execute.InternalRegionFunctionContext; +import org.apache.geode.internal.cache.partitioned.PRLocallyDestroyedException; +import org.apache.geode.internal.cache.persistence.PRPersistentConfig; +import org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; import org.apache.logging.log4j.Logger; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ColocationLogger.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ColocationLogger.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ColocationLogger.java index fab8eca..0a37547 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ColocationLogger.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ColocationLogger.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.ArrayList; import java.util.List; @@ -22,12 +22,12 @@ import java.util.Map; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.distributed.DistributedSystem; -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.CancelCriterion; +import org.apache.geode.SystemFailure; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * Provides logging when regions are missing from a colocation hierarchy. This logger runs in http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CommitReplyException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CommitReplyException.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CommitReplyException.java index bf3e341..d25b146 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CommitReplyException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CommitReplyException.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.ReplyException; +import org.apache.geode.distributed.internal.ReplyException; 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/CompactableOplog.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CompactableOplog.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CompactableOplog.java index 8691ec9..7780204 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CompactableOplog.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CompactableOplog.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.internal.cache.DiskStoreImpl.OplogCompactor; -import com.gemstone.gemfire.internal.cache.persistence.BytesAndBits; -import com.gemstone.gemfire.internal.cache.persistence.DiskRegionView; +import org.apache.geode.internal.cache.DiskStoreImpl.OplogCompactor; +import org.apache.geode.internal.cache.persistence.BytesAndBits; +import org.apache.geode.internal.cache.persistence.DiskRegionView; /** * Contract that must be implemented by oplogs so that * they can be compacted. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/Conflatable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/Conflatable.java b/geode-core/src/main/java/org/apache/geode/internal/cache/Conflatable.java index cb5cb0d..26a4bc6 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/Conflatable.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/Conflatable.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; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ControllerAdvisor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ControllerAdvisor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ControllerAdvisor.java index fb826f4..87c956e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ControllerAdvisor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ControllerAdvisor.java @@ -15,18 +15,18 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.util.List; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisee; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.ServerLocator; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.distributed.internal.DistributionAdvisee; +import org.apache.geode.distributed.internal.DistributionAdvisor; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.ServerLocator; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CountingDataInputStream.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CountingDataInputStream.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CountingDataInputStream.java index ce0273d..8468e4e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CountingDataInputStream.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CountingDataInputStream.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.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CreateRegionProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CreateRegionProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CreateRegionProcessor.java index bc44c1c..7517f9b 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CreateRegionProcessor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CreateRegionProcessor.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -27,40 +27,40 @@ 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.CacheFactory; -import com.gemstone.gemfire.cache.PartitionAttributes; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisee; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.HighPriorityDistributionMessage; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.MessageWithReply; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.CacheProfile; -import com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.InitialImageAdvice; -import com.gemstone.gemfire.internal.cache.partitioned.PRLocallyDestroyedException; -import com.gemstone.gemfire.internal.cache.partitioned.RegionAdvisor; -import com.gemstone.gemfire.internal.cache.partitioned.RegionAdvisor.PartitionProfile; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.CacheFactory; +import org.apache.geode.cache.PartitionAttributes; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.Scope; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DistributionAdvisee; +import org.apache.geode.distributed.internal.DistributionAdvisor; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.HighPriorityDistributionMessage; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.MessageWithReply; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.cache.CacheDistributionAdvisor.CacheProfile; +import org.apache.geode.internal.cache.CacheDistributionAdvisor.InitialImageAdvice; +import org.apache.geode.internal.cache.partitioned.PRLocallyDestroyedException; +import org.apache.geode.internal.cache.partitioned.RegionAdvisor; +import org.apache.geode.internal.cache.partitioned.RegionAdvisor.PartitionProfile; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * This message processor handles creation and initial exchange of - * com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.Profiles. It + * org.apache.geode.internal.cache.CacheDistributionAdvisor.Profiles. It * represents creation of * a {@link CacheDistributionAdvisee}. Name remains CreateRegion to avoid * merge conflicts. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/CustomEntryExpiryTask.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/CustomEntryExpiryTask.java b/geode-core/src/main/java/org/apache/geode/internal/cache/CustomEntryExpiryTask.java index 2c380f2..1b52125 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/CustomEntryExpiryTask.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/CustomEntryExpiryTask.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.ExpirationAttributes; +import org.apache.geode.cache.ExpirationAttributes; /** * Remembers the expiration attributes returned from http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DataLocationException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DataLocationException.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DataLocationException.java index fc98762..1332668 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DataLocationException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DataLocationException.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.GemFireCheckedException; +import org.apache.geode.GemFireCheckedException; /** * This exception is meant to represent the class of exceptions that occur http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyOperation.java index 5bfb3cc..90e9d2e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyOperation.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; @@ -23,18 +23,18 @@ import java.io.IOException; import java.util.Collections; import java.util.List; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.distributed.internal.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.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.distributed.internal.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.i18n.LocalizedStrings; +import org.apache.geode.internal.offheap.annotations.Retained; /** * Handles distribution messaging for destroying 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/DestroyPartitionedRegionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyPartitionedRegionMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyPartitionedRegionMessage.java index 4539526..67e4df5 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyPartitionedRegionMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyPartitionedRegionMessage.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; @@ -24,35 +24,35 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -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.internal.Assert; -import com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage; -import com.gemstone.gemfire.internal.cache.partitioned.RegionAdvisor; -import com.gemstone.gemfire.internal.cache.partitioned.RegionAdvisor.PartitionProfile; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.Operation; +import org.apache.geode.distributed.internal.DistributionAdvisor; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +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.internal.Assert; +import org.apache.geode.internal.cache.partitioned.PartitionMessage; +import org.apache.geode.internal.cache.partitioned.RegionAdvisor; +import org.apache.geode.internal.cache.partitioned.RegionAdvisor.PartitionProfile; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; /** * This message is sent for two purposes <br> * 1) To destroy the - * {@link com.gemstone.gemfire.internal.cache.PartitionedRegion} for all members + * {@link org.apache.geode.internal.cache.PartitionedRegion} for all members * specified (typically sent to all members that have the * <code>PartitionedRegion</code> defined.) <br> - * 2) To inform the other nodes that {@link com.gemstone.gemfire.internal.cache.PartitionedRegion} is closed/locally destroyed or cache is closed on a node<br> + * 2) To inform the other nodes that {@link org.apache.geode.internal.cache.PartitionedRegion} is closed/locally destroyed or cache is closed on a node<br> * This results in updating of the RegionAdvisor of the remote nodes. * * Sending this message should flush all previous - * {@link com.gemstone.gemfire.cache.Region} operations, which means this + * {@link org.apache.geode.cache.Region} operations, which means this * operation should not over-ride - * {@link com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage#getProcessorId()}. It is critical + * {@link org.apache.geode.internal.cache.partitioned.PartitionMessage#getProcessorId()}. It is critical * guarantee delivery of events sent prior to this message. * A standard {@link ReplyMessage} is used to send the reply, however any exception that it carries http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyRegionOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyRegionOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyRegionOperation.java index 2cb83ea..ee02075 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyRegionOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyRegionOperation.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; @@ -23,34 +23,34 @@ import java.io.IOException; import java.util.HashMap; import java.util.Iterator; import java.util.Set; -//import com.gemstone.gemfire.internal.*; -//import com.gemstone.gemfire.distributed.internal.*; +//import org.apache.geode.internal.*; +//import org.apache.geode.distributed.internal.*; import java.util.concurrent.RejectedExecutionException; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.CacheFactory; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.partitioned.PRLocallyDestroyedException; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.CacheFactory; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.distributed.internal.DistributionAdvisor; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.partitioned.PRLocallyDestroyedException; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyedEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyedEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyedEntry.java index c5533a1..3a971ce 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyedEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DestroyedEntry.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.CacheStatistics; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; +import org.apache.geode.cache.CacheStatistics; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; /** * Represents a destroyed entry that can be returned from an <code>Iterator</code> http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DirectReplyMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DirectReplyMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DirectReplyMessage.java index a5e6d85..25982da 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DirectReplyMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DirectReplyMessage.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.distributed.internal.DirectReplyProcessor; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.DirectReplyProcessor; +import org.apache.geode.distributed.internal.DistributionMessage; /** * A message that can reply directly to the sender @@ -35,14 +35,14 @@ public interface DirectReplyMessage { /** * Indicates whether the message could send an acknowledgement * back on the connection the request was sent on. This flag - * only takes effect when {@link com.gemstone.gemfire.distributed.DistributedSystem#setThreadsSocketPolicy(boolean)} + * only takes effect when {@link org.apache.geode.distributed.DistributedSystem#setThreadsSocketPolicy(boolean)} * is set to <code>false</code> * If this flag is set to true, the process method <b> must </b> reply - * by calling {@link DistributionMessage#getReplySender(com.gemstone.gemfire.distributed.internal.DM)} and using + * by calling {@link DistributionMessage#getReplySender(org.apache.geode.distributed.internal.DM)} and using * the result to send the reply. the ReplySender determines whether to reply * directly or through the shared channel. * @return true if a direct acknowledgement is allowed - * @see com.gemstone.gemfire.distributed.internal.direct.DirectChannel + * @see org.apache.geode.distributed.internal.direct.DirectChannel */ boolean supportsDirectAck(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DirectoryHolder.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DirectoryHolder.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DirectoryHolder.java index d3ad07e..0239123 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DirectoryHolder.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DirectoryHolder.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.File; import java.util.concurrent.atomic.AtomicLong; -import com.gemstone.gemfire.StatisticsFactory; +import org.apache.geode.StatisticsFactory; /** * A holder for a disk Directory. Used for maintaining the available space and http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskDirectoryStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskDirectoryStats.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskDirectoryStats.java index a0d7022..2dfdec1 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskDirectoryStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskDirectoryStats.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.*; -//import com.gemstone.gemfire.internal.NanoTimer; -//import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.*; +//import org.apache.geode.internal.NanoTimer; +//import org.apache.geode.cache.Region; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; /** * GemFire statistics about Disk Directories http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskEntry.java index 144ffe4..20e11ce 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskEntry.java @@ -14,40 +14,40 @@ * 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.ByteBuffer; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.ByteArrayDataInput; -import com.gemstone.gemfire.internal.HeapDataOutputStream; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.DiskStoreImpl.AsyncDiskEntry; -import com.gemstone.gemfire.internal.cache.Token.Tombstone; -import com.gemstone.gemfire.internal.cache.lru.EnableLRU; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.LRUEntry; -import com.gemstone.gemfire.internal.cache.persistence.BytesAndBits; -import com.gemstone.gemfire.internal.cache.persistence.DiskRecoveryStore; -import com.gemstone.gemfire.internal.cache.persistence.DiskRegionView; -import com.gemstone.gemfire.internal.cache.versions.VersionStamp; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.AddressableMemoryManager; -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.util.BlobHelper; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.ByteArrayDataInput; +import org.apache.geode.internal.HeapDataOutputStream; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.DiskStoreImpl.AsyncDiskEntry; +import org.apache.geode.internal.cache.Token.Tombstone; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.LRUEntry; +import org.apache.geode.internal.cache.persistence.BytesAndBits; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.cache.persistence.DiskRegionView; +import org.apache.geode.internal.cache.versions.VersionStamp; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.AddressableMemoryManager; +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.util.BlobHelper; /** * Represents an entry in an {@link RegionMap} whose value may be http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskId.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskId.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskId.java index 3da3879..a22c522 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskId.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskId.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.i18n.LocalizedStrings; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * This id stores seven pieces of information: http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskInitFile.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskInitFile.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskInitFile.java index 0d8ff05..83fc7c5 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskInitFile.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskInitFile.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import it.unimi.dsi.fastutil.ints.Int2ObjectMap; import it.unimi.dsi.fastutil.ints.Int2ObjectOpenHashMap; @@ -51,37 +51,37 @@ import java.util.concurrent.ConcurrentHashMap; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.Instantiator; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.cache.EvictionAction; -import com.gemstone.gemfire.cache.EvictionAlgorithm; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.compression.Compressor; -import com.gemstone.gemfire.internal.FileUtil; -import com.gemstone.gemfire.internal.HeapDataOutputStream; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.InternalInstantiator; -import com.gemstone.gemfire.internal.InternalInstantiator.InstantiatorAttributesHolder; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.persistence.CanonicalIdHolder; -import com.gemstone.gemfire.internal.cache.persistence.DiskExceptionHandler; -import com.gemstone.gemfire.internal.cache.persistence.DiskInitFileInterpreter; -import com.gemstone.gemfire.internal.cache.persistence.DiskInitFileParser; -import com.gemstone.gemfire.internal.cache.persistence.DiskRegionView; -import com.gemstone.gemfire.internal.cache.persistence.DiskStoreID; -import com.gemstone.gemfire.internal.cache.persistence.PRPersistentConfig; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberPattern; -import com.gemstone.gemfire.internal.cache.versions.DiskRegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionHolder; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.CancelCriterion; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.Instantiator; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.cache.EvictionAction; +import org.apache.geode.cache.EvictionAlgorithm; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.compression.Compressor; +import org.apache.geode.internal.FileUtil; +import org.apache.geode.internal.HeapDataOutputStream; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.InternalInstantiator; +import org.apache.geode.internal.InternalInstantiator.InstantiatorAttributesHolder; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.persistence.CanonicalIdHolder; +import org.apache.geode.internal.cache.persistence.DiskExceptionHandler; +import org.apache.geode.internal.cache.persistence.DiskInitFileInterpreter; +import org.apache.geode.internal.cache.persistence.DiskInitFileParser; +import org.apache.geode.internal.cache.persistence.DiskRegionView; +import org.apache.geode.internal.cache.persistence.DiskStoreID; +import org.apache.geode.internal.cache.persistence.PRPersistentConfig; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.cache.persistence.PersistentMemberPattern; +import org.apache.geode.internal.cache.versions.DiskRegionVersionVector; +import org.apache.geode.internal.cache.versions.RegionVersionHolder; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; /** * Does all the IF file work for a DiskStoreImpl. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskRegion.java index 3f511f0..e4dfdcc 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskRegion.java @@ -14,27 +14,27 @@ * 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.EnumSet; import java.util.Map; import java.util.concurrent.atomic.AtomicInteger; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.compression.Compressor; -import com.gemstone.gemfire.internal.cache.DiskEntry.Helper.ValueWrapper; -import com.gemstone.gemfire.internal.cache.DiskInitFile.DiskRegionFlag; -import com.gemstone.gemfire.internal.cache.DiskStoreImpl.AsyncDiskEntry; -import com.gemstone.gemfire.internal.cache.InitialImageOperation.GIIStatus; -import com.gemstone.gemfire.internal.cache.LocalRegion.RegionEntryCallback; -import com.gemstone.gemfire.internal.cache.persistence.BytesAndBits; -import com.gemstone.gemfire.internal.cache.persistence.DiskExceptionHandler; -import com.gemstone.gemfire.internal.cache.persistence.DiskRecoveryStore; -import com.gemstone.gemfire.internal.cache.persistence.DiskStoreID; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionStamp; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantReadWriteLock; +import org.apache.geode.CancelCriterion; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.compression.Compressor; +import org.apache.geode.internal.cache.DiskEntry.Helper.ValueWrapper; +import org.apache.geode.internal.cache.DiskInitFile.DiskRegionFlag; +import org.apache.geode.internal.cache.DiskStoreImpl.AsyncDiskEntry; +import org.apache.geode.internal.cache.InitialImageOperation.GIIStatus; +import org.apache.geode.internal.cache.LocalRegion.RegionEntryCallback; +import org.apache.geode.internal.cache.persistence.BytesAndBits; +import org.apache.geode.internal.cache.persistence.DiskExceptionHandler; +import org.apache.geode.internal.cache.persistence.DiskRecoveryStore; +import org.apache.geode.internal.cache.persistence.DiskStoreID; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionStamp; +import org.apache.geode.internal.util.concurrent.StoppableReentrantReadWriteLock; import joptsimple.internal.Strings; /**
