3f5a1521dc4332801d40302849fe092f377f3fd7
[controller.git] / opendaylight / md-sal / sal-distributed-datastore / src / main / java / org / opendaylight / controller / cluster / datastore / NoOpTransactionContext.java
1 /*
2  * Copyright (c) 2015 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.cluster.datastore;
9
10 import akka.actor.ActorSelection;
11 import com.google.common.util.concurrent.SettableFuture;
12 import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
13 import org.opendaylight.controller.cluster.datastore.exceptions.NoShardLeaderException;
14 import org.opendaylight.controller.cluster.datastore.messages.AbstractRead;
15 import org.opendaylight.controller.cluster.datastore.modification.AbstractModification;
16 import org.opendaylight.controller.md.sal.common.api.data.DataStoreUnavailableException;
17 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
18 import org.slf4j.Logger;
19 import org.slf4j.LoggerFactory;
20 import scala.concurrent.Future;
21
22 final class NoOpTransactionContext extends AbstractTransactionContext {
23     private static final Logger LOG = LoggerFactory.getLogger(NoOpTransactionContext.class);
24
25     private final Throwable failure;
26
27     public NoOpTransactionContext(Throwable failure, TransactionIdentifier identifier) {
28         super(identifier);
29         this.failure = failure;
30     }
31
32     @Override
33     public void closeTransaction() {
34         LOG.debug("NoOpTransactionContext {} closeTransaction called", getIdentifier());
35     }
36
37     @Override
38     public Future<Object> directCommit() {
39         LOG.debug("Tx {} directCommit called, failure: {}", getIdentifier(), failure);
40         return akka.dispatch.Futures.failed(failure);
41     }
42
43     @Override
44     public Future<ActorSelection> readyTransaction() {
45         LOG.debug("Tx {} readyTransaction called, failure: {}", getIdentifier(), failure);
46         return akka.dispatch.Futures.failed(failure);
47     }
48
49     @Override
50     public void executeModification(AbstractModification modification) {
51         LOG.debug("Tx {} executeModification {} called path = {}", getIdentifier(), modification.getClass().getSimpleName(),
52                 modification.getPath());
53     }
54
55     @Override
56     public <T> void executeRead(AbstractRead<T> readCmd, SettableFuture<T> proxyFuture) {
57         LOG.debug("Tx {} executeRead {} called path = {}", getIdentifier(), readCmd.getClass().getSimpleName(),
58                 readCmd.getPath());
59
60         final Throwable t;
61         if (failure instanceof NoShardLeaderException) {
62             t = new DataStoreUnavailableException(failure.getMessage(), failure);
63         } else {
64             t = failure;
65         }
66         proxyFuture.setException(new ReadFailedException("Error executeRead " + readCmd.getClass().getSimpleName()
67                 + " for path " + readCmd.getPath(), t));
68     }
69 }

©2013 OpenDaylight, A Linux Foundation Collaborative Project. All Rights Reserved.
OpenDaylight is a registered trademark of The OpenDaylight Project, Inc.
Linux Foundation and OpenDaylight are registered trademarks of the Linux Foundation.
Linux is a registered trademark of Linus Torvalds.