opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/shard/ShardStats.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8
   9 package org.opendaylight.controller.cluster.datastore.jmx.mbeans.shard;
  10
  11 import java.util.List;
  12 import java.util.concurrent.ExecutorService;
  13 import java.util.concurrent.atomic.AtomicLong;
  14
  15 import org.opendaylight.controller.md.sal.common.util.jmx.AbstractMXBean;
  16 import org.opendaylight.controller.md.sal.common.util.jmx.QueuedNotificationManagerMXBeanImpl;
  17 import org.opendaylight.controller.md.sal.common.util.jmx.ThreadExecutorStats;
  18 import org.opendaylight.controller.md.sal.common.util.jmx.ThreadExecutorStatsMXBeanImpl;
  19 import org.opendaylight.yangtools.util.concurrent.ListenerNotificationQueueStats;
  20 import org.opendaylight.yangtools.util.concurrent.QueuedNotificationManager;
  21
  22 import java.text.SimpleDateFormat;
  23 import java.util.Date;
  24
  25 /**
  26  * Maintains statistics for a shard.
  27  *
  28  * @author  Basheeruddin syedbahm@cisco.com
  29  */
  30 public class ShardStats extends AbstractMXBean implements ShardStatsMXBean {
  31     public static String JMX_CATEGORY_SHARD = "Shards";
  32
  33     private final AtomicLong committedTransactionsCount = new AtomicLong();
  34
  35     private final AtomicLong readOnlyTransactionCount = new AtomicLong();
  36
  37     private final AtomicLong writeOnlyTransactionCount = new AtomicLong();
  38
  39     private final AtomicLong readWriteTransactionCount = new AtomicLong();
  40
  41     private String leader;
  42
  43     private String raftState;
  44
  45     private volatile long lastLogTerm = -1L;
  46
  47     private volatile long lastLogIndex = -1L;
  48
  49     private volatile long currentTerm = -1L;
  50
  51     private volatile long commitIndex = -1L;
  52
  53     private volatile long lastApplied = -1L;
  54
  55     private volatile long lastCommittedTransactionTime;
  56
  57     private final AtomicLong failedTransactionsCount = new AtomicLong();
  58
  59     private final AtomicLong failedReadTransactionsCount = new AtomicLong();
  60
  61     private final AtomicLong abortTransactionsCount = new AtomicLong();
  62
  63     private ThreadExecutorStatsMXBeanImpl notificationExecutorStatsBean;
  64
  65     private ThreadExecutorStatsMXBeanImpl dataStoreExecutorStatsBean;
  66
  67     private QueuedNotificationManagerMXBeanImpl notificationManagerStatsBean;
  68
  69     private final SimpleDateFormat sdf =
  70         new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
  71
  72     public ShardStats(String shardName, String mxBeanType) {
  73         super(shardName, mxBeanType, JMX_CATEGORY_SHARD);
  74     }
  75
  76     public void setDataStoreExecutor(ExecutorService dsExecutor) {
  77         this.dataStoreExecutorStatsBean = ThreadExecutorStatsMXBeanImpl.create(dsExecutor);
  78     }
  79
  80     public void setNotificationManager(QueuedNotificationManager<?, ?> manager) {
  81         this.notificationManagerStatsBean = new QueuedNotificationManagerMXBeanImpl(manager,
  82                 "notification-manager", getMBeanType(), getMBeanCategory());
  83
  84         this.notificationExecutorStatsBean = ThreadExecutorStatsMXBeanImpl.create(manager.getExecutor());
  85     }
  86
  87     @Override
  88     public String getShardName() {
  89         return getMBeanName();
  90     }
  91
  92     @Override
  93     public long getCommittedTransactionsCount() {
  94         return committedTransactionsCount.get();
  95     }
  96
  97     @Override
  98     public String getLeader() {
  99         return leader;
 100     }
 101
 102     @Override
 103     public String getRaftState() {
 104         return raftState;
 105     }
 106
 107     @Override
 108     public long getReadOnlyTransactionCount() {
 109         return readOnlyTransactionCount.get();
 110     }
 111
 112     @Override
 113     public long getWriteOnlyTransactionCount() {
 114         return writeOnlyTransactionCount.get();
 115     }
 116
 117     @Override
 118     public long getReadWriteTransactionCount() {
 119         return readWriteTransactionCount.get();
 120     }
 121
 122     @Override
 123     public long getLastLogIndex() {
 124         return lastLogIndex;
 125     }
 126
 127     @Override
 128     public long getLastLogTerm() {
 129         return lastLogTerm;
 130     }
 131
 132     @Override
 133     public long getCurrentTerm() {
 134         return currentTerm;
 135     }
 136
 137     @Override
 138     public long getCommitIndex() {
 139         return commitIndex;
 140     }
 141
 142     @Override
 143     public long getLastApplied() {
 144         return lastApplied;
 145     }
 146
 147     @Override
 148     public String getLastCommittedTransactionTime() {
 149
 150         return sdf.format(new Date(lastCommittedTransactionTime));
 151     }
 152
 153     @Override
 154     public long getFailedTransactionsCount() {
 155         return failedTransactionsCount.get();
 156     }
 157
 158     @Override
 159     public long getFailedReadTransactionsCount() {
 160         return failedReadTransactionsCount.get();
 161     }
 162
 163     @Override
 164     public long getAbortTransactionsCount() {
 165         return abortTransactionsCount.get();
 166     }
 167
 168     public long incrementCommittedTransactionCount() {
 169         return committedTransactionsCount.incrementAndGet();
 170     }
 171
 172     public long incrementReadOnlyTransactionCount() {
 173         return readOnlyTransactionCount.incrementAndGet();
 174     }
 175
 176     public long incrementWriteOnlyTransactionCount() {
 177         return writeOnlyTransactionCount.incrementAndGet();
 178     }
 179
 180     public long incrementReadWriteTransactionCount() {
 181         return readWriteTransactionCount.incrementAndGet();
 182     }
 183
 184     public long incrementFailedTransactionsCount() {
 185         return failedTransactionsCount.incrementAndGet();
 186     }
 187
 188     public long incrementFailedReadTransactionsCount() {
 189         return failedReadTransactionsCount.incrementAndGet();
 190     }
 191
 192     public long incrementAbortTransactionsCount ()
 193     {
 194         return abortTransactionsCount.incrementAndGet();
 195     }
 196
 197     public void setLeader(String leader) {
 198         this.leader = leader;
 199     }
 200
 201     public void setRaftState(String raftState) {
 202         this.raftState = raftState;
 203     }
 204
 205     public void setLastLogTerm(long lastLogTerm) {
 206         this.lastLogTerm = lastLogTerm;
 207     }
 208
 209     public void setLastLogIndex(long lastLogIndex) {
 210         this.lastLogIndex = lastLogIndex;
 211     }
 212
 213     public void setCurrentTerm(long currentTerm) {
 214         this.currentTerm = currentTerm;
 215     }
 216
 217     public void setCommitIndex(long commitIndex) {
 218         this.commitIndex = commitIndex;
 219     }
 220
 221     public void setLastApplied(long lastApplied) {
 222         this.lastApplied = lastApplied;
 223     }
 224
 225     public void setLastCommittedTransactionTime(long lastCommittedTransactionTime) {
 226         this.lastCommittedTransactionTime = lastCommittedTransactionTime;
 227     }
 228
 229     @Override
 230     public ThreadExecutorStats getDataStoreExecutorStats() {
 231         return dataStoreExecutorStatsBean == null ? null :
 232                                         dataStoreExecutorStatsBean.toThreadExecutorStats();
 233     }
 234
 235     @Override
 236     public ThreadExecutorStats getNotificationMgrExecutorStats() {
 237         return notificationExecutorStatsBean.toThreadExecutorStats();
 238     }
 239
 240     @Override
 241     public List<ListenerNotificationQueueStats> getCurrentNotificationMgrListenerQueueStats() {
 242         return notificationManagerStatsBean.getCurrentListenerQueueStats();
 243     }
 244
 245     @Override
 246     public int getMaxNotificationMgrListenerQueueSize() {
 247         return notificationManagerStatsBean.getMaxListenerQueueSize();
 248     }
 249
 250     /**
 251      * resets the counters related to transactions
 252      */
 253     @Override
 254     public void resetTransactionCounters(){
 255         committedTransactionsCount.set(0);
 256
 257         readOnlyTransactionCount.set(0);
 258
 259         writeOnlyTransactionCount.set(0);
 260
 261         readWriteTransactionCount.set(0);
 262
 263         lastCommittedTransactionTime = 0;
 264
 265         failedTransactionsCount.set(0);
 266
 267         failedReadTransactionsCount.set(0);
 268
 269         abortTransactionsCount.set(0);
 270
 271     }
 272 }