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 = new ThreadExecutorStatsMXBeanImpl(dsExecutor,
  78                 "notification-executor", getMBeanType(), getMBeanCategory());
  79     }
  80
  81     public void setNotificationManager(QueuedNotificationManager<?, ?> manager) {
  82         this.notificationManagerStatsBean = new QueuedNotificationManagerMXBeanImpl(manager,
  83                 "notification-manager", getMBeanType(), getMBeanCategory());
  84
  85         this.notificationExecutorStatsBean = new ThreadExecutorStatsMXBeanImpl(manager.getExecutor(),
  86                 "data-store-executor", getMBeanType(), getMBeanCategory());
  87     }
  88
  89     @Override
  90     public String getShardName() {
  91         return getMBeanName();
  92     }
  93
  94     @Override
  95     public long getCommittedTransactionsCount() {
  96         return committedTransactionsCount.get();
  97     }
  98
  99     @Override
 100     public String getLeader() {
 101         return leader;
 102     }
 103
 104     @Override
 105     public String getRaftState() {
 106         return raftState;
 107     }
 108
 109     @Override
 110     public long getReadOnlyTransactionCount() {
 111         return readOnlyTransactionCount.get();
 112     }
 113
 114     @Override
 115     public long getWriteOnlyTransactionCount() {
 116         return writeOnlyTransactionCount.get();
 117     }
 118
 119     @Override
 120     public long getReadWriteTransactionCount() {
 121         return readWriteTransactionCount.get();
 122     }
 123
 124     @Override
 125     public long getLastLogIndex() {
 126         return lastLogIndex;
 127     }
 128
 129     @Override
 130     public long getLastLogTerm() {
 131         return lastLogTerm;
 132     }
 133
 134     @Override
 135     public long getCurrentTerm() {
 136         return currentTerm;
 137     }
 138
 139     @Override
 140     public long getCommitIndex() {
 141         return commitIndex;
 142     }
 143
 144     @Override
 145     public long getLastApplied() {
 146         return lastApplied;
 147     }
 148
 149     @Override
 150     public String getLastCommittedTransactionTime() {
 151
 152         return sdf.format(new Date(lastCommittedTransactionTime));
 153     }
 154
 155     @Override
 156     public long getFailedTransactionsCount() {
 157         return failedTransactionsCount.get();
 158     }
 159
 160     @Override
 161     public long getFailedReadTransactionsCount() {
 162         return failedReadTransactionsCount.get();
 163     }
 164
 165     @Override
 166     public long getAbortTransactionsCount() {
 167         return abortTransactionsCount.get();
 168     }
 169
 170     public long incrementCommittedTransactionCount() {
 171         return committedTransactionsCount.incrementAndGet();
 172     }
 173
 174     public long incrementReadOnlyTransactionCount() {
 175         return readOnlyTransactionCount.incrementAndGet();
 176     }
 177
 178     public long incrementWriteOnlyTransactionCount() {
 179         return writeOnlyTransactionCount.incrementAndGet();
 180     }
 181
 182     public long incrementReadWriteTransactionCount() {
 183         return readWriteTransactionCount.incrementAndGet();
 184     }
 185
 186     public long incrementFailedTransactionsCount() {
 187         return failedTransactionsCount.incrementAndGet();
 188     }
 189
 190     public long incrementFailedReadTransactionsCount() {
 191         return failedReadTransactionsCount.incrementAndGet();
 192     }
 193
 194     public long incrementAbortTransactionsCount ()
 195     {
 196         return abortTransactionsCount.incrementAndGet();
 197     }
 198
 199     public void setLeader(String leader) {
 200         this.leader = leader;
 201     }
 202
 203     public void setRaftState(String raftState) {
 204         this.raftState = raftState;
 205     }
 206
 207     public void setLastLogTerm(long lastLogTerm) {
 208         this.lastLogTerm = lastLogTerm;
 209     }
 210
 211     public void setLastLogIndex(long lastLogIndex) {
 212         this.lastLogIndex = lastLogIndex;
 213     }
 214
 215     public void setCurrentTerm(long currentTerm) {
 216         this.currentTerm = currentTerm;
 217     }
 218
 219     public void setCommitIndex(long commitIndex) {
 220         this.commitIndex = commitIndex;
 221     }
 222
 223     public void setLastApplied(long lastApplied) {
 224         this.lastApplied = lastApplied;
 225     }
 226
 227     public void setLastCommittedTransactionTime(long lastCommittedTransactionTime) {
 228         this.lastCommittedTransactionTime = lastCommittedTransactionTime;
 229     }
 230
 231     @Override
 232     public ThreadExecutorStats getDataStoreExecutorStats() {
 233         return dataStoreExecutorStatsBean.toThreadExecutorStats();
 234     }
 235
 236     @Override
 237     public ThreadExecutorStats getNotificationMgrExecutorStats() {
 238         return notificationExecutorStatsBean.toThreadExecutorStats();
 239     }
 240
 241     @Override
 242     public List<ListenerNotificationQueueStats> getCurrentNotificationMgrListenerQueueStats() {
 243         return notificationManagerStatsBean.getCurrentListenerQueueStats();
 244     }
 245
 246     @Override
 247     public int getMaxNotificationMgrListenerQueueSize() {
 248         return notificationManagerStatsBean.getMaxListenerQueueSize();
 249     }
 250
 251     /**
 252      * resets the counters related to transactions
 253      */
 254     @Override
 255     public void resetTransactionCounters(){
 256         committedTransactionsCount.set(0);
 257
 258         readOnlyTransactionCount.set(0);
 259
 260         writeOnlyTransactionCount.set(0);
 261
 262         readWriteTransactionCount.set(0);
 263
 264         lastCommittedTransactionTime = 0;
 265
 266         failedTransactionsCount.set(0);
 267
 268         failedReadTransactionsCount.set(0);
 269
 270         abortTransactionsCount.set(0);
 271
 272     }
 273 }