X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDataTreeCohortActorRegistry.java;fp=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDataTreeCohortActorRegistry.java;h=4364e22d2ba85120e2c162d23f1547578caff589;hp=fb3743d426d1ac4636db0d43b8cef37eb7094b27;hb=925cb4a228d0fda99c7bfeb432eb25285a223887;hpb=cab1d5845cb951fe31a3243653ed567583dc73c1 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataTreeCohortActorRegistry.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataTreeCohortActorRegistry.java index fb3743d426..4364e22d2b 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataTreeCohortActorRegistry.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataTreeCohortActorRegistry.java @@ -48,7 +48,7 @@ class DataTreeCohortActorRegistry extends AbstractRegistrationTree { private final Map> cohortToNode = new HashMap<>(); - + @SuppressWarnings("checkstyle:IllegalCatch") void registerCohort(final ActorRef sender, final RegisterCohort cohort) { takeLock(); try { @@ -92,7 +92,7 @@ class DataTreeCohortActorRegistry extends AbstractRegistrationTree { } } - static abstract class CohortRegistryCommand { + abstract static class CohortRegistryCommand { private final ActorRef cohort; @@ -137,7 +137,8 @@ class DataTreeCohortActorRegistry extends AbstractRegistrationTree { private final Collection messages = new ArrayList<>(); - CanCommitMessageBuilder(final TransactionIdentifier txId, final DataTreeCandidate candidate, final SchemaContext schema) { + CanCommitMessageBuilder(final TransactionIdentifier txId, final DataTreeCandidate candidate, + final SchemaContext schema) { this.txId = Preconditions.checkNotNull(txId); this.candidate = Preconditions.checkNotNull(candidate); this.schema = schema; @@ -160,8 +161,8 @@ class DataTreeCohortActorRegistry extends AbstractRegistrationTree { } } - private void lookupAndCreateCanCommits(final YangInstanceIdentifier path, final RegistrationTreeNode regNode, - final DataTreeCandidateNode candNode) { + private void lookupAndCreateCanCommits(final YangInstanceIdentifier path, + final RegistrationTreeNode regNode, final DataTreeCandidateNode candNode) { if (candNode.getModificationType() == ModificationType.UNMODIFIED) { LOG.debug("Skipping unmodified candidate {}", path); return; @@ -189,9 +190,9 @@ class DataTreeCohortActorRegistry extends AbstractRegistrationTree { private void createCanCommits(final Collection regs, final YangInstanceIdentifier path, final DataTreeCandidateNode node) { - final DOMDataTreeCandidate candidate = DOMDataTreeCandidateTO.create(treeIdentifier(path), node); + final DOMDataTreeCandidate domCandidate = DOMDataTreeCandidateTO.create(treeIdentifier(path), node); for (final ActorRef reg : regs) { - final CanCommit message = new DataTreeCohortActor.CanCommit(txId, candidate, schema, reg); + final CanCommit message = new DataTreeCohortActor.CanCommit(txId, domCandidate, schema, reg); messages.add(message); } }