Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fixup checkstyle
[controller.git]
/
opendaylight
/
md-sal
/
eos-dom-akka
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
eos
/
akka
/
bootstrap
/
EOSMain.java
diff --git
a/opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/bootstrap/EOSMain.java
b/opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/bootstrap/EOSMain.java
index be1415ed5bf7a1f2e1f0d6b603ba07f4a1ca1447..dab699e394d5fc65bca8ab681d1cefdc9b045136 100644
(file)
--- a/
opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/bootstrap/EOSMain.java
+++ b/
opendaylight/md-sal/eos-dom-akka/src/main/java/org/opendaylight/controller/eos/akka/bootstrap/EOSMain.java
@@
-9,6
+9,7
@@
package org.opendaylight.controller.eos.akka.bootstrap;
import akka.actor.typed.ActorRef;
import akka.actor.typed.Behavior;
import akka.actor.typed.ActorRef;
import akka.actor.typed.Behavior;
+import akka.actor.typed.SupervisorStrategy;
import akka.actor.typed.javadsl.AbstractBehavior;
import akka.actor.typed.javadsl.ActorContext;
import akka.actor.typed.javadsl.Behaviors;
import akka.actor.typed.javadsl.AbstractBehavior;
import akka.actor.typed.javadsl.ActorContext;
import akka.actor.typed.javadsl.Behaviors;
@@
-43,12
+44,13
@@
public final class EOSMain extends AbstractBehavior<BootstrapCommand> {
final String role = Cluster.get(context.getSystem()).selfMember().getRoles().iterator().next();
listenerRegistry = context.spawn(EntityTypeListenerRegistry.create(role), "ListenerRegistry");
final String role = Cluster.get(context.getSystem()).selfMember().getRoles().iterator().next();
listenerRegistry = context.spawn(EntityTypeListenerRegistry.create(role), "ListenerRegistry");
- candidateRegistry = context.spawn(CandidateRegistryInit.create(), "CandidateRegistry");
final ClusterSingleton clusterSingleton = ClusterSingleton.get(context.getSystem());
// start the initial sync behavior that switches to the regular one after syncing
ownerSupervisor = clusterSingleton.init(
final ClusterSingleton clusterSingleton = ClusterSingleton.get(context.getSystem());
// start the initial sync behavior that switches to the regular one after syncing
ownerSupervisor = clusterSingleton.init(
- SingletonActor.of(IdleSupervisor.create(iidCodec), "OwnerSupervisor"));
+ SingletonActor.of(Behaviors.supervise(IdleSupervisor.create(iidCodec))
+ .onFailure(SupervisorStrategy.restart()), "OwnerSupervisor"));
+ candidateRegistry = context.spawn(CandidateRegistryInit.create(ownerSupervisor), "CandidateRegistry");
ownerStateChecker = context.spawn(OwnerStateChecker.create(role, ownerSupervisor, iidCodec),
"OwnerStateChecker");
ownerStateChecker = context.spawn(OwnerStateChecker.create(role, ownerSupervisor, iidCodec),
"OwnerStateChecker");
@@
-73,7
+75,7
@@
public final class EOSMain extends AbstractBehavior<BootstrapCommand> {
}
private Behavior<BootstrapCommand> onTerminate(final Terminate request) {
}
private Behavior<BootstrapCommand> onTerminate(final Terminate request) {
- request.getReplyTo().tell(Empty.
getInstanc
e());
+ request.getReplyTo().tell(Empty.
valu
e());
return Behaviors.stopped();
}
}
\ No newline at end of file
return Behaviors.stopped();
}
}
\ No newline at end of file