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.datastore;
10 import static com.google.common.base.Preconditions.checkState;
11 import static java.util.Objects.requireNonNull;
13 import com.google.common.primitives.UnsignedLong;
14 import java.util.HashMap;
16 import org.eclipse.jdt.annotation.NonNull;
17 import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier;
18 import org.opendaylight.controller.cluster.access.concepts.LocalHistoryIdentifier;
19 import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
20 import org.opendaylight.controller.cluster.datastore.persisted.FrontendHistoryMetadata;
21 import org.opendaylight.controller.cluster.datastore.utils.ImmutableUnsignedLongSet;
22 import org.opendaylight.controller.cluster.datastore.utils.MutableUnsignedLongSet;
23 import org.opendaylight.controller.cluster.datastore.utils.UnsignedLongBitmap;
24 import org.opendaylight.yangtools.concepts.Builder;
25 import org.opendaylight.yangtools.concepts.Identifiable;
27 final class FrontendHistoryMetadataBuilder implements Builder<FrontendHistoryMetadata>,
28 Identifiable<LocalHistoryIdentifier> {
30 private final @NonNull Map<UnsignedLong, Boolean> closedTransactions;
31 private final @NonNull MutableUnsignedLongSet purgedTransactions;
32 private final @NonNull LocalHistoryIdentifier identifier;
34 private boolean closed;
36 FrontendHistoryMetadataBuilder(final LocalHistoryIdentifier identifier) {
37 this.identifier = requireNonNull(identifier);
38 purgedTransactions = MutableUnsignedLongSet.of();
39 closedTransactions = new HashMap<>(2);
42 FrontendHistoryMetadataBuilder(final ClientIdentifier clientId, final FrontendHistoryMetadata meta) {
43 identifier = new LocalHistoryIdentifier(clientId, meta.getHistoryId(), meta.getCookie());
44 closedTransactions = meta.getClosedTransactions().mutableCopy();
45 purgedTransactions = meta.getPurgedTransactions().mutableCopy();
46 closed = meta.isClosed();
50 public LocalHistoryIdentifier getIdentifier() {
55 public FrontendHistoryMetadata build() {
56 return new FrontendHistoryMetadata(identifier.getHistoryId(), identifier.getCookie(), closed,
57 UnsignedLongBitmap.copyOf(closedTransactions), purgedTransactions.immutableCopy());
60 void onHistoryClosed() {
61 checkState(identifier.getHistoryId() != 0);
65 void onTransactionAborted(final TransactionIdentifier txId) {
66 closedTransactions.put(UnsignedLong.fromLongBits(txId.getTransactionId()), Boolean.FALSE);
69 void onTransactionCommitted(final TransactionIdentifier txId) {
70 closedTransactions.put(UnsignedLong.fromLongBits(txId.getTransactionId()), Boolean.TRUE);
73 void onTransactionPurged(final TransactionIdentifier txId) {
74 final long txidBits = txId.getTransactionId();
75 closedTransactions.remove(UnsignedLong.fromLongBits(txidBits));
76 purgedTransactions.add(txidBits);
79 void onTransactionsSkipped(final ImmutableUnsignedLongSet txIds) {
80 purgedTransactions.addAll(txIds);
84 * Transform frontend metadata for a particular client history into its {@link LocalFrontendHistory} counterpart.
86 * @param shard parent shard
87 * @return Leader history state
89 @NonNull AbstractFrontendHistory toLeaderState(final @NonNull Shard shard) {
90 if (identifier.getHistoryId() == 0) {
91 return StandaloneFrontendHistory.recreate(shard.persistenceId(), identifier.getClientId(),
92 shard.getDataStore(), closedTransactions, purgedTransactions);
95 return LocalFrontendHistory.recreate(shard.persistenceId(), shard.getDataStore(),
96 shard.getDataStore().recreateTransactionChain(identifier, closed), closedTransactions, purgedTransactions);