opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/AbstractWriteTransaction.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.controller.md.sal.binding.impl;
   9
  10 import java.util.Map.Entry;
  11
  12 import org.opendaylight.controller.md.sal.common.api.TransactionStatus;
  13 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  14 import org.opendaylight.controller.md.sal.dom.api.DOMDataWriteTransaction;
  15 import org.opendaylight.yangtools.yang.binding.DataObject;
  16 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  17 import org.opendaylight.yangtools.yang.common.RpcResult;
  18 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
  19 import org.slf4j.Logger;
  20 import org.slf4j.LoggerFactory;
  21
  22 import com.google.common.util.concurrent.ListenableFuture;
  23
  24 /**
  25  *
  26  * Abstract Base Transaction for transactions which are backed by
  27  * {@link DOMDataWriteTransaction}
  28  */
  29 public class AbstractWriteTransaction<T extends DOMDataWriteTransaction> extends
  30         AbstractForwardedTransaction<T> {
  31
  32     private static final Logger LOG = LoggerFactory.getLogger(AbstractWriteTransaction.class);
  33
  34     protected AbstractWriteTransaction(final T delegate,
  35             final BindingToNormalizedNodeCodec codec) {
  36         super(delegate, codec);
  37     }
  38
  39     protected final void doPut(final LogicalDatastoreType store,
  40             final InstanceIdentifier<?> path, final DataObject data) {
  41         final Entry<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, NormalizedNode<?, ?>> normalized = getCodec()
  42                 .toNormalizedNode(path, data);
  43         getDelegate().put(store, normalized.getKey(), normalized.getValue());
  44     }
  45
  46     protected final void doMerge(final LogicalDatastoreType store,
  47             final InstanceIdentifier<?> path, final DataObject data) {
  48         final Entry<org.opendaylight.yangtools.yang.data.api.InstanceIdentifier, NormalizedNode<?, ?>> normalized = getCodec()
  49                 .toNormalizedNode(path, data);
  50         getDelegate().merge(store, normalized.getKey(), normalized.getValue());
  51     }
  52
  53     protected final void doDelete(final LogicalDatastoreType store,
  54             final InstanceIdentifier<?> path) {
  55         final org.opendaylight.yangtools.yang.data.api.InstanceIdentifier normalized = getCodec().toNormalized(path);
  56         getDelegate().delete(store, normalized);
  57     }
  58
  59     protected final ListenableFuture<RpcResult<TransactionStatus>> doCommit() {
  60         return getDelegate().commit();
  61     }
  62
  63     protected final boolean doCancel() {
  64         return getDelegate().cancel();
  65     }
  66
  67 }