[47/50] [abbrv] incubator-geode git commit: GEODE-288: move admin packages to internal
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/b6c305f8/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java
--
diff --git a/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java
b/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java
deleted file mode 100755
index 81f4a38..000
--- a/geode-core/src/main/java/org/apache/geode/admin/CacheVmConfig.java
+++ /dev/null
@@ -1,51 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license
- * agreements. See the NOTICE file distributed with this work for additional
information regarding
- * copyright ownership. The ASF licenses this file to You under the Apache
License, Version 2.0 (the
- * "License"); you may not use this file except in compliance with the
License. You may obtain a
- * copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
distributed under the License
- * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express
- * or implied. See the License for the specific language governing permissions
and limitations under
- * the License.
- */
-package org.apache.geode.admin;
-
-/**
- * Configuration for a GemFire cache server VM that is managed by the
administration API. The VM may
- * or may not be running.
- *
- * @see AdminDistributedSystem#addCacheVm()
- *
- * @since GemFire 5.7
- * @deprecated as of 7.0 use the management
- * package instead
- */
-public interface CacheVmConfig extends ManagedEntityConfig {
- /**
- * Returns the cache.xml declarative caching initialization
file used to configure
- * this cache server VM. By default, a cache server VM is started without an
XML file.
- */
- public String getCacheXMLFile();
-
- /**
- * Sets the cache.xml declarative caching initialization file
used to configure this
- * cache server VM.
- */
- public void setCacheXMLFile(String cacheXml);
-
- /**
- * Returns the location(s) of user classes (such as cache loaders) required
by the cache server
- * VM.
- */
- public String getClassPath();
-
- /**
- * Sets the location(s) of user classes (such as cache loaders) required by
the cache server VM.
- */
- public void setClassPath(String classpath);
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/b6c305f8/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java
--
diff --git
a/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java
b/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java
deleted file mode 100755
index 74e1510..000
---
a/geode-core/src/main/java/org/apache/geode/admin/ConfigurationParameter.java
+++ /dev/null
@@ -1,72 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license
- * agreements. See the NOTICE file distributed with this work for additional
information regarding
- * copyright ownership. The ASF licenses this file to You under the Apache
License, Version 2.0 (the
- * "License"); you may not use this file except in compliance with the
License. You may obtain a
- * copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
distributed under the License
- * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express
- * or implied. See the License for the specific language governing permissions
and limitations under
- * the License.
- */
-
-package org.apache.geode.admin;
-
-/**
- * A single configuration parameter of a {@link SystemMember}.
- *
- * @since GemFire 3.5
- *
- * @deprecated as of 7.0 use the management
- * package instead
- */
-public interface ConfigurationParameter {
-
- /** Gets the identifying name of this configuration parameter. */
- public String getName();
-
- /** Gets the full description of this configuration parameter */
- public String getDescription();
-
- /** Gets the current value */
- public Object getValue();
-
- /** Gets the current value as a string */
- public String getValueAsString();
-
- /** Gets the class type of the value */
- public Class getValueType();
-
- /** True if this is modifiable; false if read-only */
- public boolean isModifiable();
-
- /** Returns true if this config parameter uses a string array for value. */
- public boolean isArray();
-
- /** Returns true if this config parameter represents an InetAddress value. */
- public boolean isInetAddress();
-
- /** Returns true if this config parameter represents a File value. */
- public boolean isFile();
-
- /** Returns true if this config parameter represents an octal value. */
-
[47/50] [abbrv] incubator-geode git commit: GEODE-288: move admin packages to internal
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6bb27bf1/geode-core/src/main/java/org/apache/geode/admin/RegionSubRegionSnapshot.java
--
diff --git
a/geode-core/src/main/java/org/apache/geode/admin/RegionSubRegionSnapshot.java
b/geode-core/src/main/java/org/apache/geode/admin/RegionSubRegionSnapshot.java
deleted file mode 100644
index 19f89b2..000
---
a/geode-core/src/main/java/org/apache/geode/admin/RegionSubRegionSnapshot.java
+++ /dev/null
@@ -1,183 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license
- * agreements. See the NOTICE file distributed with this work for additional
information regarding
- * copyright ownership. The ASF licenses this file to You under the Apache
License, Version 2.0 (the
- * "License"); you may not use this file except in compliance with the
License. You may obtain a
- * copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
distributed under the License
- * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express
- * or implied. See the License for the specific language governing permissions
and limitations under
- * the License.
- */
-package org.apache.geode.admin;
-
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.IOException;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.Set;
-
-import org.apache.geode.DataSerializable;
-import org.apache.geode.DataSerializer;
-import org.apache.geode.cache.Region;
-import org.apache.geode.i18n.LogWriterI18n;
-import org.apache.geode.internal.cache.PartitionedRegion;
-
-/**
- * Class RegionSubRegionSnapshot provides information about
Regions. This
- * also provides the information about sub regions This class is used by the
monitoring tool.
- *
- *
- * @since GemFire 5.7
- * @deprecated as of 7.0 use the management
- * package instead
- */
-public class RegionSubRegionSnapshot implements DataSerializable {
- private static final long serialVersionUID = -8052137675270041871L;
-
- public RegionSubRegionSnapshot() {
-this.parent = null;
-this.subRegionSnapshots = new HashSet();
- }
-
- public RegionSubRegionSnapshot(Region reg) {
-this();
-this.name = reg.getName();
-if (reg instanceof PartitionedRegion) {
- PartitionedRegion p_reg = (PartitionedRegion) reg;
- this.entryCount = p_reg.entryCount(true);
-} else {
- this.entryCount = reg.entrySet().size();
-}
-final LogWriterI18n logger = reg.getCache().getLoggerI18n();
-if ((logger != null) && logger.fineEnabled()) {
- logger.fine("RegionSubRegionSnapshot Region entry count =" +
this.entryCount + " for region ="
- + this.name);
-}
- }
-
- /**
- * add the snapshot of sub region
- *
- * @param snap snapshot of sub region
- * @return true if operation is successful
- */
- public boolean addSubRegion(RegionSubRegionSnapshot snap) {
-if (subRegionSnapshots.contains(snap)) {
- return true;
-}
-
-if (subRegionSnapshots.add(snap)) {
- snap.setParent(this);
- return true;
-}
-
-return false;
- }
-
- /**
- * @return get entry count of region
- */
- public final int getEntryCount() {
-return entryCount;
- }
-
- /**
- * @param entryCount entry count of region
- */
- public final void setEntryCount(int entryCount) {
-this.entryCount = entryCount;
- }
-
- /**
- * @return name of region
- */
- public final String getName() {
-return name;
- }
-
- /**
- * @param name name of region
- */
- public final void setName(String name) {
-this.name = name;
- }
-
- /**
- * @return subRegionSnapshots of all the sub regions
- */
- public final Set getSubRegionSnapshots() {
-return subRegionSnapshots;
- }
-
- /**
- * @param subRegionSnapshots subRegionSnapshots of all the sub regions
- */
- public final void setSubRegionSnapshots(Set subRegionSnapshots) {
-this.subRegionSnapshots = subRegionSnapshots;
- }
-
- /**
- * @return snapshot of parent region
- */
- public final RegionSubRegionSnapshot getParent() {
-return parent;
- }
-
- /**
- * @param parent snapshot of parent region
- */
- public final void setParent(RegionSubRegionSnapshot parent) {
-this.parent = parent;
- }
-
- /**
- *
- * @return full path of region
- */
- public String getFullPath() {
-return (getParent() == null ? "/" : getParent().getFullPath()) + getName()
+ "/";
- }
-
- public void toData(DataOutput out) throws IOException {
-DataSerializer.writeString(this.name, out);
-out.writeInt(this.entryCount);
-DataSerializer.writeHashSet((HashSet) this.subRegionSnapshots, out);
- }
-
- public void fromData(DataInput in) throws IOException,
ClassNotFoundException {
-this.name =
[47/50] [abbrv] incubator-geode git commit: GEODE-288: move admin packages to internal
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/20a32286/geode-core/src/main/java/org/apache/geode/admin/internal/AdminDistributedSystemImpl.java
--
diff --git
a/geode-core/src/main/java/org/apache/geode/admin/internal/AdminDistributedSystemImpl.java
b/geode-core/src/main/java/org/apache/geode/admin/internal/AdminDistributedSystemImpl.java
deleted file mode 100755
index 59fce55..000
---
a/geode-core/src/main/java/org/apache/geode/admin/internal/AdminDistributedSystemImpl.java
+++ /dev/null
@@ -1,2400 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license
- * agreements. See the NOTICE file distributed with this work for additional
information regarding
- * copyright ownership. The ASF licenses this file to You under the Apache
License, Version 2.0 (the
- * "License"); you may not use this file except in compliance with the
License. You may obtain a
- * copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
distributed under the License
- * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express
- * or implied. See the License for the specific language governing permissions
and limitations under
- * the License.
- */
-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.admin.Alert;
-import org.apache.geode.admin.AlertListener;
-import org.apache.geode.cache.persistence.PersistentID;
-import org.apache.geode.distributed.DistributedMember;
-import org.apache.geode.distributed.FutureCancelledException;
-import org.apache.geode.distributed.internal.*;
-import
org.apache.geode.distributed.internal.membership.InternalDistributedMember;
-import org.apache.geode.internal.Assert;
-import org.apache.geode.internal.Banner;
-import org.apache.geode.internal.admin.*;
-import org.apache.geode.internal.admin.remote.*;
-import org.apache.geode.internal.cache.persistence.PersistentMemberPattern;
-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.log4j.LocalizedMessage;
-import org.apache.geode.internal.logging.log4j.LogMarker;
-import org.apache.geode.internal.logging.log4j.LogWriterAppender;
-import org.apache.geode.internal.logging.log4j.LogWriterAppenders;
-import org.apache.geode.internal.util.concurrent.FutureResult;
-import org.apache.logging.log4j.Logger;
-
-import java.io.File;
-import java.io.IOException;
-import java.net.InetAddress;
-import java.text.SimpleDateFormat;
-import java.util.*;
-import java.util.concurrent.*;
-
-import static org.apache.geode.distributed.ConfigurationProperties.*;
-
-/**
- * Represents a GemFire distributed system for remote
administration/management.
- *
- * @since GemFire 3.5
- */
-public class AdminDistributedSystemImpl implements
org.apache.geode.admin.AdminDistributedSystem,
-org.apache.geode.internal.admin.JoinLeaveListener,
-org.apache.geode.internal.admin.AlertListener,
-
org.apache.geode.distributed.internal.InternalDistributedSystem.DisconnectListener
{
-
- private static final Logger logger = LogService.getLogger();
-
- /** String identity of this distributed system */
- private String id;
-
- /** Latest alert broadcast by any system members */
- private Alert latestAlert;
-
- // -
-
- /** Internal admin agent to delegate low-level work to */
- private volatile GfManagerAgent gfManagerAgent;
-
- /** Monitors the health of this distributed system */
- private GemFireHealth health;
-
- /** Set of non-Manager members in this system */
- private final Set applicationSet = new HashSet();
-
- /** Set of DistributionLocators for this system */
- private final Set locatorSet = new HashSet();
-
- /** Set of dedicated CacheServer members in this system */
- private final Set cacheServerSet = new HashSet();
-
- /** Configuration defining this distributed system */
- private final DistributedSystemConfigImpl config;
-
- /** Controller for starting and stopping managed entities */
- private ManagedEntityController controller;
-
- /** Log file collator for gathering and merging system member logs */
- private LogCollator logCollator = new LogCollator();
-
- /**
- * The level above which alerts will be delivered to the alert listeners
- */
- private AlertLevel alertLevel = AlertLevel.WARNING;
-
- /** The alert listeners registered on this distributed system. */
- private volatile Set alertListeners = Collections.emptySet();
- private final Object
