http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DSClock.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DSClock.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DSClock.java index d96e7c3..b759b2e 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DSClock.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DSClock.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; - -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.internal.SystemTimer; -import com.gemstone.gemfire.internal.SystemTimer.SystemTimerTask; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.DateFormatter; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +package org.apache.geode.distributed.internal; + +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.internal.SystemTimer; +import org.apache.geode.internal.SystemTimer.SystemTimerTask; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.DateFormatter; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; import org.apache.logging.log4j.Logger; import java.util.Date;
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DefaultServerLauncherCacheProvider.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DefaultServerLauncherCacheProvider.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DefaultServerLauncherCacheProvider.java index 6f155ad..7b4ca94 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DefaultServerLauncherCacheProvider.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DefaultServerLauncherCacheProvider.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.util.Properties; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheFactory; -import com.gemstone.gemfire.distributed.ServerLauncher; -import com.gemstone.gemfire.distributed.ServerLauncherCacheProvider; -import com.gemstone.gemfire.internal.cache.CacheConfig; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheFactory; +import org.apache.geode.distributed.ServerLauncher; +import org.apache.geode.distributed.ServerLauncherCacheProvider; +import org.apache.geode.internal.cache.CacheConfig; public class DefaultServerLauncherCacheProvider implements ServerLauncherCacheProvider { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DirectReplyProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DirectReplyProcessor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DirectReplyProcessor.java index fa06c4e..6fcb080 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DirectReplyProcessor.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DirectReplyProcessor.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.util.Collection; import java.util.Collections; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.CancelCriterion; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; /** * A reply processor optimized for direct ack responses (It skips synchronization, http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionAdvisee.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionAdvisee.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionAdvisee.java index 655b9d1..3b137b7 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionAdvisee.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionAdvisee.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.CancelCriterion; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; /** * Resource which uses a {@link DistributionAdvisor}. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionAdvisor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionAdvisor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionAdvisor.java index c93eeb3..843c478 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionAdvisor.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionAdvisor.java @@ -15,25 +15,25 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; - -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.GemFireIOException; -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.InternalDataSerializer; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.cache.CacheDistributionAdvisor.CacheProfile; -import com.gemstone.gemfire.internal.cache.DistributedRegion; -import com.gemstone.gemfire.internal.cache.UpdateAttributesProcessor; -import com.gemstone.gemfire.internal.cache.persistence.PersistentMemberID; -import com.gemstone.gemfire.internal.cache.versions.VersionSource; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.util.ArrayUtils; +package org.apache.geode.distributed.internal; + +import org.apache.geode.CancelException; +import org.apache.geode.GemFireIOException; +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.InternalDataSerializer; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.cache.CacheDistributionAdvisor.CacheProfile; +import org.apache.geode.internal.cache.DistributedRegion; +import org.apache.geode.internal.cache.UpdateAttributesProcessor; +import org.apache.geode.internal.cache.persistence.PersistentMemberID; +import org.apache.geode.internal.cache.versions.VersionSource; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.util.ArrayUtils; import org.apache.logging.log4j.Logger; import java.io.DataInput; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionChannel.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionChannel.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionChannel.java index e96753f..c8f7b05 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionChannel.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionChannel.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.io.NotSerializableException; import java.util.HashSet; @@ -22,13 +22,13 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.distributed.DistributedSystemDisconnectedException; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.MembershipManager; -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 org.apache.geode.distributed.DistributedSystemDisconnectedException; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.distributed.internal.membership.MembershipManager; +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; /** * To change this generated comment edit the template variable "typecomment": http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfig.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfig.java index e122189..0a4a72b 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfig.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfig.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.*; +import static org.apache.geode.distributed.ConfigurationProperties.*; import java.io.File; import java.lang.reflect.Field; @@ -30,14 +30,14 @@ import java.util.List; import java.util.Map; import java.util.Properties; -import com.gemstone.gemfire.distributed.ConfigurationProperties; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.internal.Config; -import com.gemstone.gemfire.internal.ConfigSource; -import com.gemstone.gemfire.internal.logging.InternalLogWriter; -import com.gemstone.gemfire.internal.logging.LogConfig; -import com.gemstone.gemfire.internal.tcp.Connection; -import com.gemstone.gemfire.memcached.GemFireMemcachedServer; +import org.apache.geode.distributed.ConfigurationProperties; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.internal.Config; +import org.apache.geode.internal.ConfigSource; +import org.apache.geode.internal.logging.InternalLogWriter; +import org.apache.geode.internal.logging.LogConfig; +import org.apache.geode.internal.tcp.Connection; +import org.apache.geode.memcached.GemFireMemcachedServer; /** * Provides accessor (and in some cases mutator) methods for the @@ -49,7 +49,7 @@ import com.gemstone.gemfire.memcached.GemFireMemcachedServer; * <p> * Descriptions of these properties can be found {@link ConfigurationProperties}. * - * @see com.gemstone.gemfire.internal.Config + * @see org.apache.geode.internal.Config * @since GemFire 2.1 */ public interface DistributionConfig extends Config, LogConfig { @@ -77,8 +77,8 @@ public interface DistributionConfig extends Config, LogConfig { * <p> The name can not be changed while the system is running. * * @throws IllegalArgumentException if the specified value is not acceptable. - * @throws com.gemstone.gemfire.UnmodifiableException if this attribute can not be modified. - * @throws com.gemstone.gemfire.GemFireIOException if the set failure is caused by an error + * @throws org.apache.geode.UnmodifiableException if this attribute can not be modified. + * @throws org.apache.geode.GemFireIOException if the set failure is caused by an error * when writing to the system's configuration file. */ @ConfigAttributeSetter(name = NAME) @@ -300,8 +300,8 @@ public interface DistributionConfig extends Config, LogConfig { * @param value must be of the form <code>hostName[portNum]</code>. * Multiple elements are allowed and must be seperated by a comma. * @throws IllegalArgumentException if the specified value is not acceptable. - * @throws com.gemstone.gemfire.UnmodifiableException if this attribute can not be modified. - * @throws com.gemstone.gemfire.GemFireIOException if the set failure is caused by an error + * @throws org.apache.geode.UnmodifiableException if this attribute can not be modified. + * @throws org.apache.geode.GemFireIOException if the set failure is caused by an error * when writing to the system's configuration file. */ @ConfigAttributeSetter(name = LOCATORS) @@ -370,8 +370,8 @@ public interface DistributionConfig extends Config, LogConfig { * Sets the system's deploy working directory. * * @throws IllegalArgumentException if the specified value is not acceptable. - * @throws com.gemstone.gemfire.UnmodifiableException if this attribute can not be modified. - * @throws com.gemstone.gemfire.GemFireIOException if the set failure is caused by an error + * @throws org.apache.geode.UnmodifiableException if this attribute can not be modified. + * @throws org.apache.geode.GemFireIOException if the set failure is caused by an error * when writing to the system's configuration file. */ @ConfigAttributeSetter(name = DEPLOY_WORKING_DIR) @@ -399,8 +399,8 @@ public interface DistributionConfig extends Config, LogConfig { * Sets the system's user command path. * * @throws IllegalArgumentException if the specified value is not acceptable. - * @throws com.gemstone.gemfire.UnmodifiableException if this attribute can not be modified. - * @throws com.gemstone.gemfire.GemFireIOException if the set failure is caused by an error + * @throws org.apache.geode.UnmodifiableException if this attribute can not be modified. + * @throws org.apache.geode.GemFireIOException if the set failure is caused by an error * when writing to the system's configuration file. */ @ConfigAttributeSetter(name = USER_COMMAND_PACKAGES) @@ -432,8 +432,8 @@ public interface DistributionConfig extends Config, LogConfig { * <p> The system log file can not be changed while the system is running. * * @throws IllegalArgumentException if the specified value is not acceptable. - * @throws com.gemstone.gemfire.UnmodifiableException if this attribute can not be modified. - * @throws com.gemstone.gemfire.GemFireIOException if the set failure is caused by an error + * @throws org.apache.geode.UnmodifiableException if this attribute can not be modified. + * @throws org.apache.geode.GemFireIOException if the set failure is caused by an error * when writing to the system's configuration file. */ @@ -456,7 +456,7 @@ public interface DistributionConfig extends Config, LogConfig { /** * Returns the value of the {@link ConfigurationProperties#LOG_LEVEL} property * - * @see com.gemstone.gemfire.internal.logging.LogWriterImpl + * @see org.apache.geode.internal.logging.LogWriterImpl */ @ConfigAttributeGetter(name = LOG_LEVEL) int getLogLevel(); @@ -464,7 +464,7 @@ public interface DistributionConfig extends Config, LogConfig { /** * Sets the value of the {@link ConfigurationProperties#LOG_LEVEL} property * - * @see com.gemstone.gemfire.internal.logging.LogWriterImpl + * @see org.apache.geode.internal.logging.LogWriterImpl */ @ConfigAttributeSetter(name = LOG_LEVEL) void setLogLevel(int value); @@ -1187,7 +1187,7 @@ public interface DistributionConfig extends Config, LogConfig { /** * The name of an internal property that specifies a {@link - * com.gemstone.gemfire.i18n.LogWriterI18n} instance to log to. + * org.apache.geode.i18n.LogWriterI18n} instance to log to. * Set this property with put(), not with setProperty() * * @since GemFire 4.0 @@ -1223,7 +1223,7 @@ public interface DistributionConfig extends Config, LogConfig { /** * The name of an internal property that specifies a {@link - * com.gemstone.gemfire.LogWriter} instance to log security messages to. Set + * org.apache.geode.LogWriter} instance to log security messages to. Set * this property with put(), not with setProperty() * * @since GemFire 5.5 @@ -2351,8 +2351,8 @@ public interface DistributionConfig extends Config, LogConfig { * The security log file can not be changed while the system is running. * * @throws IllegalArgumentException if the specified value is not acceptable. - * @throws com.gemstone.gemfire.UnmodifiableException if this attribute can not be modified. - * @throws com.gemstone.gemfire.GemFireIOException if the set failure is caused by an error when writing to + * @throws org.apache.geode.UnmodifiableException if this attribute can not be modified. + * @throws org.apache.geode.GemFireIOException if the set failure is caused by an error when writing to * the system's configuration file. */ @ConfigAttributeSetter(name = SECURITY_LOG_FILE) @@ -2598,8 +2598,8 @@ public interface DistributionConfig extends Config, LogConfig { * <p> The groups can not be changed while the system is running. * * @throws IllegalArgumentException if the specified value is not acceptable. - * @throws com.gemstone.gemfire.UnmodifiableException if this attribute can not be modified. - * @throws com.gemstone.gemfire.GemFireIOException if the set failure is caused by an error + * @throws org.apache.geode.UnmodifiableException if this attribute can not be modified. + * @throws org.apache.geode.GemFireIOException if the set failure is caused by an error * when writing to the system's configuration file. * @since GemFire 7.0 */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigImpl.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigImpl.java index 2ebb7d0..40bf089 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigImpl.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigImpl.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.*; +import static org.apache.geode.distributed.ConfigurationProperties.*; import java.io.File; import java.io.IOException; @@ -37,15 +37,15 @@ import java.util.Set; import org.apache.commons.lang.StringUtils; import org.apache.geode.redis.GeodeRedisServer; -import com.gemstone.gemfire.GemFireConfigException; -import com.gemstone.gemfire.GemFireIOException; -import com.gemstone.gemfire.distributed.DistributedSystem; +import org.apache.geode.GemFireConfigException; +import org.apache.geode.GemFireIOException; +import org.apache.geode.distributed.DistributedSystem; import org.apache.geode.security.SecurableComponents; -import com.gemstone.gemfire.internal.ConfigSource; -import com.gemstone.gemfire.internal.SocketCreator; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.process.ProcessLauncherContext; -import com.gemstone.gemfire.memcached.GemFireMemcachedServer; +import org.apache.geode.internal.ConfigSource; +import org.apache.geode.internal.SocketCreator; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.process.ProcessLauncherContext; +import org.apache.geode.memcached.GemFireMemcachedServer; /** * Provides an implementation of <code>DistributionConfig</code> that @@ -109,7 +109,7 @@ public class DistributionConfigImpl /** The level at which log messages are logged * - * @see com.gemstone.gemfire.internal.logging.LogWriterImpl#levelNameToCode(String) + * @see org.apache.geode.internal.logging.LogWriterImpl#levelNameToCode(String) */ protected int logLevel = DEFAULT_LOG_LEVEL; @@ -244,7 +244,7 @@ public class DistributionConfigImpl /** * The level at which security related log messages are logged * - * @see com.gemstone.gemfire.internal.logging.LogWriterImpl#levelNameToCode(String) + * @see org.apache.geode.internal.logging.LogWriterImpl#levelNameToCode(String) */ protected int securityLogLevel = DEFAULT_LOG_LEVEL; @@ -623,7 +623,7 @@ public class DistributionConfigImpl /** * Creates a new <code>DistributionConfigImpl</code> with the given * non-default configuration properties. See {@link - * com.gemstone.gemfire.distributed.DistributedSystem#connect} for a + * org.apache.geode.distributed.DistributedSystem#connect} for a * list of exceptions that may be thrown. * * @param nonDefault @@ -636,7 +636,7 @@ public class DistributionConfigImpl /** * Creates a new <code>DistributionConfigImpl</code> with the given * non-default configuration properties. See - * {@link com.gemstone.gemfire.distributed.DistributedSystem#connect} for a + * {@link org.apache.geode.distributed.DistributedSystem#connect} for a * list of exceptions that may be thrown. * * @param nonDefault @@ -656,7 +656,7 @@ public class DistributionConfigImpl /** * Creates a new <code>DistributionConfigImpl</code> with the given * non-default configuration properties. See - * {@link com.gemstone.gemfire.distributed.DistributedSystem#connect} for a + * {@link org.apache.geode.distributed.DistributedSystem#connect} for a * list of exceptions that may be thrown. * * @param nonDefault @@ -3194,14 +3194,14 @@ public class DistributionConfigImpl } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DistributionConfig#getMembershipPortRange() + * @see org.apache.geode.distributed.internal.DistributionConfig#getMembershipPortRange() */ public int[] getMembershipPortRange() { return membershipPortRange; } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DistributionConfig#setMembershipPortRange(int[]) + * @see org.apache.geode.distributed.internal.DistributionConfig#setMembershipPortRange(int[]) */ public void setMembershipPortRange(int[] range) { membershipPortRange = (int[])checkAttribute(MEMBERSHIP_PORT_RANGE, range); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigSnapshot.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigSnapshot.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigSnapshot.java index d50ff74..9d55437 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigSnapshot.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionConfigSnapshot.java @@ -15,11 +15,11 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.util.HashSet; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * Provides an implementation of the {@link DistributionConfig} interface http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionException.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionException.java index 7254504..6bfa55b 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionException.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionException.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.GemFireException; +import org.apache.geode.GemFireException; /** * This exception is thrown when a problem occurs when accessing the http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java index 259f7c2..ef69b7b 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java @@ -14,33 +14,33 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; - -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.admin.GemFireHealthConfig; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystemDisconnectedException; -import com.gemstone.gemfire.distributed.Locator; -import com.gemstone.gemfire.distributed.Role; -import com.gemstone.gemfire.distributed.internal.locks.ElderState; -import com.gemstone.gemfire.distributed.internal.membership.*; -import com.gemstone.gemfire.i18n.StringId; -import com.gemstone.gemfire.internal.*; -import com.gemstone.gemfire.internal.admin.remote.AdminConsoleDisconnectMessage; -import com.gemstone.gemfire.internal.admin.remote.RemoteGfManagerAgent; -import com.gemstone.gemfire.internal.admin.remote.RemoteTransportConfig; -import com.gemstone.gemfire.internal.cache.InitialImageOperation; -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.AlertAppender; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.sequencelog.MembershipLogger; -import com.gemstone.gemfire.internal.tcp.Connection; -import com.gemstone.gemfire.internal.tcp.ConnectionTable; -import com.gemstone.gemfire.internal.tcp.ReenteredConnectException; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantLock; +package org.apache.geode.distributed.internal; + +import org.apache.geode.*; +import org.apache.geode.admin.GemFireHealthConfig; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystemDisconnectedException; +import org.apache.geode.distributed.Locator; +import org.apache.geode.distributed.Role; +import org.apache.geode.distributed.internal.locks.ElderState; +import org.apache.geode.distributed.internal.membership.*; +import org.apache.geode.i18n.StringId; +import org.apache.geode.internal.*; +import org.apache.geode.internal.admin.remote.AdminConsoleDisconnectMessage; +import org.apache.geode.internal.admin.remote.RemoteGfManagerAgent; +import org.apache.geode.internal.admin.remote.RemoteTransportConfig; +import org.apache.geode.internal.cache.InitialImageOperation; +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.AlertAppender; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.sequencelog.MembershipLogger; +import org.apache.geode.internal.tcp.Connection; +import org.apache.geode.internal.tcp.ConnectionTable; +import org.apache.geode.internal.tcp.ReenteredConnectException; +import org.apache.geode.internal.util.concurrent.StoppableReentrantLock; import org.apache.logging.log4j.Logger; import java.io.*; @@ -88,7 +88,7 @@ public class DistributionManager /** * WARNING: setting this to true may break dunit tests. - * <p>see com.gemstone.gemfire.cache30.ClearMultiVmCallBkDUnitTest + * <p>see org.apache.geode.cache30.ClearMultiVmCallBkDUnitTest */ public static final boolean INLINE_PROCESS = !Boolean.getBoolean("DistributionManager.enqueueOrderedMessages"); @@ -176,7 +176,7 @@ public class DistributionManager /** * an NIO priority type - * @see com.gemstone.gemfire.distributed.internal.PooledDistributionMessage + * @see org.apache.geode.distributed.internal.PooledDistributionMessage * @see #SERIAL_EXECUTOR * @see #HIGH_PRIORITY_EXECUTOR * @see #WAITING_POOL_EXECUTOR @@ -186,7 +186,7 @@ public class DistributionManager /** * an NIO priority type * - * @see com.gemstone.gemfire.distributed.internal.SerialDistributionMessage + * @see org.apache.geode.distributed.internal.SerialDistributionMessage * @see #STANDARD_EXECUTOR */ public static final int SERIAL_EXECUTOR = 74; @@ -194,7 +194,7 @@ public class DistributionManager /** * an NIO priority type - * @see com.gemstone.gemfire.distributed.internal.HighPriorityDistributionMessage + * @see org.apache.geode.distributed.internal.HighPriorityDistributionMessage * @see #STANDARD_EXECUTOR */ public static final int HIGH_PRIORITY_EXECUTOR = 75; @@ -204,7 +204,7 @@ public class DistributionManager /** * an NIO priority type * - * @see com.gemstone.gemfire.internal.cache.InitialImageOperation + * @see org.apache.geode.internal.cache.InitialImageOperation * @see #STANDARD_EXECUTOR */ public static final int WAITING_POOL_EXECUTOR = 77; @@ -212,7 +212,7 @@ public class DistributionManager /** * an NIO priority type * - * @see com.gemstone.gemfire.internal.cache.InitialImageOperation + * @see org.apache.geode.internal.cache.InitialImageOperation * @see #STANDARD_EXECUTOR */ public static final int PARTITIONED_REGION_EXECUTOR = 78; @@ -221,7 +221,7 @@ public class DistributionManager /** * Executor for view related messages * - * @see com.gemstone.gemfire.distributed.internal.membership.gms.messages.ViewAckMessage + * @see org.apache.geode.distributed.internal.membership.gms.messages.ViewAckMessage * @see #STANDARD_EXECUTOR */ public static final int VIEW_EXECUTOR = 79; @@ -389,8 +389,8 @@ public class DistributionManager private ThreadPoolExecutor prMetaDataCleanupThreadPool; /** - * Thread used to decouple {@link com.gemstone.gemfire.internal.cache.partitioned.PartitionMessage}s from - * {@link com.gemstone.gemfire.internal.cache.DistributedCacheOperation}s </b> + * Thread used to decouple {@link org.apache.geode.internal.cache.partitioned.PartitionMessage}s from + * {@link org.apache.geode.internal.cache.DistributedCacheOperation}s </b> * @see #SERIAL_EXECUTOR */ private ThreadPoolExecutor partitionedRegionThread; @@ -402,7 +402,7 @@ public class DistributionManager private ThreadPoolExecutor serialThread; /** Message processing executor for view messages - * @see com.gemstone.gemfire.distributed.internal.membership.gms.messages.ViewAckMessage + * @see org.apache.geode.distributed.internal.membership.gms.messages.ViewAckMessage */ private ThreadPoolExecutor viewThread; @@ -2364,9 +2364,9 @@ public class DistributionManager /** * This thread processes member events as they occur. * - * @see com.gemstone.gemfire.distributed.internal.DistributionManager.MemberCrashedEvent - * @see com.gemstone.gemfire.distributed.internal.DistributionManager.MemberJoinedEvent - * @see com.gemstone.gemfire.distributed.internal.DistributionManager.MemberDepartedEvent + * @see org.apache.geode.distributed.internal.DistributionManager.MemberCrashedEvent + * @see org.apache.geode.distributed.internal.DistributionManager.MemberJoinedEvent + * @see org.apache.geode.distributed.internal.DistributionManager.MemberDepartedEvent * */ protected class MemberEventInvoker implements Runnable { @@ -2556,10 +2556,10 @@ public class DistributionManager public Set addAllMembershipListenerAndGetAllIds(MembershipListener l) { // TO fix this deadlock: // "View Message Processor": - // waiting to lock monitor 0x080f691c (object 0xe3ba7680, a com.gemstone.gemfire.distributed.internal.DistributionManager$MembersLock), + // waiting to lock monitor 0x080f691c (object 0xe3ba7680, a org.apache.geode.distributed.internal.DistributionManager$MembersLock), // which is held by "RMI TCP Connection(259)-10.80.10.55" // "RMI TCP Connection(259)-10.80.10.55": - // waiting to lock monitor 0x080f6598 (object 0xe3bacd90, a com.gemstone.gemfire.distributed.internal.membership.jgroup.JGroupMembershipManager$ViewLock), + // waiting to lock monitor 0x080f6598 (object 0xe3bacd90, a org.apache.geode.distributed.internal.membership.jgroup.JGroupMembershipManager$ViewLock), // which is held by "View Message Processor" // NEED to prevent view changes while installing a listener. DistributionChannel ch = this.channel; @@ -3469,7 +3469,7 @@ public class DistributionManager for (int i = 0; i < message.getRecipients().length; i ++) result.add(message.getRecipients()[i]); return result; - /* if (ex instanceof com.gemstone.gemfire.GemFireIpcResourceException) { + /* if (ex instanceof org.apache.geode.GemFireIpcResourceException) { return; }*/ } @@ -4545,21 +4545,21 @@ public class DistributionManager /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DM#getRootCause() + * @see org.apache.geode.distributed.internal.DM#getRootCause() */ public Throwable getRootCause() { return this.rootCause; } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DM#setRootCause(java.lang.Throwable) + * @see org.apache.geode.distributed.internal.DM#setRootCause(java.lang.Throwable) */ public void setRootCause(Throwable t) { this.rootCause = t; } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DM#getMembersOnThisHost() + * @see org.apache.geode.distributed.internal.DM#getMembersOnThisHost() * @since GemFire 5.9 */ public Set<InternalDistributedMember> getMembersInThisZone() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionMessage.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionMessage.java index f93e652..f07dca4 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionMessage.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionMessage.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.io.DataInput; import java.io.DataOutput; @@ -28,32 +28,32 @@ import java.util.concurrent.RejectedExecutionException; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.distributed.internal.deadlock.MessageDependencyMonitor; -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.EventID; -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.sequencelog.MessageLogger; -import com.gemstone.gemfire.internal.tcp.Connection; -import com.gemstone.gemfire.internal.util.Breadcrumbs; +import org.apache.geode.CancelException; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.SystemFailure; +import org.apache.geode.distributed.internal.deadlock.MessageDependencyMonitor; +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.EventID; +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.sequencelog.MessageLogger; +import org.apache.geode.internal.tcp.Connection; +import org.apache.geode.internal.util.Breadcrumbs; /** * <P>A <code>DistributionMessage</code> carries some piece of * information to a distribution manager. </P> * * <P>Messages that don't have strict ordering requirements should extend - * {@link com.gemstone.gemfire.distributed.internal.PooledDistributionMessage}. + * {@link org.apache.geode.distributed.internal.PooledDistributionMessage}. * Messages that must be processed serially in the order they were received * can extend - * {@link com.gemstone.gemfire.distributed.internal.SerialDistributionMessage}. + * {@link org.apache.geode.distributed.internal.SerialDistributionMessage}. * To customize the sequentialness/thread requirements of a message, extend * DistributionMessage and implement getExecutor().</P> * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionMessageObserver.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionMessageObserver.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionMessageObserver.java index 3b4161c..d5afe6d 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionMessageObserver.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionMessageObserver.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; /** http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionStats.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionStats.java index fbfd0c6..ca2a8c1 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionStats.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionStats.java @@ -14,21 +14,21 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import org.apache.logging.log4j.Logger; -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.NanoTimer; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; -import com.gemstone.gemfire.internal.logging.LogService; +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.NanoTimer; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.internal.logging.LogService; //import java.io.*; -import com.gemstone.gemfire.internal.tcp.Buffers; -import com.gemstone.gemfire.internal.util.Breadcrumbs; +import org.apache.geode.internal.tcp.Buffers; +import org.apache.geode.internal.util.Breadcrumbs; /** * This class maintains statistics in GemFire about the distribution http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/FlowControlParams.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/FlowControlParams.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/FlowControlParams.java index b656805..c4c7b83 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/FlowControlParams.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/FlowControlParams.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; /** FlowControlParams are used to represent mcast-flow-control parameters for a DistributedSystem. Instances of this class are used in DistributionConfig to http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/FunctionExecutionPooledExecutor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/FunctionExecutionPooledExecutor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/FunctionExecutionPooledExecutor.java index 1ac6f30..6a05591 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/FunctionExecutionPooledExecutor.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/FunctionExecutionPooledExecutor.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.SystemFailure; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.util.List; import java.util.concurrent.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/HealthMonitor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/HealthMonitor.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/HealthMonitor.java index 92cafe8..46da196 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/HealthMonitor.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/HealthMonitor.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.admin.GemFireHealth; +import org.apache.geode.admin.GemFireHealth; /** * Represents a thread that monitor the health of the vm it lives in. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/HealthMonitorImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/HealthMonitorImpl.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/HealthMonitorImpl.java index 7862390..5773583 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/HealthMonitorImpl.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/HealthMonitorImpl.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.admin.GemFireHealth; -import com.gemstone.gemfire.admin.GemFireHealthConfig; -import com.gemstone.gemfire.admin.internal.GemFireHealthEvaluator; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.admin.remote.HealthListenerMessage; -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 org.apache.geode.admin.GemFireHealth; +import org.apache.geode.admin.GemFireHealthConfig; +import org.apache.geode.admin.internal.GemFireHealthEvaluator; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.admin.remote.HealthListenerMessage; +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; /** * Implements a thread that monitors the health of the vm it lives in. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityAckedMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityAckedMessage.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityAckedMessage.java index ffae0fe..2733c39 100755 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityAckedMessage.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityAckedMessage.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.io.DataInput; import java.io.DataOutput; @@ -26,14 +26,14 @@ import java.util.concurrent.ThreadPoolExecutor; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.OSProcess; -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.DataSerializer; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.OSProcess; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * A message that is sent to a given collection of managers and then http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityDistributionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityDistributionMessage.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityDistributionMessage.java index d13927a..5b9b01c 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityDistributionMessage.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/HighPriorityDistributionMessage.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; /** * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/IgnoredByManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/IgnoredByManager.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/IgnoredByManager.java index 4090d3a..001087f 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/IgnoredByManager.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/IgnoredByManager.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; /** * This marker indicates messages (usually {@link http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalDistributedSystem.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalDistributedSystem.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalDistributedSystem.java index b9566df..44960c8 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalDistributedSystem.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalDistributedSystem.java @@ -15,59 +15,59 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; - -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.admin.AlertLevel; -import com.gemstone.gemfire.cache.CacheClosedException; -import com.gemstone.gemfire.cache.CacheFactory; -import com.gemstone.gemfire.cache.execute.internal.FunctionServiceManager; -import com.gemstone.gemfire.cache.server.CacheServer; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.DistributedSystemDisconnectedException; -import com.gemstone.gemfire.distributed.DurableClientAttributes; -import com.gemstone.gemfire.distributed.internal.locks.GrantorRequestProcessor; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.MembershipManager; -import com.gemstone.gemfire.distributed.internal.membership.QuorumChecker; -import com.gemstone.gemfire.distributed.internal.membership.gms.Services; -import com.gemstone.gemfire.distributed.internal.membership.gms.mgr.GMSMembershipManager; -import com.gemstone.gemfire.i18n.LogWriterI18n; -import com.gemstone.gemfire.internal.*; -import com.gemstone.gemfire.internal.admin.remote.DistributionLocatorId; -import com.gemstone.gemfire.internal.cache.CacheConfig; -import com.gemstone.gemfire.internal.cache.CacheServerImpl; -import com.gemstone.gemfire.internal.cache.EventID; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.execute.FunctionServiceStats; -import com.gemstone.gemfire.internal.cache.execute.FunctionStats; -import com.gemstone.gemfire.internal.cache.tier.sockets.HandShake; -import com.gemstone.gemfire.internal.cache.xmlcache.CacheServerCreation; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.InternalLogWriter; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.LogWriterFactory; -import com.gemstone.gemfire.internal.logging.LoggingThreadGroup; -import com.gemstone.gemfire.internal.logging.log4j.AlertAppender; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogWriterAppender; -import com.gemstone.gemfire.internal.logging.log4j.LogWriterAppenders; -import com.gemstone.gemfire.internal.offheap.MemoryAllocator; -import com.gemstone.gemfire.internal.offheap.OffHeapStorage; -import com.gemstone.gemfire.internal.statistics.DummyStatisticsImpl; -import com.gemstone.gemfire.internal.statistics.GemFireStatSampler; -import com.gemstone.gemfire.internal.statistics.platform.LinuxProcFsStatistics; -import com.gemstone.gemfire.internal.statistics.LocalStatisticsImpl; -import com.gemstone.gemfire.internal.statistics.platform.OsStatisticsFactory; -import com.gemstone.gemfire.internal.statistics.StatisticsImpl; -import com.gemstone.gemfire.internal.statistics.StatisticsManager; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; -import com.gemstone.gemfire.internal.tcp.ConnectionTable; -import com.gemstone.gemfire.internal.util.concurrent.StoppableCondition; -import com.gemstone.gemfire.internal.util.concurrent.StoppableReentrantLock; -import com.gemstone.gemfire.management.ManagementException; -import com.gemstone.gemfire.security.GemFireSecurityException; +package org.apache.geode.distributed.internal; + +import org.apache.geode.*; +import org.apache.geode.admin.AlertLevel; +import org.apache.geode.cache.CacheClosedException; +import org.apache.geode.cache.CacheFactory; +import org.apache.geode.cache.execute.internal.FunctionServiceManager; +import org.apache.geode.cache.server.CacheServer; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.DistributedSystemDisconnectedException; +import org.apache.geode.distributed.DurableClientAttributes; +import org.apache.geode.distributed.internal.locks.GrantorRequestProcessor; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.distributed.internal.membership.MembershipManager; +import org.apache.geode.distributed.internal.membership.QuorumChecker; +import org.apache.geode.distributed.internal.membership.gms.Services; +import org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManager; +import org.apache.geode.i18n.LogWriterI18n; +import org.apache.geode.internal.*; +import org.apache.geode.internal.admin.remote.DistributionLocatorId; +import org.apache.geode.internal.cache.CacheConfig; +import org.apache.geode.internal.cache.CacheServerImpl; +import org.apache.geode.internal.cache.EventID; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.execute.FunctionServiceStats; +import org.apache.geode.internal.cache.execute.FunctionStats; +import org.apache.geode.internal.cache.tier.sockets.HandShake; +import org.apache.geode.internal.cache.xmlcache.CacheServerCreation; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.InternalLogWriter; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.LogWriterFactory; +import org.apache.geode.internal.logging.LoggingThreadGroup; +import org.apache.geode.internal.logging.log4j.AlertAppender; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogWriterAppender; +import org.apache.geode.internal.logging.log4j.LogWriterAppenders; +import org.apache.geode.internal.offheap.MemoryAllocator; +import org.apache.geode.internal.offheap.OffHeapStorage; +import org.apache.geode.internal.statistics.DummyStatisticsImpl; +import org.apache.geode.internal.statistics.GemFireStatSampler; +import org.apache.geode.internal.statistics.platform.LinuxProcFsStatistics; +import org.apache.geode.internal.statistics.LocalStatisticsImpl; +import org.apache.geode.internal.statistics.platform.OsStatisticsFactory; +import org.apache.geode.internal.statistics.StatisticsImpl; +import org.apache.geode.internal.statistics.StatisticsManager; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.internal.tcp.ConnectionTable; +import org.apache.geode.internal.util.concurrent.StoppableCondition; +import org.apache.geode.internal.util.concurrent.StoppableReentrantLock; +import org.apache.geode.management.ManagementException; +import org.apache.geode.security.GemFireSecurityException; import org.apache.logging.log4j.Logger; import java.io.File; @@ -81,8 +81,8 @@ import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicReference; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.LOCATORS; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.MCAST_PORT; +import static org.apache.geode.distributed.ConfigurationProperties.LOCATORS; +import static org.apache.geode.distributed.ConfigurationProperties.MCAST_PORT; /** * The concrete implementation of {@link DistributedSystem} that @@ -430,7 +430,7 @@ public class InternalDistributedSystem // if (DistributionConfigImpl.forceDisableTcp) { // this.logger.warning("Use of UDP has been forced"); // } -// if (com.gemstone.gemfire.distributed.internal.membership.jgroup.JGroupMembershipManager.multicastTest) { +// if (org.apache.geode.distributed.internal.membership.jgroup.JGroupMembershipManager.multicastTest) { // this.logger.warning("Use of multicast for all distributed cache operations has been forced"); // } @@ -1513,7 +1513,7 @@ public class InternalDistributedSystem * This is actually the port of the distribution manager's * distribution channel. * - * @see com.gemstone.gemfire.distributed.internal.DistributionChannel#getId + * @see org.apache.geode.distributed.internal.DistributionChannel#getId */ @Override public long getId() { @@ -2879,7 +2879,7 @@ public class InternalDistributedSystem } /** - * see {@link com.gemstone.gemfire.admin.AdminDistributedSystemFactory} + * see {@link org.apache.geode.admin.AdminDistributedSystemFactory} * @since GemFire 5.7 */ public static void setEnableAdministrationOnly(boolean adminOnly) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalLocator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalLocator.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalLocator.java index 026efb9..a44e336 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalLocator.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/InternalLocator.java @@ -14,49 +14,49 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.CacheFactory; -import com.gemstone.gemfire.cache.GemFireCache; -import com.gemstone.gemfire.cache.client.internal.locator.*; -import com.gemstone.gemfire.cache.client.internal.locator.wan.LocatorMembershipListener; -import com.gemstone.gemfire.distributed.DistributedSystem; -import com.gemstone.gemfire.distributed.Locator; -import com.gemstone.gemfire.distributed.LockServiceDestroyedException; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem.ConnectListener; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem.DisconnectListener; -import com.gemstone.gemfire.distributed.internal.membership.MemberFactory; -import com.gemstone.gemfire.distributed.internal.membership.QuorumChecker; -import com.gemstone.gemfire.distributed.internal.membership.gms.NetLocator; -import com.gemstone.gemfire.distributed.internal.membership.gms.locator.PeerLocatorRequest; -import com.gemstone.gemfire.distributed.internal.tcpserver.TcpClient; -import com.gemstone.gemfire.distributed.internal.tcpserver.TcpHandler; -import com.gemstone.gemfire.distributed.internal.tcpserver.TcpServer; -import com.gemstone.gemfire.internal.SocketCreator; -import com.gemstone.gemfire.internal.admin.remote.DistributionLocatorId; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.wan.WANServiceProvider; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.InternalLogWriter; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.LogWriterFactory; -import com.gemstone.gemfire.internal.logging.LoggingThreadGroup; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; -import com.gemstone.gemfire.internal.logging.log4j.LogWriterAppenders; -import com.gemstone.gemfire.internal.logging.log4j.LogWriterLogger; -import com.gemstone.gemfire.management.internal.JmxManagerLocator; -import com.gemstone.gemfire.management.internal.JmxManagerLocatorRequest; -import com.gemstone.gemfire.management.internal.JmxManagerLocatorResponse; -import com.gemstone.gemfire.management.internal.cli.CliUtil; -import com.gemstone.gemfire.management.internal.configuration.domain.SharedConfigurationStatus; -import com.gemstone.gemfire.management.internal.configuration.handlers.ConfigurationRequestHandler; -import com.gemstone.gemfire.management.internal.configuration.handlers.SharedConfigurationStatusRequestHandler; -import com.gemstone.gemfire.management.internal.configuration.messages.ConfigurationRequest; -import com.gemstone.gemfire.management.internal.configuration.messages.SharedConfigurationStatusRequest; -import com.gemstone.gemfire.management.internal.configuration.messages.SharedConfigurationStatusResponse; +import org.apache.geode.CancelException; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.CacheFactory; +import org.apache.geode.cache.GemFireCache; +import org.apache.geode.cache.client.internal.locator.*; +import org.apache.geode.cache.client.internal.locator.wan.LocatorMembershipListener; +import org.apache.geode.distributed.DistributedSystem; +import org.apache.geode.distributed.Locator; +import org.apache.geode.distributed.LockServiceDestroyedException; +import org.apache.geode.distributed.internal.InternalDistributedSystem.ConnectListener; +import org.apache.geode.distributed.internal.InternalDistributedSystem.DisconnectListener; +import org.apache.geode.distributed.internal.membership.MemberFactory; +import org.apache.geode.distributed.internal.membership.QuorumChecker; +import org.apache.geode.distributed.internal.membership.gms.NetLocator; +import org.apache.geode.distributed.internal.membership.gms.locator.PeerLocatorRequest; +import org.apache.geode.distributed.internal.tcpserver.TcpClient; +import org.apache.geode.distributed.internal.tcpserver.TcpHandler; +import org.apache.geode.distributed.internal.tcpserver.TcpServer; +import org.apache.geode.internal.SocketCreator; +import org.apache.geode.internal.admin.remote.DistributionLocatorId; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.wan.WANServiceProvider; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.InternalLogWriter; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.LogWriterFactory; +import org.apache.geode.internal.logging.LoggingThreadGroup; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.internal.logging.log4j.LogMarker; +import org.apache.geode.internal.logging.log4j.LogWriterAppenders; +import org.apache.geode.internal.logging.log4j.LogWriterLogger; +import org.apache.geode.management.internal.JmxManagerLocator; +import org.apache.geode.management.internal.JmxManagerLocatorRequest; +import org.apache.geode.management.internal.JmxManagerLocatorResponse; +import org.apache.geode.management.internal.cli.CliUtil; +import org.apache.geode.management.internal.configuration.domain.SharedConfigurationStatus; +import org.apache.geode.management.internal.configuration.handlers.ConfigurationRequestHandler; +import org.apache.geode.management.internal.configuration.handlers.SharedConfigurationStatusRequestHandler; +import org.apache.geode.management.internal.configuration.messages.ConfigurationRequest; +import org.apache.geode.management.internal.configuration.messages.SharedConfigurationStatusRequest; +import org.apache.geode.management.internal.configuration.messages.SharedConfigurationStatusResponse; import org.apache.logging.log4j.Logger; import java.io.File; @@ -71,7 +71,7 @@ import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.*; +import static org.apache.geode.distributed.ConfigurationProperties.*; /** * Provides the implementation of a distribution <code>Locator</code> http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorLoadSnapshot.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorLoadSnapshot.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorLoadSnapshot.java index 4933e25..67373f9 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorLoadSnapshot.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorLoadSnapshot.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.util.ArrayList; import java.util.Collection; @@ -35,9 +35,9 @@ import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; -import com.gemstone.gemfire.cache.server.ServerLoad; -import com.gemstone.gemfire.cache.wan.GatewayReceiver; -import com.gemstone.gemfire.internal.cache.tier.sockets.ClientProxyMembershipID; +import org.apache.geode.cache.server.ServerLoad; +import org.apache.geode.cache.wan.GatewayReceiver; +import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; /** * A data structure used to hold load information for a locator http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorStats.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorStats.java index 897b8c3..6f9c42d 100755 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorStats.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/LocatorStats.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.*; -import com.gemstone.gemfire.internal.statistics.StatisticsTypeFactoryImpl; +import org.apache.geode.*; +import org.apache.geode.internal.statistics.StatisticsTypeFactoryImpl; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.LOCATORS; +import static org.apache.geode.distributed.ConfigurationProperties.LOCATORS; /** * This class maintains statistics for the locator http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java index c4621ce..6ea471a 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java @@ -14,22 +14,22 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; - -import com.gemstone.gemfire.CancelCriterion; -import com.gemstone.gemfire.InternalGemFireError; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.DurableClientAttributes; -import com.gemstone.gemfire.distributed.Role; -import com.gemstone.gemfire.distributed.internal.locks.ElderState; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.MemberAttributes; -import com.gemstone.gemfire.distributed.internal.membership.MembershipManager; -import com.gemstone.gemfire.i18n.LogWriterI18n; -import com.gemstone.gemfire.internal.SocketCreator; -import com.gemstone.gemfire.internal.Version; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.InternalLogWriter; +package org.apache.geode.distributed.internal; + +import org.apache.geode.CancelCriterion; +import org.apache.geode.InternalGemFireError; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.DurableClientAttributes; +import org.apache.geode.distributed.Role; +import org.apache.geode.distributed.internal.locks.ElderState; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.distributed.internal.membership.MemberAttributes; +import org.apache.geode.distributed.internal.membership.MembershipManager; +import org.apache.geode.i18n.LogWriterI18n; +import org.apache.geode.internal.SocketCreator; +import org.apache.geode.internal.Version; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.InternalLogWriter; import java.io.Serializable; import java.net.InetAddress; @@ -88,7 +88,7 @@ public class LonerDistributionManager implements DM { try { host = InetAddress.getLocalHost().getCanonicalHostName(); MemberAttributes.setDefaults(65535, - com.gemstone.gemfire.internal.OSProcess.getId(), + org.apache.geode.internal.OSProcess.getId(), DistributionManager.LONER_DM_TYPE, MemberAttributes.parseRoles(system.getConfig().getRoles())); id = new InternalDistributedMember(host, 65535); // noise value for port number @@ -895,7 +895,7 @@ public class LonerDistributionManager implements DM { } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DM#getMembershipManager() + * @see org.apache.geode.distributed.internal.DM#getMembershipManager() */ public MembershipManager getMembershipManager() { // no membership manager @@ -903,20 +903,20 @@ public class LonerDistributionManager implements DM { } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DM#getRootCause() + * @see org.apache.geode.distributed.internal.DM#getRootCause() */ public Throwable getRootCause() { return null; } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DM#setRootCause(java.lang.Throwable) + * @see org.apache.geode.distributed.internal.DM#setRootCause(java.lang.Throwable) */ public void setRootCause(Throwable t) { } /* (non-Javadoc) - * @see com.gemstone.gemfire.distributed.internal.DM#getMembersOnThisHost() + * @see org.apache.geode.distributed.internal.DM#getMembersOnThisHost() * @since GemFire 5.9 */ public Set<InternalDistributedMember> getMembersInThisZone() { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/MQueue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/MQueue.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/MQueue.java index 304a7fa..b9e169e 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/MQueue.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/MQueue.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.util.concurrent.BlockingQueue; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/MembershipListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/MembershipListener.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/MembershipListener.java index 8fe2d67..4255bab 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/MembershipListener.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/MembershipListener.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.util.List; import java.util.Set; -import com.gemstone.gemfire.distributed.internal.membership.*; +import org.apache.geode.distributed.internal.membership.*; /** * This interface specifies callback methods that are invoked when http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/MessageFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/MessageFactory.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/MessageFactory.java index ec09bd7..5b62a0f 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/MessageFactory.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/MessageFactory.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * This class is a factory that creates instances http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/MessageWithReply.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/MessageWithReply.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/MessageWithReply.java index a5c028c..219d7da 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/MessageWithReply.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/MessageWithReply.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.distributed.internal.membership.*; +import org.apache.geode.distributed.internal.membership.*; /** * A marker interface that denotes {@link DistributionMessage}s that @@ -30,7 +30,7 @@ public interface MessageWithReply { /** * Returns the id of the {@link - * com.gemstone.gemfire.distributed.internal.ReplyProcessor21} that is used to + * org.apache.geode.distributed.internal.ReplyProcessor21} that is used to * handle the reply to this message. */ public int getProcessorId(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/OverflowQueueWithDMStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/OverflowQueueWithDMStats.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/OverflowQueueWithDMStats.java index 03b7f64..54f5d8f 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/OverflowQueueWithDMStats.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/OverflowQueueWithDMStats.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/PoolStatHelper.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/PoolStatHelper.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/PoolStatHelper.java index f4b8f83..ba03294 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/PoolStatHelper.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/PoolStatHelper.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; /** * Used to implement statistics on a pool. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/PooledDistributionMessage.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/PooledDistributionMessage.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/PooledDistributionMessage.java index 2f22918..ea1a2a1 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/PooledDistributionMessage.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/PooledDistributionMessage.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; /** * A PooledDistributionMessage passes processing off to a thread that http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/PooledExecutorWithDMStats.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/PooledExecutorWithDMStats.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/PooledExecutorWithDMStats.java index 5bb82f0..31760c8 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/PooledExecutorWithDMStats.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/PooledExecutorWithDMStats.java @@ -15,10 +15,10 @@ * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.SystemFailure; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.util.List; import java.util.concurrent.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/ProcessorKeeper21.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/ProcessorKeeper21.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/ProcessorKeeper21.java index 650a02c..bb7df56 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/ProcessorKeeper21.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/ProcessorKeeper21.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.internal.*; +import org.apache.geode.internal.*; import java.lang.ref.WeakReference; import java.util.concurrent.atomic.AtomicInteger; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/ProductUseLog.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/ProductUseLog.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/ProductUseLog.java index c8e066d..18b51b9 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/ProductUseLog.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/ProductUseLog.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; import java.io.File; import java.io.FileNotFoundException; @@ -23,12 +23,12 @@ import java.io.PrintStream; import java.util.List; import java.util.Set; -import com.gemstone.gemfire.GemFireIOException; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.distributed.internal.membership.MembershipManager; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.InternalLogWriter; -import com.gemstone.gemfire.internal.logging.PureLogWriter; +import org.apache.geode.GemFireIOException; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.distributed.internal.membership.MembershipManager; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.InternalLogWriter; +import org.apache.geode.internal.logging.PureLogWriter; /** * A log intended for recording product-use. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/939fcf2f/geode-core/src/main/java/org/apache/geode/distributed/internal/ProfileListener.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/distributed/internal/ProfileListener.java b/geode-core/src/main/java/org/apache/geode/distributed/internal/ProfileListener.java index 5797f84..8619a05 100644 --- a/geode-core/src/main/java/org/apache/geode/distributed/internal/ProfileListener.java +++ b/geode-core/src/main/java/org/apache/geode/distributed/internal/ProfileListener.java @@ -14,9 +14,9 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.distributed.internal; +package org.apache.geode.distributed.internal; -import com.gemstone.gemfire.distributed.internal.DistributionAdvisor.Profile; +import org.apache.geode.distributed.internal.DistributionAdvisor.Profile; /** * Callback for changes to profiles in a DistributionAdvisor. A ProfileListener
