Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Bug 2787: Batch AppendEntries to speed up follower sync
[controller.git]
/
opendaylight
/
md-sal
/
sal-akka-raft
/
src
/
test
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
raft
/
MockRaftActorContext.java
diff --git
a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActorContext.java
b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActorContext.java
index 01ff6ce14f4eb44930f13dc5661ad7c6ab9c82fc..31a12d5659dcef801dce2bfa14357d9f53e58838 100644
(file)
--- a/
opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActorContext.java
+++ b/
opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActorContext.java
@@
-243,7
+243,8
@@
public class MockRaftActorContext implements RaftActorContext {
}
public static class SimpleReplicatedLog extends AbstractReplicatedLogImpl {
}
public static class SimpleReplicatedLog extends AbstractReplicatedLogImpl {
- @Override public void appendAndPersist(
+ @Override
+ public void appendAndPersist(
ReplicatedLogEntry replicatedLogEntry) {
append(replicatedLogEntry);
}
ReplicatedLogEntry replicatedLogEntry) {
append(replicatedLogEntry);
}
@@
-253,6
+254,10
@@
public class MockRaftActorContext implements RaftActorContext {
return -1;
}
return -1;
}
+ @Override
+ public void captureSnapshotIfReady(ReplicatedLogEntry replicatedLogEntry) {
+ }
+
@Override public void removeFromAndPersist(long index) {
removeFrom(index);
}
@Override public void removeFromAndPersist(long index) {
removeFrom(index);
}
@@
-430,7
+435,7
@@
public class MockRaftActorContext implements RaftActorContext {
public MockReplicatedLogBuilder createEntries(int start, int end, int term) {
for (int i=start; i<end; i++) {
public MockReplicatedLogBuilder createEntries(int start, int end, int term) {
for (int i=start; i<end; i++) {
- this.mockLog.append(new ReplicatedLogImplEntry(i, term, new MockRaftActorContext.MockPayload(
"foo" + i
)));
+ this.mockLog.append(new ReplicatedLogImplEntry(i, term, new MockRaftActorContext.MockPayload(
Integer.toString(i)
)));
}
return this;
}
}
return this;
}