Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Trace the originating generation in RGE
[controller.git]
/
opendaylight
/
md-sal
/
sal-distributed-datastore
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
datastore
/
DelayedListenerRegistration.java
diff --git
a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DelayedListenerRegistration.java
b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DelayedListenerRegistration.java
index 18d23aa0cd95fb2270d46ebd3a24b30814bbf959..e1c9f0ba2c8b84df5f8302ca7f74a679431786a2 100644
(file)
--- a/
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DelayedListenerRegistration.java
+++ b/
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DelayedListenerRegistration.java
@@
-13,7
+13,7
@@
import javax.annotation.concurrent.GuardedBy;
import org.opendaylight.controller.cluster.datastore.messages.ListenerRegistrationMessage;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
import org.opendaylight.controller.cluster.datastore.messages.ListenerRegistrationMessage;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
-
abstract
class DelayedListenerRegistration<L extends EventListener, M extends ListenerRegistrationMessage>
+class DelayedListenerRegistration<L extends EventListener, M extends ListenerRegistrationMessage>
implements ListenerRegistration<L> {
private final M registrationMessage;
private final ActorRef registrationActor;
implements ListenerRegistration<L> {
private final M registrationMessage;
private final ActorRef registrationActor;
@@
-30,7
+30,7
@@
abstract class DelayedListenerRegistration<L extends EventListener, M extends Li
return registrationMessage;
}
return registrationMessage;
}
- synchronized void
createDelegate(final AbstractDataListenerSupport<L, M, ?
> support) {
+ synchronized void
doRegistration(final AbstractDataListenerSupport<L, M
> support) {
if (!closed) {
support.doRegistration(registrationMessage, registrationActor);
}
if (!closed) {
support.doRegistration(registrationMessage, registrationActor);
}