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:48 UTC
[31/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/main/java/com/vmware/gemfire/tools/pulse/internal/data/Cluster.java
----------------------------------------------------------------------
diff --git a/geode-pulse/src/main/java/com/vmware/gemfire/tools/pulse/internal/data/Cluster.java b/geode-pulse/src/main/java/com/vmware/gemfire/tools/pulse/internal/data/Cluster.java
deleted file mode 100644
index 786861f..0000000
--- a/geode-pulse/src/main/java/com/vmware/gemfire/tools/pulse/internal/data/Cluster.java
+++ /dev/null
@@ -1,3815 +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.internal.data;
-
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.databind.node.ArrayNode;
-import com.fasterxml.jackson.databind.node.ObjectNode;
-import com.vmware.gemfire.tools.pulse.internal.log.PulseLogWriter;
-import com.vmware.gemfire.tools.pulse.internal.util.StringUtils;
-import org.apache.commons.collections.buffer.CircularFifoBuffer;
-
-import javax.management.remote.JMXConnector;
-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.lang.reflect.Constructor;
-import java.lang.reflect.InvocationTargetException;
-import java.net.ConnectException;
-import java.net.URL;
-import java.text.DateFormat;
-import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Random;
-import java.util.ResourceBundle;
-import java.util.Set;
-import java.util.TimeZone;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.atomic.AtomicInteger;
-/**
- * Class Cluster This class is the Data Model for the data used for the Pulse
- * Web UI.
- *
- * @since GemFire version 7.0.Beta 2012-09-23
- */
-public class Cluster extends Thread {
- private static final int POLL_INTERVAL = 5000;
- public static final int MAX_SAMPLE_SIZE = 180;
- public static final int ALERTS_MAX_SIZE = 1000;
- public static final int PAGE_ALERTS_MAX_SIZE = 100;
-
- private final PulseLogWriter LOGGER = PulseLogWriter.getLogger();
- private final ResourceBundle resourceBundle = Repository.get()
- .getResourceBundle();
-
- private String jmxUserName;
- private String jmxUserPassword;
- private String serverName;
- private String port;
- private int stale = 0;
- private double loadPerSec;
-
- // start: fields defined in System MBean
- private IClusterUpdater updater = null;
- private DataBrowser dataBrowser = null;
- private int memberCount;
- private long clientConnectionCount;
- private int locatorCount;
- private int totalRegionCount;
- private long totalHeapSize = 0L;
- private long totalRegionEntryCount;
- private int currentQueryCount;
- private long totalBytesOnDisk;
- private double diskReadsRate;
- private double diskWritesRate;
- private double writePerSec;
- private double readPerSec;
- private double queriesPerSec;
- private int avgDiskStorage;
- private int avgDiskWritesRate;
- private int runningFunctionCount;
- private long registeredCQCount;
- private int subscriptionCount;
- private int serverCount;
- private int txnCommittedCount;
- private int txnRollbackCount;
- private long usedHeapSize = 0L;
- private long garbageCollectionCount = 0L;
- private int clusterId;
- private int notificationPageNumber = 1;
- private boolean connectedFlag;
- private String connectionErrorMsg = "";
-
- private Set<String> deletedMembers = new HashSet<String>();
-
- private Map<String, List<Cluster.Member>> physicalToMember = new HashMap<String, List<Cluster.Member>>();
-
- private Map<String, Cluster.Member> membersHMap = new HashMap<String, Cluster.Member>();
-
- private Set<String> deletedRegions = new HashSet<String>();
-
- private Map<String, Cluster.Region> clusterRegionMap = new ConcurrentHashMap<String, Cluster.Region>();
- private List<Cluster.Alert> alertsList = new ArrayList<Cluster.Alert>();
-
- private CircularFifoBuffer totalBytesOnDiskTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer throughoutWritesTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer throughoutReadsTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer writePerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer readPerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer queriesPerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer memoryUsageTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer garbageCollectionTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private long previousJVMPauseCount = 0L;
-
- private HashMap<String, Boolean> wanInformation = new HashMap<String, Boolean>();
- private Map<String, Cluster.Statement> clusterStatementMap = new ConcurrentHashMap<String, Cluster.Statement>();
-
- public static final int CLUSTER_STAT_TOTAL_BYTES_ON_DISK = 0;
- public static final int CLUSTER_STAT_THROUGHPUT_WRITES = 1;
- public static final int CLUSTER_STAT_THROUGHPUT_READS = 2;
- public static final int CLUSTER_STAT_WRITES_PER_SECOND = 3;
- public static final int CLUSTER_STAT_READ_PER_SECOND = 4;
- public static final int CLUSTER_STAT_QUERIES_PER_SECOND = 5;
- public static final int CLUSTER_STAT_MEMORY_USAGE = 6;
- public static final int CLUSTER_STAT_GARBAGE_COLLECTION = 7;
-
- // end: fields defined in System MBean
-
- // used for updating member's client data
- public static long LAST_UPDATE_TIME = 0;
-
- public int getStaleStatus() {
- return this.stale;
- }
-
- private boolean stopUpdates = false;
-
- private static final int MAX_HOSTS = 40;
-
- private final List<String> hostNames = new ArrayList<String>();
-
- private final ObjectMapper mapper = new ObjectMapper();
-
- public Object[] getStatisticTrend(int trendId) {
-
- Object[] returnArray = null;
- switch (trendId) {
- case CLUSTER_STAT_TOTAL_BYTES_ON_DISK:
- synchronized (this.totalBytesOnDiskTrend) {
- returnArray = this.totalBytesOnDiskTrend.toArray();
- }
-
- break;
-
- case CLUSTER_STAT_THROUGHPUT_READS:
- synchronized (this.throughoutReadsTrend) {
- returnArray = this.throughoutReadsTrend.toArray();
- }
- break;
-
- case CLUSTER_STAT_THROUGHPUT_WRITES:
- synchronized (this.throughoutWritesTrend) {
- returnArray = this.throughoutWritesTrend.toArray();
- }
- break;
-
- case CLUSTER_STAT_WRITES_PER_SECOND:
- synchronized (this.writePerSecTrend) {
- returnArray = this.writePerSecTrend.toArray();
- }
- break;
-
- case CLUSTER_STAT_READ_PER_SECOND:
- synchronized (this.readPerSecTrend) {
- returnArray = this.readPerSecTrend.toArray();
- }
- break;
-
- case CLUSTER_STAT_QUERIES_PER_SECOND:
- synchronized (this.queriesPerSecTrend) {
- returnArray = this.queriesPerSecTrend.toArray();
- }
- break;
-
- case CLUSTER_STAT_MEMORY_USAGE:
- synchronized (this.memoryUsageTrend) {
- returnArray = this.memoryUsageTrend.toArray();
- }
- break;
-
- case CLUSTER_STAT_GARBAGE_COLLECTION:
- synchronized (this.garbageCollectionTrend) {
- returnArray = this.garbageCollectionTrend.toArray();
- }
- break;
- }
-
- return returnArray;
- }
-
- /**
- * Member Inner Class
- *
- *
- */
- public static class Member {
-
- // start: fields defined in MBean
- private String gemfireVersion;
- private boolean manager;
- private int totalRegionCount;
- private String host;
- private String hostnameForClients;
- private String bindAddress;
- private long currentHeapSize;
- private long maxHeapSize;
- private int avgHeapUsage;
- private long OffHeapFreeSize;
- private long OffHeapUsedSize;
- private long totalBytesOnDisk;
- private String memberPort;
-
- private double cpuUsage = 0.0d;
- private double hostCpuUsage = 0.0d;
- private long uptime;
- private String name;
- private double getsRate;
- private double putsRate;
- private boolean isCache;
- private boolean isGateway;
- private boolean isLocator;
- private boolean isServer;
- private double loadAverage;
- private int numThreads;
- private long totalFileDescriptorOpen;
- private long garbageCollectionCount = 0L;
- private double throughputWrites;
- private double throughputReads;
- private long totalDiskUsage;
- private String queueBacklog;
- private String id;
- private long numSqlfireClients = 0;
-
- private List<String> serverGroups = new ArrayList<String>();
- private List<String> redundancyZones = new ArrayList<String>();
-
- private CircularFifoBuffer cpuUsageSamples = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer heapUsageSamples = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private HashMap<String, Cluster.Region> memberRegions = new HashMap<String, Cluster.Region>();
- private HashMap<String, Cluster.Client> memberClientsHMap = new HashMap<String, Cluster.Client>();
- private CircularFifoBuffer totalBytesOnDiskSamples = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer getsPerSecond = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer putsPerSecond = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer throughputWritesTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer throughputReadsTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer garbageCollectionSamples = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private long previousJVMPauseCount = 0L;
-
- private Cluster.GatewayReceiver gatewayReceiver = null;
- private List<Cluster.GatewaySender> gatewaySenderList = new ArrayList<Cluster.GatewaySender>();
- private List<Cluster.AsyncEventQueue> asyncEventQueueList = new ArrayList<Cluster.AsyncEventQueue>();
- // end: fields defined in MBean
-
- public static final int MEMBER_STAT_GARBAGE_COLLECTION = 0;
- public static final int MEMBER_STAT_HEAP_USAGE_SAMPLE = 1;
- public static final int MEMBER_STAT_CPU_USAGE_SAMPLE = 2;
- public static final int MEMBER_STAT_GETS_PER_SECOND = 3;
- public static final int MEMBER_STAT_PUTS_PER_SECOND = 4;
- public static final int MEMBER_STAT_THROUGHPUT_WRITES = 5;
- public static final int MEMBER_STAT_THROUGHPUT_READS = 6;
-
- public Cluster.Region[] getMemberRegionsList() {
- Cluster.Region[] memberReg = null;
- synchronized (memberRegions) {
- memberReg = new Cluster.Region[memberRegions.size()];
- memberReg = memberRegions.values().toArray(memberReg);
- }
-
- return memberReg;
- }
-
- public Cluster.Client[] getMemberClients() {
- Cluster.Client[] memberClients = null;
- synchronized (memberClientsHMap) {
- memberClients = new Cluster.Client[memberClientsHMap.size()];
- memberClients = memberClientsHMap.values().toArray(memberClients);
- }
-
- return memberClients;
- }
-
- public Cluster.GatewaySender[] getMemberGatewaySenders() {
- Cluster.GatewaySender[] memberGWS = null;
- synchronized (gatewaySenderList) {
- memberGWS = new Cluster.GatewaySender[gatewaySenderList.size()];
- memberGWS = gatewaySenderList.toArray(memberGWS);
- }
- return memberGWS;
- }
-
- public Cluster.AsyncEventQueue[] getMemberAsyncEventQueueList() {
- Cluster.AsyncEventQueue[] memberAEQ = null;
- synchronized (asyncEventQueueList) {
- memberAEQ = new Cluster.AsyncEventQueue[asyncEventQueueList.size()];
- memberAEQ = asyncEventQueueList.toArray(memberAEQ);
- }
- return memberAEQ;
- }
-
- public Object[] getMemberStatisticTrend(int trendId) {
- Object[] returnArray = null;
- switch (trendId) {
- case MEMBER_STAT_GARBAGE_COLLECTION:
- synchronized (this.garbageCollectionSamples) {
- returnArray = this.garbageCollectionSamples.toArray();
- }
-
- break;
-
- case MEMBER_STAT_HEAP_USAGE_SAMPLE:
- synchronized (this.heapUsageSamples) {
- returnArray = this.heapUsageSamples.toArray();
- }
- break;
-
- case MEMBER_STAT_CPU_USAGE_SAMPLE:
- synchronized (this.cpuUsageSamples) {
- returnArray = this.cpuUsageSamples.toArray();
- }
- break;
-
- case MEMBER_STAT_GETS_PER_SECOND:
- synchronized (this.getsPerSecond) {
- returnArray = this.getsPerSecond.toArray();
- }
- break;
-
- case MEMBER_STAT_PUTS_PER_SECOND:
- synchronized (this.putsPerSecond) {
- returnArray = this.putsPerSecond.toArray();
- }
- break;
-
- case MEMBER_STAT_THROUGHPUT_WRITES:
- synchronized (this.throughputWritesTrend) {
- returnArray = this.throughputWritesTrend.toArray();
- }
- break;
-
- case MEMBER_STAT_THROUGHPUT_READS:
- synchronized (this.throughputReadsTrend) {
- returnArray = this.throughputReadsTrend.toArray();
- }
- break;
- }
-
- return returnArray;
- }
-
- public String getGemfireVersion() {
- return gemfireVersion;
- }
-
- public void setGemfireVersion(String gemfireVersion) {
- this.gemfireVersion = gemfireVersion;
- }
-
- public String getMemberPort() {
- return this.memberPort;
- }
-
- public void setMemberPort(String memberPort) {
- this.memberPort = memberPort;
- }
-
- public double getThroughputWrites() {
- return this.throughputWrites;
- }
-
- public void setThroughputWrites(double throughputWrites) {
- this.throughputWrites = throughputWrites;
- }
-
- public double getThroughputReads() {
- return this.throughputReads;
- }
-
- public void setThroughputReads(double throughputReads) {
- this.throughputReads = throughputReads;
- }
-
- public long getTotalDiskUsage() {
- return this.totalDiskUsage;
- }
-
- public void setTotalDiskUsage(long totalDiskUsage) {
- this.totalDiskUsage = totalDiskUsage;
- }
-
- public String getId() {
- return this.id;
- }
-
- public String getName() {
- return this.name;
- }
-
- public double getLoadAverage() {
- return this.loadAverage;
- }
-
- public void setLoadAverage(Double loadAverage) {
- this.loadAverage = loadAverage;
- }
-
- public String getHost() {
- return this.host;
- }
-
- public String getHostnameForClients() {
- if(StringUtils.isNotNullNotEmptyNotWhiteSpace(hostnameForClients))
- return this.hostnameForClients;
- else if(StringUtils.isNotNullNotEmptyNotWhiteSpace(bindAddress))
- return this.bindAddress;
- return null;
- }
-
- public long getUptime() {
- return this.uptime;
- }
-
- public String getQueueBacklog() {
- return this.queueBacklog;
- }
-
- public HashMap<String, Cluster.Region> getMemberRegions() {
- return this.memberRegions;
- }
-
- public void setMemberRegions(HashMap<String, Cluster.Region> memberRegions) {
- this.memberRegions = memberRegions;
- }
-
- public long getCurrentHeapSize() {
- return this.currentHeapSize;
- }
-
- public void setCurrentHeapSize(long currentHeapSize) {
- this.currentHeapSize = currentHeapSize;
- }
-
- public long getMaxHeapSize() {
- return this.maxHeapSize;
- }
-
- public void setMaxHeapSize(long maxHeapSize) {
- this.maxHeapSize = maxHeapSize;
- }
-
- public boolean isManager() {
- return this.manager;
- }
-
- public void setManager(boolean manager) {
- this.manager = manager;
- }
-
- public int getAvgHeapUsage() {
- return this.avgHeapUsage;
- }
-
- public void setAvgHeapUsage(int avgHeapUsage) {
- this.avgHeapUsage = avgHeapUsage;
- }
-
- public long getOffHeapFreeSize() {
- return OffHeapFreeSize;
- }
-
- public void setOffHeapFreeSize(long offHeapFreeSize) {
- this.OffHeapFreeSize = offHeapFreeSize;
- }
-
- public long getOffHeapUsedSize() {
- return OffHeapUsedSize;
- }
-
- public void setOffHeapUsedSize(long offHeapUsedSize) {
- this.OffHeapUsedSize = offHeapUsedSize;
- }
-
- public void setId(String id) {
- this.id = id;
- }
-
- public void setName(String name) {
- this.name = name;
- }
-
- public void setHost(String host) {
- this.host = host;
- }
-
- public void setHostnameForClients(String hostnameForClients) {
- this.hostnameForClients = hostnameForClients;
- }
-
- public void setBindAddress(String bindAddress){
- this.bindAddress = bindAddress;
- }
-
- public void setUptime(long uptime) {
- this.uptime = uptime;
- }
-
- public void setQueueBacklog(String queueBacklog) {
- this.queueBacklog = queueBacklog;
- }
-
- public int getTotalRegionCount() {
- return this.totalRegionCount;
- }
-
- public void setTotalRegionCount(int totalRegionCount) {
- this.totalRegionCount = totalRegionCount;
- }
-
- public long getTotalBytesOnDisk() {
- return this.totalBytesOnDisk;
- }
-
- public void setTotalBytesOnDisk(long totalBytesOnDisk) {
- this.totalBytesOnDisk = totalBytesOnDisk;
- }
-
- public double getCpuUsage() {
- return this.cpuUsage;
- }
-
- public void setCpuUsage(double cpuUsage) {
- this.cpuUsage = cpuUsage;
- }
-
- public double getHostCpuUsage() {
- return this.hostCpuUsage;
- }
-
- public void setHostCpuUsage(double hostCpuUsage) {
- this.hostCpuUsage = hostCpuUsage;
- }
-
- public double getGetsRate() {
- return this.getsRate;
- }
-
- public void setGetsRate(double getsRate) {
- this.getsRate = getsRate;
- }
-
- public double getPutsRate() {
- return this.putsRate;
- }
-
- public void setPutsRate(double putsRate) {
- this.putsRate = putsRate;
- }
-
- public HashMap<String, Cluster.Client> getMemberClientsHMap() {
- return this.memberClientsHMap;
- }
-
- public void setMemberClientsHMap(
- HashMap<String, Cluster.Client> memberClientsHMap) {
- this.memberClientsHMap = memberClientsHMap;
- }
-
- public boolean isCache() {
- return this.isCache;
- }
-
- public void setCache(boolean isCache) {
- this.isCache = isCache;
- }
-
- public boolean isGateway() {
- return this.isGateway;
- }
-
- public void setGateway(boolean isGateway) {
- this.isGateway = isGateway;
- }
-
- public int getNumThreads() {
- return this.numThreads;
- }
-
- public void setNumThreads(int numThreads) {
- this.numThreads = numThreads;
- }
-
- public long getTotalFileDescriptorOpen() {
- return this.totalFileDescriptorOpen;
- }
-
- public void setTotalFileDescriptorOpen(long totalFileDescriptorOpen) {
- this.totalFileDescriptorOpen = totalFileDescriptorOpen;
- }
-
- public long getGarbageCollectionCount() {
- return this.garbageCollectionCount;
- }
-
- public void setGarbageCollectionCount(long garbageCollectionCount) {
- this.garbageCollectionCount = garbageCollectionCount;
- }
-
- public boolean isLocator() {
- return this.isLocator;
- }
-
- public void setLocator(boolean isLocator) {
- this.isLocator = isLocator;
- }
-
- public Cluster.GatewayReceiver getGatewayReceiver() {
- return this.gatewayReceiver;
- }
-
- public void setGatewayReceiver(Cluster.GatewayReceiver gatewayReceiver) {
- this.gatewayReceiver = gatewayReceiver;
- }
-
- public List<Cluster.GatewaySender> getGatewaySenderList() {
- return this.gatewaySenderList;
- }
-
- public void setGatewaySenderList(
- List<Cluster.GatewaySender> gatewaySenderList) {
- this.gatewaySenderList = gatewaySenderList;
- }
-
- public List<Cluster.AsyncEventQueue> getAsyncEventQueueList() {
- return this.asyncEventQueueList;
- }
-
- public void setAsyncEventQueueList(
- List<Cluster.AsyncEventQueue> asyncEventQueueList) {
- this.asyncEventQueueList = asyncEventQueueList;
- }
-
- public boolean isServer() {
- return this.isServer;
- }
-
- public void setServer(boolean isServer) {
- this.isServer = isServer;
- }
-
- public List<String> getServerGroups() {
- return this.serverGroups;
- }
-
- public void setServerGroups(List<String> serverGroups) {
- this.serverGroups = serverGroups;
- }
-
- public List<String> getRedundancyZones() {
- return this.redundancyZones;
- }
-
- public void setRedundancyZones(List<String> redundancyZones) {
- this.redundancyZones = redundancyZones;
- }
-
- public CircularFifoBuffer getCpuUsageSamples() {
- return this.cpuUsageSamples;
- }
-
- public void setCpuUsageSamples(CircularFifoBuffer cpuUsageSamples) {
- this.cpuUsageSamples = cpuUsageSamples;
- }
-
- public CircularFifoBuffer getHeapUsageSamples() {
- return this.heapUsageSamples;
- }
-
- public void setHeapUsageSamples(CircularFifoBuffer heapUsageSamples) {
- this.heapUsageSamples = heapUsageSamples;
- }
-
- public CircularFifoBuffer getTotalBytesOnDiskSamples() {
- return this.totalBytesOnDiskSamples;
- }
-
- public void setTotalBytesOnDiskSamples(
- CircularFifoBuffer totalBytesOnDiskSamples) {
- this.totalBytesOnDiskSamples = totalBytesOnDiskSamples;
- }
-
- public CircularFifoBuffer getGetsPerSecond() {
- return this.getsPerSecond;
- }
-
- public void setGetsPerSecond(CircularFifoBuffer getsPerSecond) {
- this.getsPerSecond = getsPerSecond;
- }
-
- public CircularFifoBuffer getPutsPerSecond() {
- return this.putsPerSecond;
- }
-
- public void setPutsPerSecond(CircularFifoBuffer putsPerSecond) {
- this.putsPerSecond = putsPerSecond;
- }
-
- public CircularFifoBuffer getThroughputWritesTrend() {
- return this.throughputWritesTrend;
- }
-
- public void setThroughputWritesTrend(
- CircularFifoBuffer throughputWritesTrend) {
- this.throughputWritesTrend = throughputWritesTrend;
- }
-
- public CircularFifoBuffer getThroughputReadsTrend() {
- return this.throughputReadsTrend;
- }
-
- public void setThroughputReadsTrend(CircularFifoBuffer throughputReadsTrend) {
- this.throughputReadsTrend = throughputReadsTrend;
- }
-
- public CircularFifoBuffer getGarbageCollectionSamples() {
- return this.garbageCollectionSamples;
- }
-
- public void setGarbageCollectionSamples(
- CircularFifoBuffer garbageCollectionSamples) {
- this.garbageCollectionSamples = garbageCollectionSamples;
- }
-
- public long getPreviousJVMPauseCount() {
- return this.previousJVMPauseCount;
- }
-
- public void setPreviousJVMPauseCount(long previousJVMPauseCount) {
- this.previousJVMPauseCount = previousJVMPauseCount;
- }
-
- public long getNumSqlfireClients() {
- return numSqlfireClients;
- }
-
- public void setNumSqlfireClients(long numSqlfireClients) {
- this.numSqlfireClients = numSqlfireClients;
- }
-
- public void updateMemberClientsHMap(
- HashMap<String, Cluster.Client> memberClientsHM) {
-
- if (Cluster.LAST_UPDATE_TIME == 0) {
- Cluster.LAST_UPDATE_TIME = System.nanoTime();
- }
-
- long systemNanoTime = System.nanoTime();
-
- for (Map.Entry<String, Cluster.Client> entry : memberClientsHM.entrySet()) {
- String clientId = entry.getKey();
- Cluster.Client client = entry.getValue();
-
- if (memberClientsHMap.get(clientId) != null) {
- Client existingClient = memberClientsHMap.get(clientId);
- Client updatedClient = memberClientsHM.get(clientId);
-
- existingClient.setConnected(updatedClient.isConnected());
- existingClient.setGets(updatedClient.getGets());
- existingClient.setPuts(updatedClient.getPuts());
- existingClient.setCpus(updatedClient.getCpus());
- existingClient.setQueueSize(updatedClient.getQueueSize());
- existingClient.setStatus(updatedClient.getStatus());
- existingClient.setThreads(updatedClient.getThreads());
- existingClient.setClientCQCount(updatedClient.getClientCQCount());
- existingClient.setSubscriptionEnabled(updatedClient.isSubscriptionEnabled());
- long elapsedTime = updatedClient.getUptime()
- - existingClient.getUptime();
- existingClient.setUptime(updatedClient.getUptime());
-
- // set cpu usage
- long lastCPUTime = 0;
- lastCPUTime = existingClient.getProcessCpuTime();
- long currCPUTime = 0;
- currCPUTime = updatedClient.getProcessCpuTime();
-
- double newCPUTime = (double) (currCPUTime - lastCPUTime)
- / (elapsedTime * 1000000000);
-
- double newCPUUsage = 0;
- int availableCpus = updatedClient.getCpus();
- if (availableCpus > 0) {
- newCPUUsage = newCPUTime / availableCpus;
- }
-
- existingClient.setCpuUsage(newCPUUsage);
- existingClient.setProcessCpuTime(currCPUTime);
-
- } else {
- // Add client to clients list
- memberClientsHMap.put(clientId, client);
- }
-
- }
-
- // Remove unwanted entries from clients list
- HashMap<String, Cluster.Client> memberClientsHMapNew = new HashMap<String, Cluster.Client>();
- for (Map.Entry<String, Cluster.Client> entry : memberClientsHMap
- .entrySet()) {
- String clientId = entry.getKey();
- if (memberClientsHM.get(clientId) != null) {
- memberClientsHMapNew.put(clientId, memberClientsHMap.get(clientId));
- }
- }
- // replace existing memberClientsHMap by memberClientsHMapNew
- this.setMemberClientsHMap(memberClientsHMapNew);
-
- // update last update time
- Cluster.LAST_UPDATE_TIME = systemNanoTime;
-
- }
-
- }
-
- /**
- * Member Inner Class
- *
- *
- */
- public static class Statement {
-
- private String queryDefn;
- private long numTimesCompiled;
- private long numExecution;
- private long numExecutionsInProgress;
- private long numTimesGlobalIndexLookup;
- private long numRowsModified;
- private long parseTime;
- private long bindTime;
- private long optimizeTime;
- private long routingInfoTime;
- private long generateTime;
- private long totalCompilationTime;
- private long executionTime;
- private long projectionTime;
- private long totalExecutionTime;
- private long rowsModificationTime;
- private long qNNumRowsSeen;
- private long qNMsgSendTime;
- private long qNMsgSerTime;
- private long qNRespDeSerTime;
-
- public static String[] getGridColumnNames() {
- String[] colNames = new String[] {
- PulseConstants.MBEAN_COLNAME_QUERYDEFINITION,
- PulseConstants.MBEAN_COLNAME_NUMEXECUTION,
- PulseConstants.MBEAN_COLNAME_TOTALEXECUTIONTIME,
- PulseConstants.MBEAN_COLNAME_NUMEXECUTIONSINPROGRESS,
- PulseConstants.MBEAN_COLNAME_NUMTIMESCOMPILED,
- PulseConstants.MBEAN_COLNAME_NUMTIMESGLOBALINDEXLOOKUP,
- PulseConstants.MBEAN_COLNAME_NUMROWSMODIFIED,
- PulseConstants.MBEAN_COLNAME_PARSETIME,
- PulseConstants.MBEAN_COLNAME_BINDTIME,
- PulseConstants.MBEAN_COLNAME_OPTIMIZETIME,
- PulseConstants.MBEAN_COLNAME_ROUTINGINFOTIME,
- PulseConstants.MBEAN_COLNAME_GENERATETIME,
- PulseConstants.MBEAN_COLNAME_TOTALCOMPILATIONTIME,
- PulseConstants.MBEAN_COLNAME_EXECUTIONTIME,
- PulseConstants.MBEAN_COLNAME_PROJECTIONTIME,
- PulseConstants.MBEAN_COLNAME_ROWSMODIFICATIONTIME,
- PulseConstants.MBEAN_COLNAME_QNNUMROWSSEEN,
- PulseConstants.MBEAN_COLNAME_QNMSGSENDTIME,
- PulseConstants.MBEAN_COLNAME_QNMSGSERTIME,
- PulseConstants.MBEAN_COLNAME_QNRESPDESERTIME };
- return colNames;
- }
-
- public static String[] getGridColumnAttributes() {
- String[] colAttributes = new String[] {
- PulseConstants.MBEAN_ATTRIBUTE_QUERYDEFINITION,
- PulseConstants.MBEAN_ATTRIBUTE_NUMEXECUTION,
- PulseConstants.MBEAN_ATTRIBUTE_TOTALEXECUTIONTIME,
- PulseConstants.MBEAN_ATTRIBUTE_NUMEXECUTIONSINPROGRESS,
- PulseConstants.MBEAN_ATTRIBUTE_NUMTIMESCOMPILED,
- PulseConstants.MBEAN_ATTRIBUTE_NUMTIMESGLOBALINDEXLOOKUP,
- PulseConstants.MBEAN_ATTRIBUTE_NUMROWSMODIFIED,
- PulseConstants.MBEAN_ATTRIBUTE_PARSETIME,
- PulseConstants.MBEAN_ATTRIBUTE_BINDTIME,
- PulseConstants.MBEAN_ATTRIBUTE_OPTIMIZETIME,
- PulseConstants.MBEAN_ATTRIBUTE_ROUTINGINFOTIME,
- PulseConstants.MBEAN_ATTRIBUTE_GENERATETIME,
- PulseConstants.MBEAN_ATTRIBUTE_TOTALCOMPILATIONTIME,
- PulseConstants.MBEAN_ATTRIBUTE_EXECUTIONTIME,
- PulseConstants.MBEAN_ATTRIBUTE_PROJECTIONTIME,
-
- PulseConstants.MBEAN_ATTRIBUTE_ROWSMODIFICATIONTIME,
- PulseConstants.MBEAN_ATTRIBUTE_QNNUMROWSSEEN,
- PulseConstants.MBEAN_ATTRIBUTE_QNMSGSENDTIME,
- PulseConstants.MBEAN_ATTRIBUTE_QNMSGSERTIME,
- PulseConstants.MBEAN_ATTRIBUTE_QNRESPDESERTIME };
- return colAttributes;
- }
-
- public static int[] getGridColumnWidths() {
- int[] colWidths = new int[] { 300, 150, 160, 180, 150, 200, 150, 130, 130,
- 160, 140, 180, 170, 160, 130, 190, 170, 170, 170, 200 };
- return colWidths;
- }
-
- /**
- * @return the numTimesCompiled
- */
- public String getQueryDefinition() {
- return queryDefn;
- }
-
- /**
- * @param queryDefn
- * the query to set
- */
- public void setQueryDefinition(String queryDefn) {
- this.queryDefn = queryDefn;
- }
-
- /**
- * @return the numTimesCompiled
- */
- public long getNumTimesCompiled() {
- return numTimesCompiled;
- }
-
- /**
- * @param numTimesCompiled
- * the numTimesCompiled to set
- */
- public void setNumTimesCompiled(long numTimesCompiled) {
- this.numTimesCompiled = numTimesCompiled;
- }
-
- /**
- * @return the numExecution
- */
- public long getNumExecution() {
- return numExecution;
- }
-
- /**
- * @param numExecution
- * the numExecution to set
- */
- public void setNumExecution(long numExecution) {
- this.numExecution = numExecution;
- }
-
- /**
- * @return the numExecutionsInProgress
- */
- public long getNumExecutionsInProgress() {
- return numExecutionsInProgress;
- }
-
- /**
- * @param numExecutionsInProgress
- * the numExecutionsInProgress to set
- */
- public void setNumExecutionsInProgress(long numExecutionsInProgress) {
- this.numExecutionsInProgress = numExecutionsInProgress;
- }
-
- /**
- * @return the numTimesGlobalIndexLookup
- */
- public long getNumTimesGlobalIndexLookup() {
- return numTimesGlobalIndexLookup;
- }
-
- /**
- * @param numTimesGlobalIndexLookup
- * the numTimesGlobalIndexLookup to set
- */
- public void setNumTimesGlobalIndexLookup(long numTimesGlobalIndexLookup) {
- this.numTimesGlobalIndexLookup = numTimesGlobalIndexLookup;
- }
-
- /**
- * @return the numRowsModified
- */
- public long getNumRowsModified() {
- return numRowsModified;
- }
-
- /**
- * @param numRowsModified
- * the numRowsModified to set
- */
- public void setNumRowsModified(long numRowsModified) {
- this.numRowsModified = numRowsModified;
- }
-
- /**
- * @return the parseTime
- */
- public long getParseTime() {
- return parseTime;
- }
-
- /**
- * @param parseTime
- * the parseTime to set
- */
- public void setParseTime(long parseTime) {
- this.parseTime = parseTime;
- }
-
- /**
- * @return the bindTime
- */
- public long getBindTime() {
- return bindTime;
- }
-
- /**
- * @param bindTime
- * the bindTime to set
- */
- public void setBindTime(long bindTime) {
- this.bindTime = bindTime;
- }
-
- /**
- * @return the optimizeTime
- */
- public long getOptimizeTime() {
- return optimizeTime;
- }
-
- /**
- * @param optimizeTime
- * the optimizeTime to set
- */
- public void setOptimizeTime(long optimizeTime) {
- this.optimizeTime = optimizeTime;
- }
-
- /**
- * @return the routingInfoTime
- */
- public long getRoutingInfoTime() {
- return routingInfoTime;
- }
-
- /**
- * @param routingInfoTime
- * the routingInfoTime to set
- */
- public void setRoutingInfoTime(long routingInfoTime) {
- this.routingInfoTime = routingInfoTime;
- }
-
- /**
- * @return the generateTime
- */
- public long getGenerateTime() {
- return generateTime;
- }
-
- /**
- * @param generateTime
- * the generateTime to set
- */
- public void setGenerateTime(long generateTime) {
- this.generateTime = generateTime;
- }
-
- /**
- * @return the totalCompilationTime
- */
- public long getTotalCompilationTime() {
- return totalCompilationTime;
- }
-
- /**
- * @param totalCompilationTime
- * the totalCompilationTime to set
- */
- public void setTotalCompilationTime(long totalCompilationTime) {
- this.totalCompilationTime = totalCompilationTime;
- }
-
- /**
- * @return the executionTime
- */
- public long getExecutionTime() {
- return executionTime;
- }
-
- /**
- * @param executionTime
- * the executionTime to set
- */
- public void setExecutionTime(long executionTime) {
- this.executionTime = executionTime;
- }
-
- /**
- * @return the projectionTime
- */
- public long getProjectionTime() {
- return projectionTime;
- }
-
- /**
- * @param projectionTime
- * the projectionTime to set
- */
- public void setProjectionTime(long projectionTime) {
- this.projectionTime = projectionTime;
- }
-
- /**
- * @return the totalExecutionTime
- */
- public long getTotalExecutionTime() {
- return totalExecutionTime;
- }
-
- /**
- * @param totalExecutionTime
- * the totalExecutionTime to set
- */
- public void setTotalExecutionTime(long totalExecutionTime) {
- this.totalExecutionTime = totalExecutionTime;
- }
-
- /**
- * @return the rowsModificationTime
- */
- public long getRowsModificationTime() {
- return rowsModificationTime;
- }
-
- /**
- * @param rowsModificationTime
- * the rowsModificationTime to set
- */
- public void setRowsModificationTime(long rowsModificationTime) {
- this.rowsModificationTime = rowsModificationTime;
- }
-
- /**
- * @return the qNNumRowsSeen
- */
- public long getqNNumRowsSeen() {
- return qNNumRowsSeen;
- }
-
- /**
- * @param qNNumRowsSeen
- * the qNNumRowsSeen to set
- */
- public void setqNNumRowsSeen(long qNNumRowsSeen) {
- this.qNNumRowsSeen = qNNumRowsSeen;
- }
-
- /**
- * @return the qNMsgSendTime
- */
- public long getqNMsgSendTime() {
- return qNMsgSendTime;
- }
-
- /**
- * @param qNMsgSendTime
- * the qNMsgSendTime to set
- */
- public void setqNMsgSendTime(long qNMsgSendTime) {
- this.qNMsgSendTime = qNMsgSendTime;
- }
-
- /**
- * @return the qNMsgSerTime
- */
- public long getqNMsgSerTime() {
- return qNMsgSerTime;
- }
-
- /**
- * @param qNMsgSerTime
- * the qNMsgSerTime to set
- */
- public void setqNMsgSerTime(long qNMsgSerTime) {
- this.qNMsgSerTime = qNMsgSerTime;
- }
-
- /**
- * @return the qNRespDeSerTime
- */
- public long getqNRespDeSerTime() {
- return qNRespDeSerTime;
- }
-
- /**
- * @param qNRespDeSerTime
- * the qNRespDeSerTime to set
- */
- public void setqNRespDeSerTime(long qNRespDeSerTime) {
- this.qNRespDeSerTime = qNRespDeSerTime;
- }
- }
-
- public static class RegionOnMember {
-
- public static final int REGION_ON_MEMBER_STAT_GETS_PER_SEC_TREND = 0;
- public static final int REGION_ON_MEMBER_STAT_PUTS_PER_SEC_TREND = 1;
- public static final int REGION_ON_MEMBER_STAT_DISK_READS_PER_SEC_TREND = 3;
- public static final int REGION_ON_MEMBER_STAT_DISK_WRITES_PER_SEC_TREND = 4;
-
- private String regionFullPath;
- private String memberName;
- private long entrySize;
- private long entryCount;
- private double getsRate;
- private double putsRate;
- private double diskGetsRate;
- private double diskPutsRate;
- private int localMaxMemory;
-
- private CircularFifoBuffer getsPerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer putsPerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer diskReadsPerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer diskWritesPerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
-
- /**
- * @return the entrySize
- */
- public long getEntrySize() {
- return entrySize;
- }
-
- /**
- * @param entrySize the entrySize to set
- */
- public void setEntrySize(long entrySize) {
- this.entrySize = entrySize;
- }
-
- /**
- * @return the entryCount
- */
- public long getEntryCount() {
- return entryCount;
- }
-
- /**
- * @param entryCount the entryCount to set
- */
- public void setEntryCount(long entryCount) {
- this.entryCount = entryCount;
- }
-
- /**
- * @return the putsRate
- */
- public double getPutsRate() {
- return putsRate;
- }
-
- /**
- * @param putsRate the putsRate to set
- */
- public void setPutsRate(double putsRate) {
- this.putsRate = putsRate;
- }
-
- /**
- * @return the getsRate
- */
- public double getGetsRate() {
- return getsRate;
- }
-
- /**
- * @param getsRate the getsRate to set
- */
- public void setGetsRate(double getsRate) {
- this.getsRate = getsRate;
- }
-
- /**
- * @return the diskGetsRate
- */
- public double getDiskGetsRate() {
- return diskGetsRate;
- }
-
- /**
- * @param diskGetsRate the diskGetsRate to set
- */
- public void setDiskGetsRate(double diskGetsRate) {
- this.diskGetsRate = diskGetsRate;
- }
-
- /**
- * @return the diskPutsRate
- */
- public double getDiskPutsRate() {
- return diskPutsRate;
- }
-
- /**
- * @param diskPutsRate the diskPutsRate to set
- */
- public void setDiskPutsRate(double diskPutsRate) {
- this.diskPutsRate = diskPutsRate;
- }
-
- /**
- * @return the local maximum memory
- */
- public int getLocalMaxMemory() {
- return this.localMaxMemory;
- }
-
- /**
- * @param localMaxMemory
- */
- public void setLocalMaxMemory(int localMaxMemory) {
- this.localMaxMemory = localMaxMemory;
- }
-
- /**
- * @return the getsPerSecTrend
- */
- public CircularFifoBuffer getGetsPerSecTrend() {
- return getsPerSecTrend;
- }
-
- /**
- * @param getsPerSecTrend the getsPerSecTrend to set
- */
- public void setGetsPerSecTrend(CircularFifoBuffer getsPerSecTrend) {
- this.getsPerSecTrend = getsPerSecTrend;
- }
-
- /**
- * @return the putsPerSecTrend
- */
- public CircularFifoBuffer getPutsPerSecTrend() {
- return putsPerSecTrend;
- }
-
- /**
- * @param putsPerSecTrend the putsPerSecTrend to set
- */
- public void setPutsPerSecTrend(CircularFifoBuffer putsPerSecTrend) {
- this.putsPerSecTrend = putsPerSecTrend;
- }
-
- /**
- * @return the diskReadsPerSecTrend
- */
- public CircularFifoBuffer getDiskReadsPerSecTrend() {
- return diskReadsPerSecTrend;
- }
-
- /**
- * @param diskReadsPerSecTrend the diskReadsPerSecTrend to set
- */
- public void setDiskReadsPerSecTrend(CircularFifoBuffer diskReadsPerSecTrend) {
- this.diskReadsPerSecTrend = diskReadsPerSecTrend;
- }
-
- /**
- * @return the diskWritesPerSecTrend
- */
- public CircularFifoBuffer getDiskWritesPerSecTrend() {
- return diskWritesPerSecTrend;
- }
-
- /**
- * @param diskWritesPerSecTrend the diskWritesPerSecTrend to set
- */
- public void setDiskWritesPerSecTrend(CircularFifoBuffer diskWritesPerSecTrend) {
- this.diskWritesPerSecTrend = diskWritesPerSecTrend;
- }
-
- public Object[] getRegionOnMemberStatisticTrend(int trendId) {
-
- Object[] returnArray = null;
- switch (trendId) {
- case REGION_ON_MEMBER_STAT_GETS_PER_SEC_TREND:
- synchronized (this.getsPerSecTrend) {
- returnArray = this.getsPerSecTrend.toArray();
- }
- break;
-
- case REGION_ON_MEMBER_STAT_PUTS_PER_SEC_TREND:
- synchronized (this.putsPerSecTrend) {
- returnArray = this.putsPerSecTrend.toArray();
- }
- break;
-
- case REGION_ON_MEMBER_STAT_DISK_READS_PER_SEC_TREND:
- synchronized (this.diskReadsPerSecTrend) {
- returnArray = this.diskReadsPerSecTrend.toArray();
- }
- break;
-
- case REGION_ON_MEMBER_STAT_DISK_WRITES_PER_SEC_TREND:
- synchronized (this.diskWritesPerSecTrend) {
- returnArray = this.diskWritesPerSecTrend.toArray();
- }
- break;
- }
-
- return returnArray;
- }
-
- /**
- * @return the regionFullPath
- */
- public String getRegionFullPath() {
- return regionFullPath;
- }
-
- /**
- * @param regionFullPath the regionFullPath to set
- */
- public void setRegionFullPath(String regionFullPath) {
- this.regionFullPath = regionFullPath;
- }
-
- /**
- * @return the memberName
- */
- public String getMemberName() {
- return memberName;
- }
-
- /**
- * @param memberName the memberName to set
- */
- public void setMemberName(String memberName) {
- this.memberName = memberName;
- }
- }
-
- /**
- * Region Inner Class
- *
- *
- */
- public static class Region {
- // start: fields defined in MBean
- private String fullPath;
- private double diskReadsRate;
- private double diskWritesRate;
- private double getsRate;
- private double putsRate;
- private double lruEvictionRate;
- private String regionType;
- private long systemRegionEntryCount;
- private int memberCount;
- private String name;
- private boolean persistentEnabled;
- private long entrySize;
- private boolean wanEnabled;
- private int emptyNode;
- private long diskUsage;
- private String scope;
- private String diskStoreName;
- private boolean diskSynchronous;
- private boolean enableOffHeapMemory;
- private String compressionCodec = "";
-
- private List<String> memberName = new ArrayList<String>();
- private List<RegionOnMember> regionOnMembers = new ArrayList<RegionOnMember>();
- private CircularFifoBuffer getsPerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer putsPerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer diskReadsPerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
- private CircularFifoBuffer diskWritesPerSecTrend = new CircularFifoBuffer(
- MAX_SAMPLE_SIZE);
-
- public static final int REGION_STAT_GETS_PER_SEC_TREND = 0;
- public static final int REGION_STAT_PUTS_PER_SEC_TREND = 1;
- public static final int REGION_STAT_DISK_READS_PER_SEC_TREND = 3;
- public static final int REGION_STAT_DISK_WRITES_PER_SEC_TREND = 4;
-
- // end: fields defined in MBean
-
- public Object[] getRegionStatisticTrend(int trendId) {
-
- Object[] returnArray = null;
- switch (trendId) {
- case REGION_STAT_GETS_PER_SEC_TREND:
- synchronized (this.getsPerSecTrend) {
- returnArray = this.getsPerSecTrend.toArray();
- }
- break;
-
- case REGION_STAT_PUTS_PER_SEC_TREND:
- synchronized (this.putsPerSecTrend) {
- returnArray = this.putsPerSecTrend.toArray();
- }
- break;
-
- case REGION_STAT_DISK_READS_PER_SEC_TREND:
- synchronized (this.diskReadsPerSecTrend) {
- returnArray = this.diskReadsPerSecTrend.toArray();
- }
- break;
-
- case REGION_STAT_DISK_WRITES_PER_SEC_TREND:
- synchronized (this.diskWritesPerSecTrend) {
- returnArray = this.diskWritesPerSecTrend.toArray();
- }
- break;
- }
-
- return returnArray;
- }
-
- public boolean isDiskSynchronous() {
- return this.diskSynchronous;
- }
-
- public void setDiskSynchronous(boolean diskSynchronous) {
- this.diskSynchronous = diskSynchronous;
- }
-
- public String getDiskStoreName() {
- return this.diskStoreName;
- }
-
- public void setDiskStoreName(String diskStoreName) {
- this.diskStoreName = diskStoreName;
- }
-
- public String getScope() {
- return this.scope;
- }
-
- public void setScope(String scope) {
- this.scope = scope;
- }
-
- public int getEmptyNode() {
- return this.emptyNode;
- }
-
- public void setEmptyNode(int emptyNode) {
- this.emptyNode = emptyNode;
- }
-
- public long getDiskUsage() {
- return this.diskUsage;
- }
-
- public void setDiskUsage(long diskUsage) {
- this.diskUsage = diskUsage;
- }
-
- public void setEntrySize(long entrySize) {
- this.entrySize = entrySize;
- }
-
- public boolean getWanEnabled() {
- return this.wanEnabled;
- }
-
- public void setWanEnabled(boolean wanEnabled) {
- this.wanEnabled = wanEnabled;
- }
-
- public boolean getPersistentEnabled() {
- return this.persistentEnabled;
- }
-
- public void setPersistentEnabled(boolean persistentEnabled) {
- this.persistentEnabled = persistentEnabled;
- }
-
- public String getName() {
- return this.name;
- }
-
- public void setName(String name) {
- this.name = name;
- }
-
- public long getEntrySize() {
- return this.entrySize;
- }
-
- public List<String> getMemberName() {
- return this.memberName;
- }
-
- public void setMemberName(List<String> memberName) {
- this.memberName = memberName;
- }
-
- public String getFullPath() {
- return this.fullPath;
- }
-
- public void setFullPath(String fullPath) {
- this.fullPath = fullPath;
- }
-
- public double getDiskReadsRate() {
- return this.diskReadsRate;
- }
-
- public void setDiskReadsRate(double diskReadsRate) {
- this.diskReadsRate = diskReadsRate;
- }
-
- public double getDiskWritesRate() {
- return this.diskWritesRate;
- }
-
- public void setDiskWritesRate(double diskWritesRate) {
- this.diskWritesRate = diskWritesRate;
- }
-
- public CircularFifoBuffer getDiskReadsPerSecTrend() {
- return this.diskReadsPerSecTrend;
- }
-
- public void setDiskReadsPerSecTrend(CircularFifoBuffer diskReadsPerSecTrend) {
- this.diskReadsPerSecTrend = diskReadsPerSecTrend;
- }
-
- public CircularFifoBuffer getDiskWritesPerSecTrend() {
- return this.diskWritesPerSecTrend;
- }
-
- public void setDiskWritesPerSecTrend(
- CircularFifoBuffer diskWritesPerSecTrend) {
- this.diskWritesPerSecTrend = diskWritesPerSecTrend;
- }
-
- public double getGetsRate() {
- return this.getsRate;
- }
-
- public void setGetsRate(double getsRate) {
- this.getsRate = getsRate;
- }
-
- public double getLruEvictionRate() {
- return this.lruEvictionRate;
- }
-
- public void setLruEvictionRate(double lruEvictionRate) {
- this.lruEvictionRate = lruEvictionRate;
- }
-
- public String getRegionType() {
- return this.regionType;
- }
-
- public void setRegionType(String regionType) {
- this.regionType = regionType;
- }
-
- public long getSystemRegionEntryCount() {
- return this.systemRegionEntryCount;
- }
-
- public void setSystemRegionEntryCount(long systemRegionEntryCount) {
- this.systemRegionEntryCount = systemRegionEntryCount;
- }
-
- public int getMemberCount() {
- return this.memberCount;
- }
-
- public void setMemberCount(int memberCount) {
- this.memberCount = memberCount;
- }
-
- public double getPutsRate() {
- return this.putsRate;
- }
-
- public void setPutsRate(double putsRate) {
- this.putsRate = putsRate;
- }
-
- public CircularFifoBuffer getGetsPerSecTrend() {
- return this.getsPerSecTrend;
- }
-
- public void setGetsPerSecTrend(CircularFifoBuffer getsPerSecTrend) {
- this.getsPerSecTrend = getsPerSecTrend;
- }
-
- public CircularFifoBuffer getPutsPerSecTrend() {
- return this.putsPerSecTrend;
- }
-
- public void setPutsPerSecTrend(CircularFifoBuffer putsPerSecTrend) {
- this.putsPerSecTrend = putsPerSecTrend;
- }
-
- public boolean isEnableOffHeapMemory() {
- return this.enableOffHeapMemory;
- }
-
- public void setEnableOffHeapMemory(boolean enableOffHeapMemory) {
- this.enableOffHeapMemory = enableOffHeapMemory;
- }
-
- public String getCompressionCodec() {
- return this.compressionCodec;
- }
-
- public void setCompressionCodec(String compressionCodec) {
- this.compressionCodec = compressionCodec;
- }
-
- public Cluster.RegionOnMember[] getRegionOnMembers() {
- Cluster.RegionOnMember[] regionOnMembers = null;
- synchronized (this.regionOnMembers) {
- regionOnMembers = new Cluster.RegionOnMember[this.regionOnMembers.size()];
- regionOnMembers = this.regionOnMembers.toArray(regionOnMembers);
- }
-
- return regionOnMembers;
- }
-
- /**
- * @param regionOnMembers the regionOnMembers to set
- */
- public void setRegionOnMembers(List<RegionOnMember> regionOnMembers) {
- this.regionOnMembers = regionOnMembers;
- }
- }
-
- /**
- * Alert Inner Class
- *
- *
- */
- public static class Alert {
- public static final int SEVERE = 0;
- public static final int ERROR = 1;
- public static final int WARNING = 2;
- public static final int INFO = 3;
-
- public static AtomicInteger ALERT_ID_CTR = new AtomicInteger();
-
- private int id;
- private Date timestamp;
- private int severity;
- private String memberName;
- private String description;
- private boolean isAcknowledged;
- private String iso8601Ts;
-
- public String getIso8601Ts() {
- return iso8601Ts;
- }
-
- public void setIso8601Ts(String iso8601Ts) {
- this.iso8601Ts = iso8601Ts;
- }
-
- public boolean isAcknowledged() {
- return this.isAcknowledged;
- }
-
- public void setAcknowledged(boolean isAcknowledged) {
- this.isAcknowledged = isAcknowledged;
- }
-
- public Date getTimestamp() {
- return this.timestamp;
- }
-
- public void setTimestamp(Date timestamp) {
- this.timestamp = timestamp;
- this.iso8601Ts = formatToISOTimestamp(timestamp);
- }
-
- public int getSeverity() {
- return this.severity;
- }
-
- public void setSeverity(int severity) {
- this.severity = severity;
- }
-
- public String getMemberName() {
- return this.memberName;
- }
-
- public void setMemberName(String memberName) {
- this.memberName = memberName;
- }
-
- public String getDescription() {
- return this.description;
- }
-
- public void setDescription(String description) {
- this.description = description;
- }
-
- public int getId() {
- return this.id;
- }
-
- public void setId(int id) {
- this.id = id;
- }
-
- public static int nextID() {
- /*
- * int id = -1; synchronized (Alert.class) { ALERT_ID_CTR = ALERT_ID_CTR +
- * 1; id = ALERT_ID_CTR; }
- */
- return ALERT_ID_CTR.incrementAndGet();
- }
-
- private static DateFormat df = new SimpleDateFormat(PulseConstants.PULSE_NOTIFICATION_ALERT_DATE_PATTERN);
-
- public static String formatToISOTimestamp(Date date) {
- TimeZone tz = TimeZone.getTimeZone("UTC");
- df.setTimeZone(tz);
- return df.format(date);
- }
-
- }
-
- /**
- * Client Inner Class
- *
- *
- */
- public static class Client {
-
- private String id;
- private String name;
- private String host;
- private int queueSize;
- private double cpuUsage;
- private long uptime;
- private int threads;
- private int gets;
- private int puts;
- private int cpus;
- private int clientCQCount;
- private long processCpuTime;
- private String status;
- private boolean isConnected = false;
- private boolean isSubscriptionEnabled = false;
-
- public String getId() {
- return this.id;
- }
-
- public int getGets() {
- return this.gets;
- }
-
- public int getPuts() {
- return this.puts;
- }
-
- public int getClientCQCount() {
- return clientCQCount;
- }
-
- public void setClientCQCount(int clientCQCount) {
- this.clientCQCount = clientCQCount;
- }
-
- public boolean isSubscriptionEnabled() {
- return isSubscriptionEnabled;
- }
-
- public void setSubscriptionEnabled(boolean isSubscriptionEnabled) {
- this.isSubscriptionEnabled = isSubscriptionEnabled;
- }
-
- public void setId(String id) {
- this.id = id;
- }
-
- public String getName() {
- return this.name;
- }
-
- public void setName(String name) {
- this.name = name;
- }
-
- public String getHost() {
- return this.host;
- }
-
- public void setHost(String host) {
- this.host = host;
- }
-
- public int getQueueSize() {
- return this.queueSize;
- }
-
- public void setQueueSize(int queueSize) {
- this.queueSize = queueSize;
- }
-
- public double getCpuUsage() {
- return this.cpuUsage;
- }
-
- public void setCpuUsage(double cpuUsage) {
- this.cpuUsage = cpuUsage;
- }
-
- public void setGets(int gets) {
- this.gets = gets;
- }
-
- public void setPuts(int puts) {
- this.puts = puts;
- }
-
- public long getUptime() {
- return this.uptime;
- }
-
- public void setUptime(long uptime) {
- this.uptime = uptime;
- }
-
- public int getThreads() {
- return this.threads;
- }
-
- public void setThreads(int threads) {
- this.threads = threads;
- }
-
- public String getStatus() {
- return this.status;
- }
-
- public void setStatus(String status) {
- this.status = status;
- }
-
- public int getCpus() {
- return this.cpus;
- }
-
- public void setCpus(int cpus) {
- this.cpus = cpus;
- }
-
- public long getProcessCpuTime() {
- return this.processCpuTime;
- }
-
- public void setProcessCpuTime(long processCpuTime) {
- this.processCpuTime = processCpuTime;
- }
-
- public boolean isConnected() {
- return isConnected;
- }
-
- public void setConnected(boolean isConnected) {
- this.isConnected = isConnected;
- }
-
- }
-
- /**
- * Gateway Receiver Inner Class
- *
- *
- */
- public static class GatewayReceiver {
-
- private int listeningPort;
- private double linkThroughput;
- private long avgBatchProcessingTime;
- private String id;
- private int queueSize;
- private Boolean status;
- private int batchSize;
-
- public int getListeningPort() {
- return this.listeningPort;
- }
-
- public void setListeningPort(int listeningPort) {
- this.listeningPort = listeningPort;
- }
-
- public double getLinkThroughput() {
- return this.linkThroughput;
- }
-
- public void setLinkThroughput(double linkThroughput) {
- this.linkThroughput = linkThroughput;
- }
-
- public long getAvgBatchProcessingTime() {
- return this.avgBatchProcessingTime;
- }
-
- public void setAvgBatchProcessingTime(long avgBatchProcessingTime) {
- this.avgBatchProcessingTime = avgBatchProcessingTime;
- }
-
- public String getId() {
- return this.id;
- }
-
- public void setId(String id) {
- this.id = id;
- }
-
- public int getQueueSize() {
- return this.queueSize;
- }
-
- public void setQueueSize(int queueSize) {
- this.queueSize = queueSize;
- }
-
- public Boolean getStatus() {
- return this.status;
- }
-
- public void setStatus(Boolean status) {
- this.status = status;
- }
-
- public int getBatchSize() {
- return this.batchSize;
- }
-
- public void setBatchSize(int batchSize) {
- this.batchSize = batchSize;
- }
- }
-
- /**
- * Gateway Sender Inner class
- *
- *
- */
- public static class GatewaySender {
-
- private double linkThroughput;
- private String id;
- private int queueSize;
- private Boolean status;
- private boolean primary;
- private boolean senderType;
- private int batchSize;
- private boolean persistenceEnabled;
- private int remoteDSId;
- private int eventsExceedingAlertThreshold;
-
- public double getLinkThroughput() {
- return this.linkThroughput;
- }
-
- public void setLinkThroughput(double linkThroughput) {
- this.linkThroughput = linkThroughput;
- }
-
- public String getId() {
- return this.id;
- }
-
- public void setId(String id) {
- this.id = id;
- }
-
- public int getQueueSize() {
- return this.queueSize;
- }
-
- public void setQueueSize(int queueSize) {
- this.queueSize = queueSize;
- }
-
- public Boolean getStatus() {
- return this.status;
- }
-
- public void setStatus(Boolean status) {
- this.status = status;
- }
-
- public boolean getPrimary() {
- return this.primary;
- }
-
- public void setPrimary(boolean primary) {
- this.primary = primary;
- }
-
- public boolean getSenderType() {
- return this.senderType;
- }
-
- public void setSenderType(boolean senderType) {
- this.senderType = senderType;
- }
-
- public int getBatchSize() {
- return this.batchSize;
- }
-
- public void setBatchSize(int batchSize) {
- this.batchSize = batchSize;
- }
-
- public boolean getPersistenceEnabled() {
- return this.persistenceEnabled;
- }
-
- public void setPersistenceEnabled(boolean persistenceEnabled) {
- this.persistenceEnabled = persistenceEnabled;
- }
-
- /**
- * @return the remoteDSId
- */
- public int getRemoteDSId() {
- return remoteDSId;
- }
-
- /**
- * @param remoteDSId the remoteDSId to set
- */
- public void setRemoteDSId(int remoteDSId) {
- this.remoteDSId = remoteDSId;
- }
-
- /**
- * @return the eventsExceedingAlertThreshold
- */
- public int getEventsExceedingAlertThreshold() {
- return eventsExceedingAlertThreshold;
- }
-
- /**
- * @param eventsExceedingAlertThreshold the eventsExceedingAlertThreshold to set
- */
- public void setEventsExceedingAlertThreshold(int eventsExceedingAlertThreshold) {
- this.eventsExceedingAlertThreshold = eventsExceedingAlertThreshold;
- }
- }
-
- /**
- * Async Event Queue Inner class
- *
- *
- */
- public static class AsyncEventQueue {
-
- private String id;
- private boolean primary;
- private boolean parallel;
- private int batchSize;
- private long batchTimeInterval;
- private boolean batchConflationEnabled;
- private String asyncEventListener;
- private int eventQueueSize;
-
- public String getId() {
- return this.id;
- }
-
- public void setId(String id) {
- this.id = id;
- }
-
- public boolean getPrimary() {
- return this.primary;
- }
-
- public void setPrimary(boolean primary) {
- this.primary = primary;
- }
-
- /**
- * @return the parallel
- */
- public boolean isParallel() {
- return parallel;
- }
-
- /**
- * @param parallel the parallel to set
- */
- public void setParallel(boolean parallel) {
- this.parallel = parallel;
- }
-
- public int getBatchSize() {
- return this.batchSize;
- }
-
- public void setBatchSize(int batchSize) {
- this.batchSize = batchSize;
- }
-
- /**
- * @return the batchTimeInterval
- */
- public long getBatchTimeInterval() {
- return batchTimeInterval;
- }
-
- /**
- * @param batchTimeInterval the batchTimeInterval to set
- */
- public void setBatchTimeInterval(long batchTimeInterval) {
- this.batchTimeInterval = batchTimeInterval;
- }
-
- /**
- * @return the batchConflationEnabled
- */
- public boolean isBatchConflationEnabled() {
- return batchConflationEnabled;
- }
-
- /**
- * @param batchConflationEnabled the batchConflationEnabled to set
- */
- public void setBatchConflationEnabled(boolean batchConflationEnabled) {
- this.batchConflationEnabled = batchConflationEnabled;
- }
-
- /**
- * @return the asyncEventListener
- */
- public String getAsyncEventListener() {
- return asyncEventListener;
- }
-
- /**
- * @param asyncEventListener the asyncEventListener to set
- */
- public void setAsyncEventListener(String asyncEventListener) {
- this.asyncEventListener = asyncEventListener;
- }
-
- /**
- * @return the eventQueueSize
- */
- public int getEventQueueSize() {
- return eventQueueSize;
- }
-
- /**
- * @param eventQueueSize the eventQueueSize to set
- */
- public void setEventQueueSize(int eventQueueSize) {
- this.eventQueueSize = eventQueueSize;
- }
- }
-
- /**
- * Default constructor only used for testing
- */
- public Cluster() {
- }
-
-
- /**
- * This function is used for calling getUpdator function of ClusterDataFactory
- * and starting the thread for updating the Cluster details.
- *
- * @param host
- * host name
- * @param port
- * port
- * @param userName
- * pulse user name
- * @param userPassword
- * pulse user password
- * @throws ConnectException
- */
- public Cluster(String host, String port, String userName, String userPassword)
- throws ConnectException {
- this.serverName = host;
- this.port = port;
- this.jmxUserName = userName;
- this.jmxUserPassword = userPassword;
-
- this.updater = ClusterDataFactory.getUpdater(this, host, port);
- // start();
- }
-
- /**
- * thread run method for updating the cluster data
- */
- @Override
- public void run() {
- while (!this.stopUpdates) {
- try {
- if (!this.updateData()) {
- this.stale++;
- } else {
- this.stale = 0;
- }
- } catch (Exception e) {
- if (LOGGER.infoEnabled()) {
- LOGGER.info("Exception Occurred while updating cluster data : " + e.getMessage());
- }
- }
-
- try {
- Thread.sleep(POLL_INTERVAL);
- } catch (InterruptedException e) {
- if (LOGGER.infoEnabled()) {
- LOGGER.info("InterruptedException Occurred : " + e.getMessage());
- }
- }
- }
-
- if (LOGGER.infoEnabled()) {
- LOGGER.info(resourceBundle.getString("LOG_MSG_STOP_THREAD_UPDATES")
- + " :: " + this.serverName + ":" + this.port);
- }
- }
-
- /**
- * calling updateData
- *
- * @return true if update was successful. false if it failed.
- */
- private boolean updateData() {
- // This will eventually call JMX. Currently we will update this with
- // some dummy data.
- // Connect if required or hold a connection. If unable to connect,
- // return false
- if (LOGGER.finerEnabled()) {
- LOGGER.finer(resourceBundle.getString("LOG_MSG_CLUSTER_DATA_IS_UPDATING")
- + "::" + this.serverName + ":" + this.port);
- }
- return this.updater.updateData();
- }
-
- /**
- * for stopping the update thread
- */
- public void stopThread() {
- this.stopUpdates = true;
-
- try {
- join();
- } catch (InterruptedException e) {
- if (LOGGER.infoEnabled()) {
- LOGGER.info("InterruptedException occured while stoping cluster thread : " + e.getMessage());
- }
- }
- }
-
- public Map<String, Cluster.Member> getMembersHMap() {
- return this.membersHMap;
- }
-
- public void setMembersHMap(HashMap<String, Cluster.Member> membersHMap) {
- this.membersHMap = membersHMap;
- }
-
- public Map<String, Boolean> getWanInformation() {
- Map<String, Boolean> wanMap = null;
- synchronized (this.wanInformation) {
- wanMap = (Map<String, Boolean>) this.wanInformation.clone();
- }
-
- return wanMap;
- }
-
- // Returns actual wanInformation object reference
- public Map<String, Boolean> getWanInformationObject() {
- return this.wanInformation;
- }
-
- public void setWanInformation(HashMap<String, Boolean> wanInformation) {
- this.wanInformation = wanInformation;
- }
-
- public String getJmxUserName() {
- return this.jmxUserName;
- }
-
- public void setJmxUserName(String jmxUserName) {
- this.jmxUserName = jmxUserName;
- }
-
- public String getJmxUserPassword() {
- return this.jmxUserPassword;
- }
-
- public void setJmxUserPassword(String jmxUserPassword) {
- this.jmxUserPassword = jmxUserPassword;
- }
-
- public String getConnectionErrorMsg() {
- return this.connectionErrorMsg;
- }
-
- public void setConnectionErrorMsg(String connectionErrorMsg) {
- this.connectionErrorMsg = connectionErrorMsg;
- }
-
- public String getServerName() {
- return this.serverName;
- }
-
- public boolean isConnectedFlag() {
- return this.connectedFlag;
- }
-
- public void setConnectedFlag(boolean connectedFlag) {
- this.connectedFlag = connectedFlag;
- }
-
- public String getPort() {
- return this.port;
- }
-
- public int getStale() {
- return this.stale;
- }
-
- public double getWritePerSec() {
- return this.writePerSec;
- }
-
- public void setWritePerSec(double writePerSec) {
- this.writePerSec = writePerSec;
- }
-
- public double getReadPerSec() {
- return this.readPerSec;
- }
-
- public void setReadPerSec(double readPerSec) {
- this.readPerSec = readPerSec;
- }
-
- public double getQueriesPerSec() {
- return this.queriesPerSec;
- }
-
- public void setQueriesPerSec(double queriesPerSec) {
- this.queriesPerSec = queriesPerSec;
- }
-
- public double getLoadPerSec() {
- return this.loadPerSec;
- }
-
- public void setLoadPerSec(double loadPerSec) {
- this.loadPerSec = loadPerSec;
- }
-
- public int getNotificationPageNumber() {
- return this.notificationPageNumber;
- }
-
- public void setNotificationPageNumber(int notificationPageNumber) {
- this.notificationPageNumber = notificationPageNumber;
- }
-
- public void setStale(int stale) {
- this.stale = stale;
- }
-
- public boolean isStopUpdates() {
- return this.stopUpdates;
- }
-
- public void setStopUpdates(boolean stopUpdates) {
- this.stopUpdates = stopUpdates;
- }
-
- public long getUsedHeapSize() {
- return this.usedHeapSize;
- }
-
- public void setUsedHeapSize(long usedHeapSize) {
- this.usedHeapSize = usedHeapSize;
- }
-
- public int getServerCount() {
- return this.serverCount;
- }
-
- public void setServerCount(int serverCount) {
- this.serverCount = serverCount;
- }
-
- public int getTxnCommittedCount() {
- return txnCommittedCount;
- }
-
- public void setTxnCommittedCount(int txnCommittedCount) {
- this.txnCommittedCount = txnCommittedCount;
- }
-
- public int getTxnRollbackCount() {
- return txnRollbackCount;
- }
-
- public void setTxnRollbackCount(int txnRollbackCount) {
- this.txnRollbackCount = txnRollbackCount;
- }
-
- public int getRunningFunctionCount() {
- return this.runningFunctionCount;
- }
-
- public long getRegisteredCQCount() {
- return this.registeredCQCount;
- }
-
- public int getSubscriptionCount() {
- return this.subscriptionCount;
- }
-
- public void setSubscriptionCount(int subscriptionCount) {
- this.subscriptionCount = subscriptionCount;
- }
-
- public void setRegisteredCQCount(long registeredCQCount) {
- this.registeredCQCount = registeredCQCount;
- }
-
- public void setRunningFunctionCount(int runningFunctionCount) {
- this.runningFunctionCount = runningFunctionCount;
- }
-
- public Map<String, Cluster.Region> getClusterRegions() {
- return this.clusterRegionMap;
- }
-
- public Cluster.Region getClusterRegion(String regionFullPath) {
- return this.clusterRegionMap.get(regionFullPath);
- }
-
- public void setClusterRegions(Map<String, Region> clusterRegionMap) {
- this.clusterRegionMap = clusterRegionMap;
- }
-
- public Map<String, Cluster.Statement> getClusterStatements() {
- return this.clusterStatementMap;
- }
-
- public void setClusterStatements(Map<String, Statement> clusterStatementMap) {
- this.clusterStatementMap = clusterStatementMap;
- }
-
- public Alert[] getAlertsList() {
- Alert[] list = null;
- synchronized (this.alertsList) {
- list = new Alert[this.alertsList.size()];
- list = this.alertsList.toArray(list);
- }
-
- return list;
- }
-
- public void setAlertsList(List<Alert> alertsList) {
- this.alertsList = alertsList;
- }
-
- public void setServerName(String serverName) {
- this.serverName = serverName;
- }
-
- public void setPort(String port) {
- this.port = port;
- }
-
- public Set<String> getDeletedMembers() {
- return this.deletedMembers;
- }
-
- public void setDeletedMembers(Set<String> deletedMembers) {
- this.deletedMembers = deletedMembers;
- }
-
- public Set<String> getDeletedRegions() {
- return this.deletedRegions;
- }
-
- public void setDeletedRegions(Set<String> deletedRegions) {
- this.deletedRegions = deletedRegions;
- }
-
- public Map<String, List<Member>> getPhysicalToMember() {
- Map<String, List<Member>> ptom = null;
- // synchronized (physicalToMember) {
- ptom = this.physicalToMember;
- // }
- return ptom;
- }
-
- public void setPhysicalToMember(HashMap<String, List<Member>> physicalToMember) {
- // synchronized (this.physicalToMember) {
- this.physicalToMember = physicalToMember;
- // }
- }
-
- public int getMemberCount() {
- return this.memberCount;
- }
-
- public void setMemberCount(int memberCount) {
- this.memberCount = memberCount;
- }
-
- public long getClientConnectionCount() {
- return this.clientConnectionCount;
- }
-
- public void setClientConnectionCount(long clientConnectionCount) {
- this.clientConnectionCount = clientConnectionCount;
- }
-
- public int getClusterId() {
- return this.clusterId;
- }
-
- public void setClusterId(int clusterId) {
- this.clusterId = clusterId;
- }
-
- public int getLocatorCount() {
- return this.locatorCount;
- }
-
- public void setLocatorCount(int locatorCount) {
- this.locatorCount = locatorCount;
- }
-
- public int getTotalRegionCount() {
- return this.totalRegionCount;
- }
-
- public void setTotalRegionCount(int totalRegionCount) {
- this.totalRegionCount = totalRegionCount;
- }
-
- public long getTotalHeapSize() {
- return this.totalHeapSize;
- }
-
- public void setTotalHeapSize(long totalHeapSize) {
- this.totalHeapSize = totalHeapSize;
- }
-
- public long getTotalRegionEntryCount() {
- return this.totalRegionEntryCount;
- }
-
- public void setTotalRegionEntryCount(long totalRegionEntryCount) {
- this.totalRegionEntryCount = totalRegionEntryCount;
- }
-
- public int getCurrentQueryCount() {
- return this.currentQueryCount;
- }
-
- public void setCurrentQueryCount(int currentQueryCount) {
- this.currentQueryCount = currentQueryCount;
- }
-
- public long getTotalBytesOnDisk() {
- return this.totalBytesOnDisk;
- }
-
- public void setTotalBytesOnDisk(long totalBytesOnDisk) {
- this.totalBytesOnDisk = totalBytesOnDisk;
- }
-
- public double getDiskReadsRate() {
- return this.diskReadsRate;
- }
-
- public void setDiskReadsRate(double diskReadsRate) {
- this.diskReadsRate = diskReadsRate;
- }
-
- public double getDiskWritesRate() {
- return this.diskWritesRate;
- }
-
- public void setDiskWritesRate(double diskWritesRate) {
- this.diskWritesRate = diskWritesRate;
- }
-
- public int getAvgDiskStorage() {
- return this.avgDiskStorage;
- }
-
- public void setAvgDiskStorage(int avgDiskStorage) {
- this.avgDiskStorage = avgDiskStorage;
- }
-
- public int getAvgDiskWritesRate() {
- return this.avgDiskWritesRate;
- }
-
- public void setAvgDiskWritesRate(int avgDiskWritesRate) {
- this.avgDiskWritesRate = avgDiskWritesRate;
- }
-
- public CircularFifoBuffer getWritePerSecTrend() {
- return this.writePerSecTrend;
- }
-
- public void setWritePerSecTrend(CircularFifoBuffer writePerSecTrend) {
- this.writePerSecTrend = writePerSecTrend;
- }
-
- public long getGarbageCollectionCount() {
- return this.garbageCollectionCount;
- }
-
- public void setGarbageCollectionCount(long garbageCollectionCount) {
- this.garbageCollectionCount = garbageCollectionCount;
- }
-
- public CircularFifoBuffer getTotalBytesOnDiskTrend() {
- return this.totalBytesOnDiskTrend;
- }
-
- public void setTotalBytesOnDiskTrend(CircularFifoBuffer totalBytesOnDiskTrend) {
- this.totalBytesOnDiskTrend = totalBytesOnDiskTrend;
- }
-
- public CircularFifoBuffer getThroughoutWritesTrend() {
- return this.throughoutWritesTrend;
- }
-
- public void setThroughoutWritesTrend(CircularFifoBuffer throughoutWritesTrend) {
- this.throughoutWritesTrend = throughoutWritesTrend;
- }
-
- public CircularFifoBuffer getThroughoutReadsTrend() {
- return this.throughoutReadsTrend;
- }
-
- public void setThroughoutReadsTrend(CircularFifoBuffer throughoutReadsTrend) {
- this.throughoutReadsTrend = throughoutReadsTrend;
- }
-
- public CircularFifoBuffer getReadPerSecTrend() {
- return this.readPerSecTrend;
- }
-
- public void setReadPerSecTrend(CircularFifoBuffer readPerSecTrend) {
- this.readPerSecTrend = readPerSecTrend;
- }
-
- public CircularFifoBuffer getQueriesPerSecTrend() {
- return this.queriesPerSecTrend;
- }
-
- public void setQueriesPerSecTrend(CircularFifoBuffer queriesPerSecTrend) {
- this.queriesPerSecTrend = queriesPerSecTrend;
- }
-
- public CircularFifoBuffer getMemoryUsageTrend() {
- return this.memoryUsageTrend;
- }
-
- public void setMemoryUsageTrend(CircularFifoBuffer memoryUsageTrend) {
- this.memoryUsageTrend = memoryUsageTrend;
- }
-
- public CircularFifoBuffer getGarbageCollectionTrend() {
- return this.garbageCollectionTrend;
- }
-
- public void setGarbageCollectionTrend(
- CircularFifoBuffer garbageCollectionSamples) {
- this.garbageCollectionTrend = garbageCollectionSamples;
- }
-
- public long getPreviousJVMPauseCount() {
- return this.previousJVMPauseCount;
- }
-
- public void setPreviousJVMPauseCount(long previousJVMPauseCount) {
- this.previousJVMPauseCount = previousJVMPauseCount;
- }
-
- public DataBrowser getDataBrowser() {
- // Initialize dataBrowser if null
- if (this.dataBrowser == null) {
- this.dataBrowser = new DataBrowser();
- }
- return this.dataBrowser;
- }
-
- public void setDataBrowser(DataBrowser dataBrowser) {
- this.dataBrowser = dataBrowser;
- }
-
- public ObjectNode executeQuery(String queryText, String members, int limit) {
- // Execute data browser query
- return this.updater.executeQuery(queryText, members, limit);
- }
-
- public ArrayNode getQueryHistoryByUserId(String userId) {
- return this.getDataBrowser().getQueryHistoryByUserId(userId);
- }
-
- public boolean addQueryInHistory(String queryText, String userName) {
- return this.getDataBrowser().addQueryInHistory(queryText, userName);
- }
-
- public boolean deleteQueryById(String userId, String queryId) {
- return this.getDataBrowser().deleteQueryById(userId, queryId);
- }
-
- public JMXConnector connectToGemFire() {
- if(this.updater instanceof JMXDataUpdater) {
- return ((JMXDataUpdater) this.updater).getJMXConnection(false);
- } else {
- return null;
- }
- }
-
- /**
- * inner class for creating Mock Data
- *
- *
- */
- public class MockDataUpdater implements IClusterUpdater {
- public MockDataUpdater() {
- }
-
- /**
- * function used for updating Cluster data for Mock
- */
- @Override
- public boolean updateData() {
- setConnectedFlag(true);
- Random r = new Random(System.currentTimeMillis());
- totalHeapSize = (long) Math.abs(r.nextInt(3200 - 2048) + 2048);
- usedHeapSize = (long) Math.abs(r.nextInt(2048));
- writePerSec = Math.abs(r.nextInt(100));
- subscriptionCount = Math.abs(r.nextInt(100));
- registeredCQCount = (long) Math.abs(r.nextInt(100));
- txnCommittedCount = Math.abs(r.nextInt(100));
- txnRollbackCount = Math.abs(r.nextInt(100));
- runningFunctionCount = Math.abs(r.nextInt(100));
- clusterId = Math.abs(r.nextInt(100));
- writePerSecTrend.add(writePerSec);
- diskWritesRate = writePerSec;
- garbageCollectionCount = (long) Math.abs(r.nextInt(100));
- garbageCollectionTrend.add(garbageCollectionCount);
-
- readPerSec = Math.abs(r.nextInt(100));
- readPerSecTrend.add(readPerSec);
-
- diskReadsRate = readPerSec;
- queriesPerSec = Math.abs(r.nextInt(100));
- queriesPerSecTrend.add(queriesPerSec);
-
- loadPerSec = Math.abs(r.nextInt(100));
- totalHeapSize = totalHeapSize;
- totalBytesOnDisk = totalHeapSize;
-
- totalBytesOnDiskTrend.add(totalBytesOnDisk);
-
- memoryUsageTrend.add(usedHeapSize);
- throughoutWritesTrend.add(writePerSec);
- throughoutReadsTrend.add(readPerSec);
-
- memberCount = 0;
-
- // Create 3 members first time around
- if (membersHMap.size() == 0) {
-
- membersHMap.put(
- "pnq-visitor1",
- initializeMember(
- "pnq-visitor1(Launcher_Manager-1099-13-40-24-5368)-24357",
- "pnq-visitor1", true, true, true, true));
-
- for (int i = 2; i <= 8; i++) {
- if ((i % 2) == 0) {
- membersHMap.put(
- "pnq-visitor" + i,
- initializeMember("pnq-visitor" + i
- + "(Launcher_Server-1099-13-40-24-5368)-24357",
- "pnq-visitor" + i, false, false, true, false));
- } else {
- if ((i % 3) == 0) {
- membersHMap.put(
- "pnq-visitor" + i,
- initializeMember("pnq-visitor" + i
- + "(Launcher_Server-1099-13-40-24-5368)-24357",
- "pnq-visitor" + i, false, false, false, false));
- } else {
- membersHMap.put(
- "pnq-visitor" + i,
- initializeMember("pnq-visitor" + i
- + "(Launcher_Server-1099-13-40-24-5368)-24357",
- "pnq-visitor" + i, false, true, true, true));
- }
- }
- }
-
- for (Entry<String, Member> memberSet : membersHMap.entrySet()) {
- HashMap<String, Cluster.Region> memberRegions = new HashMap<String, Cluster.Region>();
- HashMap<String, Cluster.Client> memberClientsHM = new HashMap<String, Cluster.Client>();
-
- Random randomGenerator = new Random();
- int randomInt = (randomGenerator.nextInt(15)) + 10;
- int regionExists = 0;
- for (int y = 0; y < randomInt; y++) {
- Region region = initMemberRegion(y, memberSet.getValue().getName());
- if (clusterRegionMap.entrySet().size() > 0) {
- for (Region clusterRegion : clusterRegionMap.values()) {
- if ((region.name).equals(clusterRegion.name)) {
- clusterRegion.memberName.add(memberSet.getValue().getName());
- clusterRegion.memberCount = clusterRegion.memberCount + 1;
- regionExists = 1;
- break;
- }
- }
- if (regionExists == 0) {
- addClusterRegion(region.getFullPath(), region);
- }
- } else {
- addClusterRegion(region.getFullPath(), region);
- }
- memberRegions.put(region.getFullPath(), region);
- totalRegionCount = clusterRegionMap.values().size();
- }
- membersHMap.get(memberSet.getKey()).setMemberRegions(memberRegions);
-
- if (memberSet.getValue().isCache) {
- Client client = initMemberClient(0, memberSet.getValue().getHost());
- memberClientsHM.put(client.getId(), client);
- randomInt = randomGenerator.nextInt(10);
- for (int y = 1; y < randomInt; y++) {
- Client newClient = initMemberClient(y, memberSet.getValue()
- .getHost());
- memberClientsHM.put(newClient.getId(), newClient);
- }
- membersHMap.get(memberSet.getKey()).updateMemberClientsHMap(
- memberClientsHM);
- clientConnectionCount = clientConnectionCount
- + membersHMap.get(memberSet.getKey()).getMemberClientsHMap()
- .size();
- }
-
- }
- }
-
- // add additional regions to members
- for (Entry<String, Member> memberSet : membersHMap.entrySet()) {
- HashMap<String, Cluster.Region> memberRegions = new HashMap<String, Cluster.Region>();
-
- Random randomGenerator = new Random();
- int randomInt = (randomGenerator.nextInt(5)) + 5;
- int regionExists = 0;
- for (int y = 0; y < randomInt; y++) {
- Region region = initMemberRegion(y, memberSet.getValue().getName());
- if (clusterRegionMap.entrySet().size() > 0) {
- for (Region clusterRegion : clusterRegionMap.values()) {
- if ((region.name).equals(clusterRegion.name)) {
- clusterRegion.memberName.add(memberSet.getValue().getName());
- clusterRegion.memberCount = clusterRegion.memberCount + 1;
- regionExists = 1;
- break;
- }
- }
- if (regionExists == 0) {
- addClusterRegion(region.getFullPath(), region);
- }
- } else {
- addClusterRegion(region.getFullPath(), region);
- }
- memberRegions.put(region.getFullPath(), region);
- totalRegionCount = clusterRegionMap.values().size();
- }
- membersHMap.get(memberSet.getKey()).setMemberRegions(memberRegions);
-
- }
-
- wanInformation.clear();
- int wanInfoSize = Math.abs(r.nextInt(10));
- wanInfoSize++;
- for (int i = 0; i < wanInfoSize; i++) {
- String name = "Mock Cluster" + i;
- Boolean value = false;
- if (i % 2 == 0) {
- value = true;
- }
- wanInformation.put(name, value);
- }
- memberCount = membersHMap.size();
-
- totalHeapSize = (long) 0;
- for (Entry<String, Member> memberSet : membersHMap.entrySet()) {
- refresh(membersHMap.get(memberSet.getKey()));
- Member member = membersHMap.get(memberSet.getKey());
- totalHeapSize += member.currentHeapSize;
- }
-
- for (Region region : clusterRegionMap.values()) {
- // Memory reads and writes
- region.getsRate = (Math.abs(r.nextInt(100))) + 1;
- region.putsRate = (Math.abs(r.nextInt(100))) + 1;
- region.getsPerSecTrend.add(region.getsRate);
- region.putsPerSecTrend.add(region.putsRate);
-
- // Disk reads and writes
- region.diskReadsRate = (Math.abs(r.nextInt(100))) + 1;
- region.diskWritesRate = (Math.abs(r.nextInt(100))) + 1;
- region.diskReadsPerSecTrend.add(region.diskReadsRate);
- region.diskWritesPerSecTrend.add(region.diskWritesRate);
- }
-
- if(clusterStatementMap.size() < 500){
- for(int i = 1; i <= 500;
<TRUNCATED>