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.Joiner;
15 import com.google.common.base.Stopwatch;
16 import com.google.common.cache.Cache;
17 import com.google.common.cache.CacheBuilder;
18 import java.text.SimpleDateFormat;
19 import java.util.Date;
20 import java.util.List;
22 import java.util.concurrent.TimeUnit;
23 import java.util.concurrent.atomic.AtomicLong;
24 import org.opendaylight.controller.cluster.datastore.Shard;
25 import org.opendaylight.controller.cluster.raft.base.messages.InitiateCaptureSnapshot;
26 import org.opendaylight.controller.cluster.raft.client.messages.FollowerInfo;
27 import org.opendaylight.controller.cluster.raft.client.messages.GetOnDemandRaftState;
28 import org.opendaylight.controller.cluster.raft.client.messages.OnDemandRaftState;
29 import org.opendaylight.controller.md.sal.common.util.jmx.AbstractMXBean;
30 import scala.concurrent.Await;
33 * Maintains statistics for a shard.
35 * @author Basheeruddin syedbahm@cisco.com
37 public class ShardStats extends AbstractMXBean implements ShardStatsMXBean {
38 public static String JMX_CATEGORY_SHARD = "Shards";
40 private static final SimpleDateFormat DATE_FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
42 private static final Cache<String, OnDemandRaftState> onDemandRaftStateCache =
43 CacheBuilder.newBuilder().expireAfterWrite(2, TimeUnit.SECONDS).build();
45 private long committedTransactionsCount;
47 private long readOnlyTransactionCount;
49 private long writeOnlyTransactionCount;
51 private long readWriteTransactionCount;
53 private long lastCommittedTransactionTime;
55 private long failedTransactionsCount;
57 private final AtomicLong failedReadTransactionsCount = new AtomicLong();
59 private long abortTransactionsCount;
61 private boolean followerInitialSyncStatus = false;
65 private String statRetrievalError;
67 private String statRetrievalTime;
69 private long leadershipChangeCount;
71 private long lastLeadershipChangeTime;
73 public ShardStats(final String shardName, final String mxBeanType) {
74 super(shardName, mxBeanType, JMX_CATEGORY_SHARD);
77 public void setShard(Shard shard) {
81 private OnDemandRaftState getOnDemandRaftState() {
82 String name = getShardName();
83 OnDemandRaftState state = onDemandRaftStateCache.getIfPresent(name);
85 statRetrievalError = null;
86 statRetrievalTime = null;
89 Timeout timeout = new Timeout(10, TimeUnit.SECONDS);
91 Stopwatch timer = Stopwatch.createStarted();
93 state = (OnDemandRaftState) Await.result(Patterns.ask(shard.getSelf(),
94 GetOnDemandRaftState.INSTANCE, timeout), timeout.duration());
96 statRetrievalTime = timer.stop().toString();
97 onDemandRaftStateCache.put(name, state);
98 } catch (Exception e) {
99 statRetrievalError = e.toString();
103 state = state != null ? state : OnDemandRaftState.builder().build();
110 public String getShardName() {
111 return getMBeanName();
115 public long getCommittedTransactionsCount() {
116 return committedTransactionsCount;
120 public String getLeader() {
121 return getOnDemandRaftState().getLeader();
125 public String getRaftState() {
126 return getOnDemandRaftState().getRaftState();
130 public long getReadOnlyTransactionCount() {
131 return readOnlyTransactionCount;
135 public long getWriteOnlyTransactionCount() {
136 return writeOnlyTransactionCount;
140 public long getReadWriteTransactionCount() {
141 return readWriteTransactionCount;
145 public long getLastLogIndex() {
146 return getOnDemandRaftState().getLastLogIndex();
150 public long getLastLogTerm() {
151 return getOnDemandRaftState().getLastLogTerm();
155 public long getCurrentTerm() {
156 return getOnDemandRaftState().getCurrentTerm();
160 public long getCommitIndex() {
161 return getOnDemandRaftState().getCommitIndex();
165 public long getLastApplied() {
166 return getOnDemandRaftState().getLastApplied();
170 public long getLastIndex() {
171 return getOnDemandRaftState().getLastIndex();
175 public long getLastTerm() {
176 return getOnDemandRaftState().getLastTerm();
180 public long getSnapshotIndex() {
181 return getOnDemandRaftState().getSnapshotIndex();
185 public long getSnapshotTerm() {
186 return getOnDemandRaftState().getSnapshotTerm();
190 public long getReplicatedToAllIndex() {
191 return getOnDemandRaftState().getReplicatedToAllIndex();
195 public String getVotedFor() {
196 return getOnDemandRaftState().getVotedFor();
199 public boolean isVoting() {
200 return getOnDemandRaftState().isVoting();
204 public String getPeerVotingStates() {
205 return toStringMap(getOnDemandRaftState().getPeerVotingStates());
209 public boolean isSnapshotCaptureInitiated() {
210 return getOnDemandRaftState().isSnapshotCaptureInitiated();
214 public String getLastCommittedTransactionTime() {
215 return DATE_FORMAT.format(new Date(lastCommittedTransactionTime));
219 public long getFailedTransactionsCount() {
220 return failedTransactionsCount;
224 public long getFailedReadTransactionsCount() {
225 return failedReadTransactionsCount.get();
229 public long getAbortTransactionsCount() {
230 return abortTransactionsCount;
233 public long incrementCommittedTransactionCount() {
234 return ++committedTransactionsCount;
237 public long incrementReadOnlyTransactionCount() {
238 return ++readOnlyTransactionCount;
241 public long incrementWriteOnlyTransactionCount() {
242 return ++writeOnlyTransactionCount;
245 public long incrementReadWriteTransactionCount() {
246 return ++readWriteTransactionCount;
249 public long incrementFailedTransactionsCount() {
250 return ++failedTransactionsCount;
253 public long incrementFailedReadTransactionsCount() {
254 return failedReadTransactionsCount.incrementAndGet();
257 public long incrementAbortTransactionsCount ()
259 return ++abortTransactionsCount;
262 public void setLastCommittedTransactionTime(final long lastCommittedTransactionTime) {
263 this.lastCommittedTransactionTime = lastCommittedTransactionTime;
267 public long getInMemoryJournalDataSize(){
268 return getOnDemandRaftState().getInMemoryJournalDataSize();
272 public long getInMemoryJournalLogSize() {
273 return getOnDemandRaftState().getInMemoryJournalLogSize();
277 * resets the counters related to transactions
280 public void resetTransactionCounters(){
281 committedTransactionsCount = 0;
283 readOnlyTransactionCount = 0;
285 writeOnlyTransactionCount = 0;
287 readWriteTransactionCount = 0;
289 lastCommittedTransactionTime = 0;
291 failedTransactionsCount = 0;
293 failedReadTransactionsCount.set(0);
295 abortTransactionsCount = 0;
299 public void setFollowerInitialSyncStatus(boolean followerInitialSyncStatus) {
300 this.followerInitialSyncStatus = followerInitialSyncStatus;
304 public boolean getFollowerInitialSyncStatus() {
305 return followerInitialSyncStatus;
309 public List<FollowerInfo> getFollowerInfo() {
310 return getOnDemandRaftState().getFollowerInfoList();
314 public String getPeerAddresses() {
315 return toStringMap(getOnDemandRaftState().getPeerAddresses());
318 private static String toStringMap(Map<?, ?> map) {
319 return Joiner.on(", ").withKeyValueSeparator(": ").join(map);
323 public String getStatRetrievalTime() {
324 getOnDemandRaftState();
325 return statRetrievalTime;
329 public String getStatRetrievalError() {
330 getOnDemandRaftState();
331 return statRetrievalError;
335 public long getLeadershipChangeCount() {
336 return leadershipChangeCount;
339 public void incrementLeadershipChangeCount() {
340 leadershipChangeCount++;
341 lastLeadershipChangeTime = System.currentTimeMillis();
345 public String getLastLeadershipChangeTime() {
346 return DATE_FORMAT.format(new Date(lastLeadershipChangeTime));
350 public int getPendingTxCommitQueueSize() {
351 return shard.getPendingTxCommitQueueSize();
355 public int getTxCohortCacheSize() {
356 return shard.getCohortCacheSize();
360 public void captureSnapshot() {
362 shard.getSelf().tell(new InitiateCaptureSnapshot(), ActorRef.noSender());