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.util.NetconfBaseOps;
16 import org.opendaylight.controller.sal.connect.util.RemoteDeviceId;
17 import org.opendaylight.yangtools.yang.common.RpcResult;
18 import org.opendaylight.yangtools.yang.data.api.ModifyAction;
19 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
20 import org.opendaylight.yangtools.yang.data.api.schema.DataContainerChild;
21 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
23 public abstract class AbstractWriteTx implements DOMDataWriteTransaction {
25 private final long defaultRequestTimeoutMillis;
26 protected final RemoteDeviceId id;
27 protected final NetconfBaseOps netOps;
28 protected final boolean rollbackSupport;
29 // Allow commit to be called only once
30 protected boolean finished = false;
32 public AbstractWriteTx(final long requestTimeoutMillis, final NetconfBaseOps netOps, final RemoteDeviceId id, final boolean rollbackSupport) {
33 this.defaultRequestTimeoutMillis = requestTimeoutMillis;
36 this.rollbackSupport = rollbackSupport;
40 static boolean isSuccess(final DOMRpcResult result) {
41 return result.getErrors().isEmpty();
44 protected void checkNotFinished() {
45 Preconditions.checkState(!isFinished(), "%s: Transaction %s already finished", id, getIdentifier());
48 protected boolean isFinished() {
52 protected void invokeBlocking(final String msg, final Function<NetconfBaseOps, ListenableFuture<DOMRpcResult>> op) throws NetconfDocumentedException {
54 final DOMRpcResult compositeNodeRpcResult = op.apply(netOps).get(defaultRequestTimeoutMillis, TimeUnit.MILLISECONDS);
55 if(isSuccess(compositeNodeRpcResult) == false) {
56 throw new NetconfDocumentedException(id + ": " + msg + " failed: " + compositeNodeRpcResult.getErrors(), NetconfDocumentedException.ErrorType.application,
57 NetconfDocumentedException.ErrorTag.operation_failed, NetconfDocumentedException.ErrorSeverity.warning);
59 } catch (final InterruptedException e) {
60 Thread.currentThread().interrupt();
61 throw new RuntimeException(e);
62 } catch (final ExecutionException | TimeoutException e) {
63 throw new NetconfDocumentedException(id + ": " + msg + " failed: " + e.getMessage(), e, NetconfDocumentedException.ErrorType.application,
64 NetconfDocumentedException.ErrorTag.operation_failed, NetconfDocumentedException.ErrorSeverity.warning);
69 public synchronized boolean cancel() {
79 protected abstract void init();
81 protected abstract void cleanup();
84 public Object getIdentifier() {
89 public synchronized void put(final LogicalDatastoreType store, final YangInstanceIdentifier path, final NormalizedNode<?, ?> data) {
94 netOps.createEditConfigStrcture(Optional.<NormalizedNode<?, ?>>fromNullable(data), Optional.of(ModifyAction.REPLACE), path), Optional.of(ModifyAction.NONE));
95 } catch (final NetconfDocumentedException e) {
96 handleEditException(path, data, e, "putting");
100 protected abstract void handleEditException(YangInstanceIdentifier path, NormalizedNode<?, ?> data, NetconfDocumentedException e, String editType);
101 protected abstract void handleDeleteException(YangInstanceIdentifier path, NetconfDocumentedException e);
104 public synchronized void merge(final LogicalDatastoreType store, final YangInstanceIdentifier path, final NormalizedNode<?, ?> data) {
105 checkEditable(store);
109 netOps.createEditConfigStrcture(Optional.<NormalizedNode<?, ?>>fromNullable(data), Optional.<ModifyAction>absent(), path), Optional.<ModifyAction>absent());
110 } catch (final NetconfDocumentedException e) {
111 handleEditException(path, data, e, "merge");
116 public synchronized void delete(final LogicalDatastoreType store, final YangInstanceIdentifier path) {
117 checkEditable(store);
121 netOps.createEditConfigStrcture(Optional.<NormalizedNode<?, ?>>absent(), Optional.of(ModifyAction.DELETE), path), Optional.of(ModifyAction.NONE));
122 } catch (final NetconfDocumentedException e) {
123 handleDeleteException(path, e);
128 public final ListenableFuture<RpcResult<TransactionStatus>> commit() {
132 return performCommit();
135 protected abstract ListenableFuture<RpcResult<TransactionStatus>> performCommit();
137 private void checkEditable(final LogicalDatastoreType store) {
139 Preconditions.checkArgument(store == LogicalDatastoreType.CONFIGURATION, "Can edit only configuration data, not %s", store);
142 protected abstract void editConfig(DataContainerChild<?, ?> editStructure, Optional<ModifyAction> defaultOperation) throws NetconfDocumentedException;