2 * Copyright (c) 2016 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.cluster.databroker;
10 import com.google.common.base.Preconditions;
11 import java.util.ArrayList;
12 import java.util.List;
14 import java.util.WeakHashMap;
15 import javax.annotation.concurrent.GuardedBy;
16 import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
17 import org.opendaylight.controller.cluster.databroker.actors.dds.AbstractClientHandle;
18 import org.opendaylight.controller.cluster.databroker.actors.dds.ClientLocalHistory;
19 import org.opendaylight.controller.cluster.databroker.actors.dds.ClientSnapshot;
20 import org.opendaylight.controller.cluster.databroker.actors.dds.ClientTransaction;
21 import org.opendaylight.mdsal.dom.spi.store.DOMStoreReadTransaction;
22 import org.opendaylight.mdsal.dom.spi.store.DOMStoreReadWriteTransaction;
23 import org.opendaylight.mdsal.dom.spi.store.DOMStoreTransactionChain;
24 import org.opendaylight.mdsal.dom.spi.store.DOMStoreWriteTransaction;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
29 * An implementation of {@link DOMStoreTransactionChain} backed by a {@link ClientLocalHistory}.
31 * @author Robert Varga
33 final class ClientBackedTransactionChain implements DOMStoreTransactionChain {
34 private static final Logger LOG = LoggerFactory.getLogger(ClientBackedTransactionChain.class);
37 private final Map<AbstractClientHandle<?>, Boolean> openSnapshots = new WeakHashMap<>();
39 private final ClientLocalHistory history;
40 private final boolean debugAllocation;
42 ClientBackedTransactionChain(final ClientLocalHistory history, final boolean debugAllocation) {
43 this.history = Preconditions.checkNotNull(history);
44 this.debugAllocation = debugAllocation;
48 public DOMStoreReadTransaction newReadOnlyTransaction() {
49 return new ClientBackedReadTransaction(createSnapshot(), this, allocationContext());
53 public DOMStoreReadWriteTransaction newReadWriteTransaction() {
54 return new ClientBackedReadWriteTransaction(createTransaction(), allocationContext());
58 public DOMStoreWriteTransaction newWriteOnlyTransaction() {
59 return new ClientBackedWriteTransaction(createTransaction(), allocationContext());
63 public synchronized void close() {
64 final List<TransactionIdentifier> abortedSnapshots = new ArrayList<>();
65 for (AbstractClientHandle<?> snap : openSnapshots.keySet()) {
66 final TransactionIdentifier id = snap.getIdentifier();
67 LOG.debug("Aborting recorded transaction {}", id);
69 abortedSnapshots.add(id);
72 openSnapshots.clear();
74 if (!abortedSnapshots.isEmpty()) {
75 LOG.warn("Aborted unclosed transactions {}", abortedSnapshots, new Throwable("at"));
80 synchronized void snapshotClosed(final ClientSnapshot clientTransaction) {
81 openSnapshots.remove(clientTransaction);
84 private ClientSnapshot createSnapshot() {
85 return recordSnapshot(history.takeSnapshot());
88 private ClientTransaction createTransaction() {
89 return recordSnapshot(history.createTransaction());
92 private Throwable allocationContext() {
93 return debugAllocation ? new Throwable("allocated at") : null;
96 private synchronized <T extends AbstractClientHandle<?>> T recordSnapshot(final T snapshot) {
97 openSnapshots.put(snapshot, Boolean.TRUE);