http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionInfoResponse.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionInfoResponse.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionInfoResponse.java index 754dec0..ad3e4b6 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionInfoResponse.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionInfoResponse.java @@ -16,15 +16,15 @@ */ -package com.gemstone.gemfire.internal.admin.remote; +package org.apache.geode.internal.admin.remote; -import com.gemstone.gemfire.distributed.internal.*; -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.internal.*; +import org.apache.geode.distributed.internal.*; +import org.apache.geode.*; +import org.apache.geode.internal.*; import java.io.*; //import java.net.*; //import java.util.*; -import com.gemstone.gemfire.distributed.internal.membership.*; +import org.apache.geode.distributed.internal.membership.*; /** * A message that is sent in response to a {@link VersionInfoRequest}.
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionMismatchAlert.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionMismatchAlert.java b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionMismatchAlert.java index b6985ee..e79eea2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionMismatchAlert.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/VersionMismatchAlert.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.remote; +package org.apache.geode.internal.admin.remote; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.admin.*; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.admin.*; import java.util.*; public class VersionMismatchAlert implements Alert { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/remote/package.html ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/package.html b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/package.html index a47f53d..e8f32f3 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/remote/package.html +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/remote/package.html @@ -18,7 +18,7 @@ limitations under the License. <BODY> <P>Provides an implementation of the -<a href="{@docRoot}/com/gemstone/gemfire/internal/admin/package-summary.html#package_description">internal admin API</a> that uses +<a href="{@docRoot}/org/apache/geode/internal/admin/package-summary.html#package_description">internal admin API</a> that uses GemFire's distribution mechanism to obtain information about members of a distributed system. The below diagram describes the relationships between the various classes in this package.</P> @@ -34,7 +34,7 @@ relationships between the various classes in this package.</P> <H2>Statistics</H2> <code>StatListener</code>s are assigned a {@link -com.gemstone.gemfire.internal.statistics.GemFireStatSampler#addListener} unique +org.apache.geode.internal.statistics.GemFireStatSampler#addListener} unique id} in the remote VM.</code> </BODY> http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/BaseDecoratorImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/BaseDecoratorImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/BaseDecoratorImpl.java index e74762f..02bd26e 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/BaseDecoratorImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/BaseDecoratorImpl.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.statalerts; +package org.apache.geode.internal.admin.statalerts; import java.io.DataOutput; import java.io.DataInput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.internal.admin.StatAlert; -import com.gemstone.gemfire.internal.admin.StatAlertDefinition; +import org.apache.geode.DataSerializer; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.SystemFailure; +import org.apache.geode.internal.admin.StatAlert; +import org.apache.geode.internal.admin.StatAlertDefinition; /** * Base class for all the decorators http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/DummyStatisticInfoImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/DummyStatisticInfoImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/DummyStatisticInfoImpl.java index 6e4d5f3..8540eec 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/DummyStatisticInfoImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/DummyStatisticInfoImpl.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.statalerts; +package org.apache.geode.internal.admin.statalerts; import java.io.DataOutput; import java.io.DataInput; import java.io.IOException; -import com.gemstone.gemfire.StatisticDescriptor; -import com.gemstone.gemfire.Statistics; -import com.gemstone.gemfire.internal.admin.StatAlertsManager; +import org.apache.geode.StatisticDescriptor; +import org.apache.geode.Statistics; +import org.apache.geode.internal.admin.StatAlertsManager; /** * Implementation {@link StatisticInfo} This does not contains associated http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/FunctionDecoratorImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/FunctionDecoratorImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/FunctionDecoratorImpl.java index 41d837a..f9e9a38 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/FunctionDecoratorImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/FunctionDecoratorImpl.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.statalerts; +package org.apache.geode.internal.admin.statalerts; import java.io.DataOutput; import java.io.DataInput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.internal.admin.StatAlert; -import com.gemstone.gemfire.internal.admin.StatAlertDefinition; +import org.apache.geode.DataSerializer; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.internal.admin.StatAlert; +import org.apache.geode.internal.admin.StatAlertDefinition; /** * Implementation of {@link StatAlertDefinition}, which defines function http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/FunctionHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/FunctionHelper.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/FunctionHelper.java index 759f7fb..1b047a8 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/FunctionHelper.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/FunctionHelper.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.statalerts; +package org.apache.geode.internal.admin.statalerts; -import com.gemstone.gemfire.SystemFailure; +import org.apache.geode.SystemFailure; import java.util.Arrays; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/GaugeThresholdDecoratorImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/GaugeThresholdDecoratorImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/GaugeThresholdDecoratorImpl.java index c33db67..6ab7cb4 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/GaugeThresholdDecoratorImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/GaugeThresholdDecoratorImpl.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.statalerts; +package org.apache.geode.internal.admin.statalerts; import java.io.DataOutput; import java.io.DataInput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.admin.StatAlert; -import com.gemstone.gemfire.internal.admin.StatAlertDefinition; +import org.apache.geode.DataSerializer; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.admin.StatAlert; +import org.apache.geode.internal.admin.StatAlertDefinition; /** * Implementation of {@link StatAlertDefinition}, represents threshold as data http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/MultiAttrDefinitionImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/MultiAttrDefinitionImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/MultiAttrDefinitionImpl.java index f8f9740..84e2a6b 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/MultiAttrDefinitionImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/MultiAttrDefinitionImpl.java @@ -14,19 +14,19 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.statalerts; +package org.apache.geode.internal.admin.statalerts; import java.io.DataOutput; import java.io.DataInput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.StatisticDescriptor; -import com.gemstone.gemfire.Statistics; -import com.gemstone.gemfire.StatisticsFactory; +import org.apache.geode.DataSerializer; +import org.apache.geode.StatisticDescriptor; +import org.apache.geode.Statistics; +import org.apache.geode.StatisticsFactory; -import com.gemstone.gemfire.internal.admin.StatAlert; -import com.gemstone.gemfire.internal.admin.StatAlertDefinition; +import org.apache.geode.internal.admin.StatAlert; +import org.apache.geode.internal.admin.StatAlertDefinition; /** * Implementation of {@link StatAlertDefinition} This provides the definition http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/NumberThresholdDecoratorImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/NumberThresholdDecoratorImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/NumberThresholdDecoratorImpl.java index 67db490..8096abe 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/NumberThresholdDecoratorImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/NumberThresholdDecoratorImpl.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.statalerts; +package org.apache.geode.internal.admin.statalerts; import java.io.DataOutput; import java.io.DataInput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.admin.StatAlert; -import com.gemstone.gemfire.internal.admin.StatAlertDefinition; +import org.apache.geode.DataSerializer; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.admin.StatAlert; +import org.apache.geode.internal.admin.StatAlertDefinition; /** * Implementation of {@link StatAlertDefinition}, represents threshold as http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/SingleAttrDefinitionImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/SingleAttrDefinitionImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/SingleAttrDefinitionImpl.java index e79b944..a01d398 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/SingleAttrDefinitionImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/SingleAttrDefinitionImpl.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.statalerts; +package org.apache.geode.internal.admin.statalerts; import java.io.DataOutput; import java.io.DataInput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.StatisticDescriptor; -import com.gemstone.gemfire.Statistics; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.internal.admin.StatAlert; -import com.gemstone.gemfire.internal.admin.StatAlertDefinition; +import org.apache.geode.DataSerializer; +import org.apache.geode.StatisticDescriptor; +import org.apache.geode.Statistics; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.internal.admin.StatAlert; +import org.apache.geode.internal.admin.StatAlertDefinition; /** * Implementation of {@link StatAlertDefinition} This provides the definition @@ -132,7 +132,7 @@ public final class SingleAttrDefinitionImpl implements StatAlertDefinition { /* * (non-Javadoc) * - * @see com.gemstone.gemfire.internal.admin.StatAlertDefinition#getStatisticInfo() + * @see org.apache.geode.internal.admin.StatAlertDefinition#getStatisticInfo() */ public StatisticInfo[] getStatisticInfo() { return new StatisticInfo[] { statisticInfo }; @@ -141,7 +141,7 @@ public final class SingleAttrDefinitionImpl implements StatAlertDefinition { /* * (non-Javadoc) * - * @see com.gemstone.gemfire.internal.admin.StatAlertDefinition#setStatisticInfo(com.gemstone.gemfire.internal.admin.StatisticInfo[]) + * @see org.apache.geode.internal.admin.StatAlertDefinition#setStatisticInfo(org.apache.geode.internal.admin.StatisticInfo[]) */ public void setStatisticInfo(StatisticInfo[] info) { if (info == null || info.length != 1) @@ -165,7 +165,7 @@ public final class SingleAttrDefinitionImpl implements StatAlertDefinition { /* * (non-Javadoc) * - * @see com.gemstone.gemfire.internal.admin.StatAlertDefinition#evaluate(java.lang.Number[]) + * @see org.apache.geode.internal.admin.StatAlertDefinition#evaluate(java.lang.Number[]) */ public boolean evaluate(Number[] params) { return evaluate() && params != null && params.length == 1; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfo.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfo.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfo.java index d07e6c2..cfd2883 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfo.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfo.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.statalerts; +package org.apache.geode.internal.admin.statalerts; -import com.gemstone.gemfire.DataSerializable; +import org.apache.geode.DataSerializable; -import com.gemstone.gemfire.StatisticDescriptor; -import com.gemstone.gemfire.Statistics; -import com.gemstone.gemfire.StatisticsType; +import org.apache.geode.StatisticDescriptor; +import org.apache.geode.Statistics; +import org.apache.geode.StatisticsType; /** * Provides informations of the statistic http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfoImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfoImpl.java b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfoImpl.java index f66bbff..f2453e6 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfoImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/admin/statalerts/StatisticInfoImpl.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.admin.statalerts; +package org.apache.geode.internal.admin.statalerts; import java.io.DataOutput; import java.io.DataInput; @@ -22,11 +22,11 @@ import java.io.IOException; import org.apache.commons.lang.StringUtils; -import com.gemstone.gemfire.StatisticDescriptor; -import com.gemstone.gemfire.Statistics; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.StatisticsType; -import com.gemstone.gemfire.admin.Statistic; +import org.apache.geode.StatisticDescriptor; +import org.apache.geode.Statistics; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.StatisticsType; +import org.apache.geode.admin.Statistic; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractBucketRegionQueue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractBucketRegionQueue.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractBucketRegionQueue.java index 70fb12d..8fa8597 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractBucketRegionQueue.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractBucketRegionQueue.java @@ -14,23 +14,23 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.cache.lru.LRUStatistics; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySender; -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySenderEventProcessor; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderEventImpl; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderStats; -import com.gemstone.gemfire.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue; -import com.gemstone.gemfire.internal.concurrent.ConcurrentHashSet; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.OffHeapRegionEntryHelper; -import com.gemstone.gemfire.internal.offheap.annotations.Released; +import org.apache.geode.cache.*; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.cache.lru.LRUStatistics; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.wan.AbstractGatewaySender; +import org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor; +import org.apache.geode.internal.cache.wan.GatewaySenderEventImpl; +import org.apache.geode.internal.cache.wan.GatewaySenderStats; +import org.apache.geode.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue; +import org.apache.geode.internal.concurrent.ConcurrentHashSet; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.OffHeapRegionEntryHelper; +import org.apache.geode.internal.offheap.annotations.Released; import org.apache.logging.log4j.Logger; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractCacheServer.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractCacheServer.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractCacheServer.java index 60e256d..07b1c8d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractCacheServer.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractCacheServer.java @@ -14,21 +14,21 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.cache.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.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.admin.ClientMembershipMessage; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheCreation; -import com.gemstone.gemfire.management.membership.ClientMembership; -import com.gemstone.gemfire.management.membership.ClientMembershipEvent; -import com.gemstone.gemfire.management.membership.ClientMembershipListener; +package org.apache.geode.internal.cache; + +import org.apache.geode.cache.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.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.admin.ClientMembershipMessage; +import org.apache.geode.internal.cache.xmlcache.CacheCreation; +import org.apache.geode.management.membership.ClientMembership; +import org.apache.geode.management.membership.ClientMembershipEvent; +import org.apache.geode.management.membership.ClientMembershipListener; import java.io.IOException; import java.util.Arrays; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskLRURegionEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskLRURegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskLRURegionEntry.java index a193014..d532d56 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskLRURegionEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskLRURegionEntry.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.internal.cache.lru.LRUEntry; +import org.apache.geode.internal.cache.lru.LRUEntry; /** * Abstract implementation class of RegionEntry interface. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskRegion.java index 231aa7a..562c002 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskRegion.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.PrintStream; import java.util.EnumSet; @@ -26,24 +26,24 @@ import java.util.concurrent.atomic.AtomicLong; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.EvictionAction; -import com.gemstone.gemfire.cache.EvictionAlgorithm; -import com.gemstone.gemfire.compression.Compressor; -import com.gemstone.gemfire.internal.ClassPathLoader; -import com.gemstone.gemfire.internal.CopyOnWriteHashSet; -import com.gemstone.gemfire.internal.cache.DiskInitFile.DiskRegionFlag; -import com.gemstone.gemfire.internal.cache.persistence.DiskRegionView; -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.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap; +import org.apache.geode.cache.EvictionAction; +import org.apache.geode.cache.EvictionAlgorithm; +import org.apache.geode.compression.Compressor; +import org.apache.geode.internal.ClassPathLoader; +import org.apache.geode.internal.CopyOnWriteHashSet; +import org.apache.geode.internal.cache.DiskInitFile.DiskRegionFlag; +import org.apache.geode.internal.cache.persistence.DiskRegionView; +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.cache.versions.VersionSource; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap; import joptsimple.internal.Strings; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskRegionEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskRegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskRegionEntry.java index 41cd110..4440417 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskRegionEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractDiskRegionEntry.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.internal.cache.wan.GatewaySenderEventImpl; -import com.gemstone.gemfire.internal.cache.wan.serial.SerialGatewaySenderQueue; -import com.gemstone.gemfire.internal.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; +import org.apache.geode.internal.cache.wan.GatewaySenderEventImpl; +import org.apache.geode.internal.cache.wan.serial.SerialGatewaySenderQueue; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; /** * * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionEntry.java index 036b8a6..d22bfd3 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionEntry.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.internal.cache.lru.LRUEntry; +import org.apache.geode.internal.cache.lru.LRUEntry; /** * Abstract implementation class of RegionEntry interface. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionMap.java index af9a389..95d2a3f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionMap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractLRURegionMap.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Iterator; import java.util.List; @@ -23,29 +23,29 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.cache.EvictionAction; -import com.gemstone.gemfire.cache.EvictionAlgorithm; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.control.InternalResourceManager; -import com.gemstone.gemfire.internal.cache.lru.EnableLRU; -import com.gemstone.gemfire.internal.cache.lru.HeapEvictor; -import com.gemstone.gemfire.internal.cache.lru.HeapLRUCapacityController; -import com.gemstone.gemfire.internal.cache.lru.LRUAlgorithm; -import com.gemstone.gemfire.internal.cache.lru.LRUEntry; -import com.gemstone.gemfire.internal.cache.lru.LRUStatistics; -import com.gemstone.gemfire.internal.cache.lru.MemLRUCapacityController; -import com.gemstone.gemfire.internal.cache.lru.NewLIFOClockHand; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.offheap.StoredObject; -import com.gemstone.gemfire.internal.size.ReflectionSingleObjectSizer; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.cache.EvictionAction; +import org.apache.geode.cache.EvictionAlgorithm; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.control.InternalResourceManager; +import org.apache.geode.internal.cache.lru.EnableLRU; +import org.apache.geode.internal.cache.lru.HeapEvictor; +import org.apache.geode.internal.cache.lru.HeapLRUCapacityController; +import org.apache.geode.internal.cache.lru.LRUAlgorithm; +import org.apache.geode.internal.cache.lru.LRUEntry; +import org.apache.geode.internal.cache.lru.LRUStatistics; +import org.apache.geode.internal.cache.lru.MemLRUCapacityController; +import org.apache.geode.internal.cache.lru.NewLIFOClockHand; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.offheap.StoredObject; +import org.apache.geode.internal.size.ReflectionSingleObjectSizer; /** * Abstract implementation of {@link RegionMap} that adds LRU behaviour. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractOplogDiskRegionEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractOplogDiskRegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractOplogDiskRegionEntry.java index d9b1008..fcd1400 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractOplogDiskRegionEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractOplogDiskRegionEntry.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.cache.EntryEvent; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.internal.ByteArrayDataInput; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; +import org.apache.geode.cache.EntryEvent; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.internal.ByteArrayDataInput; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.offheap.annotations.Retained; /** * Abstract implementation class of RegionEntry interface. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegion.java index 2d44979..f47c236 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegion.java @@ -15,35 +15,35 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue; -import com.gemstone.gemfire.cache.asyncqueue.internal.AsyncEventQueueImpl; -import com.gemstone.gemfire.cache.client.PoolManager; -import com.gemstone.gemfire.cache.client.internal.PoolImpl; -import com.gemstone.gemfire.cache.query.*; -import com.gemstone.gemfire.cache.query.internal.index.IndexManager; -import com.gemstone.gemfire.cache.snapshot.RegionSnapshotService; -import com.gemstone.gemfire.cache.wan.GatewaySender; -import com.gemstone.gemfire.compression.Compressor; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -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.lru.LRUAlgorithm; -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 com.gemstone.gemfire.internal.util.ArrayUtils; -import com.gemstone.gemfire.pdx.internal.PeerTypeRegistration; +package org.apache.geode.internal.cache; + +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.*; +import org.apache.geode.cache.asyncqueue.AsyncEventQueue; +import org.apache.geode.cache.asyncqueue.internal.AsyncEventQueueImpl; +import org.apache.geode.cache.client.PoolManager; +import org.apache.geode.cache.client.internal.PoolImpl; +import org.apache.geode.cache.query.*; +import org.apache.geode.cache.query.internal.index.IndexManager; +import org.apache.geode.cache.snapshot.RegionSnapshotService; +import org.apache.geode.cache.wan.GatewaySender; +import org.apache.geode.compression.Compressor; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionAdvisor; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.DataSerializableFixedID; +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.lru.LRUAlgorithm; +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; +import org.apache.geode.internal.util.ArrayUtils; +import org.apache.geode.pdx.internal.PeerTypeRegistration; import org.apache.logging.log4j.Logger; import java.io.DataInput; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionEntry.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionEntry.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionEntry.java index 5778a82..be82bd4 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionEntry.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionEntry.java @@ -15,53 +15,53 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.InvalidDeltaException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.query.IndexMaintenanceException; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.internal.index.IndexManager; -import com.gemstone.gemfire.cache.query.internal.index.IndexProtocol; -import com.gemstone.gemfire.cache.util.GatewayConflictHelper; -import com.gemstone.gemfire.cache.util.GatewayConflictResolver; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.*; -import com.gemstone.gemfire.internal.cache.lru.LRUClockNode; -import com.gemstone.gemfire.internal.cache.lru.NewLRUClockHand; -import com.gemstone.gemfire.internal.cache.persistence.DiskStoreID; -import com.gemstone.gemfire.internal.cache.versions.*; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderEventImpl; -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.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.offheap.*; -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 com.gemstone.gemfire.internal.util.Versionable; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; -import com.gemstone.gemfire.pdx.PdxInstance; -import com.gemstone.gemfire.pdx.PdxSerializable; -import com.gemstone.gemfire.pdx.PdxSerializationException; -import com.gemstone.gemfire.pdx.PdxSerializer; -import com.gemstone.gemfire.pdx.internal.ConvertableToBytes; -import com.gemstone.gemfire.pdx.internal.PdxInstanceImpl; +package org.apache.geode.internal.cache; + +import org.apache.geode.CancelException; +import org.apache.geode.InvalidDeltaException; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.*; +import org.apache.geode.cache.query.IndexMaintenanceException; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.cache.query.internal.index.IndexManager; +import org.apache.geode.cache.query.internal.index.IndexProtocol; +import org.apache.geode.cache.util.GatewayConflictHelper; +import org.apache.geode.cache.util.GatewayConflictResolver; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.*; +import org.apache.geode.internal.cache.lru.LRUClockNode; +import org.apache.geode.internal.cache.lru.NewLRUClockHand; +import org.apache.geode.internal.cache.persistence.DiskStoreID; +import org.apache.geode.internal.cache.versions.*; +import org.apache.geode.internal.cache.wan.GatewaySenderEventImpl; +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.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.offheap.*; +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; +import org.apache.geode.internal.util.Versionable; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap.HashEntry; +import org.apache.geode.pdx.PdxInstance; +import org.apache.geode.pdx.PdxSerializable; +import org.apache.geode.pdx.PdxSerializationException; +import org.apache.geode.pdx.PdxSerializer; +import org.apache.geode.pdx.internal.ConvertableToBytes; +import org.apache.geode.pdx.internal.PdxInstanceImpl; import org.apache.logging.log4j.Logger; import java.io.IOException; import java.util.Arrays; -import static com.gemstone.gemfire.internal.offheap.annotations.OffHeapIdentifier.ABSTRACT_REGION_ENTRY_FILL_IN_VALUE; -import static com.gemstone.gemfire.internal.offheap.annotations.OffHeapIdentifier.ABSTRACT_REGION_ENTRY_PREPARE_VALUE_FOR_CACHE; +import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.ABSTRACT_REGION_ENTRY_FILL_IN_VALUE; +import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.ABSTRACT_REGION_ENTRY_PREPARE_VALUE_FOR_CACHE; /** * Abstract implementation class of RegionEntry interface. @@ -1476,7 +1476,7 @@ public abstract class AbstractRegionEntry implements RegionEntry, * supporting concurrency versioning. It also sets the entry's version * stamp to the tag's values. * - * @see com.gemstone.gemfire.internal.cache.RegionEntry#generateVersionTag(com.gemstone.gemfire.distributed.DistributedMember, boolean) + * @see org.apache.geode.internal.cache.RegionEntry#generateVersionTag(org.apache.geode.distributed.DistributedMember, boolean) */ public VersionTag generateVersionTag(VersionSource mbr, boolean withDelta, LocalRegion region, EntryEventImpl event) { VersionStamp stamp = this.getVersionStamp(); @@ -1590,7 +1590,7 @@ public abstract class AbstractRegionEntry implements RegionEntry, * @throws ConcurrentCacheModificationException if the event conflicts with * an event that has already been applied to the entry. * - * @see com.gemstone.gemfire.internal.cache.RegionEntry#concurrencyCheck(com.gemstone.gemfire.cache.EntryEvent) + * @see org.apache.geode.internal.cache.RegionEntry#concurrencyCheck(org.apache.geode.cache.EntryEvent) */ public void processVersionTag(EntryEvent cacheEvent) { processVersionTag(cacheEvent, true); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java index 81e4d9f..738fef1 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractRegionMap.java @@ -15,44 +15,44 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.GemFireIOException; -import com.gemstone.gemfire.InvalidDeltaException; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.query.IndexMaintenanceException; -import com.gemstone.gemfire.cache.query.QueryException; -import com.gemstone.gemfire.cache.query.internal.index.IndexManager; -import com.gemstone.gemfire.cache.query.internal.index.IndexProtocol; -import com.gemstone.gemfire.distributed.DistributedMember; -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.DiskInitFile.DiskRegionFlag; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo.FilterInfo; -import com.gemstone.gemfire.internal.cache.ha.HAContainerWrapper; -import com.gemstone.gemfire.internal.cache.ha.HARegionQueue; -import com.gemstone.gemfire.internal.cache.lru.LRUEntry; -import com.gemstone.gemfire.internal.cache.region.entry.RegionEntryFactoryBuilder; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientNotifier; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientUpdateMessageImpl; -import com.gemstone.gemfire.internal.cache.tier.sockets.HAEventWrapper; -import com.gemstone.gemfire.internal.cache.versions.*; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderEventImpl; -import com.gemstone.gemfire.internal.concurrent.MapCallbackAdapter; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.offheap.OffHeapHelper; -import com.gemstone.gemfire.internal.offheap.OffHeapRegionEntryHelper; -import com.gemstone.gemfire.internal.offheap.ReferenceCountHelper; -import com.gemstone.gemfire.internal.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; -import com.gemstone.gemfire.internal.offheap.annotations.Unretained; -import com.gemstone.gemfire.internal.sequencelog.EntryLogger; -import com.gemstone.gemfire.internal.util.concurrent.CustomEntryConcurrentHashMap; +package org.apache.geode.internal.cache; + +import org.apache.geode.GemFireIOException; +import org.apache.geode.InvalidDeltaException; +import org.apache.geode.cache.*; +import org.apache.geode.cache.query.IndexMaintenanceException; +import org.apache.geode.cache.query.QueryException; +import org.apache.geode.cache.query.internal.index.IndexManager; +import org.apache.geode.cache.query.internal.index.IndexProtocol; +import org.apache.geode.distributed.DistributedMember; +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.DiskInitFile.DiskRegionFlag; +import org.apache.geode.internal.cache.FilterRoutingInfo.FilterInfo; +import org.apache.geode.internal.cache.ha.HAContainerWrapper; +import org.apache.geode.internal.cache.ha.HARegionQueue; +import org.apache.geode.internal.cache.lru.LRUEntry; +import org.apache.geode.internal.cache.region.entry.RegionEntryFactoryBuilder; +import org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.ClientUpdateMessageImpl; +import org.apache.geode.internal.cache.tier.sockets.HAEventWrapper; +import org.apache.geode.internal.cache.versions.*; +import org.apache.geode.internal.cache.wan.GatewaySenderEventImpl; +import org.apache.geode.internal.concurrent.MapCallbackAdapter; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.offheap.OffHeapHelper; +import org.apache.geode.internal.offheap.OffHeapRegionEntryHelper; +import org.apache.geode.internal.offheap.ReferenceCountHelper; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; +import org.apache.geode.internal.offheap.annotations.Unretained; +import org.apache.geode.internal.sequencelog.EntryLogger; +import org.apache.geode.internal.util.concurrent.CustomEntryConcurrentHashMap; import org.apache.logging.log4j.Logger; @@ -2246,7 +2246,7 @@ public abstract class AbstractRegionMap implements RegionMap { /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.RegionMap#updateEntryVersion(com.gemstone.gemfire.internal.cache.EntryEventImpl) + * @see org.apache.geode.internal.cache.RegionMap#updateEntryVersion(org.apache.geode.internal.cache.EntryEventImpl) */ @Override public void updateEntryVersion(EntryEventImpl event) throws EntryNotFoundException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java index 5a6351e..0593f20 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AbstractUpdateOperation.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,26 +24,26 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.InvalidVersionException; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DirectReplyProcessor; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.versions.ConcurrentCacheModificationException; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.util.DelayedAction; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.InvalidVersionException; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.Scope; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DirectReplyProcessor; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.versions.ConcurrentCacheModificationException; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.util.DelayedAction; /** * Common code for both UpdateOperation and DistributedPutAllOperation. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AcceptHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AcceptHelper.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AcceptHelper.java index 7675619..f90dd9a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AcceptHelper.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AcceptHelper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/AddCacheServerProfileMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/AddCacheServerProfileMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/AddCacheServerProfileMessage.java index 4609472..c6a732c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/AddCacheServerProfileMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/AddCacheServerProfileMessage.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -24,12 +24,12 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.MessageWithReply; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.SerialDistributionMessage; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.CancelException; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.MessageWithReply; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.SerialDistributionMessage; +import org.apache.geode.internal.logging.LogService; /** * OperationMessage synchronously propagates a change in the profile to http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/BackupLock.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BackupLock.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BackupLock.java index f304135..d03547f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BackupLock.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BackupLock.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.locks.Condition; import java.util.concurrent.locks.ReentrantLock; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/BucketAdvisor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketAdvisor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketAdvisor.java index 078e595..54fa618 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketAdvisor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketAdvisor.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.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.client.internal.locator.SerializationHelper; -import com.gemstone.gemfire.cache.partition.PartitionListener; -import com.gemstone.gemfire.distributed.DistributedLockService; -import com.gemstone.gemfire.distributed.DistributedSystemDisconnectedException; -import com.gemstone.gemfire.distributed.LockNotHeldException; -import com.gemstone.gemfire.distributed.LockServiceDestroyedException; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.MembershipListener; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.locks.DLockService; -import com.gemstone.gemfire.distributed.internal.locks.DistributedMemberLock; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.partitioned.Bucket; -import com.gemstone.gemfire.internal.cache.partitioned.BucketProfileUpdateMessage; -import com.gemstone.gemfire.internal.cache.partitioned.DeposePrimaryBucketMessage; -import com.gemstone.gemfire.internal.cache.partitioned.DeposePrimaryBucketMessage.DeposePrimaryBucketResponse; -import com.gemstone.gemfire.internal.cache.partitioned.RegionAdvisor; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.util.StopWatch; +package org.apache.geode.internal.cache; + +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.client.internal.locator.SerializationHelper; +import org.apache.geode.cache.partition.PartitionListener; +import org.apache.geode.distributed.DistributedLockService; +import org.apache.geode.distributed.DistributedSystemDisconnectedException; +import org.apache.geode.distributed.LockNotHeldException; +import org.apache.geode.distributed.LockServiceDestroyedException; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.MembershipListener; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.locks.DLockService; +import org.apache.geode.distributed.internal.locks.DistributedMemberLock; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.partitioned.Bucket; +import org.apache.geode.internal.cache.partitioned.BucketProfileUpdateMessage; +import org.apache.geode.internal.cache.partitioned.DeposePrimaryBucketMessage; +import org.apache.geode.internal.cache.partitioned.DeposePrimaryBucketMessage.DeposePrimaryBucketResponse; +import org.apache.geode.internal.cache.partitioned.RegionAdvisor; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.util.StopWatch; import org.apache.logging.log4j.Logger; 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/BucketDump.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketDump.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketDump.java index 22bab88..7ccdcee 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketDump.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketDump.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.ArrayList; import java.util.HashMap; import java.util.Map; import java.util.Map.Entry; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionTag; /** * This class is used for getting the contents of buckets and then optionally http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/BucketNotFoundException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketNotFoundException.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketNotFoundException.java index 2881e1f..d017304 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketNotFoundException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketNotFoundException.java @@ -17,7 +17,7 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * A version of ForceReattemptException that should be used when the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/BucketPersistenceAdvisor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketPersistenceAdvisor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketPersistenceAdvisor.java index 8c821ad..6683113 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketPersistenceAdvisor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketPersistenceAdvisor.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.Arrays; @@ -27,23 +27,23 @@ import java.util.concurrent.CountDownLatch; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.persistence.PartitionOfflineException; -import com.gemstone.gemfire.distributed.DistributedLockService; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.PartitionedRegion.BucketLock; -import com.gemstone.gemfire.internal.cache.partitioned.RedundancyAlreadyMetException; -import com.gemstone.gemfire.internal.cache.persistence.PersistenceAdvisorImpl; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberManager; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberView; -import com.gemstone.gemfire.internal.cache.persistence.PersistentStateListener.PersistentStateAdapter; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.util.TransformUtils; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.persistence.PartitionOfflineException; +import org.apache.geode.distributed.DistributedLockService; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.PartitionedRegion.BucketLock; +import org.apache.geode.internal.cache.partitioned.RedundancyAlreadyMetException; +import org.apache.geode.internal.cache.persistence.PersistenceAdvisorImpl; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.cache.persistence.PersistentMemberManager; +import org.apache.geode.internal.cache.persistence.PersistentMemberView; +import org.apache.geode.internal.cache.persistence.PersistentStateListener.PersistentStateAdapter; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.util.TransformUtils; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegion.java index 4e4c417..34beb9e 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegion.java @@ -14,51 +14,51 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.partition.PartitionListener; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.AtomicLongWithTerminalState; -import com.gemstone.gemfire.distributed.internal.DirectReplyProcessor; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.DistributionStats; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.HeapDataOutputStream; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.BucketAdvisor.BucketProfile; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo.FilterInfo; -import com.gemstone.gemfire.internal.cache.control.MemoryEvent; -import com.gemstone.gemfire.internal.cache.partitioned.Bucket; -import com.gemstone.gemfire.internal.cache.partitioned.DestroyMessage; -import com.gemstone.gemfire.internal.cache.partitioned.InvalidateMessage; -import com.gemstone.gemfire.internal.cache.partitioned.LockObject; -import com.gemstone.gemfire.internal.cache.partitioned.PRTombstoneMessage; -import com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage; -import com.gemstone.gemfire.internal.cache.partitioned.PutAllPRMessage; -import com.gemstone.gemfire.internal.cache.partitioned.PutMessage; -import com.gemstone.gemfire.internal.cache.partitioned.RemoveAllPRMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientNotifier; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientTombstoneMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientUpdateMessage; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.versions.VersionStamp; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderEventImpl; -import com.gemstone.gemfire.internal.concurrent.AtomicLong5; -import com.gemstone.gemfire.internal.concurrent.Atomics; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; -import com.gemstone.gemfire.internal.offheap.annotations.Unretained; +package org.apache.geode.internal.cache; + +import org.apache.geode.*; +import org.apache.geode.cache.*; +import org.apache.geode.cache.partition.PartitionListener; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.AtomicLongWithTerminalState; +import org.apache.geode.distributed.internal.DirectReplyProcessor; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.DistributionStats; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.HeapDataOutputStream; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.BucketAdvisor.BucketProfile; +import org.apache.geode.internal.cache.FilterRoutingInfo.FilterInfo; +import org.apache.geode.internal.cache.control.MemoryEvent; +import org.apache.geode.internal.cache.partitioned.Bucket; +import org.apache.geode.internal.cache.partitioned.DestroyMessage; +import org.apache.geode.internal.cache.partitioned.InvalidateMessage; +import org.apache.geode.internal.cache.partitioned.LockObject; +import org.apache.geode.internal.cache.partitioned.PRTombstoneMessage; +import org.apache.geode.internal.cache.partitioned.PartitionMessage; +import org.apache.geode.internal.cache.partitioned.PutAllPRMessage; +import org.apache.geode.internal.cache.partitioned.PutMessage; +import org.apache.geode.internal.cache.partitioned.RemoveAllPRMessage; +import org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.ClientTombstoneMessage; +import org.apache.geode.internal.cache.tier.sockets.ClientUpdateMessage; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.versions.VersionStamp; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.cache.wan.GatewaySenderEventImpl; +import org.apache.geode.internal.concurrent.AtomicLong5; +import org.apache.geode.internal.concurrent.Atomics; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; +import org.apache.geode.internal.offheap.annotations.Unretained; import org.apache.logging.log4j.Logger; import java.io.DataOutput; @@ -75,7 +75,7 @@ import java.util.concurrent.locks.Lock; * It does not support transactions * * Primary election for a BucketRegion can be found in the - * {@link com.gemstone.gemfire.internal.cache.BucketAdvisor} class + * {@link org.apache.geode.internal.cache.BucketAdvisor} class * * @since GemFire 5.1 * @@ -1617,7 +1617,7 @@ implements Bucket /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.LocalRegion#invokeDestroyCallbacks(com.gemstone.gemfire.internal.cache.EnumListenerEvent, com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean) + * @see org.apache.geode.internal.cache.LocalRegion#invokeDestroyCallbacks(org.apache.geode.internal.cache.EnumListenerEvent, org.apache.geode.internal.cache.EntryEventImpl, boolean) */ @Override public void invokeDestroyCallbacks( @@ -1644,7 +1644,7 @@ implements Bucket } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.LocalRegion#invokeInvalidateCallbacks(com.gemstone.gemfire.internal.cache.EnumListenerEvent, com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean) + * @see org.apache.geode.internal.cache.LocalRegion#invokeInvalidateCallbacks(org.apache.geode.internal.cache.EnumListenerEvent, org.apache.geode.internal.cache.EntryEventImpl, boolean) */ @Override public void invokeInvalidateCallbacks( @@ -1671,7 +1671,7 @@ implements Bucket } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.LocalRegion#invokePutCallbacks(com.gemstone.gemfire.internal.cache.EnumListenerEvent, com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean) + * @see org.apache.geode.internal.cache.LocalRegion#invokePutCallbacks(org.apache.geode.internal.cache.EnumListenerEvent, org.apache.geode.internal.cache.EntryEventImpl, boolean) */ @Override public void invokePutCallbacks( @@ -1776,12 +1776,12 @@ implements Bucket return; } Object instance = cd.getValue(); - if (instance instanceof com.gemstone.gemfire.Delta - && ((com.gemstone.gemfire.Delta)instance).hasDelta()) { + if (instance instanceof org.apache.geode.Delta + && ((org.apache.geode.Delta)instance).hasDelta()) { try { HeapDataOutputStream hdos = new HeapDataOutputStream(Version.CURRENT); long start = DistributionStats.getStatTime(); - ((com.gemstone.gemfire.Delta)instance).toDelta(hdos); + ((org.apache.geode.Delta)instance).toDelta(hdos); event.setDeltaBytes(hdos.toByteArray()); this.partitionedRegion.getCachePerfStats().endDeltaPrepared(start); } @@ -2017,7 +2017,7 @@ implements Bucket } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.partitioned.Bucket#getBucketOwners() + * @see org.apache.geode.internal.cache.partitioned.Bucket#getBucketOwners() * @since GemFire 5.9 */ public Set getBucketOwners() { @@ -2064,7 +2064,7 @@ implements Bucket return 0; } if (!(value instanceof byte[]) && !(value instanceof CachedDeserializable) - && !(value instanceof com.gemstone.gemfire.Delta) + && !(value instanceof org.apache.geode.Delta) && !(value instanceof GatewaySenderEventImpl)) { // ezoerner:20090401 it's possible this value is a Delta throw new InternalGemFireError("DEBUG: calcMemSize: weird value (class " http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionEvictior.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionEvictior.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionEvictior.java index fca7801..2e35c98 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionEvictior.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionEvictior.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 java.util.concurrent.Callable; -import com.gemstone.gemfire.cache.Region; +import org.apache.geode.cache.Region; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionQueue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionQueue.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionQueue.java index 92442d9..294b616 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionQueue.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketRegionQueue.java @@ -17,7 +17,7 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.IOException; import java.io.InputStream; @@ -36,24 +36,24 @@ import java.util.concurrent.atomic.AtomicReference; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.TimeoutException; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.persistence.query.mock.ByteComparator; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.wan.AbstractGatewaySenderEventProcessor; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderEventImpl; -import com.gemstone.gemfire.internal.cache.wan.parallel.BucketRegionQueueUnavailableException; -import com.gemstone.gemfire.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue; -import com.gemstone.gemfire.internal.concurrent.Atomics; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.offheap.OffHeapRegionEntryHelper; -import com.gemstone.gemfire.internal.offheap.annotations.Released; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.TimeoutException; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.persistence.query.mock.ByteComparator; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor; +import org.apache.geode.internal.cache.wan.GatewaySenderEventImpl; +import org.apache.geode.internal.cache.wan.parallel.BucketRegionQueueUnavailableException; +import org.apache.geode.internal.cache.wan.parallel.ConcurrentParallelGatewaySenderQueue; +import org.apache.geode.internal.concurrent.Atomics; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.OffHeapRegionEntryHelper; +import org.apache.geode.internal.offheap.annotations.Released; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/BucketServerLocation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketServerLocation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketServerLocation.java index 03ceab1..54d78bc 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketServerLocation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketServerLocation.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.internal.ServerLocation; +import org.apache.geode.DataSerializer; +import org.apache.geode.distributed.internal.ServerLocation; /** * Represents the {@link ServerLocation} of a {@link BucketRegion} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/BucketServerLocation66.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketServerLocation66.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketServerLocation66.java index b2c79e1..a610344 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BucketServerLocation66.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BucketServerLocation66.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.internal.ServerLocation; +import org.apache.geode.DataSerializer; +import org.apache.geode.distributed.internal.ServerLocation; /** * Represents the {@link ServerLocation} of a {@link BucketRegion} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/BytesAndBitsForCompactor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/BytesAndBitsForCompactor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/BytesAndBitsForCompactor.java index e4048a9..f9f6ff2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/BytesAndBitsForCompactor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/BytesAndBitsForCompactor.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.offheap.StoredObject; -import com.gemstone.gemfire.internal.offheap.annotations.Unretained; +import org.apache.geode.internal.offheap.StoredObject; +import org.apache.geode.internal.offheap.annotations.Unretained; /** * Used to fetch a record's raw bytes and user bits.
