You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by hi...@apache.org on 2016/09/20 22:34:28 UTC
[11/35] incubator-geode git commit: GEODE-37 renamed pulse package to
geode
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/testbed/driver/PulseUITest.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/testbed/driver/PulseUITest.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/testbed/driver/PulseUITest.java
deleted file mode 100644
index 7d047ed..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/testbed/driver/PulseUITest.java
+++ /dev/null
@@ -1,279 +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 com.vmware.gemfire.tools.pulse.testbed.driver;
-
-import static com.vmware.gemfire.tools.pulse.tests.PulseAbstractTest.*;
-import static org.junit.Assert.*;
-
-import java.net.InetAddress;
-import java.util.List;
-
-import org.junit.After;
-import org.junit.AfterClass;
-import org.junit.BeforeClass;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-import org.openqa.selenium.By;
-import org.openqa.selenium.WebDriver;
-import org.openqa.selenium.WebElement;
-import org.openqa.selenium.firefox.FirefoxDriver;
-import org.openqa.selenium.support.ui.ExpectedCondition;
-import org.openqa.selenium.support.ui.WebDriverWait;
-
-import org.apache.geode.internal.net.SSLConfigurationFactory;
-import org.apache.geode.internal.security.SecurableCommunicationChannel;
-import org.apache.geode.management.internal.JettyHelper;
-import org.apache.geode.test.junit.categories.UITest;
-import com.vmware.gemfire.tools.pulse.testbed.GemFireDistributedSystem.Locator;
-import com.vmware.gemfire.tools.pulse.testbed.GemFireDistributedSystem.Peer;
-import com.vmware.gemfire.tools.pulse.testbed.GemFireDistributedSystem.Region;
-import com.vmware.gemfire.tools.pulse.testbed.GemFireDistributedSystem.Server;
-import com.vmware.gemfire.tools.pulse.testbed.TestBed;
-
-@Ignore("TODO: test is ignored")
-@Category(UITest.class)
-public class PulseUITest {
-
- private static WebDriver driver;
- private static TestBed testBed;
- private static String pulseURL;
- private static String path;
- private static org.eclipse.jetty.server.Server jetty = null;
-
- private static final String userName = "admin";
- private static final String pasword = "admin";
-
- private static final String DATA_VIEW_LABEL = "Data View";
- private static final String CLUSTER_VIEW_MEMBERS_ID = "clusterTotalMembersText";
- private static final String CLUSTER_VIEW_SERVERS_ID = "clusterServersText";
- private static final String CLUSTER_VIEW_LOCATORS_ID = "clusterLocatorsText";
- private static final String CLUSTER_VIEW_REGIONS_ID = "clusterTotalRegionsText";
-
- @BeforeClass
- public static void setUpJetty() throws Exception {
- String host = InetAddress.getLocalHost().getHostAddress();
- int port = 8080;
- String context = "/pulse";
- path = getPulseWarPath();
- //System.setProperty("pulse.propMockDataUpdaterClass", "com.vmware.gemfire.tools.pulse.testbed.PropMockDataUpdater");
-
- jetty = JettyHelper.initJetty(host, port, SSLConfigurationFactory.getSSLConfigForComponent(SecurableCommunicationChannel.WEB));
- JettyHelper.addWebApplication(jetty, context, getPulseWarPath());
- jetty.start();
-
- pulseURL = "http://" + host + ":" + port + context;
- Thread.sleep(1000); //wait till tomcat settles down
- driver = new FirefoxDriver();
- driver.manage().window().maximize();//required to make all elements visible
-
- Thread.sleep(5000); //wait till pulse starts polling threads...
- testBed = new TestBed();
- loginToPulse(driver, userName, pasword);
- }
-
- @AfterClass
- public static void stopJetty() throws Exception {
- jetty.stop();
- }
-
- @After
- public void closeSession() {
- driver.close();
- }
-
- private static void loginToPulse(WebDriver driver, String userName,String password){
- driver.get(pulseURL);
- WebElement userNameElement = driver.findElement(By.id("user_name"));
- WebElement passwordElement = driver.findElement(By.id("user_password"));
- userNameElement.sendKeys(userName);
- passwordElement.sendKeys(password);
- passwordElement.submit();
- WebElement userNameOnPulsePage = (new WebDriverWait(driver, 10))
- .until(new ExpectedCondition<WebElement>() {
- @Override
- public WebElement apply(WebDriver d) {
- return d.findElement(By.id("userName"));
- }
- });
- assertNotNull(userNameOnPulsePage);
- }
-
-
- private void searchByLinkAndClick(String linkText){
- WebElement dataViewButton= By.linkText(linkText).findElement(driver);
- assertNotNull(dataViewButton);
- dataViewButton.click();
- }
-
- private void searchByIdAndClick(String id){
- WebElement element = driver.findElement(By.id(id));
- assertNotNull(element);
- element.click();
- }
-
- private void searchByXPathAndClick(String xpath){
- WebElement element = driver.findElement(By.xpath(xpath));
- assertNotNull(element);
- element.click();
- }
-
- private void waitForElementByClassName(final String className, int seconds){
- WebElement linkTextOnPulsePage1 = (new WebDriverWait(driver, seconds))
- .until(new ExpectedCondition<WebElement>() {
- @Override
- public WebElement apply(WebDriver d) {
- return d.findElement(By.className(className));
- }
- });
- assertNotNull(linkTextOnPulsePage1);
- }
-
- private void waitForElementById(final String id, int seconds){
- WebElement element = (new WebDriverWait(driver, 10))
- .until(new ExpectedCondition<WebElement>() {
- @Override
- public WebElement apply(WebDriver d) {
- return d.findElement(By.id(id));
- }
- });
- assertNotNull(element);
- }
-
- @Test
- public void testClusterViewTopRibbon() {
- List<Server> servers = testBed.getRootDs().getServers();
- List<Locator> locators = testBed.getRootDs().getLocators();
- List<Peer> peers = testBed.getRootDs().getPeers();
- List<Region> regions = testBed.getRootDs().getRegions();
- int totalMembers = servers.size() + locators.size() + peers.size();
- int clusterMembers = Integer.parseInt(driver.findElement(
- By.id(CLUSTER_VIEW_MEMBERS_ID)).getText());
- int clusterServers = Integer.parseInt(driver.findElement(
- By.id(CLUSTER_VIEW_SERVERS_ID)).getText());
- int clusterLocators = Integer.parseInt(driver.findElement(
- By.id(CLUSTER_VIEW_LOCATORS_ID)).getText());
- int clusterRegions = Integer.parseInt(driver.findElement(
- By.id(CLUSTER_VIEW_REGIONS_ID)).getText());
- assertEquals(totalMembers, clusterMembers);
- assertEquals(servers.size(), clusterServers);
- assertEquals(locators.size(), clusterLocators);
- assertEquals(regions.size(), clusterRegions);
- }
-
-
- @Test
- public void testDataViewRegionProperties() {
- searchByLinkAndClick(DATA_VIEW_LABEL);
- waitForElementByClassName("pointDetailsPadding",10);
- searchByIdAndClick("btngridIcon");
-
- for(int i=1;i<testBed.getRootDs().getRegions().size();i++){
- searchByIdAndClick(""+i);
- String regionName1 = driver.findElement(By.id("regionName")).getText();
- @SuppressWarnings("rawtypes")
- List regionMemberscount1 = testBed.getRootDs().getRegion(regionName1)
- .getMembers();
- int regionEntCount1 = testBed.getRootDs().getRegion(regionName1)
- .getEntryCount();
- int regionMembers1 = Integer.parseInt(driver.findElement(
- By.id("regionMembers")).getText());
- int regionEntryCount1 = Integer.parseInt(driver.findElement(
- By.id("regionEntryCount")).getText());
- assertEquals(regionMemberscount1.size(), regionMembers1);
- assertEquals(regionEntCount1, regionEntryCount1);
- }
- }
-
-
- @Test
- public void testMemberViewRegions() {
-
- searchByLinkAndClick(DATA_VIEW_LABEL);
- waitForElementByClassName("pointDetailsPadding",10);
- searchByXPathAndClick("//div[@title='peer1']");
- waitForElementById("memberRegionsCount",10);
-
- List<Server> servers = testBed.getRootDs().getServers();
- List<Locator> locators = testBed.getRootDs().getLocators();
- List<Peer> peers = testBed.getRootDs().getPeers();
-
- String prevSelectedMember = "peer1";
-
- for (Peer p : peers) {
- String peer = p.getName();
- System.out.println("Checking regions mapping for member " + peer);
- WebElement comboBox = driver.findElement(By.linkText(prevSelectedMember));
- comboBox.click();
- WebElement comboList = driver.findElement(By.id("clusterMembersContainer"));
- WebElement selectedMember = comboList.findElement(By.linkText(peer));
- selectedMember.click();
- timeout();
- String peername = driver.findElement(By.id("memberName")).getText();
- List<Region> peerRegionscount = testBed.getRootDs().getRegions(peer);
- int peerRegions = Integer.parseInt(driver.findElement(
- By.id("memberRegionsCount")).getText());
- assertEquals(peerRegionscount.size(), peerRegions);
- prevSelectedMember = peername;
- }
-
- for (Server s : servers) {
- String server = s.getName();
- System.out.println("Checking regions mapping for server " + server);
- WebElement comboBox = driver.findElement(By.linkText(prevSelectedMember));
- comboBox.click();
- WebElement comboList = driver.findElement(By.id("clusterMembersContainer"));
- WebElement selectedMember = comboList.findElement(By.linkText(server));
- selectedMember.click();
- timeout();
- String peername = driver.findElement(By.id("memberName")).getText();
- List<Region> serverRegionscount = testBed.getRootDs().getRegions(server);
- int serverRegions = Integer.parseInt(driver.findElement(
- By.id("memberRegionsCount")).getText());
- assertEquals(serverRegionscount.size(), serverRegions);
- prevSelectedMember = peername;
- }
- /*
- for (Locator l : locators) {
- String locator = l.getName();
- System.out.println("Checking regions mapping for locator " + locator);
- WebElement comboBox = driver.findElement(By.linkText(prevSelectedMember));
- comboBox.click();
- WebElement comboList = driver.findElement(By.id("clusterMembersContainer"));
- WebElement selectedMember = comboList.findElement(By.linkText(locator));
- selectedMember.click();
- timeout();
- String peername = driver.findElement(By.id("memberName")).getText();
- List<Region> locatorRegionscount = testBed.getRootDs().getRegions(locator);
- int locatorRegions = Integer.parseInt(driver.findElement(
- By.id("memberRegionsCount")).getText());
- assertIndexDetailsEquals(locatorRegionscount.size(), locatorRegions);
- prevSelectedMember = peername;
- }*/
- }
-
- public void timeout() {
- WebElement memberNameOnPulsePage = (new WebDriverWait(driver, 10))
- .until(new ExpectedCondition<WebElement>() {
- @Override
- public WebElement apply(WebDriver d) {
- return d.findElement(By.id("memberName"));
- }
- });
- assertNotNull(memberNameOnPulsePage);
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/AggregateStatement.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/AggregateStatement.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/AggregateStatement.java
deleted file mode 100644
index 3c5b507..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/AggregateStatement.java
+++ /dev/null
@@ -1,217 +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 com.vmware.gemfire.tools.pulse.tests;
-
-public class AggregateStatement extends JMXBaseBean implements AggregateStatementMBean {
- private String name = null;
-
- public AggregateStatement(String name) {
- this.name = name;
- }
-
- protected String getKey(String propName) {
- return "aggregatestatement." + name + "." + propName;
- }
-
- /**
- * Query definition
- *
- * @return
- */
- public String getQueryDefinition(){
- return getString("queryDefinition");
- }
-
- /**
- * Number of times this statement is compiled (including re compilations)
- *
- * @return
- */
- @Override
- public long getNumTimesCompiled(){
- return getLong("numTimesCompiled");
- }
-
- /**
- * Number of times this statement is executed
- *
- * @return
- */
- @Override
- public long getNumExecution(){
- return getLong("numExecution");
- }
-
- /**
- * Statements that are actively being processed during the statistics snapshot
- *
- * @return
- */
- public long getNumExecutionsInProgress(){
- return getLong("numExecutionsInProgress");
- }
-
- /**
- * Number of times global index lookup message exchanges occurred
- *
- * @return
- */
- public long getNumTimesGlobalIndexLookup(){
- return getLong("numTimesGlobalIndexLookup");
- }
-
- /**
- * Number of rows modified by DML operation of insert/delete/update
- *
- * @return
- */
- public long getNumRowsModified(){
- return getLong("numRowsModified");
- }
-
- /**
- * Time spent(in milliseconds) in parsing the query string
- *
- * @return
- */
- public long getParseTime(){
- return getLong("parseTime");
- }
-
- /**
- * Time spent (in milliseconds) mapping this statement with database object's metadata (bind)
- *
- * @return
- */
- public long getBindTime(){
- return getLong("bindTime");
- }
-
- /**
- * Time spent (in milliseconds) determining the best execution path for this statement
- * (optimize)
- *
- * @return
- */
- public long getOptimizeTime(){
- return getLong("optimizeTime");
- }
-
- /**
- * Time spent (in milliseconds) compiling details about routing information of query strings to
- * data node(s) (processQueryInfo)
- *
- * @return
- */
- public long getRoutingInfoTime(){
- return getLong("routingInfoTime");
- }
-
- /**
- * Time spent (in milliseconds) to generate query execution plan definition (activation class)
- *
- * @return
- */
- public long getGenerateTime(){
- return getLong("generateTime");
- }
-
- /**
- * Total compilation time (in milliseconds) of the statement on this node (prepMinion)
- *
- * @return
- */
- public long getTotalCompilationTime(){
- return getLong("totalCompilationTime");
- }
-
- /**
- * Time spent (in nanoseconds) in creation of all the layers of query processing (ac.execute)
- *
- * @return
- */
- public long getExecutionTime(){
- return getLong("executionTime");
- }
-
- /**
- * Time to apply (in nanoseconds) the projection and additional filters. (projectrestrict)
- *
- * @return
- */
- public long getProjectionTime(){
- return getLong("projectionTime");
- }
-
- /**
- * Total execution time (in nanoseconds) taken to process the statement on this node
- * (execute/open/next/close)
- *
- * @return
- */
- public long getTotalExecutionTime(){
- return getLong("totalExecutionTime");
- }
-
- /**
- * Time taken (in nanoseconds) to modify rows by DML operation of insert/delete/update
- *
- * @return
- */
- public long getRowsModificationTime(){
- return getLong("rowsModificationTime");
- }
-
- /**
- * Number of rows returned from remote nodes (ResultHolder/Get convertibles)
- *
- * @return
- */
- public long getQNNumRowsSeen(){
- return getLong("qnNumRowsSeen");
- }
-
- /**
- * TCP send time (in nanoseconds) of all the messages including serialization time and queue
- * wait time
- *
- * @return
- */
- public long getQNMsgSendTime(){
- return getLong("qnMsgSendTime");
- }
-
- /**
- * Serialization time (in nanoseconds) for all the messages while sending to remote node(s)
- *
- * @return
- */
- public long getQNMsgSerTime(){
- return getLong("qnMsgSerTime");
- }
-
- /**
- *
- *
- * @return
- */
- public long getQNRespDeSerTime(){
- return getLong("qnRespDeSerTime");
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/AggregateStatementMBean.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/AggregateStatementMBean.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/AggregateStatementMBean.java
deleted file mode 100644
index 02c431f..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/AggregateStatementMBean.java
+++ /dev/null
@@ -1,168 +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 com.vmware.gemfire.tools.pulse.tests;
-
-public interface AggregateStatementMBean {
- String OBJECT_NAME = "GemFireXD:service=Statement,type=Aggregate";
-
- /**
- * Query definition
- *
- * @return
- */
- String getQueryDefinition();
-
- /**
- * Number of times this statement is compiled (including re compilations)
- *
- * @return
- */
- long getNumTimesCompiled();
-
- /**
- * Number of times this statement is executed
- *
- * @return
- */
- long getNumExecution();
-
- /**
- * Statements that are actively being processed during the statistics snapshot
- *
- * @return
- */
- long getNumExecutionsInProgress();
-
- /**
- * Number of times global index lookup message exchanges occurred
- *
- * @return
- */
- long getNumTimesGlobalIndexLookup();
-
- /**
- * Number of rows modified by DML operation of insert/delete/update
- *
- * @return
- */
- long getNumRowsModified();
-
- /**
- * Time spent(in milliseconds) in parsing the query string
- *
- * @return
- */
- long getParseTime();
-
- /**
- * Time spent (in milliseconds) mapping this statement with database object's metadata (bind)
- *
- * @return
- */
- long getBindTime();
-
- /**
- * Time spent (in milliseconds) determining the best execution path for this statement
- * (optimize)
- *
- * @return
- */
- long getOptimizeTime();
-
- /**
- * Time spent (in milliseconds) compiling details about routing information of query strings to
- * data node(s) (processQueryInfo)
- *
- * @return
- */
- long getRoutingInfoTime();
-
- /**
- * Time spent (in milliseconds) to generate query execution plan definition (activation class)
- *
- * @return
- */
- long getGenerateTime();
-
- /**
- * Total compilation time (in milliseconds) of the statement on this node (prepMinion)
- *
- * @return
- */
- long getTotalCompilationTime();
-
- /**
- * Time spent (in nanoseconds) in creation of all the layers of query processing (ac.execute)
- *
- * @return
- */
- long getExecutionTime();
-
- /**
- * Time to apply (in nanoseconds) the projection and additional filters. (projectrestrict)
- *
- * @return
- */
- long getProjectionTime();
-
- /**
- * Total execution time (in nanoseconds) taken to process the statement on this node
- * (execute/open/next/close)
- *
- * @return
- */
- long getTotalExecutionTime();
-
- /**
- * Time taken (in nanoseconds) to modify rows by DML operation of insert/delete/update
- *
- * @return
- */
- long getRowsModificationTime();
-
- /**
- * Number of rows returned from remote nodes (ResultHolder/Get convertibles)
- *
- * @return
- */
- long getQNNumRowsSeen();
-
- /**
- * TCP send time (in nanoseconds) of all the messages including serialization time and queue
- * wait time
- *
- * @return
- */
- long getQNMsgSendTime();
-
- /**
- * Serialization time (in nanoseconds) for all the messages while sending to remote node(s)
- *
- * @return
- */
- long getQNMsgSerTime();
-
- /**
- *
- *
- * @return
- */
- long getQNRespDeSerTime();
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/DataBrowserResultLoader.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/DataBrowserResultLoader.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/DataBrowserResultLoader.java
deleted file mode 100644
index e595ef2..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/DataBrowserResultLoader.java
+++ /dev/null
@@ -1,84 +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 com.vmware.gemfire.tools.pulse.tests;
-
-import java.io.BufferedReader;
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.net.URL;
-
-public class DataBrowserResultLoader {
- private static DataBrowserResultLoader dbResultLoader = new DataBrowserResultLoader();
-
- public static DataBrowserResultLoader getInstance() {
- return dbResultLoader;
- }
-
- public String load(String queryString) throws IOException {
-
- URL url = null;
- InputStream inputStream = null;
- BufferedReader streamReader = null;
- String inputStr = null;
- StringBuilder sampleQueryResultResponseStrBuilder = null;
-
- try {
- ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
-
- if (queryString.equals(PulseAbstractTest.QUERY_TYPE_ONE)) {
- url = classLoader.getResource("testQueryResultClusterSmall.txt");
- } else if (queryString.equals(PulseAbstractTest.QUERY_TYPE_TWO)) {
- url = classLoader.getResource("testQueryResultSmall.txt");
- } else if (queryString.equals(PulseAbstractTest.QUERY_TYPE_THREE)) {
- url = classLoader.getResource("testQueryResult.txt");
- } else if (queryString.equals(PulseAbstractTest.QUERY_TYPE_FOUR)) {
- url = classLoader.getResource("testQueryResultWithStructSmall.txt");
- } else if (queryString.equals(PulseAbstractTest.QUERY_TYPE_FIVE)) {
- url = classLoader.getResource("testQueryResultClusterWithStruct.txt");
- } else if (queryString.equals(PulseAbstractTest.QUERY_TYPE_SIX)) {
- url = classLoader.getResource("testQueryResultHashMapSmall.txt");
- } else if (queryString.equals(PulseAbstractTest.QUERY_TYPE_SEVENE)) {
- url = classLoader.getResource("testQueryResult1000.txt");
- } else {
- url = classLoader.getResource("testQueryResult.txt");
- }
-
- File sampleQueryResultFile = new File(url.getPath());
- inputStream = new FileInputStream(sampleQueryResultFile);
- streamReader = new BufferedReader(new InputStreamReader(inputStream,
- "UTF-8"));
- sampleQueryResultResponseStrBuilder = new StringBuilder();
-
- while ((inputStr = streamReader.readLine()) != null) {
- sampleQueryResultResponseStrBuilder.append(inputStr);
- }
-
- // close stream reader
- streamReader.close();
-
- } catch (IOException ex) {
- ex.printStackTrace();
- }
-
- return sampleQueryResultResponseStrBuilder.toString();
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDAggregateTable.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDAggregateTable.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDAggregateTable.java
deleted file mode 100644
index 18a452e..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDAggregateTable.java
+++ /dev/null
@@ -1,46 +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 com.vmware.gemfire.tools.pulse.tests;
-
-import javax.management.NotificationBroadcasterSupport;
-
-public class GemFireXDAggregateTable extends NotificationBroadcasterSupport
- implements GemFireXDAggregateTableMBean {
- private String name = null;
-
- public GemFireXDAggregateTable(String name) {
- this.name = name;
- }
-
- private String getKey(String propName) {
- return "table." + name + "." + propName;
- }
-
- @Override
- public long getEntrySize() {
- return Long.parseLong(JMXProperties.getInstance().getProperty(
- getKey("EntrySize")));
- }
-
- @Override
- public int getNumberOfRows() {
- return Integer.parseInt(JMXProperties.getInstance().getProperty(
- getKey("NumberOfRows")));
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDAggregateTableMBean.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDAggregateTableMBean.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDAggregateTableMBean.java
deleted file mode 100644
index 774db0b..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDAggregateTableMBean.java
+++ /dev/null
@@ -1,28 +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 com.vmware.gemfire.tools.pulse.tests;
-
-public interface GemFireXDAggregateTableMBean {
- public static final String OBJECT_NAME = "GemFireXD:service=Table,type=Aggregate,table=";
-
- public long getEntrySize();
-
- public int getNumberOfRows();
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDCluster.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDCluster.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDCluster.java
deleted file mode 100644
index c4a60a7..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDCluster.java
+++ /dev/null
@@ -1,95 +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 com.vmware.gemfire.tools.pulse.tests;
-
-import javax.management.NotificationBroadcasterSupport;
-import javax.management.openmbean.CompositeData;
-import javax.management.openmbean.CompositeDataSupport;
-import javax.management.openmbean.CompositeType;
-import javax.management.openmbean.OpenDataException;
-import javax.management.openmbean.OpenType;
-import javax.management.openmbean.SimpleType;
-
-public class GemFireXDCluster extends NotificationBroadcasterSupport implements
- GemFireXDClusterMBean {
- private String name = null;
-
- private static String[] itemNames = { "connectionsAttempted",
- "connectionsActive", "connectionsClosed", "connectionsFailed" };;
- private static String[] itemDescriptions = { "connectionsAttempted",
- "connectionsActive", "connectionsClosed", "connectionsFailed" };
- private static OpenType[] itemTypes = { SimpleType.LONG, SimpleType.LONG,
- SimpleType.LONG, SimpleType.LONG };
- private static CompositeType networkServerClientConnectionStats = null;
-
- static {
- try {
- networkServerClientConnectionStats = new CompositeType(
- "NetworkServerClientConnectionStats",
- "Network Server Client Connection Stats Information", itemNames,
- itemDescriptions, itemTypes);
-
- } catch (OpenDataException e) {
- e.printStackTrace();
- }
- }
-
- public GemFireXDCluster(String name) {
- this.name = name;
- }
-
- private String getKey(String propName) {
- return "gemfirexd." + name + "." + propName;
- }
-
- @Override
- public int getProcedureCallsCompleted() {
- return Integer.parseInt(JMXProperties.getInstance().getProperty(
- getKey("ProcedureCallsCompleted")));
- }
-
- @Override
- public int getProcedureCallsInProgress() {
- return Integer.parseInt(JMXProperties.getInstance().getProperty(
- getKey("ProcedureCallsInProgress")));
- }
-
- @Override
- public CompositeData getNetworkServerClientConnectionStats() {
- String value = JMXProperties.getInstance().getProperty(
- getKey("NetworkServerClientConnectionStats"), "");
- String[] values = value.split(",");
- Long[] itemValues = new Long[values.length];
- for (int i = 0; i < values.length; i++) {
- itemValues[i] = Long.parseLong(values[i]);
- }
-
- CompositeData nscCompData;
- try {
- nscCompData = new CompositeDataSupport(
- networkServerClientConnectionStats, itemNames, itemValues);
- } catch (OpenDataException e) {
- e.printStackTrace();
- nscCompData = null;
- }
- return nscCompData;
-
- }
-
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDClusterMBean.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDClusterMBean.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDClusterMBean.java
deleted file mode 100644
index 43b8f92..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDClusterMBean.java
+++ /dev/null
@@ -1,32 +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 com.vmware.gemfire.tools.pulse.tests;
-
-import javax.management.openmbean.CompositeData;
-
-public interface GemFireXDClusterMBean {
- public static final String OBJECT_NAME = "GemFireXD:service=Cluster";
-
- public int getProcedureCallsCompleted();
-
- public int getProcedureCallsInProgress();
-
- public CompositeData getNetworkServerClientConnectionStats();
-
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDMember.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDMember.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDMember.java
deleted file mode 100644
index 1c042c6..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDMember.java
+++ /dev/null
@@ -1,80 +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 com.vmware.gemfire.tools.pulse.tests;
-
-import javax.management.openmbean.CompositeData;
-import javax.management.openmbean.CompositeDataSupport;
-import javax.management.openmbean.CompositeType;
-import javax.management.openmbean.OpenDataException;
-import javax.management.openmbean.OpenType;
-import javax.management.openmbean.SimpleType;
-
-public class GemFireXDMember extends JMXBaseBean implements
- GemFireXDMemberMBean {
- private String name = null;
-
- private static String[] itemNames = { "connectionsAttempted",
- "connectionsActive", "connectionsClosed", "connectionsFailed" };;
- private static String[] itemDescriptions = { "connectionsAttempted",
- "connectionsActive", "connectionsClosed", "connectionsFailed" };
- private static OpenType[] itemTypes = { SimpleType.LONG, SimpleType.LONG,
- SimpleType.LONG, SimpleType.LONG };
- private static CompositeType networkServerClientConnectionStats = null;
-
- static {
- try {
- networkServerClientConnectionStats = new CompositeType(
- "NetworkServerClientConnectionStats",
- "Network Server Client Connection Stats Information", itemNames,
- itemDescriptions, itemTypes);
-
- } catch (OpenDataException e) {
- e.printStackTrace();
- }
- }
-
- public GemFireXDMember(String name) {
- this.name = name;
- }
-
- @Override
- protected String getKey(String propName) {
- return "gemfirexdmember." + name + "." + propName;
- }
-
- @Override
- public boolean getDataStore() {
- return getBoolean("DataStore");
- }
-
- @Override
- public CompositeData getNetworkServerClientConnectionStats() {
- Long[] itemValues = getLongArray("NetworkServerClientConnectionStats");
- CompositeData nscCompData;
- try {
- nscCompData = new CompositeDataSupport(
- networkServerClientConnectionStats, itemNames, itemValues);
- } catch (OpenDataException e) {
- e.printStackTrace();
- nscCompData = null;
- }
- return nscCompData;
- }
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDMemberMBean.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDMemberMBean.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDMemberMBean.java
deleted file mode 100644
index f4392cf..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/GemFireXDMemberMBean.java
+++ /dev/null
@@ -1,31 +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 com.vmware.gemfire.tools.pulse.tests;
-
-import javax.management.openmbean.CompositeData;
-
-public interface GemFireXDMemberMBean {
-
- public static final String OBJECT_NAME = "GemFireXD:group=DEFAULT,type=Member";
-
- public boolean getDataStore();
-
- public CompositeData getNetworkServerClientConnectionStats();
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/JMXBaseBean.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/JMXBaseBean.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/JMXBaseBean.java
deleted file mode 100644
index cff8d9a..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/JMXBaseBean.java
+++ /dev/null
@@ -1,67 +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 com.vmware.gemfire.tools.pulse.tests;
-
-public abstract class JMXBaseBean {
-
- protected abstract String getKey(String propName);
-
- protected String getString(String key) {
- return JMXProperties.getInstance().getProperty(getKey(key));
- }
-
- protected String[] getStringArray(String key) {
- return JMXProperties.getInstance().getProperty(getKey(key), "").split(" ");
- }
-
- protected boolean getBoolean(String key) {
- return Boolean.parseBoolean(JMXProperties.getInstance().getProperty(
- getKey(key)));
- }
-
- protected int getInt(String key) {
- return Integer.parseInt(JMXProperties.getInstance()
- .getProperty(getKey(key)));
- }
-
- protected long getLong(String key) {
- return Long.parseLong(JMXProperties.getInstance().getProperty(getKey(key)));
- }
-
- protected Long[] getLongArray(String key) {
- String value = JMXProperties.getInstance().getProperty(getKey(key), "");
- String[] values = value.split(",");
- Long[] longValues = new Long[values.length];
- for (int i = 0; i < values.length; i++) {
- longValues[i] = Long.parseLong(values[i]);
- }
- return longValues;
- }
-
- protected double getDouble(String key) {
- return Double.parseDouble(JMXProperties.getInstance().getProperty(
- getKey(key)));
- }
-
- protected float getFloat(String key) {
- return Float.parseFloat(JMXProperties.getInstance()
- .getProperty(getKey(key)));
- }
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/JMXProperties.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/JMXProperties.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/JMXProperties.java
deleted file mode 100644
index bc91254..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/JMXProperties.java
+++ /dev/null
@@ -1,47 +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 com.vmware.gemfire.tools.pulse.tests;
-
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.IOException;
-import java.util.Properties;
-
-public class JMXProperties extends Properties {
- private static final long serialVersionUID = -6210901350494570026L;
-
- private static JMXProperties props = new JMXProperties();
-
- public static JMXProperties getInstance() {
- return props;
- }
-
- public void load(String propFile) throws IOException {
- if (propFile != null) {
- FileInputStream fin;
- fin = new FileInputStream(new File(propFile));
- if (fin != null) {
- clear();
- load(fin);
- }
-
- fin.close();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/Member.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/Member.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/Member.java
deleted file mode 100644
index 98e015e..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/Member.java
+++ /dev/null
@@ -1,193 +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 com.vmware.gemfire.tools.pulse.tests;
-
-public class Member extends JMXBaseBean implements MemberMBean {
- private String name = null;
-
- public Member(String name) {
- this.name = name;
- }
-
- protected String getKey(String propName) {
- return "member." + name + "." + propName;
- }
-
- @Override
- public boolean getManager() {
- return getBoolean("manager");
- }
-
- @Override
- public int getTotalRegionCount() {
-// This count is built dynamically in Pulse backend and region count is maintained in Cluster.Member data structure
-// return getInt("totalRegionCount");
- return 0;
- }
-
- @Override
- public boolean getLocator() {
- return getBoolean("locator");
- }
-
- @Override
- public long getTotalDiskUsage() {
- return getLong("totalDiskUsage");
- }
-
- @Override
- public boolean getServer() {
- return getBoolean("sever");
- }
-
- @Override
- public String[] getGroups() {
- return getStringArray("Groups");
- }
-
- @Override
- /*public String[] getRedundancyZone() {
- return getStringArray("RedundancyZone");
- }*/
- public String getRedundancyZone() {
- return getString("RedundancyZone");
- }
-
- @Override
- public long getTotalFileDescriptorOpen() {
- return getLong("totalFileDescriptorOpen");
- }
-
- @Override
- public double getLoadAverage() {
- return getDouble("loadAverage");
- }
-
- @Override
- public double getDiskWritesRate() {
- return getDouble("diskWritesRate");
- }
-
- @Override
- public long getJVMPauses() {
- return getLong("JVMPauses");
- }
-
- @Override
- public long getCurrentHeapSize() {
-// return getLong("currentHeapSize");
- return getLong("UsedMemory");
- }
-
- @Override
- public long getMaximumHeapSize() {
-// return getLong("maximumHeapSize");
- return getLong("MaxMemory");
- }
-
- @Override
- public long getUsedMemory() {
- return getLong("UsedMemory");
- }
-
- @Override
- public long getMaxMemory() {
- return getLong("MaxMemory");
- }
-
- @Override
- public int getNumThreads() {
- return getInt("numThreads");
- }
-
- @Override
- public long getMemberUpTime() {
- return getLong("memberUpTime");
- }
-
- @Override
- public String getHost() {
- return getString("host");
- }
-
- @Override
- public long getTotalBytesOnDisk() {
- return getLong("totalBytesOnDisk");
- }
-
- @Override
- public double getCpuUsage() {
- return getDouble("cpuUsage");
- }
-
- @Override
- public String getMember() {
- return getString("member");
- }
-
- @Override
- public String getId() {
- return getString("id");
- }
-
- @Override
- public double getAverageReads() {
- return getDouble("averageReads");
- }
-
- @Override
- public double getAverageWrites() {
- return getDouble("averageWrites");
- }
-
- @Override
- public int getPort() {
- return getInt("port");
- }
-
- @Override
- public long getFoo() {
- return getLong("foo");
- }
-
- @Override
- public long getOffHeapFreeSize() {
- return getLong("OffHeapFreeSize");
- }
-
- @Override
- public long getOffHeapUsedSize() {
- return getLong("OffHeapUsedSize");
- }
-
- @Override
- public long getOffHeapFreeMemory() {
- return getLong("OffHeapFreeMemory");
- }
-
- @Override
- public long getOffHeapUsedMemory() {
- return getLong("OffHeapUsedMemory");
- }
-
- @Override
- public String getVersion() {
- return getString("Version");
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/9a2b5d7b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/MemberMBean.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/MemberMBean.java b/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/MemberMBean.java
deleted file mode 100644
index f57d80f..0000000
--- a/geode-pulse/src/test/java/com/vmware/gemfire/tools/pulse/tests/MemberMBean.java
+++ /dev/null
@@ -1,86 +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 com.vmware.gemfire.tools.pulse.tests;
-
-public interface MemberMBean {
- String OBJECT_NAME = "GemFire:type=Member";
-
- boolean getManager();
-
- int getTotalRegionCount();
-
- boolean getLocator();
-
- long getTotalDiskUsage();
-
- boolean getServer();
-
- String[] getGroups();
-
- //public String[] getRedundancyZone();
- String getRedundancyZone();
-
- long getTotalFileDescriptorOpen();
-
- double getLoadAverage();
-
- double getDiskWritesRate();
-
- long getJVMPauses();
-
- long getCurrentHeapSize();
-
- long getMaximumHeapSize();
-
- long getUsedMemory();
-
- long getMaxMemory();
-
- int getNumThreads();
-
- long getMemberUpTime();
-
- String getHost();
-
- long getTotalBytesOnDisk();
-
- double getCpuUsage();
-
- String getMember();
-
- String getId();
-
- double getAverageReads();
-
- double getAverageWrites();
-
- int getPort();
-
- long getFoo();
-
- long getOffHeapFreeSize();
-
- long getOffHeapUsedSize();
-
- long getOffHeapFreeMemory();
-
- long getOffHeapUsedMemory();
-
- String getVersion();
-}