1 package org.opendaylight.controller.sal.connect.netconf.sal.tx;
3 import com.google.common.base.Function;
4 import com.google.common.base.Optional;
5 import com.google.common.base.Preconditions;
6 import com.google.common.util.concurrent.ListenableFuture;
7 import java.util.concurrent.ExecutionException;
8 import java.util.concurrent.TimeUnit;
9 import java.util.concurrent.TimeoutException;
10 import org.opendaylight.controller.md.sal.common.api.TransactionStatus;
11 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
12 import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
13 import org.opendaylight.controller.md.sal.dom.api.DOMRpcResult;
14 import org.opendaylight.controller.netconf.api.NetconfDocumentedException;
15 import org.opendaylight.controller.sal.connect.netconf.listener.NetconfSessionPreferences;
16 import org.opendaylight.controller.sal.connect.netconf.util.NetconfBaseOps;
17 import org.opendaylight.controller.sal.connect.util.RemoteDeviceId;
18 import org.opendaylight.yangtools.yang.common.RpcResult;
19 import org.opendaylight.yangtools.yang.data.api.ModifyAction;
20 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
21 import org.opendaylight.yangtools.yang.data.api.schema.DataContainerChild;
22 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
24 public abstract class AbstractWriteTx implements DOMDataWriteTransaction {
26 private final long defaultRequestTimeoutMillis;
28 protected final RemoteDeviceId id;
29 protected final NetconfBaseOps netOps;
30 protected final NetconfSessionPreferences netconfSessionPreferences;
31 // Allow commit to be called only once
32 protected boolean finished = false;
34 public AbstractWriteTx(final NetconfBaseOps netOps, final RemoteDeviceId id, final NetconfSessionPreferences netconfSessionPreferences, long defaultRequestTimeoutMillis) {
37 this.netconfSessionPreferences = netconfSessionPreferences;
38 this.defaultRequestTimeoutMillis = defaultRequestTimeoutMillis;
42 static boolean isSuccess(final DOMRpcResult result) {
43 return result.getErrors().isEmpty();
46 protected void checkNotFinished() {
47 Preconditions.checkState(!isFinished(), "%s: Transaction %s already finished", id, getIdentifier());
50 protected boolean isFinished() {
54 protected void invokeBlocking(final String msg, final Function<NetconfBaseOps, ListenableFuture<DOMRpcResult>> op) throws NetconfDocumentedException {
56 final DOMRpcResult compositeNodeRpcResult = op.apply(netOps).get(defaultRequestTimeoutMillis, TimeUnit.MILLISECONDS);
57 if(isSuccess(compositeNodeRpcResult) == false) {
58 throw new NetconfDocumentedException(id + ": " + msg + " failed: " + compositeNodeRpcResult.getErrors(), NetconfDocumentedException.ErrorType.application,
59 NetconfDocumentedException.ErrorTag.operation_failed, NetconfDocumentedException.ErrorSeverity.warning);
61 } catch (final InterruptedException e) {
62 Thread.currentThread().interrupt();
63 throw new RuntimeException(e);
64 } catch (final ExecutionException | TimeoutException e) {
65 throw new NetconfDocumentedException(id + ": " + msg + " failed: " + e.getMessage(), e, NetconfDocumentedException.ErrorType.application,
66 NetconfDocumentedException.ErrorTag.operation_failed, NetconfDocumentedException.ErrorSeverity.warning);
71 public synchronized boolean cancel() {
81 protected abstract void init();
83 protected abstract void cleanup();
86 public Object getIdentifier() {
91 public synchronized void put(final LogicalDatastoreType store, final YangInstanceIdentifier path, final NormalizedNode<?, ?> data) {
96 netOps.createEditConfigStrcture(Optional.<NormalizedNode<?, ?>>fromNullable(data), Optional.of(ModifyAction.REPLACE), path), Optional.of(ModifyAction.NONE));
97 } catch (final NetconfDocumentedException e) {
98 handleEditException(path, data, e, "putting");
102 protected abstract void handleEditException(YangInstanceIdentifier path, NormalizedNode<?, ?> data, NetconfDocumentedException e, String editType);
103 protected abstract void handleDeleteException(YangInstanceIdentifier path, NetconfDocumentedException e);
106 public synchronized void merge(final LogicalDatastoreType store, final YangInstanceIdentifier path, final NormalizedNode<?, ?> data) {
107 checkEditable(store);
111 netOps.createEditConfigStrcture(Optional.<NormalizedNode<?, ?>>fromNullable(data), Optional.<ModifyAction>absent(), path), Optional.<ModifyAction>absent());
112 } catch (final NetconfDocumentedException e) {
113 handleEditException(path, data, e, "merge");
118 public synchronized void delete(final LogicalDatastoreType store, final YangInstanceIdentifier path) {
119 checkEditable(store);
123 netOps.createEditConfigStrcture(Optional.<NormalizedNode<?, ?>>absent(), Optional.of(ModifyAction.DELETE), path), Optional.of(ModifyAction.NONE));
124 } catch (final NetconfDocumentedException e) {
125 handleDeleteException(path, e);
130 public final ListenableFuture<RpcResult<TransactionStatus>> commit() {
134 return performCommit();
137 protected abstract ListenableFuture<RpcResult<TransactionStatus>> performCommit();
139 private void checkEditable(final LogicalDatastoreType store) {
141 Preconditions.checkArgument(store == LogicalDatastoreType.CONFIGURATION, "Can edit only configuration data, not %s", store);
144 protected abstract void editConfig(DataContainerChild<?, ?> editStructure, Optional<ModifyAction> defaultOperation) throws NetconfDocumentedException;