http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskRegionStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskRegionStats.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskRegionStats.java index 014fd6f..7d9c0ad 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskRegionStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskRegionStats.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; - -import com.gemstone.gemfire.StatisticDescriptor; -import com.gemstone.gemfire.Statistics; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.StatisticsType; -import com.gemstone.gemfire.StatisticsTypeFactory; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; +package org.apache.geode.internal.cache; + +import org.apache.geode.StatisticDescriptor; +import org.apache.geode.Statistics; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.StatisticsType; +import org.apache.geode.StatisticsTypeFactory; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; /** * GemFire statistics about a {@link DiskRegion}.
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreAttributes.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreAttributes.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreAttributes.java index 451a907..ea2a35d 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreAttributes.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreAttributes.java @@ -17,14 +17,14 @@ /** * */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.File; import java.io.Serializable; import java.util.UUID; -import com.gemstone.gemfire.cache.DiskStore; -import com.gemstone.gemfire.cache.DiskStoreFactory; +import org.apache.geode.cache.DiskStore; +import org.apache.geode.cache.DiskStoreFactory; /** * Creates an attribute object for DiskStore. @@ -73,28 +73,28 @@ public class DiskStoreAttributes implements Serializable, DiskStore { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.DiskStore#getAllowForceCompaction() + * @see org.apache.geode.cache.DiskStore#getAllowForceCompaction() */ public boolean getAllowForceCompaction() { return this.allowForceCompaction; } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.DiskStore#getAutoCompact() + * @see org.apache.geode.cache.DiskStore#getAutoCompact() */ public boolean getAutoCompact() { return this.autoCompact; } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.DiskStore#getCompactionThreshold() + * @see org.apache.geode.cache.DiskStore#getCompactionThreshold() */ public int getCompactionThreshold() { return this.compactionThreshold; } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.DiskStore#getDiskDirSizes() + * @see org.apache.geode.cache.DiskStore#getDiskDirSizes() */ public int[] getDiskDirSizes() { int[] result = new int[this.diskDirSizes.length]; @@ -103,7 +103,7 @@ public class DiskStoreAttributes implements Serializable, DiskStore { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.DiskStore#getDiskDirs() + * @see org.apache.geode.cache.DiskStore#getDiskDirs() */ public File[] getDiskDirs() { File[] result = new File[this.diskDirs.length]; @@ -112,7 +112,7 @@ public class DiskStoreAttributes implements Serializable, DiskStore { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.DiskStore#getMaxOplogSize() + * @see org.apache.geode.cache.DiskStore#getMaxOplogSize() */ public long getMaxOplogSize() { // TODO Auto-generated method stub @@ -127,28 +127,28 @@ public class DiskStoreAttributes implements Serializable, DiskStore { } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.DiskStore#getName() + * @see org.apache.geode.cache.DiskStore#getName() */ public String getName() { return this.name; } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.DiskStore#getQueueSize() + * @see org.apache.geode.cache.DiskStore#getQueueSize() */ public int getQueueSize() { return this.queueSize; } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.DiskStore#getTimeInterval() + * @see org.apache.geode.cache.DiskStore#getTimeInterval() */ public long getTimeInterval() { return this.timeInterval; } /* (non-Javadoc) - * @see com.gemstone.gemfire.cache.DiskStore#getWriteBufferSize() + * @see org.apache.geode.cache.DiskStore#getWriteBufferSize() */ public int getWriteBufferSize() { return this.writeBufferSize; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreBackup.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreBackup.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreBackup.java index aacec8c..5de7b1a 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreBackup.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreBackup.java @@ -14,20 +14,20 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.File; import java.util.Arrays; import java.util.HashSet; import java.util.Set; -import com.gemstone.gemfire.internal.cache.persistence.BackupInspector; +import org.apache.geode.internal.cache.persistence.BackupInspector; /** * This class manages the state of the backup of an individual disk store. It * holds the list of oplogs that still need to be backed up, along with the * lists of oplog files that should be deleted when the oplog is backed up. See - * {@link DiskStoreImpl#startBackup(File, BackupInspector, com.gemstone.gemfire.internal.cache.persistence.RestoreScript)} + * {@link DiskStoreImpl#startBackup(File, BackupInspector, org.apache.geode.internal.cache.persistence.RestoreScript)} * * */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreFactoryImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreFactoryImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreFactoryImpl.java index 1c57db9..b3482d0 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreFactoryImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreFactoryImpl.java @@ -14,25 +14,25 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.io.File; import java.io.IOException; import java.util.Arrays; -import com.gemstone.gemfire.GemFireIOException; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.DiskStoreFactory; -import com.gemstone.gemfire.cache.DiskStore; -import com.gemstone.gemfire.distributed.internal.ResourceEvent; -import com.gemstone.gemfire.internal.cache.DiskStoreAttributes; -import com.gemstone.gemfire.internal.cache.persistence.BackupManager; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheCreation; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheXml; -import com.gemstone.gemfire.internal.cache.xmlcache.DiskStoreAttributesCreation; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.pdx.internal.TypeRegistry; +import org.apache.geode.GemFireIOException; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.DiskStoreFactory; +import org.apache.geode.cache.DiskStore; +import org.apache.geode.distributed.internal.ResourceEvent; +import org.apache.geode.internal.cache.DiskStoreAttributes; +import org.apache.geode.internal.cache.persistence.BackupManager; +import org.apache.geode.internal.cache.xmlcache.CacheCreation; +import org.apache.geode.internal.cache.xmlcache.CacheXml; +import org.apache.geode.internal.cache.xmlcache.DiskStoreAttributesCreation; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.pdx.internal.TypeRegistry; /** * Implementation of DiskStoreFactory http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreImpl.java index 0aabda0..921d2b1 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreImpl.java @@ -14,44 +14,44 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.StatisticsFactory; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.persistence.PersistentID; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.i18n.StringId; -import com.gemstone.gemfire.internal.FileUtil; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.DiskEntry.Helper.ValueWrapper; -import com.gemstone.gemfire.internal.cache.DiskEntry.RecoveredEntry; -import com.gemstone.gemfire.internal.cache.ExportDiskRegion.ExportWriter; -import com.gemstone.gemfire.internal.cache.lru.LRUAlgorithm; -import com.gemstone.gemfire.internal.cache.lru.LRUStatistics; -import com.gemstone.gemfire.internal.cache.persistence.*; -import com.gemstone.gemfire.internal.cache.snapshot.GFSnapshot; -import com.gemstone.gemfire.internal.cache.snapshot.GFSnapshot.SnapshotWriter; -import com.gemstone.gemfire.internal.cache.snapshot.SnapshotPacket.SnapshotRecord; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.versions.VersionStamp; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.concurrent.ConcurrentHashSet; -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.util.BlobHelper; -import com.gemstone.gemfire.pdx.internal.EnumInfo; -import com.gemstone.gemfire.pdx.internal.PdxField; -import com.gemstone.gemfire.pdx.internal.PdxType; -import com.gemstone.gemfire.pdx.internal.PeerTypeRegistration; +package org.apache.geode.internal.cache; + +import org.apache.geode.CancelCriterion; +import org.apache.geode.CancelException; +import org.apache.geode.StatisticsFactory; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.*; +import org.apache.geode.cache.persistence.PersistentID; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.i18n.StringId; +import org.apache.geode.internal.FileUtil; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.DiskEntry.Helper.ValueWrapper; +import org.apache.geode.internal.cache.DiskEntry.RecoveredEntry; +import org.apache.geode.internal.cache.ExportDiskRegion.ExportWriter; +import org.apache.geode.internal.cache.lru.LRUAlgorithm; +import org.apache.geode.internal.cache.lru.LRUStatistics; +import org.apache.geode.internal.cache.persistence.*; +import org.apache.geode.internal.cache.snapshot.GFSnapshot; +import org.apache.geode.internal.cache.snapshot.GFSnapshot.SnapshotWriter; +import org.apache.geode.internal.cache.snapshot.SnapshotPacket.SnapshotRecord; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.versions.VersionStamp; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.concurrent.ConcurrentHashSet; +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.util.BlobHelper; +import org.apache.geode.pdx.internal.EnumInfo; +import org.apache.geode.pdx.internal.PdxField; +import org.apache.geode.pdx.internal.PdxType; +import org.apache.geode.pdx.internal.PeerTypeRegistration; import it.unimi.dsi.fastutil.ints.IntOpenHashSet; import it.unimi.dsi.fastutil.longs.LongOpenHashSet; import org.apache.logging.log4j.Logger; @@ -72,7 +72,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock; import java.util.regex.Matcher; import java.util.regex.Pattern; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.*; +import static org.apache.geode.distributed.ConfigurationProperties.*; /** * Represents a (disk-based) persistent store for region data. Used for both @@ -4360,9 +4360,9 @@ public class DiskStoreImpl implements DiskStore { props.setProperty(CACHE_XML_FILE, ""); DistributedSystem ds = DistributedSystem.connect(props); offlineDS = ds; - Cache c = com.gemstone.gemfire.cache.CacheFactory.create(ds); + Cache c = org.apache.geode.cache.CacheFactory.create(ds); offlineCache = c; - com.gemstone.gemfire.cache.DiskStoreFactory dsf = c + org.apache.geode.cache.DiskStoreFactory dsf = c .createDiskStoreFactory(); dsf.setDiskDirs(dsDirs); if (offlineCompacting && maxOplogSize != -1L) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreMonitor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreMonitor.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreMonitor.java index b81142b..110872a 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreMonitor.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreMonitor.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 com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.LoggingThreadGroup; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.LoggingThreadGroup; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; import org.apache.logging.log4j.Logger; import java.io.File; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreObserver.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreObserver.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreObserver.java index a756e98..14c8328 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreObserver.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreObserver.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.Map; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreStats.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreStats.java index e5f4bb2..3e5aefb 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreStats.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreStats.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.*; -//import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.distributed.internal.DistributionStats; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.*; +//import org.apache.geode.cache.Region; +import org.apache.geode.distributed.internal.DistributionStats; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; /** * GemFire statistics about a {@link DiskStoreImpl}. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreTask.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreTask.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreTask.java index f593731..208a31a 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreTask.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreTask.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; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DiskWriteAttributesImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskWriteAttributesImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskWriteAttributesImpl.java index 3e005cb..61b16b1 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskWriteAttributesImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskWriteAttributesImpl.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheXml; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.*; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.cache.xmlcache.CacheXml; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.io.File; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistPeerTXStateStub.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistPeerTXStateStub.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistPeerTXStateStub.java index 5c53df1..5cdbc45 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistPeerTXStateStub.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistPeerTXStateStub.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.Collections; @@ -22,16 +22,16 @@ import java.util.HashSet; import java.util.Set; import java.util.TreeSet; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.tx.DistTxEntryEvent; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.tx.DistTxEntryEvent; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * DistPeerTXStateStub lives on the transaction coordinator for a distributed @@ -152,7 +152,7 @@ public final class DistPeerTXStateStub extends PeerTXStateStub implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.TXStateStub#putEntry(com.gemstone.gemfire + * org.apache.geode.internal.cache.TXStateStub#putEntry(org.apache.geode * .internal.cache.EntryEventImpl, boolean, boolean, java.lang.Object, * boolean, long, boolean) */ @@ -176,7 +176,7 @@ public final class DistPeerTXStateStub extends PeerTXStateStub implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.InternalDataView#putEntryOnRemote(com + * org.apache.geode.internal.cache.InternalDataView#putEntryOnRemote(com * .gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean, * java.lang.Object, boolean, long, boolean) */ @@ -201,8 +201,8 @@ public final class DistPeerTXStateStub extends PeerTXStateStub implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.TXStateInterface#destroyExistingEntry - * (com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, + * org.apache.geode.internal.cache.TXStateInterface#destroyExistingEntry + * (org.apache.geode.internal.cache.EntryEventImpl, boolean, * java.lang.Object) */ public void destroyExistingEntry(EntryEventImpl event, boolean cacheWrite, @@ -216,8 +216,8 @@ public final class DistPeerTXStateStub extends PeerTXStateStub implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.InternalDataView#destroyOnRemote(java - * .lang.Integer, com.gemstone.gemfire.internal.cache.EntryEventImpl, + * org.apache.geode.internal.cache.InternalDataView#destroyOnRemote(java + * .lang.Integer, org.apache.geode.internal.cache.EntryEventImpl, * java.lang.Object) */ public void destroyOnRemote(EntryEventImpl event, boolean cacheWrite, @@ -231,8 +231,8 @@ public final class DistPeerTXStateStub extends PeerTXStateStub implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.TXStateInterface#invalidateExistingEntry - * (com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean) + * org.apache.geode.internal.cache.TXStateInterface#invalidateExistingEntry + * (org.apache.geode.internal.cache.EntryEventImpl, boolean, boolean) */ public void invalidateExistingEntry(EntryEventImpl event, boolean invokeCallbacks, boolean forceNewEntry) { @@ -246,8 +246,8 @@ public final class DistPeerTXStateStub extends PeerTXStateStub implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.InternalDataView#invalidateOnRemote - * (com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean) + * org.apache.geode.internal.cache.InternalDataView#invalidateOnRemote + * (org.apache.geode.internal.cache.EntryEventImpl, boolean, boolean) */ public void invalidateOnRemote(EntryEventImpl event, boolean invokeCallbacks, boolean forceNewEntry) throws DataLocationException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXAdjunctCommitMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXAdjunctCommitMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXAdjunctCommitMessage.java index 12c879b..a598d6c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXAdjunctCommitMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXAdjunctCommitMessage.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.Collections; import java.util.Iterator; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.cache.CacheRuntimeException; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.cache.CacheRuntimeException; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.internal.logging.LogService; public class DistTXAdjunctCommitMessage extends TXCommitMessage{ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXCommitMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXCommitMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXCommitMessage.java index 97623f8..e026a7f 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXCommitMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXCommitMessage.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; @@ -30,25 +30,25 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CommitIncompleteException; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.distributed.DistributedMember; -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.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.Assert; -import com.gemstone.gemfire.internal.cache.TXEntryState.DistTxThinEntryState; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CommitIncompleteException; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.distributed.DistributedMember; +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.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.Assert; +import org.apache.geode.internal.cache.TXEntryState.DistTxThinEntryState; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXCoordinatorInterface.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXCoordinatorInterface.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXCoordinatorInterface.java index 363b540..e102a52 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXCoordinatorInterface.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXCoordinatorInterface.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.HashSet; import java.util.TreeMap; import java.util.TreeSet; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.internal.cache.tx.DistTxEntryEvent; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.internal.cache.tx.DistTxEntryEvent; /** * [DISTTX] For Distributed Transaction http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXPrecommitMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXPrecommitMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXPrecommitMessage.java index 64429d1..0f15673 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXPrecommitMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXPrecommitMessage.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; @@ -31,29 +31,29 @@ import java.util.TreeMap; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CommitIncompleteException; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.distributed.DistributedMember; -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.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.Assert; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.TXEntryState.DistTxThinEntryState; -import com.gemstone.gemfire.internal.cache.locks.TXLockService; -import com.gemstone.gemfire.internal.cache.tx.DistTxEntryEvent; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CommitIncompleteException; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.distributed.DistributedMember; +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.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.Assert; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.TXEntryState.DistTxThinEntryState; +import org.apache.geode.internal.cache.locks.TXLockService; +import org.apache.geode.internal.cache.tx.DistTxEntryEvent; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXRollbackMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXRollbackMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXRollbackMessage.java index f5f6c31..fe7bfd7 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXRollbackMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXRollbackMessage.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; @@ -30,26 +30,26 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CommitIncompleteException; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.TransactionDataNotColocatedException; -import com.gemstone.gemfire.distributed.DistributedMember; -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.DistributionStats; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.ReplySender; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.RemoteOperationMessage.RemoteOperationResponse; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CommitIncompleteException; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.TransactionDataNotColocatedException; +import org.apache.geode.distributed.DistributedMember; +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.DistributionStats; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.ReplySender; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.RemoteOperationMessage.RemoteOperationResponse; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXState.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXState.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXState.java index ed59108..25a79c8 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXState.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXState.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.Iterator; @@ -24,27 +24,27 @@ import java.util.Map.Entry; import java.util.Set; import java.util.TreeMap; -import com.gemstone.gemfire.InvalidDeltaException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.CacheWriterException; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.TransactionDataRebalancedException; -import com.gemstone.gemfire.cache.TransactionWriter; -import com.gemstone.gemfire.cache.TransactionWriterException; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.TXEntryState.DistTxThinEntryState; -import com.gemstone.gemfire.internal.cache.partitioned.PutAllPRMessage; -import com.gemstone.gemfire.internal.cache.partitioned.RemoveAllPRMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.tx.DistTxKeyInfo; -import com.gemstone.gemfire.internal.cache.tx.DistTxEntryEvent; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.offheap.annotations.Released; +import org.apache.geode.InvalidDeltaException; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.CacheWriterException; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.TransactionDataRebalancedException; +import org.apache.geode.cache.TransactionWriter; +import org.apache.geode.cache.TransactionWriterException; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.TXEntryState.DistTxThinEntryState; +import org.apache.geode.internal.cache.partitioned.PutAllPRMessage; +import org.apache.geode.internal.cache.partitioned.RemoveAllPRMessage; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.tx.DistTxKeyInfo; +import org.apache.geode.internal.cache.tx.DistTxEntryEvent; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.offheap.annotations.Released; /** * TxState on a datanode VM @@ -154,7 +154,7 @@ public class DistTXState extends TXState { /* * (non-Javadoc) * - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#commit() + * @see org.apache.geode.internal.cache.TXStateInterface#commit() * * Take Locks Does conflict check on primary ([DISTTX] TODO on primary only) * Invoke TxWriter @@ -248,7 +248,7 @@ public class DistTXState extends TXState { /* * (non-Javadoc) * - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#commit() + * @see org.apache.geode.internal.cache.TXStateInterface#commit() * * Apply changes release locks */ @@ -362,7 +362,7 @@ public class DistTXState extends TXState { /* * Handle Put Operations meant for secondary. * - * @see com.gemstone.gemfire.internal.cache.partitioned.PutMessage. + * @see org.apache.geode.internal.cache.partitioned.PutMessage. * operateOnPartitionedRegion(DistributionManager, PartitionedRegion, * long) * @@ -539,9 +539,9 @@ public class DistTXState extends TXState { * * * @see - * com.gemstone.gemfire.internal.cache.InternalDataView#postPutAll(com.gemstone + * org.apache.geode.internal.cache.InternalDataView#postPutAll(org.apache * .gemfire.internal.cache.DistributedPutAllOperation, java.util.Map, - * com.gemstone.gemfire.internal.cache.LocalRegion) + * org.apache.geode.internal.cache.LocalRegion) */ public void postPutAll(final DistributedPutAllOperation putallOp, final VersionedObjectList successfulPuts, LocalRegion reg) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateOnCoordinator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateOnCoordinator.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateOnCoordinator.java index 436c637..eb028b3 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateOnCoordinator.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateOnCoordinator.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 java.util.ArrayList; import java.util.HashSet; import java.util.TreeSet; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.tx.DistTxEntryEvent; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.tx.DistTxEntryEvent; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * TxState on TX coordinator, created when coordinator is also a data node @@ -109,7 +109,7 @@ public final class DistTXStateOnCoordinator extends DistTXState implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.TXStateStub#putEntry(com.gemstone.gemfire + * org.apache.geode.internal.cache.TXStateStub#putEntry(org.apache.geode * .internal.cache.EntryEventImpl, boolean, boolean, java.lang.Object, * boolean, long, boolean) */ @@ -138,7 +138,7 @@ public final class DistTXStateOnCoordinator extends DistTXState implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.InternalDataView#putEntryOnRemote(com + * org.apache.geode.internal.cache.InternalDataView#putEntryOnRemote(com * .gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean, * java.lang.Object, boolean, long, boolean) */ @@ -168,8 +168,8 @@ public final class DistTXStateOnCoordinator extends DistTXState implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.TXStateInterface#destroyExistingEntry - * (com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, + * org.apache.geode.internal.cache.TXStateInterface#destroyExistingEntry + * (org.apache.geode.internal.cache.EntryEventImpl, boolean, * java.lang.Object) */ public void destroyExistingEntry(EntryEventImpl event, boolean cacheWrite, @@ -189,8 +189,8 @@ public final class DistTXStateOnCoordinator extends DistTXState implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.InternalDataView#destroyOnRemote(java - * .lang.Integer, com.gemstone.gemfire.internal.cache.EntryEventImpl, + * org.apache.geode.internal.cache.InternalDataView#destroyOnRemote(java + * .lang.Integer, org.apache.geode.internal.cache.EntryEventImpl, * java.lang.Object) */ public void destroyOnRemote(EntryEventImpl event, boolean cacheWrite, @@ -210,8 +210,8 @@ public final class DistTXStateOnCoordinator extends DistTXState implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.TXStateInterface#invalidateExistingEntry - * (com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean) + * org.apache.geode.internal.cache.TXStateInterface#invalidateExistingEntry + * (org.apache.geode.internal.cache.EntryEventImpl, boolean, boolean) */ public void invalidateExistingEntry(EntryEventImpl event, boolean invokeCallbacks, boolean forceNewEntry) { @@ -226,8 +226,8 @@ public final class DistTXStateOnCoordinator extends DistTXState implements * (non-Javadoc) * * @see - * com.gemstone.gemfire.internal.cache.InternalDataView#invalidateOnRemote - * (com.gemstone.gemfire.internal.cache.EntryEventImpl, boolean, boolean) + * org.apache.geode.internal.cache.InternalDataView#invalidateOnRemote + * (org.apache.geode.internal.cache.EntryEventImpl, boolean, boolean) */ public void invalidateOnRemote(EntryEventImpl event, boolean invokeCallbacks, boolean forceNewEntry) throws DataLocationException { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImpl.java index dfa2dda..92bee16 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImpl.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 org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.logging.LogService; +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/DistTXStateProxyImplOnCoordinator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImplOnCoordinator.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImplOnCoordinator.java index df3359c..3c3bf2c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImplOnCoordinator.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImplOnCoordinator.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,22 +27,22 @@ import java.util.Map.Entry; import java.util.Set; import java.util.TreeSet; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.TransactionInDoubtException; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.DistTXPrecommitMessage.DistTxPrecommitResponse; -import com.gemstone.gemfire.internal.cache.DistributedPutAllOperation.PutAllEntryData; -import com.gemstone.gemfire.internal.cache.DistributedRemoveAllOperation.RemoveAllEntryData; -import com.gemstone.gemfire.internal.cache.TXEntryState.DistTxThinEntryState; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.tx.DistClientTXStateStub; -import com.gemstone.gemfire.internal.cache.tx.DistTxEntryEvent; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.TransactionInDoubtException; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.DistTXPrecommitMessage.DistTxPrecommitResponse; +import org.apache.geode.internal.cache.DistributedPutAllOperation.PutAllEntryData; +import org.apache.geode.internal.cache.DistributedRemoveAllOperation.RemoveAllEntryData; +import org.apache.geode.internal.cache.TXEntryState.DistTxThinEntryState; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.tx.DistClientTXStateStub; +import org.apache.geode.internal.cache.tx.DistTxEntryEvent; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; public class DistTXStateProxyImplOnCoordinator extends DistTXStateProxyImpl { @@ -69,7 +69,7 @@ public class DistTXStateProxyImplOnCoordinator extends DistTXStateProxyImpl { /* * (non-Javadoc) * - * @see com.gemstone.gemfire.internal.cache.TXStateInterface#commit() + * @see org.apache.geode.internal.cache.TXStateInterface#commit() * * [DISTTX] TODO Catch all exceptions in precommit and rollback and make sure * these messages reach all http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImplOnDatanode.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImplOnDatanode.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImplOnDatanode.java index 93eedaa..5b5a526 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImplOnDatanode.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistTXStateProxyImplOnDatanode.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import java.util.ArrayList; import java.util.TreeMap; -import com.gemstone.gemfire.cache.CommitConflictException; -import com.gemstone.gemfire.cache.UnsupportedOperationInTransactionException; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.cache.TXEntryState.DistTxThinEntryState; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.cache.CommitConflictException; +import org.apache.geode.cache.UnsupportedOperationInTransactionException; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.cache.TXEntryState.DistTxThinEntryState; +import org.apache.geode.internal.i18n.LocalizedStrings; public class DistTXStateProxyImplOnDatanode extends DistTXStateProxyImpl { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedCacheOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedCacheOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedCacheOperation.java index 4ca60f9..98cb4a9 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedCacheOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedCacheOperation.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; @@ -32,54 +32,54 @@ import java.util.Vector; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.InvalidDeltaException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.CacheFactory; -import com.gemstone.gemfire.cache.DiskAccessException; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.cache.query.internal.cq.ServerCQ; -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.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.MessageWithReply; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.ReplySender; -import com.gemstone.gemfire.distributed.internal.SerialDistributionMessage; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.CopyOnWriteHashSet; -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.PutAllMessage; -import com.gemstone.gemfire.internal.cache.EntryEventImpl.OldValueImporter; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo.FilterInfo; -import com.gemstone.gemfire.internal.cache.UpdateOperation.UpdateMessage; -import com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.cache.tier.MessageType; -import com.gemstone.gemfire.internal.cache.versions.DiskVersionTag; -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.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.offheap.StoredObject; -import com.gemstone.gemfire.internal.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Unretained; -import com.gemstone.gemfire.internal.sequencelog.EntryLogger; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.InvalidDeltaException; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.CacheFactory; +import org.apache.geode.cache.DiskAccessException; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.cache.query.internal.cq.ServerCQ; +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.DistributionMessage; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.MessageWithReply; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.ReplySender; +import org.apache.geode.distributed.internal.SerialDistributionMessage; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.CopyOnWriteHashSet; +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.PutAllMessage; +import org.apache.geode.internal.cache.EntryEventImpl.OldValueImporter; +import org.apache.geode.internal.cache.FilterRoutingInfo.FilterInfo; +import org.apache.geode.internal.cache.UpdateOperation.UpdateMessage; +import org.apache.geode.internal.cache.partitioned.PartitionMessage; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.cache.tier.MessageType; +import org.apache.geode.internal.cache.versions.DiskVersionTag; +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.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.offheap.StoredObject; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Unretained; +import org.apache.geode.internal.sequencelog.EntryLogger; /** * @@ -201,7 +201,7 @@ public abstract class DistributedCacheOperation { public boolean supportsDirectAck() { // force use of shared connection if we're already in a secondary // thread-owned reader thread. See bug #49565. Also see Connection#processNIOBuffer -// int dominoCount = com.gemstone.gemfire.internal.tcp.Connection.getDominoCount(); +// int dominoCount = org.apache.geode.internal.tcp.Connection.getDominoCount(); // return dominoCount < 2; return true; } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedClearOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedClearOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedClearOperation.java index b6e1c35..8503db5 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedClearOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedClearOperation.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,16 +22,16 @@ import java.io.IOException; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.EntryNotFoundException; -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.Version; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.versions.RegionVersionVector; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.EntryNotFoundException; +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.Version; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.versions.RegionVersionVector; +import org.apache.geode.internal.cache.versions.VersionTag; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedPutAllOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedPutAllOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedPutAllOperation.java index e73ca35..6272b8c 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedPutAllOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedPutAllOperation.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; +package org.apache.geode.internal.cache; import it.unimi.dsi.fastutil.objects.Object2IntOpenHashMap; @@ -34,35 +34,35 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.cache.persistence.PersistentReplicatesOfflineException; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.DirectReplyProcessor; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.ByteArrayDataInput; -import com.gemstone.gemfire.internal.DataSerializableFixedID; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo.FilterInfo; -import com.gemstone.gemfire.internal.cache.ha.ThreadIdentifier; -import com.gemstone.gemfire.internal.cache.partitioned.PutAllPRMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.versions.DiskVersionTag; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -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.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; -import com.gemstone.gemfire.internal.offheap.annotations.Unretained; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.Scope; +import org.apache.geode.cache.persistence.PersistentReplicatesOfflineException; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.DirectReplyProcessor; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.ByteArrayDataInput; +import org.apache.geode.internal.DataSerializableFixedID; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.FilterRoutingInfo.FilterInfo; +import org.apache.geode.internal.cache.ha.ThreadIdentifier; +import org.apache.geode.internal.cache.partitioned.PutAllPRMessage; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.versions.DiskVersionTag; +import org.apache.geode.internal.cache.versions.VersionSource; +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.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; +import org.apache.geode.internal.offheap.annotations.Unretained; /** * Handles distribution of a Region.putall operation. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegion.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegion.java index aa74af7..303f0bd 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegion.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegion.java @@ -15,56 +15,56 @@ * limitations under the License. */ -package com.gemstone.gemfire.internal.cache; - -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.InvalidDeltaException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.cache.asyncqueue.internal.AsyncEventQueueImpl; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.execute.ResultCollector; -import com.gemstone.gemfire.cache.execute.ResultSender; -import com.gemstone.gemfire.cache.persistence.PersistentReplicatesOfflineException; -import com.gemstone.gemfire.cache.wan.GatewaySender; -import com.gemstone.gemfire.distributed.DistributedLockService; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.LockServiceDestroyedException; -import com.gemstone.gemfire.distributed.Role; -import com.gemstone.gemfire.distributed.internal.*; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.ProfileVisitor; -import com.gemstone.gemfire.distributed.internal.locks.DLockRemoteToken; -import com.gemstone.gemfire.distributed.internal.locks.DLockService; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.i18n.StringId; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.cache.AbstractRegionMap.ARMLockTestHook; -import com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.CacheProfile; -import com.gemstone.gemfire.internal.cache.InitialImageOperation.GIIStatus; -import com.gemstone.gemfire.internal.cache.RemoteFetchVersionMessage.FetchVersionResponse; -import com.gemstone.gemfire.internal.cache.control.InternalResourceManager.ResourceType; -import com.gemstone.gemfire.internal.cache.control.MemoryEvent; -import com.gemstone.gemfire.internal.cache.execute.*; -import com.gemstone.gemfire.internal.cache.lru.LRUEntry; -import com.gemstone.gemfire.internal.cache.persistence.*; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.versions.ConcurrentCacheModificationException; -import 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.cache.wan.AsyncEventQueueConfigurationException; -import com.gemstone.gemfire.internal.cache.wan.GatewaySenderConfigurationException; -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.offheap.annotations.Released; -import com.gemstone.gemfire.internal.offheap.annotations.Retained; -import com.gemstone.gemfire.internal.sequencelog.RegionLogger; -import com.gemstone.gemfire.internal.util.concurrent.StoppableCountDownLatch; +package org.apache.geode.internal.cache; + +import org.apache.geode.CancelException; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.InvalidDeltaException; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.*; +import org.apache.geode.cache.asyncqueue.internal.AsyncEventQueueImpl; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.ResultCollector; +import org.apache.geode.cache.execute.ResultSender; +import org.apache.geode.cache.persistence.PersistentReplicatesOfflineException; +import org.apache.geode.cache.wan.GatewaySender; +import org.apache.geode.distributed.DistributedLockService; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.LockServiceDestroyedException; +import org.apache.geode.distributed.Role; +import org.apache.geode.distributed.internal.*; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.distributed.internal.DistributionAdvisor.ProfileVisitor; +import org.apache.geode.distributed.internal.locks.DLockRemoteToken; +import org.apache.geode.distributed.internal.locks.DLockService; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.i18n.StringId; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.cache.AbstractRegionMap.ARMLockTestHook; +import org.apache.geode.internal.cache.CacheDistributionAdvisor.CacheProfile; +import org.apache.geode.internal.cache.InitialImageOperation.GIIStatus; +import org.apache.geode.internal.cache.RemoteFetchVersionMessage.FetchVersionResponse; +import org.apache.geode.internal.cache.control.InternalResourceManager.ResourceType; +import org.apache.geode.internal.cache.control.MemoryEvent; +import org.apache.geode.internal.cache.execute.*; +import org.apache.geode.internal.cache.lru.LRUEntry; +import org.apache.geode.internal.cache.persistence.*; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.versions.ConcurrentCacheModificationException; +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.cache.wan.AsyncEventQueueConfigurationException; +import org.apache.geode.internal.cache.wan.GatewaySenderConfigurationException; +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.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; +import org.apache.geode.internal.sequencelog.RegionLogger; +import org.apache.geode.internal.util.concurrent.StoppableCountDownLatch; import org.apache.logging.log4j.Logger; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegionFunctionStreamingMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegionFunctionStreamingMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegionFunctionStreamingMessage.java index a31d5e4..d1f64c4 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegionFunctionStreamingMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRegionFunctionStreamingMessage.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,26 +25,26 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.CacheException; -import com.gemstone.gemfire.cache.RegionDestroyedException; -import com.gemstone.gemfire.cache.execute.Function; -import com.gemstone.gemfire.cache.execute.FunctionException; -import com.gemstone.gemfire.cache.execute.FunctionService; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.DistributionMessage; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.distributed.internal.ReplyMessage; -import com.gemstone.gemfire.distributed.internal.ReplyProcessor21; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.SystemFailure; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheException; +import org.apache.geode.cache.RegionDestroyedException; +import org.apache.geode.cache.execute.Function; +import org.apache.geode.cache.execute.FunctionException; +import org.apache.geode.cache.execute.FunctionService; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.DistributionMessage; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.distributed.internal.ReplyMessage; +import org.apache.geode.distributed.internal.ReplyProcessor21; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; public class DistributedRegionFunctionStreamingMessage extends DistributionMessage implements TransactionMessage { @@ -420,14 +420,14 @@ public class DistributedRegionFunctionStreamingMessage extends DistributionMessa } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TransactionMessage#canStartRemoteTransaction() + * @see org.apache.geode.internal.cache.TransactionMessage#canStartRemoteTransaction() */ public boolean canStartRemoteTransaction() { return true; } /* (non-Javadoc) - * @see com.gemstone.gemfire.internal.cache.TransactionMessage#getTXUniqId() + * @see org.apache.geode.internal.cache.TransactionMessage#getTXUniqId() */ public int getTXUniqId() { return txUniqId; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRemoveAllOperation.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRemoveAllOperation.java b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRemoveAllOperation.java index 0390b29..9940a57 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRemoveAllOperation.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRemoveAllOperation.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,36 +28,36 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.CacheEvent; -import com.gemstone.gemfire.cache.DataPolicy; -import com.gemstone.gemfire.cache.EntryNotFoundException; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.RegionAttributes; -import com.gemstone.gemfire.cache.Scope; -import com.gemstone.gemfire.cache.persistence.PersistentReplicatesOfflineException; -import com.gemstone.gemfire.cache.query.internal.cq.CqService; -import com.gemstone.gemfire.distributed.internal.DirectReplyProcessor; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.ByteArrayDataInput; -import com.gemstone.gemfire.internal.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.DistributedPutAllOperation.EntryVersionsList; -import com.gemstone.gemfire.internal.cache.DistributedPutAllOperation.PutAllEntryData; -import com.gemstone.gemfire.internal.cache.FilterRoutingInfo.FilterInfo; -import com.gemstone.gemfire.internal.cache.ha.ThreadIdentifier; -import com.gemstone.gemfire.internal.cache.partitioned.PutAllPRMessage; -import com.gemstone.gemfire.internal.cache.partitioned.RemoveAllPRMessage; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; -import com.gemstone.gemfire.internal.cache.tier.sockets.VersionedObjectList; -import com.gemstone.gemfire.internal.cache.versions.ConcurrentCacheModificationException; -import com.gemstone.gemfire.internal.cache.versions.DiskVersionTag; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.cache.versions.VersionTag; -import com.gemstone.gemfire.internal.logging.LogService; -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 org.apache.geode.DataSerializer; +import org.apache.geode.cache.CacheEvent; +import org.apache.geode.cache.DataPolicy; +import org.apache.geode.cache.EntryNotFoundException; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.RegionAttributes; +import org.apache.geode.cache.Scope; +import org.apache.geode.cache.persistence.PersistentReplicatesOfflineException; +import org.apache.geode.cache.query.internal.cq.CqService; +import org.apache.geode.distributed.internal.DirectReplyProcessor; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.ByteArrayDataInput; +import org.apache.geode.internal.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.DistributedPutAllOperation.EntryVersionsList; +import org.apache.geode.internal.cache.DistributedPutAllOperation.PutAllEntryData; +import org.apache.geode.internal.cache.FilterRoutingInfo.FilterInfo; +import org.apache.geode.internal.cache.ha.ThreadIdentifier; +import org.apache.geode.internal.cache.partitioned.PutAllPRMessage; +import org.apache.geode.internal.cache.partitioned.RemoveAllPRMessage; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.internal.cache.tier.sockets.VersionedObjectList; +import org.apache.geode.internal.cache.versions.ConcurrentCacheModificationException; +import org.apache.geode.internal.cache.versions.DiskVersionTag; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.cache.versions.VersionTag; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.offheap.annotations.Released; +import org.apache.geode.internal.offheap.annotations.Retained; +import org.apache.geode.internal.offheap.annotations.Unretained; /** * Handles distribution of a Region.removeAll operation.
