Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Remove shard-snapshot-chunk-size
[controller.git]
/
opendaylight
/
md-sal
/
sal-akka-raft
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
raft
/
DefaultConfigParamsImpl.java
diff --git
a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/DefaultConfigParamsImpl.java
b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/DefaultConfigParamsImpl.java
index 0d65fa2ea1272a9ee77567cc493c7bd464b9ba27..c83f90ec430e9d4ec0228b53e65b4cd9d9d726b4 100644
(file)
--- a/
opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/DefaultConfigParamsImpl.java
+++ b/
opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/DefaultConfigParamsImpl.java
@@
-41,7
+41,7
@@
public class DefaultConfigParamsImpl implements ConfigParams {
*/
private static final int ELECTION_TIME_MAX_VARIANCE = 100;
*/
private static final int ELECTION_TIME_MAX_VARIANCE = 100;
- private static final int
SNAPSHOT_CHUNK
_SIZE = 480 * 1024; // 480KiB
+ private static final int
MAXIMUM_MESSAGE_SLICE
_SIZE = 480 * 1024; // 480KiB
/**
/**
@@
-72,7
+72,7
@@
public class DefaultConfigParamsImpl implements ConfigParams {
// 0 means direct threshold if disabled
private int snapshotDataThreshold = 0;
// 0 means direct threshold if disabled
private int snapshotDataThreshold = 0;
- private int
snapshotChunkSize = SNAPSHOT_CHUNK
_SIZE;
+ private int
maximumMessageSliceSize = MAXIMUM_MESSAGE_SLICE
_SIZE;
private long electionTimeoutFactor = 2;
private long candidateElectionTimeoutDivisor = 1;
private long electionTimeoutFactor = 2;
private long candidateElectionTimeoutDivisor = 1;
@@
-108,8
+108,8
@@
public class DefaultConfigParamsImpl implements ConfigParams {
this.snapshotDataThreshold = snapshotDataThreshold;
}
this.snapshotDataThreshold = snapshotDataThreshold;
}
- public void set
SnapshotChunkSize(final int snapshotChunk
Size) {
- this.
snapshotChunkSize = snapshotChunk
Size;
+ public void set
MaximumMessageSliceSize(final int maximumMessageSlice
Size) {
+ this.
maximumMessageSliceSize = maximumMessageSlice
Size;
}
public void setJournalRecoveryLogBatchSize(final int journalRecoveryLogBatchSize) {
}
public void setJournalRecoveryLogBatchSize(final int journalRecoveryLogBatchSize) {
@@
-191,8
+191,8
@@
public class DefaultConfigParamsImpl implements ConfigParams {
}
@Override
}
@Override
- public int get
SnapshotChunk
Size() {
- return
snapshotChunk
Size;
+ public int get
MaximumMessageSlice
Size() {
+ return
maximumMessageSlice
Size;
}
@Override
}
@Override