Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Merge "Avoid IllegalArgument on missing source"
[controller.git]
/
opendaylight
/
md-sal
/
sal-akka-raft
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
raft
/
RaftActorContextImpl.java
diff --git
a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContextImpl.java
b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContextImpl.java
index b71b3be3522e1082e46f56f681a0ee49440ab79d..eb059d60fbee1c89d6a309e5cfaedbf5bc608c64 100644
(file)
--- a/
opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContextImpl.java
+++ b/
opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContextImpl.java
@@
-37,10
+37,14
@@
public class RaftActorContextImpl implements RaftActorContext {
private final Logger LOG;
private final Logger LOG;
- private
final
ConfigParams configParams;
+ private ConfigParams configParams;
private boolean snapshotCaptureInitiated;
private boolean snapshotCaptureInitiated;
+ // Snapshot manager will need to be created on demand as it needs raft actor context which cannot
+ // be passed to it in the constructor
+ private SnapshotManager snapshotManager;
+
public RaftActorContextImpl(ActorRef actor, UntypedActorContext context,
String id,
ElectionTerm termInformation, long commitIndex,
public RaftActorContextImpl(ActorRef actor, UntypedActorContext context,
String id,
ElectionTerm termInformation, long commitIndex,
@@
-59,6
+63,10
@@
public class RaftActorContextImpl implements RaftActorContext {
this.LOG = logger;
}
this.LOG = logger;
}
+ void setConfigParams(ConfigParams configParams) {
+ this.configParams = configParams;
+ }
+
@Override
public ActorRef actorOf(Props props){
return context.actorOf(props);
@Override
public ActorRef actorOf(Props props){
return context.actorOf(props);
@@
-130,16
+138,6
@@
public class RaftActorContextImpl implements RaftActorContext {
return configParams;
}
return configParams;
}
- @Override
- public void setSnapshotCaptureInitiated(boolean snapshotCaptureInitiated) {
- this.snapshotCaptureInitiated = snapshotCaptureInitiated;
- }
-
- @Override
- public boolean isSnapshotCaptureInitiated() {
- return snapshotCaptureInitiated;
- }
-
@Override public void addToPeers(String name, String address) {
peerAddresses.put(name, address);
}
@Override public void addToPeers(String name, String address) {
peerAddresses.put(name, address);
}
@@
-162,4
+160,11
@@
public class RaftActorContextImpl implements RaftActorContext {
peerAddresses.put(peerId, peerAddress);
}
peerAddresses.put(peerId, peerAddress);
}
+
+ public SnapshotManager getSnapshotManager() {
+ if(snapshotManager == null){
+ snapshotManager = new SnapshotManager(this, LOG);
+ }
+ return snapshotManager;
+ }
}
}