*/
package org.opendaylight.controller.cluster.datastore.jmx.mbeans;
+import java.util.concurrent.TimeUnit;
import org.opendaylight.controller.cluster.datastore.DatastoreContext;
import org.opendaylight.controller.md.sal.common.util.jmx.AbstractMXBean;
private DatastoreContext context;
- public DatastoreConfigurationMXBeanImpl(String mxBeanType) {
+ public DatastoreConfigurationMXBeanImpl(final String mxBeanType) {
super("Datastore", mxBeanType, JMX_CATEGORY_CONFIGURATION);
}
- public void setContext(DatastoreContext context) {
+ public void setContext(final DatastoreContext context) {
this.context = context;
}
@Override
public long getOperationTimeoutInSeconds() {
- return context.getOperationTimeoutInSeconds();
+ return TimeUnit.MILLISECONDS.toSeconds(context.getOperationTimeoutInMillis());
}
@Override
return context.getShardRaftConfig().getSnapshotDataThresholdPercentage();
}
+ @Override
+ public int getShardSnapshotDataThreshold() {
+ return context.getShardRaftConfig().getSnapshotDataThreshold();
+ }
+
@Override
public long getShardSnapshotBatchCount() {
return context.getShardRaftConfig().getSnapshotBatchCount();
return context.getShardTransactionCommitTimeoutInSeconds();
}
+ @Override
+ public long getShardCommitQueueExpiryTimeoutInSeconds() {
+ return TimeUnit.SECONDS.convert(context.getShardCommitQueueExpiryTimeoutInMillis(), TimeUnit.MILLISECONDS);
+ }
+
@Override
public int getShardTransactionCommitQueueCapacity() {
return context.getShardTransactionCommitQueueCapacity();
}
@Override
+ public boolean getTransactionContextDebugEnabled() {
+ return context.isTransactionDebugContextEnabled();
+ }
+
+ @Override
+ @Deprecated(forRemoval = true)
public int getMaxShardDataChangeExecutorPoolSize() {
- return context.getDataStoreProperties().getMaxDataChangeExecutorPoolSize();
+ return 0;
}
@Override
+ @Deprecated(forRemoval = true)
public int getMaxShardDataChangeExecutorQueueSize() {
- return context.getDataStoreProperties().getMaxDataChangeExecutorQueueSize();
+ return 0;
}
@Override
+ @Deprecated(forRemoval = true)
public int getMaxShardDataChangeListenerQueueSize() {
- return context.getDataStoreProperties().getMaxDataChangeListenerQueueSize();
+ return 0;
}
@Override
+ @Deprecated(forRemoval = true)
public int getMaxShardDataStoreExecutorQueueSize() {
- return context.getDataStoreProperties().getMaxDataStoreExecutorQueueSize();
+ return 0;
+ }
+
+ @Override
+ public int getMaximumMessageSliceSize() {
+ return context.getMaximumMessageSliceSize();
}
}