X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fjmx%2Fmbeans%2Fshard%2FShardStats.java;h=e3c8ced878232f2a831d541f6bbb3b14b233327d;hp=22ad8e7f5a3408ff7457876635ced85f19ad2842;hb=f9a9cd1ea40d2477ccb16b03c71a87595226595a;hpb=458e216f175088b73c367c76264a6bbfb2d067b7 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/shard/ShardStats.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/shard/ShardStats.java index 22ad8e7f5a..e3c8ced878 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/shard/ShardStats.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/shard/ShardStats.java @@ -8,59 +8,125 @@ package org.opendaylight.controller.cluster.datastore.jmx.mbeans.shard; -import org.opendaylight.controller.cluster.datastore.jmx.mbeans.AbstractBaseMBean; - +import akka.actor.ActorRef; +import akka.pattern.Patterns; +import akka.util.Timeout; +import com.google.common.base.Stopwatch; +import com.google.common.cache.Cache; +import com.google.common.cache.CacheBuilder; import java.text.SimpleDateFormat; import java.util.Date; +import java.util.List; +import java.util.Map; +import java.util.concurrent.TimeUnit; +import java.util.concurrent.atomic.AtomicLong; +import org.opendaylight.controller.cluster.raft.client.messages.FollowerInfo; +import org.opendaylight.controller.cluster.raft.client.messages.GetOnDemandRaftState; +import org.opendaylight.controller.cluster.raft.client.messages.OnDemandRaftState; +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; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import scala.concurrent.Await; /** + * Maintains statistics for a shard. + * * @author Basheeruddin syedbahm@cisco.com */ -public class ShardStats extends AbstractBaseMBean implements ShardStatsMBean { +public class ShardStats extends AbstractMXBean implements ShardStatsMXBean { + public static String JMX_CATEGORY_SHARD = "Shards"; + + private static final Logger LOG = LoggerFactory.getLogger(ShardStats.class); + + private static final SimpleDateFormat DATE_FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS"); + + private static final Cache onDemandRaftStateCache = + CacheBuilder.newBuilder().expireAfterWrite(2, TimeUnit.SECONDS).build(); + + private long committedTransactionsCount; - private final String shardName; + private long readOnlyTransactionCount; - private long committedTransactionsCount = 0L; + private long writeOnlyTransactionCount; - private long readOnlyTransactionCount = 0L; + private long readWriteTransactionCount; - private long writeOnlyTransactionCount = 0L; + private long lastCommittedTransactionTime; - private long readWriteTransactionCount = 0L; + private long failedTransactionsCount; - private String leader; + private final AtomicLong failedReadTransactionsCount = new AtomicLong(); - private String raftState; + private long abortTransactionsCount; - private long lastLogTerm = -1L; + private ThreadExecutorStatsMXBeanImpl notificationExecutorStatsBean; - private long lastLogIndex = -1L; + private QueuedNotificationManagerMXBeanImpl notificationManagerStatsBean; - private long currentTerm = -1L; + private boolean followerInitialSyncStatus = false; - private long commitIndex = -1L; + private ActorRef shardActor; - private long lastApplied = -1L; + private String statRetrievalError; - private Date lastCommittedTransactionTime = new Date(0L); + private String statRetrievalTime; - private long failedTransactionsCount = 0L; + private long leadershipChangeCount; - private long failedReadTransactionsCount = 0L; + private long lastLeadershipChangeTime; - private long abortTransactionsCount = 0L; + 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()); - private SimpleDateFormat sdf = - new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS"); + this.notificationExecutorStatsBean = ThreadExecutorStatsMXBeanImpl.create(manager.getExecutor()); + } - ShardStats(String shardName) { - this.shardName = shardName; + public void setShardActor(ActorRef shardActor) { + this.shardActor = shardActor; } + private OnDemandRaftState getOnDemandRaftState() { + String name = getShardName(); + OnDemandRaftState state = onDemandRaftStateCache.getIfPresent(name); + if(state == null) { + statRetrievalError = null; + statRetrievalTime = null; + + if(shardActor != null) { + Timeout timeout = new Timeout(10, TimeUnit.SECONDS); + try { + Stopwatch timer = Stopwatch.createStarted(); + + state = (OnDemandRaftState) Await.result(Patterns.ask(shardActor, + GetOnDemandRaftState.INSTANCE, timeout), timeout.duration()); + + statRetrievalTime = timer.stop().toString(); + onDemandRaftStateCache.put(name, state); + } catch (Exception e) { + statRetrievalError = e.toString(); + } + } + + state = state != null ? state : OnDemandRaftState.builder().build(); + } + + return state; + } @Override public String getShardName() { - return shardName; + return getMBeanName(); } @Override @@ -68,161 +134,255 @@ public class ShardStats extends AbstractBaseMBean implements ShardStatsMBean { return committedTransactionsCount; } - @Override public String getLeader() { - return leader; + @Override + public String getLeader() { + return getOnDemandRaftState().getLeader(); } - @Override public String getRaftState() { - return raftState; + @Override + public String getRaftState() { + return getOnDemandRaftState().getRaftState(); } - @Override public long getReadOnlyTransactionCount() { + @Override + public long getReadOnlyTransactionCount() { return readOnlyTransactionCount; } - @Override public long getWriteOnlyTransactionCount() { + @Override + public long getWriteOnlyTransactionCount() { return writeOnlyTransactionCount; } - @Override public long getReadWriteTransactionCount() { + @Override + public long getReadWriteTransactionCount() { return readWriteTransactionCount; } - @Override public long getLastLogIndex() { - return lastLogIndex; + @Override + public long getLastLogIndex() { + return getOnDemandRaftState().getLastLogIndex(); } - @Override public long getLastLogTerm() { - return lastLogTerm; + @Override + public long getLastLogTerm() { + return getOnDemandRaftState().getLastLogTerm(); } - @Override public long getCurrentTerm() { - return currentTerm; + @Override + public long getCurrentTerm() { + return getOnDemandRaftState().getCurrentTerm(); } - @Override public long getCommitIndex() { - return commitIndex; + @Override + public long getCommitIndex() { + return getOnDemandRaftState().getCommitIndex(); } - @Override public long getLastApplied() { - return lastApplied; + @Override + public long getLastApplied() { + return getOnDemandRaftState().getLastApplied(); } @Override - public String getLastCommittedTransactionTime() { + public long getLastIndex() { + return getOnDemandRaftState().getLastIndex(); + } - return sdf.format(lastCommittedTransactionTime); + @Override + public long getLastTerm() { + return getOnDemandRaftState().getLastTerm(); } - @Override public long getFailedTransactionsCount() { - return failedTransactionsCount; + @Override + public long getSnapshotIndex() { + return getOnDemandRaftState().getSnapshotIndex(); } - @Override public long getFailedReadTransactionsCount() { - return failedReadTransactionsCount; + @Override + public long getSnapshotTerm() { + return getOnDemandRaftState().getSnapshotTerm(); } - @Override public long getAbortTransactionsCount() { - return abortTransactionsCount; + @Override + public long getReplicatedToAllIndex() { + return getOnDemandRaftState().getReplicatedToAllIndex(); } - public long incrementCommittedTransactionCount() { - return committedTransactionsCount++; + @Override + public String getVotedFor() { + return getOnDemandRaftState().getVotedFor(); } - public long incrementReadOnlyTransactionCount() { - return readOnlyTransactionCount++; + @Override + public boolean isSnapshotCaptureInitiated() { + return getOnDemandRaftState().isSnapshotCaptureInitiated(); } - public long incrementWriteOnlyTransactionCount() { - return writeOnlyTransactionCount++; + @Override + public String getLastCommittedTransactionTime() { + return DATE_FORMAT.format(new Date(lastCommittedTransactionTime)); } - public long incrementReadWriteTransactionCount() { - return readWriteTransactionCount++; + @Override + public long getFailedTransactionsCount() { + return failedTransactionsCount; } - public long incrementFailedTransactionsCount() { - return failedTransactionsCount++; + @Override + public long getFailedReadTransactionsCount() { + return failedReadTransactionsCount.get(); } - public long incrementFailedReadTransactionsCount() { - return failedReadTransactionsCount++; + @Override + public long getAbortTransactionsCount() { + return abortTransactionsCount; } - public long incrementAbortTransactionsCount () { return abortTransactionsCount++;} + public long incrementCommittedTransactionCount() { + return ++committedTransactionsCount; + } - public void setLeader(String leader) { - this.leader = leader; + public long incrementReadOnlyTransactionCount() { + return ++readOnlyTransactionCount; } - public void setRaftState(String raftState) { - this.raftState = raftState; + public long incrementWriteOnlyTransactionCount() { + return ++writeOnlyTransactionCount; } - public void setLastLogTerm(long lastLogTerm) { - this.lastLogTerm = lastLogTerm; + public long incrementReadWriteTransactionCount() { + return ++readWriteTransactionCount; } - public void setLastLogIndex(long lastLogIndex) { - this.lastLogIndex = lastLogIndex; + public long incrementFailedTransactionsCount() { + return ++failedTransactionsCount; } - public void setCurrentTerm(long currentTerm) { - this.currentTerm = currentTerm; + public long incrementFailedReadTransactionsCount() { + return failedReadTransactionsCount.incrementAndGet(); } - public void setCommitIndex(long commitIndex) { - this.commitIndex = commitIndex; + public long incrementAbortTransactionsCount () + { + return ++abortTransactionsCount; } - public void setLastApplied(long lastApplied) { - this.lastApplied = lastApplied; + public void setLastCommittedTransactionTime(final long lastCommittedTransactionTime) { + this.lastCommittedTransactionTime = lastCommittedTransactionTime; } + @Override + public long getInMemoryJournalDataSize(){ + return getOnDemandRaftState().getInMemoryJournalDataSize(); + } - public void setLastCommittedTransactionTime( - Date lastCommittedTransactionTime) { - this.lastCommittedTransactionTime = lastCommittedTransactionTime; + @Override + public long getInMemoryJournalLogSize() { + return getOnDemandRaftState().getInMemoryJournalLogSize(); + } + + @Override + public ThreadExecutorStats getDataStoreExecutorStats() { + // FIXME: this particular thing does not work, as it really is DS-specific + return null; } @Override - protected String getMBeanName() { - return shardName; + public ThreadExecutorStats getNotificationMgrExecutorStats() { + return notificationExecutorStatsBean.toThreadExecutorStats(); } @Override - protected String getMBeanType() { - return JMX_TYPE_DISTRIBUTED_DATASTORE; + public List getCurrentNotificationMgrListenerQueueStats() { + return notificationManagerStatsBean.getCurrentListenerQueueStats(); } @Override - protected String getMBeanCategory() { - return JMX_CATEGORY_SHARD; + public int getMaxNotificationMgrListenerQueueSize() { + return notificationManagerStatsBean.getMaxListenerQueueSize(); } /** * resets the counters related to transactions */ - + @Override public void resetTransactionCounters(){ - committedTransactionsCount = 0L; + committedTransactionsCount = 0; + + readOnlyTransactionCount = 0; + + writeOnlyTransactionCount = 0; + + readWriteTransactionCount = 0; + + lastCommittedTransactionTime = 0; - readOnlyTransactionCount = 0L; + failedTransactionsCount = 0; - writeOnlyTransactionCount = 0L; + failedReadTransactionsCount.set(0); - readWriteTransactionCount = 0L; + abortTransactionsCount = 0; - lastCommittedTransactionTime = new Date(0L); + } - failedTransactionsCount = 0L; + public void setDataStore(final InMemoryDOMDataStore store) { + setNotificationManager(store.getDataChangeListenerNotificationManager()); + } - failedReadTransactionsCount = 0L; + public void setFollowerInitialSyncStatus(boolean followerInitialSyncStatus) { + this.followerInitialSyncStatus = followerInitialSyncStatus; + } - abortTransactionsCount = 0L; + @Override + public boolean getFollowerInitialSyncStatus() { + return followerInitialSyncStatus; + } + @Override + public List getFollowerInfo() { + return getOnDemandRaftState().getFollowerInfoList(); } + @Override + public String getPeerAddresses() { + StringBuilder builder = new StringBuilder(); + int i = 0; + for(Map.Entry e: getOnDemandRaftState().getPeerAddresses().entrySet()) { + if(i++ > 0) { + builder.append(", "); + } + + builder.append(e.getKey()).append(": ").append(e.getValue()); + } + + return builder.toString(); + } + @Override + public String getStatRetrievalTime() { + getOnDemandRaftState(); + return statRetrievalTime; + } + + @Override + public String getStatRetrievalError() { + getOnDemandRaftState(); + return statRetrievalError; + } + + @Override + public long getLeadershipChangeCount() { + return leadershipChangeCount; + } + + public void incrementLeadershipChangeCount() { + leadershipChangeCount++; + lastLeadershipChangeTime = System.currentTimeMillis(); + } + + @Override + public String getLastLeadershipChangeTime() { + return DATE_FORMAT.format(new Date(lastLeadershipChangeTime)); + } }