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.sal;
10 import java.util.concurrent.ExecutionException;
12 import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler;
13 import org.opendaylight.controller.md.sal.common.api.data.DataModification;
14 import org.opendaylight.controller.sal.connect.util.RemoteDeviceId;
15 import org.opendaylight.controller.sal.core.api.RpcImplementation;
16 import org.opendaylight.yangtools.yang.common.RpcError;
17 import org.opendaylight.yangtools.yang.common.RpcResult;
18 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
19 import org.opendaylight.yangtools.yang.data.api.CompositeNode;
20 import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier;
21 import org.slf4j.Logger;
22 import org.slf4j.LoggerFactory;
24 public final class NetconfDeviceCommitHandler implements DataCommitHandler<InstanceIdentifier,CompositeNode> {
26 private static final Logger logger= LoggerFactory.getLogger(NetconfDeviceCommitHandler.class);
28 private final RemoteDeviceId id;
29 private final RpcImplementation rpc;
30 private final boolean rollbackSupported;
32 public NetconfDeviceCommitHandler(final RemoteDeviceId id, final RpcImplementation rpc, final boolean rollbackSupported) {
35 this.rollbackSupported = rollbackSupported;
39 public DataCommitTransaction<InstanceIdentifier, CompositeNode> requestCommit(
40 final DataModification<InstanceIdentifier, CompositeNode> modification) {
42 final NetconfDeviceTwoPhaseCommitTransaction twoPhaseCommit = new NetconfDeviceTwoPhaseCommitTransaction(id, rpc,
43 modification, true, rollbackSupported);
45 twoPhaseCommit.prepare();
46 } catch (final InterruptedException e) {
47 Thread.currentThread().interrupt();
48 throw new RuntimeException(id + ": Interrupted while waiting for response", e);
49 } catch (final ExecutionException e) {
50 logger.warn("{}: Error executing pre commit operation on remote device", id, e);
51 return new FailingTransaction(twoPhaseCommit, e);
54 return twoPhaseCommit;
58 * Always fail commit transaction that rolls back delegate transaction afterwards
60 private class FailingTransaction implements DataCommitTransaction<InstanceIdentifier, CompositeNode> {
61 private final NetconfDeviceTwoPhaseCommitTransaction twoPhaseCommit;
62 private final ExecutionException e;
64 public FailingTransaction(final NetconfDeviceTwoPhaseCommitTransaction twoPhaseCommit, final ExecutionException e) {
65 this.twoPhaseCommit = twoPhaseCommit;
70 public DataModification<InstanceIdentifier, CompositeNode> getModification() {
71 return twoPhaseCommit.getModification();
75 public RpcResult<Void> finish() throws IllegalStateException {
76 return RpcResultBuilder.<Void>failed().withError( RpcError.ErrorType.APPLICATION,
77 id + ": Unexpected operation error during pre-commit operations", e ).build();
81 public RpcResult<Void> rollback() throws IllegalStateException {
82 return twoPhaseCommit.rollback();