From: Moiz Raja Date: Sun, 25 Jan 2015 19:58:35 +0000 (+0000) Subject: Merge "Bug 2327: Handle binary data in NormalizedNode streaming" X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=commitdiff_plain;h=e91f646db188494830a8b0d8ece859de8cd33f72;hp=d0bfebae1d8f056220bc2f5b043f1f13b3b8d4e6 Merge "Bug 2327: Handle binary data in NormalizedNode streaming" --- diff --git a/features/pom.xml b/features/pom.xml index 4f9ff72927..ed4fa499a9 100644 --- a/features/pom.xml +++ b/features/pom.xml @@ -9,9 +9,7 @@ features-controller pom - - 3.0 - + config config-persister diff --git a/itests/pom.xml b/itests/pom.xml index c722149145..9021e634ea 100644 --- a/itests/pom.xml +++ b/itests/pom.xml @@ -9,9 +9,7 @@ itests-controller pom - - 3.0 - + base-features-it diff --git a/opendaylight/archetypes/opendaylight-startup/src/main/resources/archetype-resources/__artifactId__-karaf/pom.xml b/opendaylight/archetypes/opendaylight-startup/src/main/resources/archetype-resources/__artifactId__-karaf/pom.xml index c7ed46a2e3..87b955c6b9 100644 --- a/opendaylight/archetypes/opendaylight-startup/src/main/resources/archetype-resources/__artifactId__-karaf/pom.xml +++ b/opendaylight/archetypes/opendaylight-startup/src/main/resources/archetype-resources/__artifactId__-karaf/pom.xml @@ -17,7 +17,7 @@ and is available at http://www.eclipse.org/legal/epl-v10.html INTERNAL 4.0.0 ${groupId} - ${artifactId} + ${artifactId}-karaf ${version} ${project.artifactId} diff --git a/opendaylight/archetypes/pom.xml b/opendaylight/archetypes/pom.xml index d8ac923176..6d46aaec78 100644 --- a/opendaylight/archetypes/pom.xml +++ b/opendaylight/archetypes/pom.xml @@ -1,9 +1,6 @@ 4.0.0 - - 3.0 - org.opendaylight.controller commons.opendaylight diff --git a/opendaylight/commons/opendaylight/pom.xml b/opendaylight/commons/opendaylight/pom.xml index 4d95b72ce7..32aa9a3efc 100644 --- a/opendaylight/commons/opendaylight/pom.xml +++ b/opendaylight/commons/opendaylight/pom.xml @@ -12,9 +12,6 @@ commons.opendaylight 1.5.0-SNAPSHOT pom - - 3.0 - @@ -1720,7 +1717,7 @@ ${enforcer.version} - enforce-java + enforce-requirements enforce @@ -1729,6 +1726,9 @@ 1.7.0 + + 3.1.1 + diff --git a/opendaylight/commons/parent/pom.xml b/opendaylight/commons/parent/pom.xml index cbd6efaef8..f8364ca535 100644 --- a/opendaylight/commons/parent/pom.xml +++ b/opendaylight/commons/parent/pom.xml @@ -5,9 +5,6 @@ commons.parent 1.1.0-SNAPSHOT pom - - 3.0 - opendaylight.release diff --git a/opendaylight/commons/protocol-framework/pom.xml b/opendaylight/commons/protocol-framework/pom.xml index 00f7b3179b..38b9d175f2 100644 --- a/opendaylight/commons/protocol-framework/pom.xml +++ b/opendaylight/commons/protocol-framework/pom.xml @@ -15,9 +15,6 @@ bundle ${project.artifactId} Common protocol framework - - 3.0.4 - diff --git a/opendaylight/md-sal/sal-clustering-config/src/main/resources/initial/05-clustering.xml.conf b/opendaylight/md-sal/sal-clustering-config/src/main/resources/initial/05-clustering.xml.conf index 89cd033df3..96ed7f1838 100644 --- a/opendaylight/md-sal/sal-clustering-config/src/main/resources/initial/05-clustering.xml.conf +++ b/opendaylight/md-sal/sal-clustering-config/src/main/resources/initial/05-clustering.xml.conf @@ -97,7 +97,7 @@ urn:opendaylight:params:xml:ns:yang:controller:config:concurrent-data-broker?module=odl-concurrent-data-broker-cfg&revision=2014-11-24 - urn:opendaylight:params:xml:ns:yang:controller:config:distributed-datastore-provider?module=distributed-datastore-privider&revision=2014-06-12 + urn:opendaylight:params:xml:ns:yang:controller:config:distributed-datastore-provider?module=distributed-datastore-provider&revision=2014-06-12 urn:opendaylight:params:xml:ns:yang:controller:md:sal:core:spi:config-dom-store?module=opendaylight-config-dom-datastore&revision=2014-06-17 urn:opendaylight:params:xml:ns:yang:controller:md:sal:core:spi:operational-dom-store?module=opendaylight-operational-dom-datastore&revision=2014-06-17 urn:opendaylight:params:xml:ns:yang:controller:md:sal:dom?module=opendaylight-md-sal-dom&revision=2013-10-28 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/utils/ActorContext.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/utils/ActorContext.java index f81c2a87cd..f217d05bb2 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/utils/ActorContext.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/utils/ActorContext.java @@ -279,7 +279,7 @@ public class ActorContext { Preconditions.checkArgument(actor != null, "actor must not be null"); Preconditions.checkArgument(message != null, "message must not be null"); - LOG.debug("Sending message {} to {}", message.getClass().toString(), actor.toString()); + LOG.debug("Sending message {} to {}", message.getClass(), actor); return ask(actor, message, timeout); } @@ -314,7 +314,7 @@ public class ActorContext { Preconditions.checkArgument(actor != null, "actor must not be null"); Preconditions.checkArgument(message != null, "message must not be null"); - LOG.debug("Sending message {} to {}", message.getClass().toString(), actor.toString()); + LOG.debug("Sending message {} to {}", message.getClass(), actor); return ask(actor, message, timeout); } @@ -341,7 +341,7 @@ public class ActorContext { Preconditions.checkArgument(actor != null, "actor must not be null"); Preconditions.checkArgument(message != null, "message must not be null"); - LOG.debug("Sending message {} to {}", message.getClass().toString(), actor.toString()); + LOG.debug("Sending message {} to {}", message.getClass(), actor); actor.tell(message, ActorRef.noSender()); } @@ -386,14 +386,14 @@ public class ActorContext { return false; } - int pathAtIndex = path.indexOf("@"); + int pathAtIndex = path.indexOf('@'); if (pathAtIndex == -1) { //if the path is of local format, then its local and is co-located return true; } else if (selfAddressHostPort != null) { // self-address and tx actor path, both are of remote path format - int slashIndex = path.indexOf("/", pathAtIndex); + int slashIndex = path.indexOf('/', pathAtIndex); if (slashIndex == -1) { return false; diff --git a/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/restconf/impl/ControllerContext.java b/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/restconf/impl/ControllerContext.java index b0a6e0d6f3..5f6604c68d 100644 --- a/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/restconf/impl/ControllerContext.java +++ b/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/restconf/impl/ControllerContext.java @@ -94,7 +94,7 @@ public class ControllerContext implements SchemaContextListener { public void setGlobalSchema(final SchemaContext globalSchema) { this.globalSchema = globalSchema; - this.dataNormalizer = new DataNormalizer(globalSchema); + dataNormalizer = new DataNormalizer(globalSchema); } public void setMountService(final DOMMountPointService mountService) { @@ -115,11 +115,11 @@ public class ControllerContext implements SchemaContextListener { } public void setSchemas(final SchemaContext schemas) { - this.onGlobalContextUpdated(schemas); + onGlobalContextUpdated(schemas); } public InstanceIdentifierContext toInstanceIdentifier(final String restconfInstance) { - return this.toIdentifier(restconfInstance, false); + return toIdentifier(restconfInstance, false); } public SchemaContext getGlobalSchema() { @@ -127,11 +127,11 @@ public class ControllerContext implements SchemaContextListener { } public InstanceIdentifierContext toMountPointIdentifier(final String restconfInstance) { - return this.toIdentifier(restconfInstance, true); + return toIdentifier(restconfInstance, true); } private InstanceIdentifierContext toIdentifier(final String restconfInstance, final boolean toMountPointIdentifier) { - this.checkPreconditions(); + checkPreconditions(); final List pathArgs = urlPathArgsDecode(SLASH_SPLITTER.split(restconfInstance)); omitFirstAndLastEmptyString(pathArgs); @@ -139,16 +139,16 @@ public class ControllerContext implements SchemaContextListener { return null; } - String first = pathArgs.iterator().next(); + final String first = pathArgs.iterator().next(); final String startModule = ControllerContext.toModuleName(first); if (startModule == null) { throw new RestconfDocumentedException("First node in URI has to be in format \"moduleName:nodeName\"", ErrorType.PROTOCOL, ErrorTag.INVALID_VALUE); } - InstanceIdentifierBuilder builder = YangInstanceIdentifier.builder(); - Module latestModule = globalSchema.findModuleByName(startModule, null); - InstanceIdentifierContext iiWithSchemaNode = this.collectPathArguments(builder, pathArgs, latestModule, null, + final InstanceIdentifierBuilder builder = YangInstanceIdentifier.builder(); + final Module latestModule = globalSchema.findModuleByName(startModule, null); + final InstanceIdentifierContext iiWithSchemaNode = collectPathArguments(builder, pathArgs, latestModule, null, toMountPointIdentifier); if (iiWithSchemaNode == null) { @@ -163,7 +163,7 @@ public class ControllerContext implements SchemaContextListener { return list; } - String head = list.iterator().next(); + final String head = list.iterator().next(); if (head.isEmpty()) { list.remove(0); } @@ -172,7 +172,7 @@ public class ControllerContext implements SchemaContextListener { return list; } - String last = list.get(list.size() - 1); + final String last = list.get(list.size() - 1); if (last.isEmpty()) { list.remove(list.size() - 1); } @@ -180,7 +180,7 @@ public class ControllerContext implements SchemaContextListener { return list; } public Module findModuleByName(final String moduleName) { - this.checkPreconditions(); + checkPreconditions(); Preconditions.checkArgument(moduleName != null && !moduleName.isEmpty()); return globalSchema.findModuleByName(moduleName, null); } @@ -197,7 +197,7 @@ public class ControllerContext implements SchemaContextListener { } public Module findModuleByNamespace(final URI namespace) { - this.checkPreconditions(); + checkPreconditions(); Preconditions.checkArgument(namespace != null); return globalSchema.findModuleByNamespaceAndRevision(namespace, null); } @@ -214,33 +214,33 @@ public class ControllerContext implements SchemaContextListener { } public Module findModuleByNameAndRevision(final QName module) { - this.checkPreconditions(); + checkPreconditions(); Preconditions.checkArgument(module != null && module.getLocalName() != null && module.getRevision() != null); return globalSchema.findModuleByName(module.getLocalName(), module.getRevision()); } public Module findModuleByNameAndRevision(final DOMMountPoint mountPoint, final QName module) { - this.checkPreconditions(); + checkPreconditions(); Preconditions.checkArgument(module != null && module.getLocalName() != null && module.getRevision() != null && mountPoint != null); - SchemaContext schemaContext = mountPoint.getSchemaContext(); + final SchemaContext schemaContext = mountPoint.getSchemaContext(); return schemaContext == null ? null : schemaContext.findModuleByName(module.getLocalName(), module.getRevision()); } public DataNodeContainer getDataNodeContainerFor(final YangInstanceIdentifier path) { - this.checkPreconditions(); + checkPreconditions(); final Iterable elements = path.getPathArguments(); - PathArgument head = elements.iterator().next(); + final PathArgument head = elements.iterator().next(); final QName startQName = head.getNodeType(); final Module initialModule = globalSchema.findModuleByNamespaceAndRevision(startQName.getNamespace(), startQName.getRevision()); DataNodeContainer node = initialModule; for (final PathArgument element : elements) { - QName _nodeType = element.getNodeType(); + final QName _nodeType = element.getNodeType(); final DataSchemaNode potentialNode = ControllerContext.childByQName(node, _nodeType); if (potentialNode == null || !ControllerContext.isListOrContainer(potentialNode)) { return null; @@ -252,17 +252,17 @@ public class ControllerContext implements SchemaContextListener { } public String toFullRestconfIdentifier(final YangInstanceIdentifier path) { - this.checkPreconditions(); + checkPreconditions(); final Iterable elements = path.getPathArguments(); final StringBuilder builder = new StringBuilder(); - PathArgument head = elements.iterator().next(); + final PathArgument head = elements.iterator().next(); final QName startQName = head.getNodeType(); final Module initialModule = globalSchema.findModuleByNamespaceAndRevision(startQName.getNamespace(), startQName.getRevision()); DataNodeContainer node = initialModule; for (final PathArgument element : elements) { - QName _nodeType = element.getNodeType(); + final QName _nodeType = element.getNodeType(); final DataSchemaNode potentialNode = ControllerContext.childByQName(node, _nodeType); if (!ControllerContext.isListOrContainer(potentialNode)) { return null; @@ -275,7 +275,7 @@ public class ControllerContext implements SchemaContextListener { } public String findModuleNameByNamespace(final URI namespace) { - this.checkPreconditions(); + checkPreconditions(); final Module module = this.findModuleByNamespace(namespace); return module == null ? null : module.getName(); @@ -297,14 +297,14 @@ public class ControllerContext implements SchemaContextListener { } public Set getAllModules(final DOMMountPoint mountPoint) { - this.checkPreconditions(); + checkPreconditions(); - SchemaContext schemaContext = mountPoint == null ? null : mountPoint.getSchemaContext(); + final SchemaContext schemaContext = mountPoint == null ? null : mountPoint.getSchemaContext(); return schemaContext == null ? null : schemaContext.getModules(); } public Set getAllModules() { - this.checkPreconditions(); + checkPreconditions(); return globalSchema.getModules(); } @@ -314,7 +314,7 @@ public class ControllerContext implements SchemaContextListener { } public CharSequence toRestconfIdentifier(final QName qname) { - this.checkPreconditions(); + checkPreconditions(); return toRestconfIdentifier(globalSchema, qname); } @@ -339,18 +339,18 @@ public class ControllerContext implements SchemaContextListener { }; public DataSchemaNode getRestconfModuleErrorsSchemaNode() { - Module restconfModule = getRestconfModule(); + final Module restconfModule = getRestconfModule(); if (restconfModule == null) { return null; } - Set groupings = restconfModule.getGroupings(); + final Set groupings = restconfModule.getGroupings(); - Iterable filteredGroups = Iterables.filter(groupings, ERRORS_GROUPING_FILTER); + final Iterable filteredGroups = Iterables.filter(groupings, ERRORS_GROUPING_FILTER); final GroupingDefinition restconfGrouping = Iterables.getFirst(filteredGroups, null); - List instanceDataChildrenByName = findInstanceDataChildrenByName(restconfGrouping, + final List instanceDataChildrenByName = findInstanceDataChildrenByName(restconfGrouping, Draft02.RestConfModule.ERRORS_CONTAINER_SCHEMA_NODE); return Iterables.getFirst(instanceDataChildrenByName, null); } @@ -372,20 +372,20 @@ public class ControllerContext implements SchemaContextListener { return null; } - Set groupings = restconfModule.getGroupings(); - Iterable filteredGroups = Iterables.filter(groupings, GROUPING_FILTER); + final Set groupings = restconfModule.getGroupings(); + final Iterable filteredGroups = Iterables.filter(groupings, GROUPING_FILTER); final GroupingDefinition restconfGrouping = Iterables.getFirst(filteredGroups, null); - List instanceDataChildrenByName = findInstanceDataChildrenByName(restconfGrouping, + final List instanceDataChildrenByName = findInstanceDataChildrenByName(restconfGrouping, Draft02.RestConfModule.RESTCONF_CONTAINER_SCHEMA_NODE); final DataSchemaNode restconfContainer = Iterables.getFirst(instanceDataChildrenByName, null); if (Objects.equal(schemaNodeName, Draft02.RestConfModule.OPERATIONS_CONTAINER_SCHEMA_NODE)) { - List instances = findInstanceDataChildrenByName( + final List instances = findInstanceDataChildrenByName( ((DataNodeContainer) restconfContainer), Draft02.RestConfModule.OPERATIONS_CONTAINER_SCHEMA_NODE); return Iterables.getFirst(instances, null); } else if (Objects.equal(schemaNodeName, Draft02.RestConfModule.STREAMS_CONTAINER_SCHEMA_NODE)) { - List instances = findInstanceDataChildrenByName( + final List instances = findInstanceDataChildrenByName( ((DataNodeContainer) restconfContainer), Draft02.RestConfModule.STREAMS_CONTAINER_SCHEMA_NODE); return Iterables.getFirst(instances, null); } else if (Objects.equal(schemaNodeName, Draft02.RestConfModule.STREAM_LIST_SCHEMA_NODE)) { @@ -396,7 +396,7 @@ public class ControllerContext implements SchemaContextListener { Draft02.RestConfModule.STREAM_LIST_SCHEMA_NODE); return Iterables.getFirst(instances, null); } else if (Objects.equal(schemaNodeName, Draft02.RestConfModule.MODULES_CONTAINER_SCHEMA_NODE)) { - List instances = findInstanceDataChildrenByName( + final List instances = findInstanceDataChildrenByName( ((DataNodeContainer) restconfContainer), Draft02.RestConfModule.MODULES_CONTAINER_SCHEMA_NODE); return Iterables.getFirst(instances, null); } else if (Objects.equal(schemaNodeName, Draft02.RestConfModule.MODULE_LIST_SCHEMA_NODE)) { @@ -407,7 +407,7 @@ public class ControllerContext implements SchemaContextListener { Draft02.RestConfModule.MODULE_LIST_SCHEMA_NODE); return Iterables.getFirst(instances, null); } else if (Objects.equal(schemaNodeName, Draft02.RestConfModule.STREAMS_CONTAINER_SCHEMA_NODE)) { - List instances = findInstanceDataChildrenByName( + final List instances = findInstanceDataChildrenByName( ((DataNodeContainer) restconfContainer), Draft02.RestConfModule.STREAMS_CONTAINER_SCHEMA_NODE); return Iterables.getFirst(instances, null); } @@ -447,12 +447,12 @@ public class ControllerContext implements SchemaContextListener { } private static DataSchemaNode dataNodeChildByQName(final DataNodeContainer container, final QName name) { - DataSchemaNode ret = container.getDataChildByName(name); + final DataSchemaNode ret = container.getDataChildByName(name); if (ret == null) { for (final DataSchemaNode node : container.getChildNodes()) { if ((node instanceof ChoiceNode)) { final ChoiceNode choiceNode = ((ChoiceNode) node); - DataSchemaNode childByQName = ControllerContext.childByQName(choiceNode, name); + final DataSchemaNode childByQName = ControllerContext.childByQName(choiceNode, name); if (childByQName != null) { return childByQName; } @@ -479,7 +479,7 @@ public class ControllerContext implements SchemaContextListener { return new InstanceIdentifierContext(builder.toInstance(), ((DataSchemaNode) parentNode), mountPoint,mountPoint != null ? mountPoint.getSchemaContext() : globalSchema); } - String head = strings.iterator().next(); + final String head = strings.iterator().next(); final String nodeName = toNodeName(head); final String moduleName = ControllerContext.toModuleName(head); @@ -505,7 +505,7 @@ public class ControllerContext implements SchemaContextListener { throw new RestconfDocumentedException("Mount point does not exist.", ErrorType.PROTOCOL, ErrorTag.UNKNOWN_ELEMENT); } - DOMMountPoint mount = mountOpt.get(); + final DOMMountPoint mount = mountOpt.get(); final SchemaContext mountPointSchema = mount.getSchemaContext(); if (mountPointSchema == null) { @@ -514,12 +514,12 @@ public class ControllerContext implements SchemaContextListener { } if (returnJustMountPoint) { - YangInstanceIdentifier instance = YangInstanceIdentifier.builder().toInstance(); + final YangInstanceIdentifier instance = YangInstanceIdentifier.builder().toInstance(); return new InstanceIdentifierContext(instance, mountPointSchema, mount,mountPointSchema); } if (strings.size() == 1) { - YangInstanceIdentifier instance = YangInstanceIdentifier.builder().toInstance(); + final YangInstanceIdentifier instance = YangInstanceIdentifier.builder().toInstance(); return new InstanceIdentifierContext(instance, mountPointSchema, mount,mountPointSchema); } @@ -536,20 +536,21 @@ public class ControllerContext implements SchemaContextListener { + "\" module does not exist in mount point.", ErrorType.PROTOCOL, ErrorTag.UNKNOWN_ELEMENT); } - List subList = strings.subList(1, strings.size()); - return this.collectPathArguments(YangInstanceIdentifier.builder(), subList, moduleBehindMountPoint, mount, + final List subList = strings.subList(1, strings.size()); + return collectPathArguments(YangInstanceIdentifier.builder(), subList, moduleBehindMountPoint, mount, returnJustMountPoint); } Module module = null; if (mountPoint == null) { + checkPreconditions(); module = globalSchema.findModuleByName(moduleName, null); if (module == null) { throw new RestconfDocumentedException("\"" + moduleName + "\" module does not exist.", ErrorType.PROTOCOL, ErrorTag.UNKNOWN_ELEMENT); } } else { - SchemaContext schemaContext = mountPoint.getSchemaContext(); + final SchemaContext schemaContext = mountPoint.getSchemaContext(); if (schemaContext != null) { module = schemaContext.findModuleByName(moduleName, null); } else { @@ -619,7 +620,7 @@ public class ControllerContext implements SchemaContextListener { ErrorType.PROTOCOL, ErrorTag.INVALID_VALUE); } - this.addKeyValue(keyValues, listNode.getDataChildByName(key), uriKeyValue, mountPoint); + addKeyValue(keyValues, listNode.getDataChildByName(key), uriKeyValue, mountPoint); i++; } } @@ -632,7 +633,7 @@ public class ControllerContext implements SchemaContextListener { if ((targetNode instanceof DataNodeContainer)) { final List remaining = strings.subList(consumed, strings.size()); - return this.collectPathArguments(builder, remaining, ((DataNodeContainer) targetNode), mountPoint, + return collectPathArguments(builder, remaining, ((DataNodeContainer) targetNode), mountPoint, returnJustMountPoint); } @@ -645,14 +646,14 @@ public class ControllerContext implements SchemaContextListener { final List potentialSchemaNodes = findInstanceDataChildrenByName(container, name); - Predicate filter = new Predicate() { + final Predicate filter = new Predicate() { @Override public boolean apply(final DataSchemaNode node) { return Objects.equal(node.getQName().getNamespace(), namespace); } }; - Iterable result = Iterables.filter(potentialSchemaNodes, filter); + final Iterable result = Iterables.filter(potentialSchemaNodes, filter); return Iterables.getFirst(result, null); } @@ -660,7 +661,7 @@ public class ControllerContext implements SchemaContextListener { Preconditions. checkNotNull(container); Preconditions. checkNotNull(name); - List instantiatedDataNodeContainers = new ArrayList(); + final List instantiatedDataNodeContainers = new ArrayList(); collectInstanceDataNodeContainers(instantiatedDataNodeContainers, container, name); return instantiatedDataNodeContainers; } @@ -675,14 +676,14 @@ public class ControllerContext implements SchemaContextListener { private static void collectInstanceDataNodeContainers(final List potentialSchemaNodes, final DataNodeContainer container, final String name) { - Predicate filter = new Predicate() { + final Predicate filter = new Predicate() { @Override public boolean apply(final DataSchemaNode node) { return Objects.equal(node.getQName().getLocalName(), name); } }; - Iterable nodes = Iterables.filter(container.getChildNodes(), filter); + final Iterable nodes = Iterables.filter(container.getChildNodes(), filter); // Can't combine this loop with the filter above because the filter is // lazily-applied by Iterables.filter. @@ -692,8 +693,8 @@ public class ControllerContext implements SchemaContextListener { } } - Iterable choiceNodes = Iterables.filter(container.getChildNodes(), ChoiceNode.class); - Iterable> map = Iterables.transform(choiceNodes, CHOICE_FUNCTION); + final Iterable choiceNodes = Iterables.filter(container.getChildNodes(), ChoiceNode.class); + final Iterable> map = Iterables.transform(choiceNodes, CHOICE_FUNCTION); final Iterable allCases = Iterables. concat(map); for (final ChoiceCaseNode caze : allCases) { @@ -714,14 +715,14 @@ public class ControllerContext implements SchemaContextListener { final String urlDecoded = urlPathArgDecode(uriValue); final TypeDefinition typedef = ((LeafSchemaNode) node).getType(); - Codec codec = RestCodec.from(typedef, mountPoint); + final Codec codec = RestCodec.from(typedef, mountPoint); Object decoded = codec == null ? null : codec.deserialize(urlDecoded); String additionalInfo = ""; if (decoded == null) { - TypeDefinition baseType = RestUtil.resolveBaseTypeFrom(typedef); + final TypeDefinition baseType = RestUtil.resolveBaseTypeFrom(typedef); if ((baseType instanceof IdentityrefTypeDefinition)) { - decoded = this.toQName(urlDecoded); + decoded = toQName(urlDecoded); additionalInfo = "For key which is of type identityref it should be in format module_name:identity_name."; } } @@ -763,6 +764,7 @@ public class ControllerContext implements SchemaContextListener { } private QName toQName(final String name) { + checkPreconditions(); final String module = toModuleName(name); final String node = toNodeName(name); final Module m = globalSchema.findModuleByName(module, null); @@ -774,8 +776,8 @@ public class ControllerContext implements SchemaContextListener { } public RpcDefinition getRpcDefinition(final String name) { - final QName validName = this.toQName(name); - return validName == null ? null : this.qnameToRpc.get().get(validName); + final QName validName = toQName(name); + return validName == null ? null : qnameToRpc.get().get(validName); } @Override @@ -789,20 +791,20 @@ public class ControllerContext implements SchemaContextListener { } // FIXME: still not completely atomic - this.qnameToRpc.set(ImmutableMap.copyOf(newMap)); - this.setGlobalSchema(context); + qnameToRpc.set(ImmutableMap.copyOf(newMap)); + setGlobalSchema(context); } } public static List urlPathArgsDecode(final Iterable strings) { try { - List decodedPathArgs = new ArrayList(); + final List decodedPathArgs = new ArrayList(); for (final String pathArg : strings) { - String _decode = URLDecoder.decode(pathArg, URI_ENCODING_CHAR_SET); + final String _decode = URLDecoder.decode(pathArg, URI_ENCODING_CHAR_SET); decodedPathArgs.add(_decode); } return decodedPathArgs; - } catch (UnsupportedEncodingException e) { + } catch (final UnsupportedEncodingException e) { throw new RestconfDocumentedException("Invalid URL path '" + strings + "': " + e.getMessage(), ErrorType.PROTOCOL, ErrorTag.INVALID_VALUE); } @@ -812,7 +814,7 @@ public class ControllerContext implements SchemaContextListener { if (pathArg != null) { try { return URLDecoder.decode(pathArg, URI_ENCODING_CHAR_SET); - } catch (UnsupportedEncodingException e) { + } catch (final UnsupportedEncodingException e) { throw new RestconfDocumentedException("Invalid URL path arg '" + pathArg + "': " + e.getMessage(), ErrorType.PROTOCOL, ErrorTag.INVALID_VALUE); } @@ -840,16 +842,16 @@ public class ControllerContext implements SchemaContextListener { private CharSequence convertToRestconfIdentifier(final NodeIdentifierWithPredicates argument, final ListSchemaNode node) { - QName nodeType = argument.getNodeType(); + final QName nodeType = argument.getNodeType(); final CharSequence nodeIdentifier = this.toRestconfIdentifier(nodeType); final Map keyValues = argument.getKeyValues(); - StringBuilder builder = new StringBuilder(); + final StringBuilder builder = new StringBuilder(); builder.append('/'); builder.append(nodeIdentifier); builder.append('/'); - List keyDefinition = node.getKeyDefinition(); + final List keyDefinition = node.getKeyDefinition(); boolean hasElements = false; for (final QName key : keyDefinition) { if (!hasElements) { @@ -859,8 +861,8 @@ public class ControllerContext implements SchemaContextListener { } try { - builder.append(this.toUriString(keyValues.get(key))); - } catch (UnsupportedEncodingException e) { + builder.append(toUriString(keyValues.get(key))); + } catch (final UnsupportedEncodingException e) { LOG.error("Error parsing URI: {}", keyValues.get(key), e); return null; } @@ -892,7 +894,7 @@ public class ControllerContext implements SchemaContextListener { final CompositeNode compositeNode) { try { return dataNormalizer.toNormalized(legacy, compositeNode); - } catch (NullPointerException e) { + } catch (final NullPointerException e) { throw new RestconfDocumentedException("Data normalizer isn't set. Normalization isn't possible", e); } } @@ -900,7 +902,7 @@ public class ControllerContext implements SchemaContextListener { public YangInstanceIdentifier toNormalized(final YangInstanceIdentifier legacy) { try { return dataNormalizer.toNormalized(legacy); - } catch (NullPointerException e) { + } catch (final NullPointerException e) { throw new RestconfDocumentedException("Data normalizer isn't set. Normalization isn't possible", e); } } @@ -909,7 +911,7 @@ public class ControllerContext implements SchemaContextListener { final NormalizedNode normalizedNode) { try { return dataNormalizer.toLegacy(instanceIdentifier, normalizedNode); - } catch (NullPointerException e) { + } catch (final NullPointerException e) { throw new RestconfDocumentedException("Data normalizer isn't set. Normalization isn't possible", e); } }