X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=dom%2Fmdsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fmdsal%2Fdom%2Fbroker%2FAbstractDOMRpcRoutingTableEntry.java;h=021dd96b1177a66fcb80aac378fcd9fa99cf26dd;hb=c37d38386002ed12b279938051813f99a4de70ff;hp=1daf52d4db9fb18b2d401b7650b95eb363b87723;hpb=093b38a5c2a4f6ed8b015916e4765be29e3d51e2;p=mdsal.git diff --git a/dom/mdsal-dom-broker/src/main/java/org/opendaylight/mdsal/dom/broker/AbstractDOMRpcRoutingTableEntry.java b/dom/mdsal-dom-broker/src/main/java/org/opendaylight/mdsal/dom/broker/AbstractDOMRpcRoutingTableEntry.java index 1daf52d4db..021dd96b11 100644 --- a/dom/mdsal-dom-broker/src/main/java/org/opendaylight/mdsal/dom/broker/AbstractDOMRpcRoutingTableEntry.java +++ b/dom/mdsal-dom-broker/src/main/java/org/opendaylight/mdsal/dom/broker/AbstractDOMRpcRoutingTableEntry.java @@ -7,10 +7,6 @@ */ package org.opendaylight.mdsal.dom.broker; -import org.opendaylight.mdsal.dom.api.DOMRpcException; -import org.opendaylight.mdsal.dom.api.DOMRpcImplementation; -import org.opendaylight.mdsal.dom.api.DOMRpcResult; - import com.google.common.base.Preconditions; import com.google.common.collect.ImmutableMap; import com.google.common.collect.ImmutableMap.Builder; @@ -20,6 +16,9 @@ import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Set; +import org.opendaylight.mdsal.dom.api.DOMRpcException; +import org.opendaylight.mdsal.dom.api.DOMRpcImplementation; +import org.opendaylight.mdsal.dom.api.DOMRpcResult; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import org.opendaylight.yangtools.yang.model.api.SchemaPath; @@ -28,7 +27,8 @@ abstract class AbstractDOMRpcRoutingTableEntry { private final Map> impls; private final SchemaPath schemaPath; - protected AbstractDOMRpcRoutingTableEntry(final SchemaPath schemaPath, final Map> impls) { + protected AbstractDOMRpcRoutingTableEntry(final SchemaPath schemaPath, final Map> impls) { this.schemaPath = Preconditions.checkNotNull(schemaPath); this.impls = Preconditions.checkNotNull(impls); } @@ -54,12 +54,14 @@ abstract class AbstractDOMRpcRoutingTableEntry { } /** + * This method adds the given DOMRpcImplementation instance for the given list RPC identifiers. * - * @param implementation - * @param newRpcs List of new RPCs, must be mutable - * @return + * @param implementation the DOMRpcImplementation instance to add + * @param newRpcs the List of new RPCs that the DOMRpcImplementation provides, must be mutable + * @return a new instance of AbstractDOMRpcRoutingTableEntry with the additions */ - final AbstractDOMRpcRoutingTableEntry add(final DOMRpcImplementation implementation, final List newRpcs) { + final AbstractDOMRpcRoutingTableEntry add( + final DOMRpcImplementation implementation, final List newRpcs) { final Builder> vb = ImmutableMap.builder(); for (final Entry> ve : impls.entrySet()) { if (newRpcs.remove(ve.getKey())) { @@ -71,7 +73,7 @@ abstract class AbstractDOMRpcRoutingTableEntry { vb.put(ve); } } - for(final YangInstanceIdentifier ii : newRpcs) { + for (final YangInstanceIdentifier ii : newRpcs) { final ArrayList impl = new ArrayList<>(1); impl.add(implementation); vb.put(ii,impl); @@ -80,7 +82,8 @@ abstract class AbstractDOMRpcRoutingTableEntry { return newInstance(vb.build()); } - final AbstractDOMRpcRoutingTableEntry remove(final DOMRpcImplementation implementation, final List removed) { + final AbstractDOMRpcRoutingTableEntry remove( + final DOMRpcImplementation implementation, final List removed) { final Builder> vb = ImmutableMap.builder(); for (final Entry> ve : impls.entrySet()) { if (removed.remove(ve.getKey())) { @@ -101,5 +104,7 @@ abstract class AbstractDOMRpcRoutingTableEntry { } protected abstract CheckedFuture invokeRpc(final NormalizedNode input); - protected abstract AbstractDOMRpcRoutingTableEntry newInstance(final Map> impls); + + protected abstract AbstractDOMRpcRoutingTableEntry newInstance( + final Map> impls); }