2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.controller.sal.connect.netconf;
10 import java.util.Collections;
11 import java.util.List;
13 import java.util.Map.Entry;
16 import org.eclipse.xtext.xbase.lib.IterableExtensions;
17 import org.opendaylight.controller.md.sal.common.api.data.DataModification;
18 import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler.DataCommitTransaction;
19 import org.opendaylight.yangtools.yang.common.QName;
20 import org.opendaylight.yangtools.yang.common.RpcResult;
21 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
22 import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier;
23 import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier.NodeIdentifierWithPredicates;
24 import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier.PathArgument;
25 import org.opendaylight.yangtools.yang.data.api.Node;
26 import org.opendaylight.yangtools.yang.data.impl.ImmutableCompositeNode;
27 import org.opendaylight.yangtools.yang.data.impl.util.CompositeNodeBuilder;
29 import com.google.common.base.Optional;
30 import com.google.common.base.Preconditions;
31 import com.google.common.collect.Collections2;
32 import com.google.common.collect.ImmutableList;
33 import com.google.common.collect.Iterables;
34 import com.google.common.collect.Lists;
36 import static org.opendaylight.controller.sal.connect.netconf.NetconfMapping.*;
38 public class NetconfDeviceTwoPhaseCommitTransaction implements DataCommitTransaction<InstanceIdentifier, CompositeNode> {
40 private NetconfDevice device;
41 private final DataModification<InstanceIdentifier, CompositeNode> modification;
42 private boolean candidateSupported = true;
44 public NetconfDeviceTwoPhaseCommitTransaction(NetconfDevice device,
45 DataModification<InstanceIdentifier, CompositeNode> modification) {
48 this.modification = modification;
51 public void prepare() {
52 for (InstanceIdentifier toRemove : modification.getRemovedConfigurationData()) {
55 for(Entry<InstanceIdentifier, CompositeNode> toUpdate : modification.getUpdatedConfigurationData().entrySet()) {
56 sendMerge(toUpdate.getKey(),toUpdate.getValue());
61 private void sendMerge(InstanceIdentifier key, CompositeNode value) {
62 sendEditRpc(createEditStructure(key, Optional.<String>absent(), Optional.of(value)));
65 private void sendRemove(InstanceIdentifier toRemove) {
66 sendEditRpc(createEditStructure(toRemove, Optional.of("remove"), Optional.<CompositeNode> absent()));
69 private void sendEditRpc(CompositeNode editStructure) {
70 CompositeNodeBuilder<ImmutableCompositeNode> builder = configurationRpcBuilder();
71 builder.setQName(NETCONF_EDIT_CONFIG_QNAME);
72 builder.add(editStructure);
74 RpcResult<CompositeNode> rpcResult = device.invokeRpc(NETCONF_EDIT_CONFIG_QNAME, builder.toInstance());
75 Preconditions.checkState(rpcResult.isSuccessful(),"Rpc Result was unsuccessful");
79 private CompositeNodeBuilder<ImmutableCompositeNode> configurationRpcBuilder() {
80 CompositeNodeBuilder<ImmutableCompositeNode> ret = ImmutableCompositeNode.builder();
83 if(candidateSupported) {
84 targetNode = ImmutableCompositeNode.create(NETCONF_CANDIDATE_QNAME, ImmutableList.<Node<?>>of());
86 targetNode = ImmutableCompositeNode.create(NETCONF_RUNNING_QNAME, ImmutableList.<Node<?>>of());
88 Node<?> targetWrapperNode = ImmutableCompositeNode.create(NETCONF_TARGET_QNAME, ImmutableList.<Node<?>>of(targetNode));
89 ret.add(targetWrapperNode);
93 private CompositeNode createEditStructure(InstanceIdentifier dataPath, Optional<String> action,
94 Optional<CompositeNode> lastChildOverride) {
95 List<PathArgument> path = dataPath.getPath();
96 List<PathArgument> reversed = Lists.reverse(path);
97 CompositeNode previous = null;
98 boolean isLast = true;
99 for (PathArgument arg : reversed) {
100 CompositeNodeBuilder<ImmutableCompositeNode> builder = ImmutableCompositeNode.builder();
101 builder.setQName(arg.getNodeType());
102 Map<QName, Object> predicates = Collections.emptyMap();
103 if (arg instanceof NodeIdentifierWithPredicates) {
104 predicates = ((NodeIdentifierWithPredicates) arg).getKeyValues();
106 for (Entry<QName, Object> entry : predicates.entrySet()) {
107 builder.addLeaf(entry.getKey(), entry.getValue());
111 if (action.isPresent()) {
112 builder.setAttribute(NETCONF_ACTION_QNAME, action.get());
114 if (lastChildOverride.isPresent()) {
115 List<Node<?>> children = lastChildOverride.get().getChildren();
116 for(Node<?> child : children) {
117 if(!predicates.containsKey(child.getKey())) {
124 builder.add(previous);
126 previous = builder.toInstance();
129 return ImmutableCompositeNode.create(NETCONF_CONFIG_QNAME, ImmutableList.<Node<?>>of(previous));
133 public RpcResult<Void> finish() throws IllegalStateException {
134 CompositeNodeBuilder<ImmutableCompositeNode> commitInput = ImmutableCompositeNode.builder();
135 commitInput.setQName(NETCONF_COMMIT_QNAME);
136 RpcResult<?> rpcResult = device.invokeRpc(NetconfMapping.NETCONF_COMMIT_QNAME, commitInput.toInstance());
137 return (RpcResult<Void>) rpcResult;
141 public DataModification<InstanceIdentifier, CompositeNode> getModification() {
142 return this.modification;
146 public RpcResult<Void> rollback() throws IllegalStateException {
147 // TODO Auto-generated method stub