opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/compat/LegacyDOMStoreAdapter.java

   1 /*
   2  * Copyright (c) 2016 Brocade Communications 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.cluster.datastore.compat;
   9
  10 import com.google.common.base.Optional;
  11 import com.google.common.base.Preconditions;
  12 import com.google.common.collect.ForwardingObject;
  13 import com.google.common.util.concurrent.CheckedFuture;
  14 import com.google.common.util.concurrent.ListenableFuture;
  15 import javax.annotation.Nonnull;
  16 import org.opendaylight.controller.cluster.datastore.DistributedDataStoreInterface;
  17 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
  18 import org.opendaylight.controller.sal.core.compat.ReadFailedExceptionAdapter;
  19 import org.opendaylight.controller.sal.core.spi.data.DOMStore;
  20 import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadTransaction;
  21 import org.opendaylight.controller.sal.core.spi.data.DOMStoreReadWriteTransaction;
  22 import org.opendaylight.controller.sal.core.spi.data.DOMStoreThreePhaseCommitCohort;
  23 import org.opendaylight.controller.sal.core.spi.data.DOMStoreTransactionChain;
  24 import org.opendaylight.controller.sal.core.spi.data.DOMStoreWriteTransaction;
  25 import org.opendaylight.mdsal.common.api.MappingCheckedFuture;
  26 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
  27 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
  28
  29 /**
  30  * Adapter between the legacy controller API-based DOMStore and the mdsal API-based DOMStore.
  31  *
  32  * @author Thomas Pantelis
  33  */
  34 public class LegacyDOMStoreAdapter extends ForwardingObject implements DOMStore, AutoCloseable {
  35     private final DistributedDataStoreInterface delegate;
  36
  37     public LegacyDOMStoreAdapter(DistributedDataStoreInterface delegate) {
  38         this.delegate = delegate;
  39     }
  40
  41     @Override
  42     public DOMStoreReadTransaction newReadOnlyTransaction() {
  43         return new DOMStoreTransactionAdapter(delegate().newReadOnlyTransaction());
  44     }
  45
  46     @Override
  47     public DOMStoreWriteTransaction newWriteOnlyTransaction() {
  48         return new DOMStoreTransactionAdapter(delegate().newWriteOnlyTransaction());
  49     }
  50
  51     @Override
  52     public DOMStoreReadWriteTransaction newReadWriteTransaction() {
  53         return new DOMStoreTransactionAdapter(delegate().newReadWriteTransaction());
  54     }
  55
  56     @Override
  57     public DOMStoreTransactionChain createTransactionChain() {
  58         final org.opendaylight.mdsal.dom.spi.store.DOMStoreTransactionChain delegateChain =
  59                 delegate().createTransactionChain();
  60         return new DOMStoreTransactionChain() {
  61             @Override
  62             public DOMStoreReadTransaction newReadOnlyTransaction() {
  63                 return new DOMStoreTransactionAdapter(delegateChain.newReadOnlyTransaction());
  64             }
  65
  66             @Override
  67             public DOMStoreWriteTransaction newWriteOnlyTransaction() {
  68                 return new DOMStoreTransactionAdapter(delegateChain.newWriteOnlyTransaction());
  69             }
  70
  71             @Override
  72             public DOMStoreReadWriteTransaction newReadWriteTransaction() {
  73                 return new DOMStoreTransactionAdapter(delegateChain.newReadWriteTransaction());
  74             }
  75
  76             @Override
  77             public void close() {
  78                 delegateChain.close();
  79             }
  80         };
  81     }
  82
  83     @Override
  84     public void close() {
  85     }
  86
  87     @Override
  88     protected DistributedDataStoreInterface delegate() {
  89         return delegate;
  90     }
  91
  92     private static class DOMStoreTransactionAdapter implements DOMStoreReadWriteTransaction {
  93         private final org.opendaylight.mdsal.dom.spi.store.DOMStoreReadTransaction readDelegate;
  94         private final org.opendaylight.mdsal.dom.spi.store.DOMStoreWriteTransaction writeDelegate;
  95         private final Object identifier;
  96
  97         DOMStoreTransactionAdapter(@Nonnull org.opendaylight.mdsal.dom.spi.store.DOMStoreReadTransaction readDelegate) {
  98             this.readDelegate = Preconditions.checkNotNull(readDelegate);
  99             this.identifier = readDelegate.getIdentifier();
 100             this.writeDelegate = null;
 101         }
 102
 103         DOMStoreTransactionAdapter(
 104                 @Nonnull org.opendaylight.mdsal.dom.spi.store.DOMStoreWriteTransaction writeDelegate) {
 105             this.writeDelegate = Preconditions.checkNotNull(writeDelegate);
 106             this.identifier = writeDelegate.getIdentifier();
 107             this.readDelegate = null;
 108         }
 109
 110         DOMStoreTransactionAdapter(
 111                 @Nonnull org.opendaylight.mdsal.dom.spi.store.DOMStoreReadWriteTransaction rwDelegate) {
 112             this.readDelegate = Preconditions.checkNotNull(rwDelegate);
 113             this.writeDelegate = rwDelegate;
 114             this.identifier = readDelegate.getIdentifier();
 115         }
 116
 117         @Override
 118         public Object getIdentifier() {
 119             return identifier;
 120         }
 121
 122         @Override
 123         public void close() {
 124             if (writeDelegate != null) {
 125                 writeDelegate.close();
 126             } else {
 127                 readDelegate.close();
 128             }
 129         }
 130
 131         @Override
 132         public void write(YangInstanceIdentifier path, NormalizedNode<?, ?> data) {
 133             writeDelegate.write(path, data);
 134         }
 135
 136         @Override
 137         public void merge(YangInstanceIdentifier path, NormalizedNode<?, ?> data) {
 138             writeDelegate.merge(path, data);
 139         }
 140
 141         @Override
 142         public void delete(YangInstanceIdentifier path) {
 143             writeDelegate.delete(path);
 144         }
 145
 146         @Override
 147         public DOMStoreThreePhaseCommitCohort ready() {
 148             final org.opendaylight.mdsal.dom.spi.store.DOMStoreThreePhaseCommitCohort cohort = writeDelegate.ready();
 149             return new DOMStoreThreePhaseCommitCohort() {
 150                 @Override
 151                 public ListenableFuture<Boolean> canCommit() {
 152                     return cohort.canCommit();
 153                 }
 154
 155                 @Override
 156                 public ListenableFuture<Void> preCommit() {
 157                     return cohort.preCommit();
 158                 }
 159
 160                 @Override
 161                 public ListenableFuture<Void> commit() {
 162                     return cohort.commit();
 163                 }
 164
 165                 @Override
 166                 public ListenableFuture<Void> abort() {
 167                     return cohort.abort();
 168                 }
 169             };
 170         }
 171
 172         @Override
 173         public CheckedFuture<Optional<NormalizedNode<?, ?>>, ReadFailedException> read(YangInstanceIdentifier path) {
 174             return MappingCheckedFuture.create(readDelegate.read(path), ReadFailedExceptionAdapter.INSTANCE);
 175         }
 176
 177         @Override
 178         public CheckedFuture<Boolean, ReadFailedException> exists(YangInstanceIdentifier path) {
 179             return MappingCheckedFuture.create(readDelegate.exists(path), ReadFailedExceptionAdapter.INSTANCE);
 180         }
 181     }
 182 }