2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
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
9 package org.opendaylight.controller.cluster.datastore.jmx.mbeans.shard;
11 import akka.actor.ActorRef;
12 import akka.pattern.Patterns;
13 import akka.util.Timeout;
14 import com.google.common.base.Stopwatch;
15 import com.google.common.cache.Cache;
16 import com.google.common.cache.CacheBuilder;
17 import java.text.SimpleDateFormat;
18 import java.util.Date;
19 import java.util.List;
21 import java.util.concurrent.TimeUnit;
22 import java.util.concurrent.atomic.AtomicLong;
23 import org.opendaylight.controller.cluster.datastore.Shard;
24 import org.opendaylight.controller.cluster.raft.base.messages.InitiateCaptureSnapshot;
25 import org.opendaylight.controller.cluster.raft.client.messages.FollowerInfo;
26 import org.opendaylight.controller.cluster.raft.client.messages.GetOnDemandRaftState;
27 import org.opendaylight.controller.cluster.raft.client.messages.OnDemandRaftState;
28 import org.opendaylight.controller.md.sal.common.util.jmx.AbstractMXBean;
29 import scala.concurrent.Await;
32 * Maintains statistics for a shard.
34 * @author Basheeruddin syedbahm@cisco.com
36 public class ShardStats extends AbstractMXBean implements ShardStatsMXBean {
37 public static String JMX_CATEGORY_SHARD = "Shards";
39 private static final SimpleDateFormat DATE_FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
41 private static final Cache<String, OnDemandRaftState> onDemandRaftStateCache =
42 CacheBuilder.newBuilder().expireAfterWrite(2, TimeUnit.SECONDS).build();
44 private long committedTransactionsCount;
46 private long readOnlyTransactionCount;
48 private long writeOnlyTransactionCount;
50 private long readWriteTransactionCount;
52 private long lastCommittedTransactionTime;
54 private long failedTransactionsCount;
56 private final AtomicLong failedReadTransactionsCount = new AtomicLong();
58 private long abortTransactionsCount;
60 private boolean followerInitialSyncStatus = false;
64 private String statRetrievalError;
66 private String statRetrievalTime;
68 private long leadershipChangeCount;
70 private long lastLeadershipChangeTime;
72 public ShardStats(final String shardName, final String mxBeanType) {
73 super(shardName, mxBeanType, JMX_CATEGORY_SHARD);
76 public void setShard(Shard shard) {
80 private OnDemandRaftState getOnDemandRaftState() {
81 String name = getShardName();
82 OnDemandRaftState state = onDemandRaftStateCache.getIfPresent(name);
84 statRetrievalError = null;
85 statRetrievalTime = null;
88 Timeout timeout = new Timeout(10, TimeUnit.SECONDS);
90 Stopwatch timer = Stopwatch.createStarted();
92 state = (OnDemandRaftState) Await.result(Patterns.ask(shard.getSelf(),
93 GetOnDemandRaftState.INSTANCE, timeout), timeout.duration());
95 statRetrievalTime = timer.stop().toString();
96 onDemandRaftStateCache.put(name, state);
97 } catch (Exception e) {
98 statRetrievalError = e.toString();
102 state = state != null ? state : OnDemandRaftState.builder().build();
109 public String getShardName() {
110 return getMBeanName();
114 public long getCommittedTransactionsCount() {
115 return committedTransactionsCount;
119 public String getLeader() {
120 return getOnDemandRaftState().getLeader();
124 public String getRaftState() {
125 return getOnDemandRaftState().getRaftState();
129 public long getReadOnlyTransactionCount() {
130 return readOnlyTransactionCount;
134 public long getWriteOnlyTransactionCount() {
135 return writeOnlyTransactionCount;
139 public long getReadWriteTransactionCount() {
140 return readWriteTransactionCount;
144 public long getLastLogIndex() {
145 return getOnDemandRaftState().getLastLogIndex();
149 public long getLastLogTerm() {
150 return getOnDemandRaftState().getLastLogTerm();
154 public long getCurrentTerm() {
155 return getOnDemandRaftState().getCurrentTerm();
159 public long getCommitIndex() {
160 return getOnDemandRaftState().getCommitIndex();
164 public long getLastApplied() {
165 return getOnDemandRaftState().getLastApplied();
169 public long getLastIndex() {
170 return getOnDemandRaftState().getLastIndex();
174 public long getLastTerm() {
175 return getOnDemandRaftState().getLastTerm();
179 public long getSnapshotIndex() {
180 return getOnDemandRaftState().getSnapshotIndex();
184 public long getSnapshotTerm() {
185 return getOnDemandRaftState().getSnapshotTerm();
189 public long getReplicatedToAllIndex() {
190 return getOnDemandRaftState().getReplicatedToAllIndex();
194 public String getVotedFor() {
195 return getOnDemandRaftState().getVotedFor();
199 public boolean isSnapshotCaptureInitiated() {
200 return getOnDemandRaftState().isSnapshotCaptureInitiated();
204 public String getLastCommittedTransactionTime() {
205 return DATE_FORMAT.format(new Date(lastCommittedTransactionTime));
209 public long getFailedTransactionsCount() {
210 return failedTransactionsCount;
214 public long getFailedReadTransactionsCount() {
215 return failedReadTransactionsCount.get();
219 public long getAbortTransactionsCount() {
220 return abortTransactionsCount;
223 public long incrementCommittedTransactionCount() {
224 return ++committedTransactionsCount;
227 public long incrementReadOnlyTransactionCount() {
228 return ++readOnlyTransactionCount;
231 public long incrementWriteOnlyTransactionCount() {
232 return ++writeOnlyTransactionCount;
235 public long incrementReadWriteTransactionCount() {
236 return ++readWriteTransactionCount;
239 public long incrementFailedTransactionsCount() {
240 return ++failedTransactionsCount;
243 public long incrementFailedReadTransactionsCount() {
244 return failedReadTransactionsCount.incrementAndGet();
247 public long incrementAbortTransactionsCount ()
249 return ++abortTransactionsCount;
252 public void setLastCommittedTransactionTime(final long lastCommittedTransactionTime) {
253 this.lastCommittedTransactionTime = lastCommittedTransactionTime;
257 public long getInMemoryJournalDataSize(){
258 return getOnDemandRaftState().getInMemoryJournalDataSize();
262 public long getInMemoryJournalLogSize() {
263 return getOnDemandRaftState().getInMemoryJournalLogSize();
267 * resets the counters related to transactions
270 public void resetTransactionCounters(){
271 committedTransactionsCount = 0;
273 readOnlyTransactionCount = 0;
275 writeOnlyTransactionCount = 0;
277 readWriteTransactionCount = 0;
279 lastCommittedTransactionTime = 0;
281 failedTransactionsCount = 0;
283 failedReadTransactionsCount.set(0);
285 abortTransactionsCount = 0;
289 public void setFollowerInitialSyncStatus(boolean followerInitialSyncStatus) {
290 this.followerInitialSyncStatus = followerInitialSyncStatus;
294 public boolean getFollowerInitialSyncStatus() {
295 return followerInitialSyncStatus;
299 public List<FollowerInfo> getFollowerInfo() {
300 return getOnDemandRaftState().getFollowerInfoList();
304 public String getPeerAddresses() {
305 StringBuilder builder = new StringBuilder();
307 for(Map.Entry<String, String> e: getOnDemandRaftState().getPeerAddresses().entrySet()) {
309 builder.append(", ");
312 builder.append(e.getKey()).append(": ").append(e.getValue());
315 return builder.toString();
319 public String getStatRetrievalTime() {
320 getOnDemandRaftState();
321 return statRetrievalTime;
325 public String getStatRetrievalError() {
326 getOnDemandRaftState();
327 return statRetrievalError;
331 public long getLeadershipChangeCount() {
332 return leadershipChangeCount;
335 public void incrementLeadershipChangeCount() {
336 leadershipChangeCount++;
337 lastLeadershipChangeTime = System.currentTimeMillis();
341 public String getLastLeadershipChangeTime() {
342 return DATE_FORMAT.format(new Date(lastLeadershipChangeTime));
346 public int getPendingTxCommitQueueSize() {
347 return shard.getPendingTxCommitQueueSize();
350 public int getTxCohortCacheSize() {
351 return shard.getCohortCacheSize();
355 public void captureSnapshot() {
357 shard.getSelf().tell(new InitiateCaptureSnapshot(), ActorRef.noSender());