+/*
+ * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
package org.opendaylight.controller.cluster.datastore.jmx.mbeans.shard;
-import org.opendaylight.controller.cluster.datastore.jmx.mbeans.AbstractBaseMBean;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+import java.util.concurrent.atomic.AtomicLong;
+import org.opendaylight.controller.md.sal.common.util.jmx.AbstractMXBean;
+import org.opendaylight.controller.md.sal.common.util.jmx.QueuedNotificationManagerMXBeanImpl;
+import org.opendaylight.controller.md.sal.common.util.jmx.ThreadExecutorStats;
+import org.opendaylight.controller.md.sal.common.util.jmx.ThreadExecutorStatsMXBeanImpl;
+import org.opendaylight.controller.md.sal.dom.store.impl.InMemoryDOMDataStore;
+import org.opendaylight.yangtools.util.concurrent.ListenerNotificationQueueStats;
+import org.opendaylight.yangtools.util.concurrent.QueuedNotificationManager;
/**
- * @author: syedbahm
+ * Maintains statistics for a shard.
+ *
+ * @author Basheeruddin syedbahm@cisco.com
*/
-public class ShardStats extends AbstractBaseMBean implements ShardStatsMBean {
- private Long committedTransactionsCount;
- private Long journalMessagesCount;
- final private String shardName;
- private String leader;
- private String raftState;
+public class ShardStats extends AbstractMXBean implements ShardStatsMXBean {
+ public static String JMX_CATEGORY_SHARD = "Shards";
+
+ private long committedTransactionsCount;
+
+ private long readOnlyTransactionCount;
+
+ private long writeOnlyTransactionCount;
+
+ private long readWriteTransactionCount;
+
+ private String leader;
+
+ private String raftState;
+
+ private long lastLogTerm = -1L;
+
+ private long lastLogIndex = -1L;
+
+ private long currentTerm = -1L;
+
+ private long commitIndex = -1L;
+
+ private long lastApplied = -1L;
+
+ private long lastCommittedTransactionTime;
+
+ private long failedTransactionsCount;
+
+ private final AtomicLong failedReadTransactionsCount = new AtomicLong();
+
+ private long abortTransactionsCount;
+
+ private ThreadExecutorStatsMXBeanImpl notificationExecutorStatsBean;
+
+ private QueuedNotificationManagerMXBeanImpl notificationManagerStatsBean;
+
+ private long dataSize = 0;
+
+ private final SimpleDateFormat sdf =
+ new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
+
+ private boolean followerInitialSyncStatus = false;
+
+ public ShardStats(final String shardName, final String mxBeanType) {
+ super(shardName, mxBeanType, JMX_CATEGORY_SHARD);
+ }
+
+ public void setNotificationManager(final QueuedNotificationManager<?, ?> manager) {
+ this.notificationManagerStatsBean = new QueuedNotificationManagerMXBeanImpl(manager,
+ "notification-manager", getMBeanType(), getMBeanCategory());
+
+ this.notificationExecutorStatsBean = ThreadExecutorStatsMXBeanImpl.create(manager.getExecutor());
+ }
+
+ @Override
+ public String getShardName() {
+ return getMBeanName();
+ }
+
+ @Override
+ public long getCommittedTransactionsCount() {
+ return committedTransactionsCount;
+ }
+
+ @Override
+ public String getLeader() {
+ return leader;
+ }
+
+ @Override
+ public String getRaftState() {
+ return raftState;
+ }
+
+ @Override
+ public long getReadOnlyTransactionCount() {
+ return readOnlyTransactionCount;
+ }
+
+ @Override
+ public long getWriteOnlyTransactionCount() {
+ return writeOnlyTransactionCount;
+ }
+
+ @Override
+ public long getReadWriteTransactionCount() {
+ return readWriteTransactionCount;
+ }
+
+ @Override
+ public long getLastLogIndex() {
+ return lastLogIndex;
+ }
+
+ @Override
+ public long getLastLogTerm() {
+ return lastLogTerm;
+ }
+
+ @Override
+ public long getCurrentTerm() {
+ return currentTerm;
+ }
+
+ @Override
+ public long getCommitIndex() {
+ return commitIndex;
+ }
+
+ @Override
+ public long getLastApplied() {
+ return lastApplied;
+ }
+
+ @Override
+ public String getLastCommittedTransactionTime() {
+
+ return sdf.format(new Date(lastCommittedTransactionTime));
+ }
+
+ @Override
+ public long getFailedTransactionsCount() {
+ return failedTransactionsCount;
+ }
+
+ @Override
+ public long getFailedReadTransactionsCount() {
+ return failedReadTransactionsCount.get();
+ }
+
+ @Override
+ public long getAbortTransactionsCount() {
+ return abortTransactionsCount;
+ }
+
+ public long incrementCommittedTransactionCount() {
+ return ++committedTransactionsCount;
+ }
+
+ public long incrementReadOnlyTransactionCount() {
+ return ++readOnlyTransactionCount;
+ }
+
+ public long incrementWriteOnlyTransactionCount() {
+ return ++writeOnlyTransactionCount;
+ }
+
+ public long incrementReadWriteTransactionCount() {
+ return ++readWriteTransactionCount;
+ }
+
+ public long incrementFailedTransactionsCount() {
+ return ++failedTransactionsCount;
+ }
+
+ public long incrementFailedReadTransactionsCount() {
+ return failedReadTransactionsCount.incrementAndGet();
+ }
+
+ public long incrementAbortTransactionsCount ()
+ {
+ return ++abortTransactionsCount;
+ }
+
+ public void setLeader(final String leader) {
+ this.leader = leader;
+ }
+
+ public void setRaftState(final String raftState) {
+ this.raftState = raftState;
+ }
+
+ public void setLastLogTerm(final long lastLogTerm) {
+ this.lastLogTerm = lastLogTerm;
+ }
+
+ public void setLastLogIndex(final long lastLogIndex) {
+ this.lastLogIndex = lastLogIndex;
+ }
+
+ public void setCurrentTerm(final long currentTerm) {
+ this.currentTerm = currentTerm;
+ }
- ShardStats(String shardName){
- this.shardName = shardName;
- committedTransactionsCount =0L;
- journalMessagesCount = 0L;
- };
+ public void setCommitIndex(final long commitIndex) {
+ this.commitIndex = commitIndex;
+ }
+ public void setLastApplied(final long lastApplied) {
+ this.lastApplied = lastApplied;
+ }
- @Override
- public String getShardName() {
- return shardName;
- }
+ public void setLastCommittedTransactionTime(final long lastCommittedTransactionTime) {
+ this.lastCommittedTransactionTime = lastCommittedTransactionTime;
+ }
- @Override
- public Long getCommittedTransactionsCount() {
- return committedTransactionsCount;
- }
+ public void setInMemoryJournalDataSize(long dataSize){
+ this.dataSize = dataSize;
+ }
- @Override
- public Long getJournalMessagesCount() {
- //FIXME: this will be populated once after integration with Raft stuff
- return journalMessagesCount;
- }
+ @Override
+ public long getInMemoryJournalDataSize(){
+ return dataSize;
+ }
- @Override public String getLeader() {
- return leader;
- }
+ @Override
+ public ThreadExecutorStats getDataStoreExecutorStats() {
+ // FIXME: this particular thing does not work, as it really is DS-specific
+ return null;
+ }
- @Override public String getRaftState() {
- return raftState;
- }
+ @Override
+ public ThreadExecutorStats getNotificationMgrExecutorStats() {
+ return notificationExecutorStatsBean.toThreadExecutorStats();
+ }
- public Long incrementCommittedTransactionCount() {
- return committedTransactionsCount++;
- }
+ @Override
+ public List<ListenerNotificationQueueStats> getCurrentNotificationMgrListenerQueueStats() {
+ return notificationManagerStatsBean.getCurrentListenerQueueStats();
+ }
+ @Override
+ public int getMaxNotificationMgrListenerQueueSize() {
+ return notificationManagerStatsBean.getMaxListenerQueueSize();
+ }
- public void updateCommittedTransactionsCount(long currentCount){
- committedTransactionsCount = currentCount;
+ /**
+ * resets the counters related to transactions
+ */
+ @Override
+ public void resetTransactionCounters(){
+ committedTransactionsCount = 0;
- }
+ readOnlyTransactionCount = 0;
- public void updateJournalMessagesCount(long currentCount){
- journalMessagesCount = currentCount;
+ writeOnlyTransactionCount = 0;
- }
+ readWriteTransactionCount = 0;
- public void setLeader(String leader){
- this.leader = leader;
- }
+ lastCommittedTransactionTime = 0;
- public void setRaftState(String raftState){
- this.raftState = raftState;
- }
+ failedTransactionsCount = 0;
+ failedReadTransactionsCount.set(0);
- @Override
- protected String getMBeanName() {
- return shardName;
- }
+ abortTransactionsCount = 0;
- @Override
- protected String getMBeanType() {
- return JMX_TYPE_DISTRIBUTED_DATASTORE;
- }
+ }
- @Override
- protected String getMBeanCategory() {
- return JMX_CATEGORY_SHARD;
- }
+ public void setDataStore(final InMemoryDOMDataStore store) {
+ setNotificationManager(store.getDataChangeListenerNotificationManager());
+ }
+ public void setFollowerInitialSyncStatus(boolean followerInitialSyncStatus) {
+ this.followerInitialSyncStatus = followerInitialSyncStatus;
+ }
+ @Override
+ public boolean getFollowerInitialSyncStatus() {
+ return followerInitialSyncStatus;
+ }
}
Code Review / controller.git / blobdiff