X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fnetconf%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnect%2Fnetconf%2Fsal%2Ftx%2FWriteCandidateTx.java;fp=opendaylight%2Fnetconf%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnect%2Fnetconf%2Fsal%2Ftx%2FWriteCandidateTx.java;h=0000000000000000000000000000000000000000;hb=9ba2b4eca79bcc0e78099b133296801c8d45a6c4;hp=5c83366f2bc879b4838eb1383833b1f9965e500b;hpb=b2e81149739c87f0ecc2ce7f06448d7a5d3162b8;p=controller.git diff --git a/opendaylight/netconf/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/sal/tx/WriteCandidateTx.java b/opendaylight/netconf/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/sal/tx/WriteCandidateTx.java deleted file mode 100644 index 5c83366f2b..0000000000 --- a/opendaylight/netconf/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/sal/tx/WriteCandidateTx.java +++ /dev/null @@ -1,205 +0,0 @@ -/* - * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. - * - * This program and the accompanying materials are made available under the - * terms of the Eclipse Public License v1.0 which accompanies this distribution, - * and is available at http://www.eclipse.org/legal/epl-v10.html - */ - -package org.opendaylight.controller.sal.connect.netconf.sal.tx; - -import com.google.common.base.Function; -import com.google.common.base.Optional; -import com.google.common.base.Preconditions; -import com.google.common.util.concurrent.CheckedFuture; -import com.google.common.util.concurrent.Futures; -import com.google.common.util.concurrent.ListenableFuture; -import org.opendaylight.controller.md.sal.common.api.TransactionStatus; -import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException; -import org.opendaylight.controller.md.sal.dom.api.DOMRpcResult; -import org.opendaylight.controller.netconf.api.NetconfDocumentedException; -import org.opendaylight.controller.sal.connect.netconf.util.NetconfBaseOps; -import org.opendaylight.controller.sal.connect.netconf.util.NetconfRpcFutureCallback; -import org.opendaylight.controller.sal.connect.util.RemoteDeviceId; -import org.opendaylight.yangtools.yang.common.RpcError; -import org.opendaylight.yangtools.yang.common.RpcResult; -import org.opendaylight.yangtools.yang.common.RpcResultBuilder; -import org.opendaylight.yangtools.yang.data.api.ModifyAction; -import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; -import org.opendaylight.yangtools.yang.data.api.schema.DataContainerChild; -import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -/** - * Tx implementation for netconf devices that support only candidate datastore and no writable running - * The sequence goes as: - *
    - *
  1. Lock candidate datastore on tx construction - * - *
  2. Edit-config in candidate N times - * - *
  3. Commit and Unlock candidate datastore async - *
- */ -public class WriteCandidateTx extends AbstractWriteTx { - - private static final Logger LOG = LoggerFactory.getLogger(WriteCandidateTx.class); - - private static final Function> RPC_RESULT_TO_TX_STATUS = new Function>() { - @Override - public RpcResult apply(final DOMRpcResult input) { - if (isSuccess(input)) { - return RpcResultBuilder.success(TransactionStatus.COMMITED).build(); - } else { - final RpcResultBuilder failed = RpcResultBuilder.failed(); - for (final RpcError rpcError : input.getErrors()) { - failed.withError(rpcError.getErrorType(), rpcError.getTag(), rpcError.getMessage(), - rpcError.getApplicationTag(), rpcError.getInfo(), rpcError.getCause()); - } - return failed.build(); - } - } - }; - - public WriteCandidateTx(final RemoteDeviceId id, final NetconfBaseOps rpc, final boolean rollbackSupport, long requestTimeoutMillis) { - super(requestTimeoutMillis, rpc, id, rollbackSupport); - } - - @Override - protected synchronized void init() { - LOG.trace("{}: Initializing {} transaction", id, getClass().getSimpleName()); - - try { - lock(); - } catch (final NetconfDocumentedException e) { - try { - LOG.warn("{}: Failed to lock candidate, attempting discard changes", id); - discardChanges(); - LOG.warn("{}: Changes discarded successfully, attempting lock", id); - lock(); - } catch (final NetconfDocumentedException secondE) { - LOG.error("{}: Failed to prepare candidate. Failed to initialize transaction", id, secondE); - throw new RuntimeException(id + ": Failed to prepare candidate. Failed to initialize transaction", secondE); - } - } - } - - private void lock() throws NetconfDocumentedException { - try { - invokeBlocking("Lock candidate", new Function>() { - @Override - public ListenableFuture apply(final NetconfBaseOps input) { - return input.lockCandidate(new NetconfRpcFutureCallback("Lock candidate", id)); - } - }); - } catch (final NetconfDocumentedException e) { - LOG.warn("{}: Failed to lock candidate", id, e); - throw e; - } - } - - @Override - protected void cleanup() { - discardChanges(); - cleanupOnSuccess(); - } - - @Override - protected void handleEditException(final YangInstanceIdentifier path, final NormalizedNode data, final NetconfDocumentedException e, final String editType) { - LOG.warn("{}: Error {} data to (candidate){}, data: {}, canceling", id, editType, path, data, e); - cancel(); - throw new RuntimeException(id + ": Error while " + editType + ": (candidate)" + path, e); - } - - @Override - protected void handleDeleteException(final YangInstanceIdentifier path, final NetconfDocumentedException e) { - LOG.warn("{}: Error deleting data (candidate){}, canceling", id, path, e); - cancel(); - throw new RuntimeException(id + ": Error while deleting (candidate)" + path, e); - } - - @Override - public synchronized CheckedFuture submit() { - final ListenableFuture commitFutureAsVoid = Futures.transform(commit(), new Function, Void>() { - @Override - public Void apply(final RpcResult input) { - Preconditions.checkArgument(input.isSuccessful() && input.getErrors().isEmpty(), "Submit failed with errors: %s", input.getErrors()); - return null; - } - }); - - return Futures.makeChecked(commitFutureAsVoid, new Function() { - @Override - public TransactionCommitFailedException apply(final Exception input) { - return new TransactionCommitFailedException("Submit of transaction " + getIdentifier() + " failed", input); - } - }); - } - - /** - * This has to be non blocking since it is called from a callback on commit and its netty threadpool that is really sensitive to blocking calls - */ - private void discardChanges() { - netOps.discardChanges(new NetconfRpcFutureCallback("Discarding candidate", id)); - } - - @Override - public synchronized ListenableFuture> performCommit() { - final ListenableFuture rpcResult = netOps.commit(new NetconfRpcFutureCallback("Commit", id) { - @Override - public void onSuccess(final DOMRpcResult result) { - super.onSuccess(result); - LOG.debug("{}: Write successful, transaction: {}. Unlocking", id, getIdentifier()); - cleanupOnSuccess(); - } - - @Override - protected void onUnsuccess(final DOMRpcResult result) { - LOG.error("{}: Write failed, transaction {}, discarding changes, unlocking: {}", id, getIdentifier(), result.getErrors()); - cleanup(); - } - - @Override - public void onFailure(final Throwable t) { - LOG.error("{}: Write failed, transaction {}, discarding changes, unlocking", id, getIdentifier(), t); - cleanup(); - } - }); - - return Futures.transform(rpcResult, RPC_RESULT_TO_TX_STATUS); - } - - protected void cleanupOnSuccess() { - unlock(); - } - - @Override - protected void editConfig(final DataContainerChild editStructure, final Optional defaultOperation) throws NetconfDocumentedException { - invokeBlocking("Edit candidate", new Function>() { - @Override - public ListenableFuture apply(final NetconfBaseOps input) { - return defaultOperation.isPresent() - ? input.editConfigCandidate(new NetconfRpcFutureCallback("Edit candidate", id), editStructure, defaultOperation.get(), - rollbackSupport) - : input.editConfigCandidate(new NetconfRpcFutureCallback("Edit candidate", id), editStructure, - rollbackSupport); - } - }); - } - - /** - * This has to be non blocking since it is called from a callback on commit and its netty threadpool that is really sensitive to blocking calls - */ - private void unlock() { - netOps.unlockCandidate(new NetconfRpcFutureCallback("Unlock candidate", id)); - } - -}