http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedTombstoneOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedTombstoneOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedTombstoneOperation.java index 1627fb8..c4995cb 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedTombstoneOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedTombstoneOperation.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.DataSerializer; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.SerializationVersions; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.VersionedDataSerializable; -import com.gemstone.gemfire.internal.cache.persistence.DiskStoreID; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo.FilterInfo; +package org.apache.geode.internal.cache; + +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Operation; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.SerializationVersions; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.VersionedDataSerializable; +import org.apache.geode.internal.cache.persistence.DiskStoreID; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.FilterRoutingInfo.FilterInfo; import java.io.DataInput; import java.io.DataOutput; @@ -86,7 +86,7 @@ public class DistributedTombstoneOperation extends DistributedCacheOperation { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.DistributedCacheOperation#getLocalFilterRouting(com.gemstone.gemfire.internal.cache.FilterRoutingInfo) + * @see org.apache.geode.internal.cache.DistributedCacheOperation#getLocalFilterRouting(org.apache.geode.internal.cache.FilterRoutingInfo) */ @Override protected FilterInfo getLocalFilterRouting(FilterRoutingInfo frInfo) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DummyCachePerfStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DummyCachePerfStats.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DummyCachePerfStats.java index 8c0eabf..0122d5a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DummyCachePerfStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DummyCachePerfStats.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.Statistics; -import com.gemstone.gemfire.distributed.internal.PoolStatHelper; +import org.apache.geode.Statistics; +import org.apache.geode.distributed.internal.PoolStatHelper; /** * @since GemFire 5.7 http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DynamicRegionAttributes.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DynamicRegionAttributes.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DynamicRegionAttributes.java index f855255..5f69999 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DynamicRegionAttributes.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DynamicRegionAttributes.java @@ -15,14 +15,14 @@ * 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.DataSerializable; -import com.gemstone.gemfire.DataSerializer; +import org.apache.geode.DataSerializable; +import org.apache.geode.DataSerializer; /** * Class <code>DynamicRegionAttributes</code> encapsulates the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DynamicRegionFactoryImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DynamicRegionFactoryImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DynamicRegionFactoryImpl.java index 09afc91..584a2a7 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DynamicRegionFactoryImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DynamicRegionFactoryImpl.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.CacheException; -import com.gemstone.gemfire.cache.DynamicRegionFactory; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.DynamicRegionFactory; /** This class provides non-published methods that allow the cache to initialize and close the factory. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/EntriesMap.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EntriesMap.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EntriesMap.java index 3db1320..0f01bcf 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EntriesMap.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EntriesMap.java @@ -15,15 +15,15 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.*; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.internal.InternalStatisticsDisabledException; +import org.apache.geode.cache.*; +import org.apache.geode.internal.InternalStatisticsDisabledException; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentMap; -import com.gemstone.gemfire.distributed.internal.DM; +import org.apache.geode.distributed.internal.DM; /** * Interface for accessing extended features of a ConcurrentMap used for http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/EntriesSet.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EntriesSet.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EntriesSet.java index 109b9c7..de91f03 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EntriesSet.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EntriesSet.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.AbstractSet; import java.util.ArrayList; @@ -24,12 +24,12 @@ import java.util.Iterator; import java.util.List; import java.util.NoSuchElementException; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.query.internal.QueryExecutionContext; -import com.gemstone.gemfire.internal.cache.LocalRegion.IteratorType; -import com.gemstone.gemfire.internal.cache.LocalRegion.NonTXEntry; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.query.internal.QueryExecutionContext; +import org.apache.geode.internal.cache.LocalRegion.IteratorType; +import org.apache.geode.internal.cache.LocalRegion.NonTXEntry; +import org.apache.geode.internal.i18n.LocalizedStrings; /** Set view of entries */ public class EntriesSet extends AbstractSet { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/EntryBits.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EntryBits.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EntryBits.java index a67a335..bf453ca 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EntryBits.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EntryBits.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * Interprets a one-byte bit field used for entry properties. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/EntryEventImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EntryEventImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EntryEventImpl.java index bd7596f..a555cca 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EntryEventImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EntryEventImpl.java @@ -15,50 +15,50 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.*; -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.query.internal.index.IndexUtils; -import com.gemstone.gemfire.cache.util.TimestampedEntryEvent; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.*; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo.FilterInfo; -import com.gemstone.gemfire.internal.cache.lru.Sizeable; -import com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage; -import com.gemstone.gemfire.internal.cache.partitioned.PutMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheServerHelper; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tx.DistTxKeyInfo; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderEventCallbackArgument; -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.ArrayUtils; -import com.gemstone.gemfire.internal.util.BlobHelper; -import com.gemstone.gemfire.pdx.internal.PeerTypeRegistration; +package org.apache.geode.internal.cache; + +import org.apache.geode.*; +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.query.internal.index.IndexUtils; +import org.apache.geode.cache.util.TimestampedEntryEvent; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.*; +import org.apache.geode.internal.cache.FilterRoutingInfo.FilterInfo; +import org.apache.geode.internal.cache.lru.Sizeable; +import org.apache.geode.internal.cache.partitioned.PartitionMessage; +import org.apache.geode.internal.cache.partitioned.PutMessage; +import org.apache.geode.internal.cache.tier.sockets.CacheServerHelper; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tx.DistTxKeyInfo; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.cache.wan.GatewaySenderEventCallbackArgument; +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.ArrayUtils; +import org.apache.geode.internal.util.BlobHelper; +import org.apache.geode.pdx.internal.PeerTypeRegistration; import org.apache.logging.log4j.Logger; import java.io.*; import java.util.function.Function; -import static com.gemstone.gemfire.internal.offheap.annotations.OffHeapIdentifier.ENTRY_EVENT_NEW_VALUE; -import static com.gemstone.gemfire.internal.offheap.annotations.OffHeapIdentifier.ENTRY_EVENT_OLD_VALUE; +import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.ENTRY_EVENT_NEW_VALUE; +import static org.apache.geode.internal.offheap.annotations.OffHeapIdentifier.ENTRY_EVENT_OLD_VALUE; /** * Implementation of an entry event @@ -1036,7 +1036,7 @@ public class EntryEventImpl } /** - * @see com.gemstone.gemfire.cache.CacheEvent#getRegion() + * @see org.apache.geode.cache.CacheEvent#getRegion() */ public final LocalRegion getRegion() { return region; @@ -1057,7 +1057,7 @@ public class EntryEventImpl } /** - * @see com.gemstone.gemfire.cache.CacheEvent#getCallbackArgument() + * @see org.apache.geode.cache.CacheEvent#getCallbackArgument() */ public Object getCallbackArgument() { @@ -1390,7 +1390,7 @@ public class EntryEventImpl || obj == Token.NOT_AVAILABLE || Token.isInvalidOrRemoved(obj) // don't serialize delta object already serialized - || obj instanceof com.gemstone.gemfire.Delta) { // internal delta + || obj instanceof org.apache.geode.Delta) { // internal delta return obj; } final CachedDeserializable cd; @@ -1579,7 +1579,7 @@ public class EntryEventImpl //This is a horrible hack, but we need to get the size of the object //When we store an entry. This code is only used when we do a put //in the primary. - if(v instanceof com.gemstone.gemfire.Delta && region.isUsedForPartitionedRegionBucket()) { + if(v instanceof org.apache.geode.Delta && region.isUsedForPartitionedRegionBucket()) { int vSize; Object ov = basicGetOldValue(); if(ov instanceof CachedDeserializable && !GemFireCacheImpl.DELTAS_RECALCULATE_SIZE) { @@ -1703,7 +1703,7 @@ public class EntryEventImpl boolean deltaBytesApplied = false; try { long start = CachePerfStats.getStatTime(); - ((com.gemstone.gemfire.Delta)value).fromDelta(new DataInputStream( + ((org.apache.geode.Delta)value).fromDelta(new DataInputStream( new ByteArrayInputStream(getDeltaBytes()))); this.region.getCachePerfStats().endDeltaUpdate(start); deltaBytesApplied = true; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/EntryExpiryTask.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EntryExpiryTask.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EntryExpiryTask.java index ac2a054..816f32f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EntryExpiryTask.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EntryExpiryTask.java @@ -15,17 +15,17 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * EntryExpiryTask represents a timeout event for a region entry. */ -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.InternalStatisticsDisabledException; -import com.gemstone.gemfire.internal.logging.LogService; -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.InternalStatisticsDisabledException; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.annotations.Released; import org.apache.logging.log4j.Logger; import java.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/EntryOperationImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EntryOperationImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EntryOperationImpl.java index 4b757fb..0c78af8 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EntryOperationImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EntryOperationImpl.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.EntryOperation; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.Region; +import org.apache.geode.cache.EntryOperation; +import org.apache.geode.cache.Operation; +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/EntrySnapshot.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EntrySnapshot.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EntrySnapshot.java index b5c828f..240aed1 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EntrySnapshot.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EntrySnapshot.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -22,14 +22,14 @@ import java.io.IOException; import java.util.Hashtable; import java.util.Map; -import com.gemstone.gemfire.DataSerializable; -import com.gemstone.gemfire.cache.CacheStatistics; -import com.gemstone.gemfire.cache.EntryDestroyedException; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.StatisticsDisabledException; -import com.gemstone.gemfire.internal.cache.versions.VersionStamp; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.DataSerializable; +import org.apache.geode.cache.CacheStatistics; +import org.apache.geode.cache.EntryDestroyedException; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.StatisticsDisabledException; +import org.apache.geode.internal.cache.versions.VersionStamp; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * A Region.Entry implementation for remote entries and all PR entries @@ -205,7 +205,7 @@ private static final long serialVersionUID = -2139749921655693280L; /* * (non-Javadoc) - * @see com.gemstone.gemfire.cache.Region.Entry#isLocal() + * @see org.apache.geode.cache.Region.Entry#isLocal() */ public boolean isLocal() { // pr entries are always non-local to support the bucket being moved out http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/EnumListenerEvent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EnumListenerEvent.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EnumListenerEvent.java index 1fa5709..5212614 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EnumListenerEvent.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EnumListenerEvent.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.*; +import org.apache.geode.cache.*; public abstract class EnumListenerEvent { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/EventID.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EventID.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EventID.java index a9fb7da..6d17a67 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EventID.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EventID.java @@ -14,24 +14,24 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.HeapDataOutputStream; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.ha.HARegionQueue; -import com.gemstone.gemfire.internal.cache.ha.ThreadIdentifier; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.util.Breadcrumbs; +package org.apache.geode.internal.cache; + +import org.apache.geode.DataSerializer; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.HeapDataOutputStream; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.ha.HARegionQueue; +import org.apache.geode.internal.cache.ha.ThreadIdentifier; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.util.Breadcrumbs; 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/EventIDHolder.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EventIDHolder.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EventIDHolder.java index 6dd8586..4d27aee 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EventIDHolder.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EventIDHolder.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; /** * This class is an event that just holds an EventID. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/EventStateHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EventStateHelper.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EventStateHelper.java index b59b0a4..3ba96ad 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EventStateHelper.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EventStateHelper.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 com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.cache.CreateRegionProcessor.CreateRegionReplyMessage; -import com.gemstone.gemfire.internal.cache.EventTracker.EventSeqnoHolder; -import com.gemstone.gemfire.internal.cache.InitialImageOperation.RegionStateMessage; -import com.gemstone.gemfire.internal.cache.ha.HARegionQueue.DispatchedAndCurrentEvents; -import com.gemstone.gemfire.internal.cache.ha.ThreadIdentifier; +import org.apache.geode.DataSerializer; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.cache.CreateRegionProcessor.CreateRegionReplyMessage; +import org.apache.geode.internal.cache.EventTracker.EventSeqnoHolder; +import org.apache.geode.internal.cache.InitialImageOperation.RegionStateMessage; +import org.apache.geode.internal.cache.ha.HARegionQueue.DispatchedAndCurrentEvents; +import org.apache.geode.internal.cache.ha.ThreadIdentifier; import java.io.DataInput; import java.io.DataOutput; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/EventTracker.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EventTracker.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EventTracker.java index ee24cf9..af294a9 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EventTracker.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EventTracker.java @@ -17,22 +17,22 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.DataSerializable; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.client.PoolFactory; -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.SystemTimer.SystemTimerTask; -import com.gemstone.gemfire.internal.cache.ha.ThreadIdentifier; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.util.concurrent.StoppableCountDownLatch; +import org.apache.geode.DataSerializable; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.client.PoolFactory; +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.SystemTimer.SystemTimerTask; +import org.apache.geode.internal.cache.ha.ThreadIdentifier; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.util.concurrent.StoppableCountDownLatch; import org.apache.logging.log4j.Logger; import java.io.DataInput; @@ -57,7 +57,7 @@ public class EventTracker * a mapping of originator to the last event applied to this cache * * Keys are instances of {@link ThreadIdentifier}, values are instances - * of {@link com.gemstone.gemfire.internal.cache.EventTracker.EventSeqnoHolder}. + * of {@link org.apache.geode.internal.cache.EventTracker.EventSeqnoHolder}. */ protected final ConcurrentMap<ThreadIdentifier, EventSeqnoHolder> recordedEvents = new ConcurrentHashMap<ThreadIdentifier, EventSeqnoHolder>(100); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/EvictionAttributesImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/EvictionAttributesImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/EvictionAttributesImpl.java index 50242aa..c30b7b5 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/EvictionAttributesImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/EvictionAttributesImpl.java @@ -14,24 +14,24 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.EvictionAction; -import com.gemstone.gemfire.cache.EvictionAlgorithm; -import com.gemstone.gemfire.cache.EvictionAttributes; -import com.gemstone.gemfire.cache.EvictionAttributesMutator; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.util.ObjectSizer; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.cache.lru.HeapLRUCapacityController; -import com.gemstone.gemfire.internal.cache.lru.LRUAlgorithm; -import com.gemstone.gemfire.internal.cache.lru.LRUCapacityController; -import com.gemstone.gemfire.internal.cache.lru.MemLRUCapacityController; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.EvictionAction; +import org.apache.geode.cache.EvictionAlgorithm; +import org.apache.geode.cache.EvictionAttributes; +import org.apache.geode.cache.EvictionAttributesMutator; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.util.ObjectSizer; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.cache.lru.HeapLRUCapacityController; +import org.apache.geode.internal.cache.lru.LRUAlgorithm; +import org.apache.geode.internal.cache.lru.LRUCapacityController; +import org.apache.geode.internal.cache.lru.MemLRUCapacityController; /** * Defines the attributes for configuring the eviction controller associated @@ -39,14 +39,14 @@ import com.gemstone.gemfire.internal.cache.lru.MemLRUCapacityController; * previoulsy deprecated CapacityController interface. Eviction, as defined * here, is the process of removing an Entry from the Region and potentially * placing it elsewhere, as defined by the - * {@link com.gemstone.gemfire.cache.EvictionAction}. The algorithms used to + * {@link org.apache.geode.cache.EvictionAction}. The algorithms used to * determine when to perform the <code>EvictionAction</code> are enumerated in - * the {@link com.gemstone.gemfire.cache.EvictionAlgorithm} class. + * the {@link org.apache.geode.cache.EvictionAlgorithm} class. * - * @see com.gemstone.gemfire.cache.EvictionAlgorithm - * @see com.gemstone.gemfire.cache.AttributesFactory - * @see com.gemstone.gemfire.cache.RegionAttributes - * @see com.gemstone.gemfire.cache.AttributesMutator + * @see org.apache.geode.cache.EvictionAlgorithm + * @see org.apache.geode.cache.AttributesFactory + * @see org.apache.geode.cache.RegionAttributes + * @see org.apache.geode.cache.AttributesMutator * * @since GemFire 5.0 */ @@ -98,7 +98,7 @@ public final class EvictionAttributesImpl extends EvictionAttributes } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.EvictionAttributes#getObjectSizer() + * @see org.apache.geode.cache.EvictionAttributes#getObjectSizer() */ @Override public ObjectSizer getObjectSizer() @@ -107,7 +107,7 @@ public final class EvictionAttributesImpl extends EvictionAttributes } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.EvictionAttributes#getAlgorithm() + * @see org.apache.geode.cache.EvictionAttributes#getAlgorithm() */ @Override public EvictionAlgorithm getAlgorithm() @@ -135,7 +135,7 @@ public final class EvictionAttributesImpl extends EvictionAttributes } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.EvictionAttributes#getMaximum() + * @see org.apache.geode.cache.EvictionAttributes#getMaximum() */ @Override public int getMaximum() @@ -166,7 +166,7 @@ public final class EvictionAttributesImpl extends EvictionAttributes } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.EvictionAttributes#getAction() + * @see org.apache.geode.cache.EvictionAttributes#getAction() */ @Override public EvictionAction getAction() http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ExpirationScheduler.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ExpirationScheduler.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ExpirationScheduler.java index 754db38..83f0c07 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ExpirationScheduler.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ExpirationScheduler.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 com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.SystemTimer; -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.EntryNotFoundException; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.SystemTimer; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; import org.apache.logging.log4j.Logger; import java.util.concurrent.atomic.AtomicInteger; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ExpiryTask.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ExpiryTask.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ExpiryTask.java index 5e09cbe..72e2e70 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ExpiryTask.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ExpiryTask.java @@ -15,25 +15,25 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; /** * ExpiryTask represents a timeout event for expiration */ -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.PooledExecutorWithDMStats; -import com.gemstone.gemfire.internal.SystemTimer; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.LoggingThreadGroup; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.tcp.ConnectionTable; +import org.apache.geode.CancelException; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.*; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.PooledExecutorWithDMStats; +import org.apache.geode.internal.SystemTimer; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.LoggingThreadGroup; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.tcp.ConnectionTable; import org.apache.logging.log4j.Logger; import java.util.concurrent.RejectedExecutionException; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ExportDiskRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ExportDiskRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ExportDiskRegion.java index 17b73b4..83e4703 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ExportDiskRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ExportDiskRegion.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.io.IOException; import java.util.HashMap; import java.util.Map; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.DiskEntry.RecoveredEntry; -import com.gemstone.gemfire.internal.cache.persistence.DiskRegionView; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.DiskEntry.RecoveredEntry; +import org.apache.geode.internal.cache.persistence.DiskRegionView; /** * An implementation if DiskRegion used for offline export. After each oplog http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/FilterProfile.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/FilterProfile.java b/geode-core/src/main/java/org/apache/geode/internal/cache/FilterProfile.java index 73df7be..e64cb1a 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/FilterProfile.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/FilterProfile.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; @@ -35,47 +35,47 @@ import java.util.regex.Pattern; 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.EntryEvent; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.cache.SerializedCacheValue; -import com.gemstone.gemfire.cache.query.internal.CqStateImpl; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.cache.query.internal.cq.CqServiceProvider; -import com.gemstone.gemfire.cache.query.internal.cq.ServerCQ; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -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.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.ClassLoadUtil; -import com.gemstone.gemfire.internal.CopyOnWriteHashSet; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.CacheProfile; -import com.gemstone.gemfire.internal.cache.DistributedPutAllOperation.PutAllEntryData; -import com.gemstone.gemfire.internal.cache.DistributedRemoveAllOperation.RemoveAllEntryData; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo.FilterInfo; -import com.gemstone.gemfire.internal.cache.tier.InterestType; -import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientNotifier; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.UnregisterAllInterest; -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.Unretained; -import com.gemstone.gemfire.internal.util.concurrent.CopyOnWriteHashMap; +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.EntryEvent; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.Region; +import org.apache.geode.cache.SerializedCacheValue; +import org.apache.geode.cache.query.internal.CqStateImpl; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.cache.query.internal.cq.CqServiceProvider; +import org.apache.geode.cache.query.internal.cq.ServerCQ; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +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.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.ClassLoadUtil; +import org.apache.geode.internal.CopyOnWriteHashSet; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.CacheDistributionAdvisor.CacheProfile; +import org.apache.geode.internal.cache.DistributedPutAllOperation.PutAllEntryData; +import org.apache.geode.internal.cache.DistributedRemoveAllOperation.RemoveAllEntryData; +import org.apache.geode.internal.cache.FilterRoutingInfo.FilterInfo; +import org.apache.geode.internal.cache.tier.InterestType; +import org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.UnregisterAllInterest; +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.Unretained; +import org.apache.geode.internal.util.concurrent.CopyOnWriteHashMap; /** * FilterProfile represents a distributed system member and is used for @@ -1809,7 +1809,7 @@ public class FilterProfile implements DataSerializableFixedID { String serverCqName; /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DistributionMessage#process(com.gemstone.gemfire.distributed.internal.DistributionManager) + * @see org.apache.geode.distributed.internal.DistributionMessage#process(org.apache.geode.distributed.internal.DistributionManager) */ @Override protected void process(DistributionManager dm) { @@ -1934,7 +1934,7 @@ public class FilterProfile implements DataSerializableFixedID { } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.DataSerializableFixedID#getDSFID() + * @see org.apache.geode.internal.DataSerializableFixedID#getDSFID() */ public int getDSFID() { return FILTER_PROFILE_UPDATE; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/FilterRoutingInfo.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/FilterRoutingInfo.java b/geode-core/src/main/java/org/apache/geode/internal/cache/FilterRoutingInfo.java index 46fd295..7901397 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/FilterRoutingInfo.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/FilterRoutingInfo.java @@ -14,19 +14,19 @@ * 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.DataSerializable; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.HeapDataOutputStream; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.VersionedDataInputStream; -import com.gemstone.gemfire.internal.VersionedDataSerializable; +import org.apache.geode.DataSerializable; +import org.apache.geode.DataSerializer; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.HeapDataOutputStream; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.VersionedDataInputStream; +import org.apache.geode.internal.VersionedDataSerializable; import java.io.ByteArrayInputStream; 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/FindDurableQueueProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/FindDurableQueueProcessor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/FindDurableQueueProcessor.java index 7ec993a..241a965 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/FindDurableQueueProcessor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/FindDurableQueueProcessor.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; @@ -28,20 +28,20 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.MessageWithReply; -import com.gemstone.gemfire.distributed.internal.PooledDistributionMessage; -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.ServerLocation; -import com.gemstone.gemfire.distributed.internal.ServerLocator; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.Cache; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.MessageWithReply; +import org.apache.geode.distributed.internal.PooledDistributionMessage; +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.ServerLocation; +import org.apache.geode.distributed.internal.ServerLocator; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.logging.LogService; /** * A processor for helping a locator find the durable queues for a given durable client id. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/FindRemoteTXMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/FindRemoteTXMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/FindRemoteTXMessage.java index 5310495..d9321bc 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/FindRemoteTXMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/FindRemoteTXMessage.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; @@ -25,23 +25,23 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.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.ReplySender; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.DataSerializer; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.Cache; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.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.ReplySender; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.cache.partitioned.PartitionMessage; +import org.apache.geode.internal.logging.LogService; /** * Message to all the peers to ask which member hosts the transaction http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/FindVersionTagOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/FindVersionTagOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/FindVersionTagOperation.java index 221d7dc..3fbfaba 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/FindVersionTagOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/FindVersionTagOperation.java @@ -17,7 +17,7 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.DataInput; import java.io.DataOutput; @@ -27,18 +27,18 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.HighPriorityDistributionMessage; -import com.gemstone.gemfire.distributed.internal.MessageWithReply; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.HighPriorityDistributionMessage; +import org.apache.geode.distributed.internal.MessageWithReply; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.logging.LogService; /** * @@ -126,7 +126,7 @@ public class FindVersionTagOperation { } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DistributionMessage#process(com.gemstone.gemfire.distributed.internal.DistributionManager) + * @see org.apache.geode.distributed.internal.DistributionMessage#process(org.apache.geode.distributed.internal.DistributionManager) */ @Override protected void process(DistributionManager dm) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/FixedPartitionAttributesImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/FixedPartitionAttributesImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/FixedPartitionAttributesImpl.java index e0b915a..ce11829 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/FixedPartitionAttributesImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/FixedPartitionAttributesImpl.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.DataSerializable; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.FixedPartitionAttributes; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; +import org.apache.geode.DataSerializable; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.FixedPartitionAttributes; +import org.apache.geode.distributed.internal.DistributionConfig; import java.io.DataInput; import java.io.DataOutput; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ForceReattemptException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ForceReattemptException.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ForceReattemptException.java index 04b95bb..e3df1a6 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ForceReattemptException.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ForceReattemptException.java @@ -15,18 +15,18 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.internal.Assert; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.internal.Assert; /** * Indicates that the current partitioned region operation failed. It * is only thrown in a context where the higher level operation needs to * instigate a retry of some sort. * - * @see com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage + * @see org.apache.geode.internal.cache.partitioned.PartitionMessage * @since GemFire 5.0 */ public class ForceReattemptException extends http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/ForceableLinkedBlockingQueue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ForceableLinkedBlockingQueue.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ForceableLinkedBlockingQueue.java index f58fc02..8f1c3a8 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ForceableLinkedBlockingQueue.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ForceableLinkedBlockingQueue.java @@ -26,7 +26,7 @@ * Expert Group and released to the public domain, as explained at * http://creativecommons.org/licenses/publicdomain */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicInteger; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/FunctionStreamingOrderedReplyMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/FunctionStreamingOrderedReplyMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/FunctionStreamingOrderedReplyMessage.java index 3c196bc..c0d3d4d 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/FunctionStreamingOrderedReplyMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/FunctionStreamingOrderedReplyMessage.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 org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +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/FunctionStreamingReplyMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/FunctionStreamingReplyMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/FunctionStreamingReplyMessage.java index aaf6548..fef5f95 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/FunctionStreamingReplyMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/FunctionStreamingReplyMessage.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; @@ -23,14 +23,14 @@ import java.io.NotSerializableException; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.DistributedSystemDisconnectedException; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.distributed.DistributedSystemDisconnectedException; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.logging.LogService; public class FunctionStreamingReplyMessage extends ReplyMessage{ private static final Logger logger = LogService.getLogger(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/GatewayEventFilter.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/GatewayEventFilter.java b/geode-core/src/main/java/org/apache/geode/internal/cache/GatewayEventFilter.java index e791b12..94e3fb2 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/GatewayEventFilter.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/GatewayEventFilter.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; /** * *
