import java.util.Map;
import java.util.Set;
import org.opendaylight.controller.cluster.datastore.DataStoreVersions;
+import org.opendaylight.controller.cluster.datastore.node.utils.stream.NormalizedNodeDataInput;
import org.opendaylight.controller.cluster.datastore.node.utils.stream.NormalizedNodeDataOutput;
import org.opendaylight.controller.cluster.datastore.node.utils.stream.NormalizedNodeInputOutput;
import org.opendaylight.controller.cluster.datastore.node.utils.stream.NormalizedNodeInputStreamReader;
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
in.readShort(); // Read the version
- NormalizedNodeInputStreamReader streamReader = new NormalizedNodeInputStreamReader(in);
+ NormalizedNodeDataInput streamReader = new NormalizedNodeInputStreamReader(in);
// Note: the scope passed to builder is not actually used.
Builder builder = DOMImmutableDataChangeEvent.builder(DataChangeScope.SUBTREE);
// Read created data
int size = in.readInt();
- for(int i = 0; i < size; i++) {
+ for (int i = 0; i < size; i++) {
YangInstanceIdentifier path = streamReader.readYangInstanceIdentifier();
NormalizedNode<?, ?> node = streamReader.readNormalizedNode();
builder.addCreated(path, node);
// Read updated data
size = in.readInt();
- for(int i = 0; i < size; i++) {
+ for (int i = 0; i < size; i++) {
YangInstanceIdentifier path = streamReader.readYangInstanceIdentifier();
NormalizedNode<?, ?> before = streamReader.readNormalizedNode();
NormalizedNode<?, ?> after = streamReader.readNormalizedNode();
// Read removed data
size = in.readInt();
- for(int i = 0; i < size; i++) {
+ for (int i = 0; i < size; i++) {
YangInstanceIdentifier path = streamReader.readYangInstanceIdentifier();
NormalizedNode<?, ?> node = streamReader.readNormalizedNode();
builder.addRemoved(path, node);
// Read original subtree
boolean present = in.readBoolean();
- if(present) {
+ if (present) {
builder.setBefore(streamReader.readNormalizedNode());
}
// Read updated subtree
present = in.readBoolean();
- if(present) {
+ if (present) {
builder.setAfter(streamReader.readNormalizedNode());
}
Map<YangInstanceIdentifier, NormalizedNode<?, ?>> createdData = change.getCreatedData();
out.writeInt(createdData.size());
- for(Map.Entry<YangInstanceIdentifier, NormalizedNode<?, ?>> e: createdData.entrySet()) {
+ for (Map.Entry<YangInstanceIdentifier, NormalizedNode<?, ?>> e: createdData.entrySet()) {
streamWriter.writeYangInstanceIdentifier(e.getKey());
streamWriter.writeNormalizedNode(e.getValue());
}
Map<YangInstanceIdentifier, NormalizedNode<?, ?>> originalData = change.getOriginalData();
Map<YangInstanceIdentifier, NormalizedNode<?, ?>> updatedData = change.getUpdatedData();
out.writeInt(updatedData.size());
- for(Map.Entry<YangInstanceIdentifier, NormalizedNode<?, ?>> e: updatedData.entrySet()) {
+ for (Map.Entry<YangInstanceIdentifier, NormalizedNode<?, ?>> e: updatedData.entrySet()) {
streamWriter.writeYangInstanceIdentifier(e.getKey());
streamWriter.writeNormalizedNode(originalData.get(e.getKey()));
streamWriter.writeNormalizedNode(e.getValue());
Set<YangInstanceIdentifier> removed = change.getRemovedPaths();
out.writeInt(removed.size());
- for(YangInstanceIdentifier path: removed) {
+ for (YangInstanceIdentifier path: removed) {
streamWriter.writeYangInstanceIdentifier(path);
streamWriter.writeNormalizedNode(originalData.get(path));
}
NormalizedNode<?, ?> originalSubtree = change.getOriginalSubtree();
out.writeBoolean(originalSubtree != null);
- if(originalSubtree != null) {
+ if (originalSubtree != null) {
streamWriter.writeNormalizedNode(originalSubtree);
}
NormalizedNode<?, ?> updatedSubtree = change.getUpdatedSubtree();
out.writeBoolean(updatedSubtree != null);
- if(updatedSubtree != null) {
+ if (updatedSubtree != null) {
streamWriter.writeNormalizedNode(updatedSubtree);
}
}