package org.opendaylight.controller.cluster.databroker.actors.dds;
import com.google.common.annotations.Beta;
+import com.google.common.base.MoreObjects;
import com.google.common.base.Preconditions;
import java.util.Collection;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
import java.util.function.Function;
-import javax.annotation.Nullable;
+import org.eclipse.jdt.annotation.Nullable;
import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
import org.opendaylight.yangtools.concepts.Identifiable;
import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
}
@Override
- public final TransactionIdentifier getIdentifier() {
+ public TransactionIdentifier getIdentifier() {
return transactionId;
}
*
* @return True if this transaction became closed during this call
*/
- public final boolean abort() {
+ public boolean abort() {
if (commonAbort()) {
parent.onTransactionAbort(this);
return true;
* @return null if this snapshot has already been closed, otherwise a collection of proxies, which need to be
* closed, too.
*/
- @Nullable final Collection<T> ensureClosed() {
+ final @Nullable Collection<T> ensureClosed() {
@SuppressWarnings("unchecked")
final State<T> local = STATE_UPDATER.getAndSet(this, null);
return local == null ? null : local.values();
Preconditions.checkState(local != null, "Transaction %s is closed", transactionId);
return local;
}
+
+ @Override
+ public final String toString() {
+ return MoreObjects.toStringHelper(this).omitNullValues().add("identifier", transactionId).add("state", state)
+ .toString();
+ }
}