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-8056: make doCommit/finishCommit package-private
[controller.git]
/
opendaylight
/
md-sal
/
sal-distributed-datastore
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
datastore
/
messages
/
RegisterDataTreeChangeListener.java
diff --git
a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/RegisterDataTreeChangeListener.java
b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/RegisterDataTreeChangeListener.java
index 941336e630985379366097906d4e326e93d77c1e..c9c0c0ceea914631c426304dea984971765a36b5 100644
(file)
--- a/
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/RegisterDataTreeChangeListener.java
+++ b/
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/messages/RegisterDataTreeChangeListener.java
@@
-13,23
+13,31
@@
import java.io.Externalizable;
import java.io.IOException;
import java.io.ObjectInput;
import java.io.ObjectOutput;
import java.io.IOException;
import java.io.ObjectInput;
import java.io.ObjectOutput;
-import org.opendaylight.controller.cluster.datastore.
utils
.SerializationUtils;
+import org.opendaylight.controller.cluster.datastore.
node.utils.stream
.SerializationUtils;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
/**
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
/**
- * Request a {@link org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener} registration be made on the
shard
- * leader.
+ * Request a {@link org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener} registration be made on the
+ *
shard
leader.
*/
*/
-public final class RegisterDataTreeChangeListener implements Externalizable {
+public final class RegisterDataTreeChangeListener implements Externalizable
, ListenerRegistrationMessage
{
private static final long serialVersionUID = 1L;
private ActorRef dataTreeChangeListenerPath;
private YangInstanceIdentifier path;
private static final long serialVersionUID = 1L;
private ActorRef dataTreeChangeListenerPath;
private YangInstanceIdentifier path;
+ private boolean registerOnAllInstances;
- public RegisterDataTreeChangeListener(final YangInstanceIdentifier path, final ActorRef dataTreeChangeListenerPath) {
+ public RegisterDataTreeChangeListener() {
+ // For Externalizable
+ }
+
+ public RegisterDataTreeChangeListener(final YangInstanceIdentifier path, final ActorRef dataTreeChangeListenerPath,
+ final boolean registerOnAllInstances) {
this.path = Preconditions.checkNotNull(path);
this.dataTreeChangeListenerPath = Preconditions.checkNotNull(dataTreeChangeListenerPath);
this.path = Preconditions.checkNotNull(path);
this.dataTreeChangeListenerPath = Preconditions.checkNotNull(dataTreeChangeListenerPath);
+ this.registerOnAllInstances = registerOnAllInstances;
}
}
+ @Override
public YangInstanceIdentifier getPath() {
return path;
}
public YangInstanceIdentifier getPath() {
return path;
}
@@
-38,15
+46,22
@@
public final class RegisterDataTreeChangeListener implements Externalizable {
return dataTreeChangeListenerPath;
}
return dataTreeChangeListenerPath;
}
+ @Override
+ public boolean isRegisterOnAllInstances() {
+ return registerOnAllInstances;
+ }
+
@Override
public void writeExternal(final ObjectOutput out) throws IOException {
out.writeObject(dataTreeChangeListenerPath);
SerializationUtils.serializePath(path, out);
@Override
public void writeExternal(final ObjectOutput out) throws IOException {
out.writeObject(dataTreeChangeListenerPath);
SerializationUtils.serializePath(path, out);
+ out.writeBoolean(registerOnAllInstances);
}
@Override
public void readExternal(final ObjectInput in) throws IOException, ClassNotFoundException {
dataTreeChangeListenerPath = (ActorRef) in.readObject();
path = SerializationUtils.deserializePath(in);
}
@Override
public void readExternal(final ObjectInput in) throws IOException, ClassNotFoundException {
dataTreeChangeListenerPath = (ActorRef) in.readObject();
path = SerializationUtils.deserializePath(in);
+ registerOnAllInstances = in.readBoolean();
}
}
}
}