import com.google.common.primitives.UnsignedLong;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.primitives.UnsignedLong;
import com.google.common.util.concurrent.FutureCallback;
import java.util.Optional;
import java.util.SortedSet;
import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
import java.util.Optional;
import java.util.SortedSet;
import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
private RuntimeException lastBatchedModificationsException;
private int totalBatchedModificationsReceived;
private RuntimeException lastBatchedModificationsException;
private int totalBatchedModificationsReceived;
private ShardDataTreeCohort cohort;
private boolean doImmediateCommit;
private ActorRef replySender;
private Shard shard;
private CohortEntry(final ReadWriteShardDataTreeTransaction transaction, final short clientVersion) {
private ShardDataTreeCohort cohort;
private boolean doImmediateCommit;
private ActorRef replySender;
private Shard shard;
private CohortEntry(final ReadWriteShardDataTreeTransaction transaction, final short clientVersion) {
this.transactionId = transaction.getIdentifier();
this.clientVersion = clientVersion;
}
private CohortEntry(final ShardDataTreeCohort cohort, final short clientVersion) {
this.transactionId = transaction.getIdentifier();
this.clientVersion = clientVersion;
}
private CohortEntry(final ShardDataTreeCohort cohort, final short clientVersion) {
RuntimeException getLastBatchedModificationsException() {
return lastBatchedModificationsException;
}
@SuppressWarnings("checkstyle:IllegalCatch")
RuntimeException getLastBatchedModificationsException() {
return lastBatchedModificationsException;
}
@SuppressWarnings("checkstyle:IllegalCatch")
Optional<SortedSet<String>> getParticipatingShardNames() {
return cohort != null ? cohort.getParticipatingShardNames() : Optional.empty();
}
Optional<SortedSet<String>> getParticipatingShardNames() {
return cohort != null ? cohort.getParticipatingShardNames() : Optional.empty();
}