http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/DistributionLocatorConfigImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/DistributionLocatorConfigImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/DistributionLocatorConfigImpl.java index 719cd14..1e23a3e 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/DistributionLocatorConfigImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/DistributionLocatorConfigImpl.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.DistributionLocator; -import com.gemstone.gemfire.admin.DistributionLocatorConfig; -import com.gemstone.gemfire.distributed.internal.tcpserver.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.admin.DistributionLocator; +import org.apache.geode.admin.DistributionLocatorConfig; +import org.apache.geode.distributed.internal.tcpserver.*; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.net.InetAddress; import java.util.Properties; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.MCAST_PORT; +import static org.apache.geode.distributed.ConfigurationProperties.MCAST_PORT; /** * Provides an implementation of
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/DistributionLocatorImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/DistributionLocatorImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/DistributionLocatorImpl.java index bda1b59..d8ad205 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/DistributionLocatorImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/DistributionLocatorImpl.java @@ -15,19 +15,19 @@ * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; - -import com.gemstone.gemfire.admin.AdminDistributedSystem; -import com.gemstone.gemfire.admin.DistributionLocator; -import com.gemstone.gemfire.admin.DistributionLocatorConfig; -import com.gemstone.gemfire.admin.ManagedEntityConfig; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.admin.remote.DistributionLocatorId; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +package org.apache.geode.admin.internal; + +import org.apache.geode.admin.AdminDistributedSystem; +import org.apache.geode.admin.DistributionLocator; +import org.apache.geode.admin.DistributionLocatorConfig; +import org.apache.geode.admin.ManagedEntityConfig; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.admin.remote.DistributionLocatorId; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; import org.apache.logging.log4j.Logger; import java.net.InetAddress; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/EnabledManagedEntityController.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/EnabledManagedEntityController.java b/geode-core/src/main/java/org/apache/geode/admin/internal/EnabledManagedEntityController.java index 465d7ae..20871d8 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/EnabledManagedEntityController.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/EnabledManagedEntityController.java @@ -14,25 +14,25 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; - -import com.gemstone.gemfire.admin.AdminDistributedSystem; -import com.gemstone.gemfire.admin.DistributedSystemConfig; -import com.gemstone.gemfire.admin.ManagedEntity; -import com.gemstone.gemfire.admin.ManagedEntityConfig; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.internal.ProcessOutputReader; -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; +package org.apache.geode.admin.internal; + +import org.apache.geode.admin.AdminDistributedSystem; +import org.apache.geode.admin.DistributedSystemConfig; +import org.apache.geode.admin.ManagedEntity; +import org.apache.geode.admin.ManagedEntityConfig; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.internal.ProcessOutputReader; +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.logging.log4j.Logger; import java.io.File; import java.util.Iterator; import java.util.Properties; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.*; +import static org.apache.geode.distributed.ConfigurationProperties.*; /** * Implements the actual administration (starting, stopping, etc.) of http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupRequest.java b/geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupRequest.java index 582ab62..2de4b08 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupRequest.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupRequest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; import java.io.DataInput; import java.io.DataOutput; @@ -29,22 +29,22 @@ 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.persistence.PersistentID; -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.internal.admin.remote.AdminFailureResponse; -import com.gemstone.gemfire.internal.admin.remote.AdminMultipleReplyProcessor; -import com.gemstone.gemfire.internal.admin.remote.AdminResponse; -import com.gemstone.gemfire.internal.admin.remote.CliLegacyMessage; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.CancelException; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.persistence.PersistentID; +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.internal.admin.remote.AdminFailureResponse; +import org.apache.geode.internal.admin.remote.AdminMultipleReplyProcessor; +import org.apache.geode.internal.admin.remote.AdminResponse; +import org.apache.geode.internal.admin.remote.CliLegacyMessage; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * A request send from an admin VM to all of the peers to indicate http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupResponse.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupResponse.java b/geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupResponse.java index eee8917..d3595ef 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupResponse.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/FinishBackupResponse.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.util.HashSet; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.persistence.PersistentID; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.admin.remote.AdminResponse; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.persistence.PersistentID; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.admin.remote.AdminResponse; /** * The reply for a {@link FinishBackupRequest}. The http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskRequest.java b/geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskRequest.java index 9c84820..2232377 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskRequest.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskRequest.java @@ -14,22 +14,22 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; import java.util.Collection; import java.util.HashSet; import java.util.Set; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.cache.persistence.PersistentID; -import com.gemstone.gemfire.distributed.internal.DM; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.ReplyException; -import com.gemstone.gemfire.internal.admin.remote.AdminMultipleReplyProcessor; -import com.gemstone.gemfire.internal.admin.remote.AdminResponse; -import com.gemstone.gemfire.internal.admin.remote.CliLegacyMessage; -import com.gemstone.gemfire.internal.cache.DiskStoreImpl; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; +import org.apache.geode.CancelException; +import org.apache.geode.cache.persistence.PersistentID; +import org.apache.geode.distributed.internal.DM; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.ReplyException; +import org.apache.geode.internal.admin.remote.AdminMultipleReplyProcessor; +import org.apache.geode.internal.admin.remote.AdminResponse; +import org.apache.geode.internal.admin.remote.CliLegacyMessage; +import org.apache.geode.internal.cache.DiskStoreImpl; +import org.apache.geode.internal.cache.GemFireCacheImpl; /** * A request to from an admin VM to all non admin members http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskResponse.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskResponse.java b/geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskResponse.java index 050f4ac..622abd3 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskResponse.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/FlushToDiskResponse.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.admin.remote.AdminResponse; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.admin.remote.AdminResponse; /** * The response to the {@link FlushToDiskRequest} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthConfigImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthConfigImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthConfigImpl.java index 11122d3..754b0fb 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthConfigImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthConfigImpl.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.admin.*; +import org.apache.geode.internal.i18n.LocalizedStrings; // @todo davidw Delegate to a "parent" config for properties that are not overridden. // This will be made easier with a special <code>HealthConfigAttribute</code> class. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthEvaluator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthEvaluator.java b/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthEvaluator.java index ddd1358..f07cb2c 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthEvaluator.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthEvaluator.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; import java.util.ArrayList; import java.util.Iterator; @@ -22,12 +22,12 @@ import java.util.List; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.admin.GemFireHealth; -import com.gemstone.gemfire.admin.GemFireHealthConfig; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.admin.GemFireHealth; +import org.apache.geode.admin.GemFireHealthConfig; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; /** * Evaluates the health of various GemFire components in the VM http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthImpl.java index f8ae44a..f944482 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/GemFireHealthImpl.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.admin.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.CancelException; +import org.apache.geode.admin.*; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.admin.*; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.net.InetAddress; import java.net.UnknownHostException; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/InetAddressUtil.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/InetAddressUtil.java b/geode-core/src/main/java/org/apache/geode/admin/internal/InetAddressUtil.java index 32462f1..698a627 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/InetAddressUtil.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/InetAddressUtil.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; import java.net.InetAddress; import java.net.NetworkInterface; @@ -23,11 +23,11 @@ import java.util.Enumeration; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.GemFireIOException; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.net.SocketCreator; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.GemFireIOException; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.net.SocketCreator; +import org.apache.geode.internal.i18n.LocalizedStrings; +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/admin/internal/InternalManagedEntity.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/InternalManagedEntity.java b/geode-core/src/main/java/org/apache/geode/admin/internal/InternalManagedEntity.java index 4ead1df..d963a21 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/InternalManagedEntity.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/InternalManagedEntity.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.AdminDistributedSystem; -import com.gemstone.gemfire.admin.ManagedEntity; -import com.gemstone.gemfire.admin.ManagedEntityConfig; +import org.apache.geode.admin.AdminDistributedSystem; +import org.apache.geode.admin.ManagedEntity; +import org.apache.geode.admin.ManagedEntityConfig; /** * Provides internal-only functionality that is expected of all http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/LogCollator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/LogCollator.java b/geode-core/src/main/java/org/apache/geode/admin/internal/LogCollator.java index 633fa89..6a183c5 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/LogCollator.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/LogCollator.java @@ -15,12 +15,12 @@ * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.internal.admin.GfManagerAgent; -import com.gemstone.gemfire.internal.admin.GemFireVM; -import com.gemstone.gemfire.internal.admin.ApplicationVM; -import com.gemstone.gemfire.internal.logging.MergeLogFiles; +import org.apache.geode.internal.admin.GfManagerAgent; +import org.apache.geode.internal.admin.GemFireVM; +import org.apache.geode.internal.admin.ApplicationVM; +import org.apache.geode.internal.logging.MergeLogFiles; import java.io.ByteArrayInputStream; import java.io.InputStream; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigImpl.java index 2a59cdd..3f1e0d3 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigImpl.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; - -//import com.gemstone.gemfire.admin.DistributedSystemConfig; -//import com.gemstone.gemfire.admin.ManagedEntity; -import com.gemstone.gemfire.admin.ManagedEntityConfig; -import com.gemstone.gemfire.internal.admin.GemFireVM; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.GemFireVersion; -import com.gemstone.gemfire.internal.net.SocketCreator; +package org.apache.geode.admin.internal; + +//import org.apache.geode.admin.DistributedSystemConfig; +//import org.apache.geode.admin.ManagedEntity; +import org.apache.geode.admin.ManagedEntityConfig; +import org.apache.geode.internal.admin.GemFireVM; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.GemFireVersion; +import org.apache.geode.internal.net.SocketCreator; import java.io.File; import java.net.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXml.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXml.java b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXml.java index ff6deca..6313e21 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXml.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXml.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.distributed.ConfigurationProperties; -import com.gemstone.gemfire.internal.ClassPathLoader; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.distributed.ConfigurationProperties; +import org.apache.geode.internal.ClassPathLoader; +import org.apache.geode.internal.i18n.LocalizedStrings; import org.xml.sax.*; import java.io.InputStream; /** * The abstract superclass of classes that convert XML into a {@link - * com.gemstone.gemfire.admin.DistributedSystemConfig} and vice versa. + * org.apache.geode.admin.DistributedSystemConfig} and vice versa. * It provides helper methods and constants. * * @since GemFire 4.0 @@ -34,7 +34,7 @@ abstract class ManagedEntityConfigXml implements EntityResolver, ErrorHandler { /** The location of the DTD file */ protected static final String DTD_LOCATION = - "/com/gemstone/gemfire/admin/doc-files/ds5_0.dtd"; + "/org/apache/geode/admin/doc-files/ds5_0.dtd"; /** The URL for the DTD */ protected static final String SYSTEM_ID = @@ -150,7 +150,7 @@ abstract class ManagedEntityConfigXml implements EntityResolver, ErrorHandler { } /** - * Throws a {@link com.gemstone.gemfire.cache.CacheXmlException} + * Throws a {@link org.apache.geode.cache.CacheXmlException} */ public void error(SAXParseException ex) throws SAXException { IllegalArgumentException ex2 = new IllegalArgumentException(LocalizedStrings.ManagedEntityConfigXml_ERROR_WHILE_PARSING_XML.toLocalizedString()); @@ -159,7 +159,7 @@ abstract class ManagedEntityConfigXml implements EntityResolver, ErrorHandler { } /** - * Throws a {@link com.gemstone.gemfire.cache.CacheXmlException} + * Throws a {@link org.apache.geode.cache.CacheXmlException} */ public void fatalError(SAXParseException ex) throws SAXException { IllegalArgumentException ex2 = new IllegalArgumentException(LocalizedStrings.ManagedEntityConfigXml_FATAL_ERROR_WHILE_PARSING_XML.toLocalizedString()); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXmlGenerator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXmlGenerator.java b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXmlGenerator.java index e406ba3..80f183d 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXmlGenerator.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXmlGenerator.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.admin.*; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.i18n.LocalizedStrings; import javax.xml.transform.*; //import javax.xml.transform.dom.DOMSource; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXmlParser.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXmlParser.java b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXmlParser.java index 58e90e9..1065caf 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXmlParser.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityConfigXmlParser.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.admin.*; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.i18n.LocalizedStrings; import javax.xml.parsers.SAXParser; import javax.xml.parsers.SAXParserFactory; @@ -88,7 +88,7 @@ public class ManagedEntityConfigXmlParser /** * Helper method for parsing an integer * - * @throws com.gemstone.gemfire.cache.CacheXmlException + * @throws org.apache.geode.cache.CacheXmlException * If <code>s</code> is a malformed integer */ private static int parseInt(String s) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityController.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityController.java b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityController.java index 85193ef..c1a3fd1 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityController.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityController.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.DistributedSystemConfig; -import com.gemstone.gemfire.admin.ManagedEntity; -import com.gemstone.gemfire.admin.ManagedEntityConfig; +import org.apache.geode.admin.DistributedSystemConfig; +import org.apache.geode.admin.ManagedEntity; +import org.apache.geode.admin.ManagedEntityConfig; /** * Defines the actual administration (starting, stopping, etc.) of http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityControllerFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityControllerFactory.java b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityControllerFactory.java index c745835..372b2ed 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityControllerFactory.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedEntityControllerFactory.java @@ -14,15 +14,15 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.admin.AdminDistributedSystem; -import com.gemstone.gemfire.admin.ManagedEntity; -import com.gemstone.gemfire.internal.ClassPathLoader; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LogMarker; +import org.apache.geode.admin.AdminDistributedSystem; +import org.apache.geode.admin.ManagedEntity; +import org.apache.geode.internal.ClassPathLoader; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LogMarker; /** * Creates ManagedEntityController for administration (starting, stopping, etc.) @@ -33,7 +33,7 @@ public class ManagedEntityControllerFactory { private static final Logger logger = LogService.getLogger(); - private static final String ENABLED_MANAGED_ENTITY_CONTROLLER_CLASS_NAME = "com.gemstone.gemfire.admin.internal.EnabledManagedEntityController"; + private static final String ENABLED_MANAGED_ENTITY_CONTROLLER_CLASS_NAME = "org.apache.geode.admin.internal.EnabledManagedEntityController"; static ManagedEntityController createManagedEntityController(final AdminDistributedSystem system) { if (isEnabledManagedEntityController()) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedSystemMemberImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedSystemMemberImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedSystemMemberImpl.java index e0ba1bb..f6ca2cc 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedSystemMemberImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/ManagedSystemMemberImpl.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.AdminException; -import com.gemstone.gemfire.admin.ConfigurationParameter; -import com.gemstone.gemfire.admin.ManagedEntityConfig; -import com.gemstone.gemfire.internal.admin.GemFireVM; +import org.apache.geode.admin.AdminException; +import org.apache.geode.admin.ConfigurationParameter; +import org.apache.geode.admin.ManagedEntityConfig; +import org.apache.geode.internal.admin.GemFireVM; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.LOCATORS; +import static org.apache.geode.distributed.ConfigurationProperties.LOCATORS; /** * A <code>SystemMember</code> that is also managed (or manageable) by http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/MemberHealthConfigImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/MemberHealthConfigImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/MemberHealthConfigImpl.java index 08fd5a0..e58e975 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/MemberHealthConfigImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/MemberHealthConfigImpl.java @@ -14,12 +14,12 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.*; +import org.apache.geode.admin.*; // @todo Make this class (and all of its subclasses) {@link java.io.Externalizable} or -// {@link com.gemstone.gemfire.DataSerializable}. +// {@link org.apache.geode.DataSerializable}. /** * The implementation of <code>MemberHealthConfig</code> * http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/MemberHealthEvaluator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/MemberHealthEvaluator.java b/geode-core/src/main/java/org/apache/geode/admin/internal/MemberHealthEvaluator.java index 5344724..6c76f69 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/MemberHealthEvaluator.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/MemberHealthEvaluator.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; - -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.cache.CacheFactory; -import com.gemstone.gemfire.distributed.internal.*; -import com.gemstone.gemfire.internal.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.cache.CachePerfStats; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.statistics.GemFireStatSampler; -import com.gemstone.gemfire.internal.statistics.platform.ProcessStats; +package org.apache.geode.admin.internal; + +import org.apache.geode.CancelException; +import org.apache.geode.admin.*; +import org.apache.geode.cache.CacheFactory; +import org.apache.geode.distributed.internal.*; +import org.apache.geode.internal.*; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.cache.CachePerfStats; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.statistics.GemFireStatSampler; +import org.apache.geode.internal.statistics.platform.ProcessStats; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupRequest.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupRequest.java b/geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupRequest.java index 482dac8..f90a8e7 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupRequest.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupRequest.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; import java.io.IOException; import java.util.Collection; @@ -26,22 +26,22 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.cache.persistence.PersistentID; -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.internal.admin.remote.AdminFailureResponse; -import com.gemstone.gemfire.internal.admin.remote.AdminMultipleReplyProcessor; -import com.gemstone.gemfire.internal.admin.remote.AdminResponse; -import com.gemstone.gemfire.internal.admin.remote.CliLegacyMessage; -import com.gemstone.gemfire.internal.cache.GemFireCacheImpl; -import com.gemstone.gemfire.internal.cache.persistence.BackupManager; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; -import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage; +import org.apache.geode.CancelException; +import org.apache.geode.cache.persistence.PersistentID; +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.internal.admin.remote.AdminFailureResponse; +import org.apache.geode.internal.admin.remote.AdminMultipleReplyProcessor; +import org.apache.geode.internal.admin.remote.AdminResponse; +import org.apache.geode.internal.admin.remote.CliLegacyMessage; +import org.apache.geode.internal.cache.GemFireCacheImpl; +import org.apache.geode.internal.cache.persistence.BackupManager; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; +import org.apache.geode.internal.logging.log4j.LocalizedMessage; /** * A request to from an admin VM to all non admin members http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupResponse.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupResponse.java b/geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupResponse.java index 41f0b51..4368cce 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupResponse.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/PrepareBackupResponse.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.util.HashSet; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.cache.persistence.PersistentID; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.admin.remote.AdminResponse; +import org.apache.geode.DataSerializer; +import org.apache.geode.cache.persistence.PersistentID; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.admin.remote.AdminResponse; /** * The response to the {@link PrepareBackupRequest} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/StatisticImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/StatisticImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/StatisticImpl.java index 8ab39eb..987bdfa 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/StatisticImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/StatisticImpl.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.internal.admin.Stat; +import org.apache.geode.internal.admin.Stat; /** * Implementation of a single statistic in a <code>StatisticResource</code> @@ -26,7 +26,7 @@ import com.gemstone.gemfire.internal.admin.Stat; * */ public class StatisticImpl -implements com.gemstone.gemfire.admin.Statistic { +implements org.apache.geode.admin.Statistic { private static final long serialVersionUID = 3899296873901634399L; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/StatisticResourceImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/StatisticResourceImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/StatisticResourceImpl.java index e8054d0..9458759 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/StatisticResourceImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/StatisticResourceImpl.java @@ -14,16 +14,16 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.AdminException; -import com.gemstone.gemfire.admin.SystemMember; -import com.gemstone.gemfire.admin.Statistic; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.admin.Stat; -import com.gemstone.gemfire.internal.admin.StatResource; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -//import com.gemstone.gemfire.internal.admin.SystemMember; +import org.apache.geode.admin.AdminException; +import org.apache.geode.admin.SystemMember; +import org.apache.geode.admin.Statistic; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.admin.Stat; +import org.apache.geode.internal.admin.StatResource; +import org.apache.geode.internal.i18n.LocalizedStrings; +//import org.apache.geode.internal.admin.SystemMember; import java.util.ArrayList; //import java.util.Date; @@ -35,7 +35,7 @@ import java.util.List; * @since GemFire 3.5 */ public class StatisticResourceImpl -implements com.gemstone.gemfire.admin.StatisticResource { +implements org.apache.geode.admin.StatisticResource { /** The underlying remote StatResource which this object delegates to */ protected StatResource statResource; @@ -59,12 +59,12 @@ implements com.gemstone.gemfire.admin.StatisticResource { * * @param statResource the admin StatResource to manage/monitor * @param member the SystemMember owning this resource - * @exception com.gemstone.gemfire.admin.AdminException + * @exception org.apache.geode.admin.AdminException * if unable to create this StatisticResource for administration */ public StatisticResourceImpl(StatResource statResource, SystemMember member) - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { this.statResource = statResource; this.member = member; this.name = this.statResource.getName(); @@ -112,7 +112,7 @@ implements com.gemstone.gemfire.admin.StatisticResource { // Operations // ------------------------------------------------------------------------- - public void refresh() throws com.gemstone.gemfire.admin.AdminException { + public void refresh() throws org.apache.geode.admin.AdminException { Stat[] stats = null; if (this.statResource != null) { stats = this.statResource.getStats(); @@ -143,7 +143,7 @@ implements com.gemstone.gemfire.admin.StatisticResource { /** * Updates the value of the {@link Statistic} corresponding to the internal - * {@link com.gemstone.gemfire.internal.admin.Stat} + * {@link org.apache.geode.internal.admin.Stat} * * @param stat the internal stat to use in updating the matching statistic */ @@ -159,7 +159,7 @@ implements com.gemstone.gemfire.admin.StatisticResource { /** * Creates a new {@link StatisticImpl} to represent the internal {@link - * com.gemstone.gemfire.internal.admin.Stat} + * org.apache.geode.internal.admin.Stat} * * @param stat the internal stat to wrap in a new statistic */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberBridgeServerImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberBridgeServerImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberBridgeServerImpl.java index 0c7e941..546983c 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberBridgeServerImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberBridgeServerImpl.java @@ -14,17 +14,17 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; import java.io.Serializable; -import com.gemstone.gemfire.InternalGemFireException; -import com.gemstone.gemfire.admin.AdminException; -import com.gemstone.gemfire.admin.SystemMemberBridgeServer; -import com.gemstone.gemfire.admin.SystemMemberCacheServer; -import com.gemstone.gemfire.cache.server.ServerLoadProbe; -import com.gemstone.gemfire.internal.admin.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.InternalGemFireException; +import org.apache.geode.admin.AdminException; +import org.apache.geode.admin.SystemMemberBridgeServer; +import org.apache.geode.admin.SystemMemberCacheServer; +import org.apache.geode.cache.server.ServerLoadProbe; +import org.apache.geode.internal.admin.*; +import org.apache.geode.internal.i18n.LocalizedStrings; /** * Implementation of an object used for managing cache servers. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventImpl.java index 9907234..e4f7e60 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventImpl.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.cache.Operation; +import org.apache.geode.admin.*; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.cache.Operation; /** * An event that describes an operation on a cache. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventProcessor.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventProcessor.java b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventProcessor.java index df3d83e..43f9b89 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventProcessor.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheEventProcessor.java @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; import java.io.DataInput; import java.io.DataOutput; @@ -25,17 +25,17 @@ import java.util.Set; import org.apache.logging.log4j.Logger; -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.admin.SystemMemberCacheEvent; -import com.gemstone.gemfire.admin.SystemMemberCacheListener; -import com.gemstone.gemfire.admin.SystemMemberRegionEvent; -import com.gemstone.gemfire.cache.Cache; -import com.gemstone.gemfire.cache.Operation; -import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.distributed.internal.DistributionManager; -import com.gemstone.gemfire.distributed.internal.HighPriorityDistributionMessage; -import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem; -import com.gemstone.gemfire.internal.logging.LogService; +import org.apache.geode.DataSerializer; +import org.apache.geode.admin.SystemMemberCacheEvent; +import org.apache.geode.admin.SystemMemberCacheListener; +import org.apache.geode.admin.SystemMemberRegionEvent; +import org.apache.geode.cache.Cache; +import org.apache.geode.cache.Operation; +import org.apache.geode.cache.Region; +import org.apache.geode.distributed.internal.DistributionManager; +import org.apache.geode.distributed.internal.HighPriorityDistributionMessage; +import org.apache.geode.distributed.internal.InternalDistributedSystem; +import org.apache.geode.internal.logging.LogService; /** * This class processes the message to be delivered to admin node. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheImpl.java index ec7650c..7c1ba71 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberCacheImpl.java @@ -14,14 +14,14 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.cache.*; -import com.gemstone.gemfire.internal.Assert; -import com.gemstone.gemfire.internal.ObjIdMap; -import com.gemstone.gemfire.internal.admin.*; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; +import org.apache.geode.admin.*; +import org.apache.geode.cache.*; +import org.apache.geode.internal.Assert; +import org.apache.geode.internal.ObjIdMap; +import org.apache.geode.internal.admin.*; +import org.apache.geode.internal.i18n.LocalizedStrings; import java.util.*; @@ -136,7 +136,7 @@ public class SystemMemberCacheImpl implements SystemMemberCache { } public SystemMemberRegion getRegion(String path) - throws com.gemstone.gemfire.admin.AdminException + throws org.apache.geode.admin.AdminException { Region r = this.vm.getRegion(this.info, path); if (r == null) { @@ -234,7 +234,7 @@ public class SystemMemberCacheImpl implements SystemMemberCache { return new StatisticImpl(stat); } protected SystemMemberRegion createSystemMemberRegion(Region r) - throws com.gemstone.gemfire.admin.AdminException + throws org.apache.geode.admin.AdminException { SystemMemberRegionImpl sysMemberRegion = new SystemMemberRegionImpl(this, r); sysMemberRegion.refresh(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberImpl.java index 5bd8e5b..57db801 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberImpl.java @@ -14,22 +14,22 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; - -import com.gemstone.gemfire.CancelException; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.distributed.Role; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -import com.gemstone.gemfire.distributed.internal.DistributionConfigImpl; -import com.gemstone.gemfire.distributed.internal.membership.InternalDistributedMember; -import com.gemstone.gemfire.internal.Config; -import com.gemstone.gemfire.internal.ConfigSource; -import com.gemstone.gemfire.internal.admin.GemFireVM; -import com.gemstone.gemfire.internal.admin.StatResource; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.logging.LogService; +package org.apache.geode.admin.internal; + +import org.apache.geode.CancelException; +import org.apache.geode.SystemFailure; +import org.apache.geode.admin.*; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.distributed.Role; +import org.apache.geode.distributed.internal.DistributionConfig; +import org.apache.geode.distributed.internal.DistributionConfigImpl; +import org.apache.geode.distributed.internal.membership.InternalDistributedMember; +import org.apache.geode.internal.Config; +import org.apache.geode.internal.ConfigSource; +import org.apache.geode.internal.admin.GemFireVM; +import org.apache.geode.internal.admin.StatResource; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.logging.LogService; import org.apache.logging.log4j.Logger; import java.net.InetAddress; @@ -41,8 +41,8 @@ import java.util.*; * @since GemFire 3.5 */ public class SystemMemberImpl -implements com.gemstone.gemfire.admin.SystemMember, - com.gemstone.gemfire.admin.internal.ConfigurationParameterListener { +implements org.apache.geode.admin.SystemMember, + org.apache.geode.admin.internal.ConfigurationParameterListener { private static final Logger logger = LogService.getLogger(); @@ -209,7 +209,7 @@ implements com.gemstone.gemfire.admin.SystemMember, } public StatisticResource[] getStat(String statisticsTypeName) - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { StatisticResource[] res = new StatisticResource[0]; if (this.vm != null) { res = getStatsImpl(this.vm.getStats(statisticsTypeName)); @@ -218,7 +218,7 @@ implements com.gemstone.gemfire.admin.SystemMember, } public StatisticResource[] getStats() - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { StatisticResource[] statsImpl = new StatisticResource[0]; if (this.vm != null) { statsImpl = getStatsImpl(this.vm.getStats(null)); @@ -237,7 +237,7 @@ implements com.gemstone.gemfire.admin.SystemMember, } public final SystemMemberCache getCache() - throws com.gemstone.gemfire.admin.AdminException + throws org.apache.geode.admin.AdminException { GemFireVM vm = getGemFireVM(); // fix for bug 33505 if (vm == null) return null; @@ -253,7 +253,7 @@ implements com.gemstone.gemfire.admin.SystemMember, } public void refreshConfig() - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { GemFireVM vm = getGemFireVM(); if (vm == null) return; refreshConfig(vm.getConfig()); @@ -264,7 +264,7 @@ implements com.gemstone.gemfire.admin.SystemMember, * configuration based on the given <code>Config</code> object. */ public final void refreshConfig(Config config) - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { if (config == null) { throw new AdminException(LocalizedStrings.SystemMemberImpl_FAILED_TO_REFRESH_CONFIGURATION_PARAMETERS_FOR_0.toLocalizedString(new Object[] {getId()})); } @@ -327,11 +327,11 @@ implements com.gemstone.gemfire.admin.SystemMember, // Listener callbacks // ------------------------------------------------------------------------- - // -- com.gemstone.gemfire.admin.internal.ConfigurationParameterListener --- + // -- org.apache.geode.admin.internal.ConfigurationParameterListener --- public void configurationParameterValueChanged(ConfigurationParameter parm) { try { setConfiguration(new ConfigurationParameter[] { parm }); - } catch (com.gemstone.gemfire.admin.AdminException e) { + } catch (org.apache.geode.admin.AdminException e) { // this shouldn't occur since this is a config listener method... logger.warn(e.getMessage(), e); throw new RuntimeAdminException(e); @@ -442,7 +442,7 @@ implements com.gemstone.gemfire.admin.SystemMember, * @return new impl instance of {@link StatisticResource} */ protected StatisticResource createStatisticResource(StatResource stat) - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { return new StatisticResourceImpl(stat, this); } @@ -472,14 +472,14 @@ implements com.gemstone.gemfire.admin.SystemMember, * @return new impl instance of {@link SystemMemberCache} */ protected SystemMemberCache createSystemMemberCache(GemFireVM vm) - throws com.gemstone.gemfire.admin.AdminException + throws org.apache.geode.admin.AdminException { return new SystemMemberCacheImpl(vm); } /** Wrap the internal stats with impls of {@link StatisticResource} */ protected StatisticResource[] getStatsImpl(StatResource[] stats) - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { List statList = new ArrayList(); for (int i = 0; i < stats.length; i++) { statList.add(createStatisticResource(stats[i])); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberRegionEventImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberRegionEventImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberRegionEventImpl.java index 931d67a..c59e049 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberRegionEventImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberRegionEventImpl.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.distributed.DistributedMember; -import com.gemstone.gemfire.cache.Operation; +import org.apache.geode.admin.*; +import org.apache.geode.distributed.DistributedMember; +import org.apache.geode.cache.Operation; /** * An event that describes an operation on a region. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberRegionImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberRegionImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberRegionImpl.java index c1655f5..9e8f392 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberRegionImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMemberRegionImpl.java @@ -14,13 +14,13 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.cache.*; -//import com.gemstone.gemfire.internal.Assert; -//import com.gemstone.gemfire.internal.admin.*; -import com.gemstone.gemfire.internal.admin.remote.*; +import org.apache.geode.admin.*; +import org.apache.geode.cache.*; +//import org.apache.geode.internal.Assert; +//import org.apache.geode.internal.admin.*; +import org.apache.geode.internal.admin.remote.*; import java.io.File; import java.util.*; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMembershipEventImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMembershipEventImpl.java b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMembershipEventImpl.java index ebc5270..6ec9e94 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMembershipEventImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/SystemMembershipEventImpl.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.internal; +package org.apache.geode.admin.internal; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.distributed.DistributedMember; +import org.apache.geode.admin.*; +import org.apache.geode.distributed.DistributedMember; /** * An event delivered to a {@link SystemMembershipListener} when a http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/internal/package.html ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/internal/package.html b/geode-core/src/main/java/org/apache/geode/admin/internal/package.html index a233ec5..38f9174 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/internal/package.html +++ b/geode-core/src/main/java/org/apache/geode/admin/internal/package.html @@ -18,28 +18,28 @@ limitations under the License. <BODY> <P>Contains the implementation of the external admin APIs from -<a href="{@docRoot}/com/gemstone/gemfire/admin/package-summary.html#package_description">com.gemstone.gemfire.admin</a>.</P> +<a href="{@docRoot}/org/apache/geode/admin/package-summary.html#package_description">org.apache.geode.admin</a>.</P> <H2>Monitoring the "health" of GemFire</H2> <P>The health monitoring implementation comes in two pieces. On the client (administrator) side there is a {@link -com.gemstone.gemfire.admin.internal.GemFireHealthImpl} object that is +org.apache.geode.admin.internal.GemFireHealthImpl} object that is responsible for configuring a {@link -com.gemstone.gemfire.distributed.internal.HealthMonitorImpl} that runs +org.apache.geode.distributed.internal.HealthMonitorImpl} that runs in the member VMs. The communication between the administration process and the member process is accomplised via a {@link -com.gemstone.gemfire.internal.admin.GemFireVM GemFireVM} from the +org.apache.geode.internal.admin.GemFireVM GemFireVM} from the "internal admin" API. The <code>HealthMonitorImpl</code> is a thread that periodically consults a {@link -com.gemstone.gemfire.admin.internal.GemFireHealthEvaluator} that uses -a {@link com.gemstone.gemfire.admin.internal.GemFireHealthConfigImpl} +org.apache.geode.admin.internal.GemFireHealthEvaluator} that uses +a {@link org.apache.geode.admin.internal.GemFireHealthConfigImpl} to determine the health of a GemFire component. Most of the health -criteria are based on {@linkplain com.gemstone.gemfire.Statistics +criteria are based on {@linkplain org.apache.geode.Statistics statistics} that are maintained by GemFire. When the <code>HealthMonitorImpl</code> determines that the health of a GemFire component has changed, it alerts the administrator process via a -{@link com.gemstone.gemfire.internal.admin.HealthListener}.</P> +{@link org.apache.geode.internal.admin.HealthListener}.</P> <P>The below diagram explains how the classes that monitor the health http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/jmx/Agent.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/jmx/Agent.java b/geode-core/src/main/java/org/apache/geode/admin/jmx/Agent.java index f4139eb..9daa866 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/jmx/Agent.java +++ b/geode-core/src/main/java/org/apache/geode/admin/jmx/Agent.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.jmx; +package org.apache.geode.admin.jmx; -import com.gemstone.gemfire.LogWriter; -import com.gemstone.gemfire.admin.AdminException; -import com.gemstone.gemfire.admin.AdminDistributedSystem; +import org.apache.geode.LogWriter; +import org.apache.geode.admin.AdminException; +import org.apache.geode.admin.AdminDistributedSystem; //import javax.management.MBeanException; import javax.management.MalformedObjectNameException; @@ -67,7 +67,7 @@ import javax.management.ObjectName; * @see AgentFactory * * @since GemFire 4.0 - * @deprecated as of 7.0 use the <code><a href="{@docRoot}/com/gemstone/gemfire/management/package-summary.html">management</a></code> package instead + * @deprecated as of 7.0 use the <code><a href="{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> package instead */ public interface Agent { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/jmx/AgentConfig.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/jmx/AgentConfig.java b/geode-core/src/main/java/org/apache/geode/admin/jmx/AgentConfig.java index 9bb4c25..b2f04c8 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/jmx/AgentConfig.java +++ b/geode-core/src/main/java/org/apache/geode/admin/jmx/AgentConfig.java @@ -14,11 +14,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.jmx; +package org.apache.geode.admin.jmx; -import com.gemstone.gemfire.admin.DistributedSystemConfig; -import com.gemstone.gemfire.distributed.internal.DistributionConfig; -//import com.gemstone.gemfire.admin.internal.InetAddressUtil; +import org.apache.geode.admin.DistributedSystemConfig; +import org.apache.geode.distributed.internal.DistributionConfig; +//import org.apache.geode.admin.internal.InetAddressUtil; /** * A configuration object for a JMX administration {@linkplain Agent @@ -274,7 +274,7 @@ import com.gemstone.gemfire.distributed.internal.DistributionConfig; * * * @since GemFire 4.0 - * @deprecated as of 7.0 use the <code><a href="{@docRoot}/com/gemstone/gemfire/management/package-summary.html">management</a></code> package instead + * @deprecated as of 7.0 use the <code><a href="{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> package instead */ public interface AgentConfig extends DistributedSystemConfig { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/jmx/AgentFactory.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/jmx/AgentFactory.java b/geode-core/src/main/java/org/apache/geode/admin/jmx/AgentFactory.java index 72a7ba6..69bae36 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/jmx/AgentFactory.java +++ b/geode-core/src/main/java/org/apache/geode/admin/jmx/AgentFactory.java @@ -14,18 +14,18 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.jmx; +package org.apache.geode.admin.jmx; -//import com.gemstone.gemfire.admin.AdminDistributedSystem; -import com.gemstone.gemfire.admin.AdminException; -import com.gemstone.gemfire.admin.jmx.internal.AgentConfigImpl; -import com.gemstone.gemfire.admin.jmx.internal.AgentImpl; +//import org.apache.geode.admin.AdminDistributedSystem; +import org.apache.geode.admin.AdminException; +import org.apache.geode.admin.jmx.internal.AgentConfigImpl; +import org.apache.geode.admin.jmx.internal.AgentImpl; /** * A factory class that creates JMX administration entities. * * @since GemFire 4.0 - * @deprecated as of 7.0 use the <code><a href="{@docRoot}/com/gemstone/gemfire/management/package-summary.html">management</a></code> package instead + * @deprecated as of 7.0 use the <code><a href="{@docRoot}/org/apache/geode/management/package-summary.html">management</a></code> package instead */ public class AgentFactory { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AdminDistributedSystemJmxImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AdminDistributedSystemJmxImpl.java b/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AdminDistributedSystemJmxImpl.java index fa5a1ea..5ff4bfa 100755 --- a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AdminDistributedSystemJmxImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AdminDistributedSystemJmxImpl.java @@ -14,27 +14,27 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.jmx.internal; - -import com.gemstone.gemfire.DataSerializer; -import com.gemstone.gemfire.SystemFailure; -import com.gemstone.gemfire.admin.*; -import com.gemstone.gemfire.admin.internal.AdminDistributedSystemImpl; -import com.gemstone.gemfire.admin.internal.CacheServerConfigImpl; -import com.gemstone.gemfire.admin.internal.DistributionLocatorImpl; -import com.gemstone.gemfire.cache.persistence.PersistentID; -import com.gemstone.gemfire.distributed.DistributedMember; -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.internal.Assert; -import com.gemstone.gemfire.internal.admin.Alert; -import com.gemstone.gemfire.internal.admin.*; -import com.gemstone.gemfire.internal.admin.remote.UpdateAlertDefinitionMessage; -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.log4j.LocalizedMessage; +package org.apache.geode.admin.jmx.internal; + +import org.apache.geode.DataSerializer; +import org.apache.geode.SystemFailure; +import org.apache.geode.admin.*; +import org.apache.geode.admin.internal.AdminDistributedSystemImpl; +import org.apache.geode.admin.internal.CacheServerConfigImpl; +import org.apache.geode.admin.internal.DistributionLocatorImpl; +import org.apache.geode.cache.persistence.PersistentID; +import org.apache.geode.distributed.DistributedMember; +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.internal.Assert; +import org.apache.geode.internal.admin.Alert; +import org.apache.geode.internal.admin.*; +import org.apache.geode.internal.admin.remote.UpdateAlertDefinitionMessage; +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.log4j.LocalizedMessage; import org.apache.logging.log4j.Logger; import javax.management.*; @@ -98,7 +98,7 @@ public class AdminDistributedSystemJmxImpl * configuration defining the JMX agent. */ public AdminDistributedSystemJmxImpl(AgentConfigImpl config) - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { super(config); this.mbeanName = "GemFire:type=AdminDistributedSystem,id=" + MBeanUtil.makeCompliantMBeanNameProperty(getId()); @@ -147,7 +147,7 @@ public class AdminDistributedSystemJmxImpl /** * Registers the MBeans for monitoring the health of GemFire * - * @see com.gemstone.gemfire.admin.internal.AdminDistributedSystemImpl#getGemFireHealth + * @see org.apache.geode.admin.internal.AdminDistributedSystemImpl#getGemFireHealth */ public ObjectName monitorGemFireHealth() throws MalformedObjectNameException { GemFireHealthJmxImpl health = (GemFireHealthJmxImpl) getGemFireHealth(); @@ -234,7 +234,7 @@ public class AdminDistributedSystemJmxImpl /** Override createSystemMember by instantiating SystemMemberJmxImpl */ @Override protected SystemMember createSystemMember(ApplicationVM app) - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { return new SystemMemberJmxImpl(this, app); } @@ -246,13 +246,13 @@ public class AdminDistributedSystemJmxImpl * InternalDistributedMember instance for which a SystemMember * instance is to be constructed. * @return constructed SystemMember instance - * @throws com.gemstone.gemfire.admin.AdminException + * @throws org.apache.geode.admin.AdminException * if construction of SystemMember instance fails * * @since GemFire 6.5 */ protected SystemMember createSystemMember(InternalDistributedMember member) - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { return new SystemMemberJmxImpl(this, member); } @@ -274,7 +274,7 @@ public class AdminDistributedSystemJmxImpl /** Override createGemFireHealth by instantiating GemFireHealthJmxImpl */ @Override protected GemFireHealth createGemFireHealth(GfManagerAgent system) - throws com.gemstone.gemfire.admin.AdminException { + throws org.apache.geode.admin.AdminException { if (system == null) { throw new IllegalStateException(LocalizedStrings.AdminDistributedSystemJmxImpl_GFMANAGERAGENT_MUST_NOT_BE_NULL.toLocalizedString()); } @@ -316,7 +316,7 @@ public class AdminDistributedSystemJmxImpl private static final String EML_SUBJ_PRFX_GFE_NOTFY = "[GemFire Notification] "; private static final String EML_SUBJ_ITEM_GFE_DS = "Distributed System: "; - // --------- com.gemstone.gemfire.internal.admin.JoinLeaveListener --------- + // --------- org.apache.geode.internal.admin.JoinLeaveListener --------- /** * Listener callback for when a member has joined this DistributedSystem. * <p> @@ -325,7 +325,7 @@ public class AdminDistributedSystemJmxImpl * * @param source the distributed system that fired nodeJoined * @param joined the VM that joined - * @see com.gemstone.gemfire.internal.admin.JoinLeaveListener#nodeJoined + * @see org.apache.geode.internal.admin.JoinLeaveListener#nodeJoined */ @Override public void nodeJoined(GfManagerAgent source, GemFireVM joined) { @@ -397,7 +397,7 @@ public class AdminDistributedSystemJmxImpl * * @param source the distributed system that fired nodeLeft * @param left the VM that left - * @see com.gemstone.gemfire.internal.admin.JoinLeaveListener#nodeLeft + * @see org.apache.geode.internal.admin.JoinLeaveListener#nodeLeft */ @Override public void nodeLeft(GfManagerAgent source, GemFireVM left) { @@ -459,7 +459,7 @@ public class AdminDistributedSystemJmxImpl * * @param source the distributed system that fired nodeCrashed * @param crashed the VM that crashed - * @see com.gemstone.gemfire.internal.admin.JoinLeaveListener#nodeCrashed + * @see org.apache.geode.internal.admin.JoinLeaveListener#nodeCrashed */ @Override public void nodeCrashed(GfManagerAgent source, GemFireVM crashed) { @@ -516,7 +516,7 @@ public class AdminDistributedSystemJmxImpl } } - // ----------- com.gemstone.gemfire.internal.admin.AlertListener ----------- + // ----------- org.apache.geode.internal.admin.AlertListener ----------- /** * Listener callback for when a SystemMember of this DistributedSystem has * crashed. @@ -524,7 +524,7 @@ public class AdminDistributedSystemJmxImpl * Fires a Notification with the information from the alert. * * @param alert the gemfire alert to broadcast as a notification - * @see com.gemstone.gemfire.internal.admin.AlertListener#alert + * @see org.apache.geode.internal.admin.AlertListener#alert */ @Override public void alert(Alert alert) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/7171cec4/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AgentConfigImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AgentConfigImpl.java b/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AgentConfigImpl.java index 6aa8944..07a95df 100644 --- a/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AgentConfigImpl.java +++ b/geode-core/src/main/java/org/apache/geode/admin/jmx/internal/AgentConfigImpl.java @@ -14,10 +14,10 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.gemstone.gemfire.admin.jmx.internal; +package org.apache.geode.admin.jmx.internal; -import static com.gemstone.gemfire.distributed.ConfigurationProperties.*; -import static com.gemstone.gemfire.distributed.internal.DistributionConfig.*; +import static org.apache.geode.distributed.ConfigurationProperties.*; +import static org.apache.geode.distributed.internal.DistributionConfig.*; import java.io.File; import java.io.FileInputStream; @@ -32,16 +32,16 @@ import java.util.Iterator; import java.util.Properties; import java.util.StringTokenizer; -import com.gemstone.gemfire.GemFireIOException; -import com.gemstone.gemfire.admin.DistributedSystemConfig; -import com.gemstone.gemfire.admin.DistributionLocatorConfig; -import com.gemstone.gemfire.admin.internal.DistributedSystemConfigImpl; -import com.gemstone.gemfire.admin.internal.InetAddressUtil; -import com.gemstone.gemfire.admin.jmx.Agent; -import com.gemstone.gemfire.admin.jmx.AgentConfig; -import com.gemstone.gemfire.internal.ClassPathLoader; -import com.gemstone.gemfire.internal.i18n.LocalizedStrings; -import com.gemstone.gemfire.internal.util.IOUtils; +import org.apache.geode.GemFireIOException; +import org.apache.geode.admin.DistributedSystemConfig; +import org.apache.geode.admin.DistributionLocatorConfig; +import org.apache.geode.admin.internal.DistributedSystemConfigImpl; +import org.apache.geode.admin.internal.InetAddressUtil; +import org.apache.geode.admin.jmx.Agent; +import org.apache.geode.admin.jmx.AgentConfig; +import org.apache.geode.internal.ClassPathLoader; +import org.apache.geode.internal.i18n.LocalizedStrings; +import org.apache.geode.internal.util.IOUtils; /** * Provides the JMX Agent configuration properties. @@ -1364,7 +1364,7 @@ public class AgentConfigImpl extends DistributedSystemConfigImpl implements Agen /** * Returns {@link - * com.gemstone.gemfire.admin.jmx.AgentConfig#DEFAULT_HTTP_PORT} + * org.apache.geode.admin.jmx.AgentConfig#DEFAULT_HTTP_PORT} * if httpPort is empty; else validates * that it's an integer and returns the int form. */ @@ -1378,8 +1378,8 @@ public class AgentConfigImpl extends DistributedSystemConfigImpl implements Agen /** * Validates that httpPort is either zero or within the {@link - * com.gemstone.gemfire.admin.jmx.AgentConfig#MIN_HTTP_PORT} and {@link - * com.gemstone.gemfire.admin.jmx.AgentConfig#MAX_HTTP_PORT} values. + * org.apache.geode.admin.jmx.AgentConfig#MIN_HTTP_PORT} and {@link + * org.apache.geode.admin.jmx.AgentConfig#MAX_HTTP_PORT} values. */ private int validateHttpPort(int val) { if (val < 0 || val > MAX_HTTP_PORT) { @@ -1392,7 +1392,7 @@ public class AgentConfigImpl extends DistributedSystemConfigImpl implements Agen /** * Returns {@link - * com.gemstone.gemfire.admin.jmx.AgentConfig#DEFAULT_HTTP_BIND_ADDRESS} + * org.apache.geode.admin.jmx.AgentConfig#DEFAULT_HTTP_BIND_ADDRESS} * unless httpBindAddress can be used to * create a valid InetAddress. */ @@ -1419,7 +1419,7 @@ public class AgentConfigImpl extends DistributedSystemConfigImpl implements Agen /** * Returns {@link - * com.gemstone.gemfire.admin.jmx.AgentConfig#DEFAULT_SNMP_BIND_ADDRESS} + * org.apache.geode.admin.jmx.AgentConfig#DEFAULT_SNMP_BIND_ADDRESS} * unless snmpBindAddress can be used to * create a valid InetAddress. */ @@ -1461,7 +1461,7 @@ public class AgentConfigImpl extends DistributedSystemConfigImpl implements Agen // RMIConnectorServer property validators... /** - * Returns {@link com.gemstone.gemfire.admin.jmx.AgentConfig#DEFAULT_RMI_PORT} + * Returns {@link org.apache.geode.admin.jmx.AgentConfig#DEFAULT_RMI_PORT} * if rmiPort is empty; else validates * that it's an integer and returns the int form. */ @@ -1475,8 +1475,8 @@ public class AgentConfigImpl extends DistributedSystemConfigImpl implements Agen /** * Validates that rmiPort is either zero or within the {@link - * com.gemstone.gemfire.admin.jmx.AgentConfig#MIN_RMI_PORT} - * and {@link com.gemstone.gemfire.admin.jmx.AgentConfig#MAX_RMI_PORT} + * org.apache.geode.admin.jmx.AgentConfig#MIN_RMI_PORT} + * and {@link org.apache.geode.admin.jmx.AgentConfig#MAX_RMI_PORT} * values. */ private int validateRmiPort(int val) { @@ -1489,7 +1489,7 @@ public class AgentConfigImpl extends DistributedSystemConfigImpl implements Agen } /** - * Returns {@link com.gemstone.gemfire.admin.jmx.AgentConfig#DEFAULT_RMI_SERVER_PORT} + * Returns {@link org.apache.geode.admin.jmx.AgentConfig#DEFAULT_RMI_SERVER_PORT} * if rmi-server-port is empty; else validates that it's an integer within the * allowed range and returns the int form. */ @@ -1503,8 +1503,8 @@ public class AgentConfigImpl extends DistributedSystemConfigImpl implements Agen /** * Validates that rmiPort is either zero or within the {@link - * com.gemstone.gemfire.admin.jmx.AgentConfig#MIN_RMI_PORT} - * and {@link com.gemstone.gemfire.admin.jmx.AgentConfig#MAX_RMI_PORT} + * org.apache.geode.admin.jmx.AgentConfig#MIN_RMI_PORT} + * and {@link org.apache.geode.admin.jmx.AgentConfig#MAX_RMI_PORT} * values. */ private int validateRmiServerPort(int val) { @@ -1518,7 +1518,7 @@ public class AgentConfigImpl extends DistributedSystemConfigImpl implements Agen /** * Returns {@link - * com.gemstone.gemfire.admin.jmx.AgentConfig#DEFAULT_RMI_BIND_ADDRESS} + * org.apache.geode.admin.jmx.AgentConfig#DEFAULT_RMI_BIND_ADDRESS} * unless rmiBindAddress can be used to create a * valid InetAddress. */
