Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add direct in-memory journal threshold
[controller.git]
/
opendaylight
/
md-sal
/
sal-distributed-datastore
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
datastore
/
jmx
/
mbeans
/
DatastoreConfigurationMXBeanImpl.java
diff --git
a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/DatastoreConfigurationMXBeanImpl.java
b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/DatastoreConfigurationMXBeanImpl.java
index 20b6e79e075fb4674f4ff3e6e73f76b6d61c45cb..1bef70ab19c0b245adfb9cd74eb968b41f764e3c 100644
(file)
--- a/
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/DatastoreConfigurationMXBeanImpl.java
+++ b/
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/jmx/mbeans/DatastoreConfigurationMXBeanImpl.java
@@
-21,11
+21,11
@@
public class DatastoreConfigurationMXBeanImpl extends AbstractMXBean implements
private DatastoreContext context;
private DatastoreContext context;
- public DatastoreConfigurationMXBeanImpl(String mxBeanType) {
+ public DatastoreConfigurationMXBeanImpl(
final
String mxBeanType) {
super("Datastore", mxBeanType, JMX_CATEGORY_CONFIGURATION);
}
super("Datastore", mxBeanType, JMX_CATEGORY_CONFIGURATION);
}
- public void setContext(DatastoreContext context) {
+ public void setContext(
final
DatastoreContext context) {
this.context = context;
}
this.context = context;
}
@@
-64,6
+64,11
@@
public class DatastoreConfigurationMXBeanImpl extends AbstractMXBean implements
return context.getShardRaftConfig().getSnapshotDataThresholdPercentage();
}
return context.getShardRaftConfig().getSnapshotDataThresholdPercentage();
}
+ @Override
+ public int getShardSnapshotDataThreshold() {
+ return context.getShardRaftConfig().getSnapshotDataThreshold();
+ }
+
@Override
public long getShardSnapshotBatchCount() {
return context.getShardRaftConfig().getSnapshotBatchCount();
@Override
public long getShardSnapshotBatchCount() {
return context.getShardRaftConfig().getSnapshotBatchCount();
@@
-110,23
+115,27
@@
public class DatastoreConfigurationMXBeanImpl extends AbstractMXBean implements
}
@Override
}
@Override
+ @Deprecated(forRemoval = true)
public int getMaxShardDataChangeExecutorPoolSize() {
public int getMaxShardDataChangeExecutorPoolSize() {
- return
context.getDataStoreProperties().getMaxDataChangeExecutorPoolSize()
;
+ return
0
;
}
@Override
}
@Override
+ @Deprecated(forRemoval = true)
public int getMaxShardDataChangeExecutorQueueSize() {
public int getMaxShardDataChangeExecutorQueueSize() {
- return
context.getDataStoreProperties().getMaxDataChangeExecutorQueueSize()
;
+ return
0
;
}
@Override
}
@Override
+ @Deprecated(forRemoval = true)
public int getMaxShardDataChangeListenerQueueSize() {
public int getMaxShardDataChangeListenerQueueSize() {
- return
context.getDataStoreProperties().getMaxDataChangeListenerQueueSize()
;
+ return
0
;
}
@Override
}
@Override
+ @Deprecated(forRemoval = true)
public int getMaxShardDataStoreExecutorQueueSize() {
public int getMaxShardDataStoreExecutorQueueSize() {
- return
context.getDataStoreProperties().getMaxDataStoreExecutorQueueSize()
;
+ return
0
;
}
@Override
}
@Override