851e23ced009d733e219e3769369e5d23a6fc9cf
[controller.git] / opendaylight / md-sal / sal-distributed-datastore / src / main / java / org / opendaylight / controller / cluster / datastore / identifiers / TransactionChainIdentifier.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
9 package org.opendaylight.controller.cluster.datastore.identifiers;
10
11 import com.google.common.base.Supplier;
12 import com.google.common.base.Suppliers;
13 import java.util.concurrent.atomic.AtomicLong;
14 import org.opendaylight.controller.cluster.access.concepts.MemberName;
15
16 public class TransactionChainIdentifier {
17
18     protected static final String CHAIN_SEPARATOR = "-chn-";
19
20     private final AtomicLong txnCounter = new AtomicLong();
21     private final Supplier<String> stringRepresentation;
22     private final MemberName memberName;
23
24     public TransactionChainIdentifier(final MemberName memberName, final long counter) {
25         this.memberName = memberName;
26         stringRepresentation = Suppliers.memoize(() -> {
27             final StringBuilder sb = new StringBuilder();
28             sb.append(memberName.getName()).append(CHAIN_SEPARATOR);
29             sb.append(counter);
30             return sb.toString();
31         });
32     }
33     @Override
34     public String toString() {
35         return stringRepresentation.get();
36     }
37
38     public TransactionIdentifier newTransactionIdentifier(){
39         return new ChainedTransactionIdentifier(this, txnCounter.incrementAndGet());
40     }
41
42     public MemberName getMemberName() {
43         return memberName;
44     }
45 }