X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fbinding%2Fimpl%2FBindingToNormalizedNodeCodec.java;fp=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fbinding%2Fimpl%2FBindingToNormalizedNodeCodec.java;h=5ba5db4640d1abf048c69fb095f3f35705ce9492;hp=7b8d8c70f760ff54972fd7efbb065974b478747c;hb=db89afdefb3cfa4454dfdc6008e1d54d3ede66fb;hpb=0ac8d08952b78b20738683e806085609aced5932 diff --git a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/BindingToNormalizedNodeCodec.java b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/BindingToNormalizedNodeCodec.java index 7b8d8c70f7..5ba5db4640 100644 --- a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/BindingToNormalizedNodeCodec.java +++ b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/BindingToNormalizedNodeCodec.java @@ -33,10 +33,10 @@ import org.opendaylight.mdsal.binding.dom.codec.api.BindingCodecTree; import org.opendaylight.mdsal.binding.dom.codec.api.BindingCodecTreeFactory; import org.opendaylight.mdsal.binding.dom.codec.api.BindingCodecTreeNode; import org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer; +import org.opendaylight.mdsal.binding.generator.api.ClassLoadingStrategy; +import org.opendaylight.mdsal.binding.generator.util.BindingRuntimeContext; import org.opendaylight.yangtools.binding.data.codec.impl.BindingNormalizedNodeCodecRegistry; import org.opendaylight.yangtools.binding.data.codec.impl.MissingSchemaException; -import org.opendaylight.yangtools.sal.binding.generator.api.ClassLoadingStrategy; -import org.opendaylight.yangtools.sal.binding.generator.util.BindingRuntimeContext; import org.opendaylight.yangtools.yang.binding.BindingMapping; import org.opendaylight.yangtools.yang.binding.DataContainer; import org.opendaylight.yangtools.yang.binding.DataObject; @@ -98,10 +98,10 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto YangInstanceIdentifier toYangInstanceIdentifierBlocking(final InstanceIdentifier binding) { try { - return codecRegistry.toYangInstanceIdentifier(binding); + return this.codecRegistry.toYangInstanceIdentifier(binding); } catch (final MissingSchemaException e) { waitForSchema(decompose(binding),e); - return codecRegistry.toYangInstanceIdentifier(binding); + return this.codecRegistry.toYangInstanceIdentifier(binding); } } @@ -116,23 +116,23 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto * If supplied Instance Identifier is not valid. */ public YangInstanceIdentifier toNormalized(final InstanceIdentifier binding) { - return codecRegistry.toYangInstanceIdentifier(binding); + return this.codecRegistry.toYangInstanceIdentifier(binding); } @Override public YangInstanceIdentifier toYangInstanceIdentifier(final InstanceIdentifier binding) { - return codecRegistry.toYangInstanceIdentifier(binding); + return this.codecRegistry.toYangInstanceIdentifier(binding); } YangInstanceIdentifier toYangInstanceIdentifierCached(final InstanceIdentifier binding) { - return iiCache .getUnchecked(binding); + return this.iiCache .getUnchecked(binding); } @Override public Entry> toNormalizedNode( final InstanceIdentifier path, final T data) { - return codecRegistry.toNormalizedNode(path, data); + return this.codecRegistry.toNormalizedNode(path, data); } /** @@ -153,32 +153,32 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto @Override public Entry, DataObject> fromNormalizedNode(final YangInstanceIdentifier path, final NormalizedNode data) { - return codecRegistry.fromNormalizedNode(path, data); + return this.codecRegistry.fromNormalizedNode(path, data); } @Override public Notification fromNormalizedNodeNotification(final SchemaPath path, final ContainerNode data) { - return codecRegistry.fromNormalizedNodeNotification(path, data); + return this.codecRegistry.fromNormalizedNodeNotification(path, data); } @Override public DataObject fromNormalizedNodeRpcData(final SchemaPath path, final ContainerNode data) { - return codecRegistry.fromNormalizedNodeRpcData(path, data); + return this.codecRegistry.fromNormalizedNodeRpcData(path, data); } @Override public InstanceIdentifier fromYangInstanceIdentifier(final YangInstanceIdentifier dom) { - return codecRegistry.fromYangInstanceIdentifier(dom); + return this.codecRegistry.fromYangInstanceIdentifier(dom); } @Override public ContainerNode toNormalizedNodeNotification(final Notification data) { - return codecRegistry.toNormalizedNodeNotification(data); + return this.codecRegistry.toNormalizedNodeNotification(data); } @Override public ContainerNode toNormalizedNodeRpcData(final DataContainer data) { - return codecRegistry.toNormalizedNodeRpcData(data); + return this.codecRegistry.toNormalizedNodeRpcData(data); } /** @@ -193,14 +193,14 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto public Optional> toBinding(final YangInstanceIdentifier normalized) throws DeserializationException { try { - return Optional.>fromNullable(codecRegistry.fromYangInstanceIdentifier(normalized)); + return Optional.>fromNullable(this.codecRegistry.fromYangInstanceIdentifier(normalized)); } catch (final IllegalArgumentException e) { return Optional.absent(); } } public DataNormalizer getDataNormalizer() { - return legacyToNormalized; + return this.legacyToNormalized; } public Optional, DataObject>> toBinding( @@ -221,7 +221,7 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto * */ @SuppressWarnings("unchecked") - final Entry, DataObject> binding = Entry.class.cast(codecRegistry.fromNormalizedNode(normalized.getKey(), normalized.getValue())); + final Entry, DataObject> binding = Entry.class.cast(this.codecRegistry.fromNormalizedNode(normalized.getKey(), normalized.getValue())); return Optional.fromNullable(binding); } catch (final IllegalArgumentException e) { return Optional.absent(); @@ -230,14 +230,14 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto @Override public void onGlobalContextUpdated(final SchemaContext schemaContext) { - legacyToNormalized = new DataNormalizer(schemaContext); - BindingRuntimeContext runtimeContext = BindingRuntimeContext.create(classLoadingStrategy, schemaContext); - codecRegistry.onBindingRuntimeContextUpdated(runtimeContext); - futureSchema.onRuntimeContextUpdated(runtimeContext); + this.legacyToNormalized = new DataNormalizer(schemaContext); + final BindingRuntimeContext runtimeContext = BindingRuntimeContext.create(this.classLoadingStrategy, schemaContext); + this.codecRegistry.onBindingRuntimeContextUpdated(runtimeContext); + this.futureSchema.onRuntimeContextUpdated(runtimeContext); } public Function>, Optional> deserializeFunction(final InstanceIdentifier path) { - return codecRegistry.deserializeFunction(path); + return this.codecRegistry.deserializeFunction(path); } /** @@ -248,7 +248,7 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto */ public NormalizedNode getDefaultNodeFor(final YangInstanceIdentifier path) { final Iterator iterator = path.getPathArguments().iterator(); - DataNormalizationOperation currentOp = legacyToNormalized.getRootOperation(); + DataNormalizationOperation currentOp = this.legacyToNormalized.getRootOperation(); while (iterator.hasNext()) { final PathArgument currentArg = iterator.next(); try { @@ -261,7 +261,7 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto } public BindingNormalizedNodeCodecRegistry getCodecRegistry() { - return codecRegistry; + return this.codecRegistry; } @Override @@ -270,7 +270,7 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto } public BindingNormalizedNodeCodecRegistry getCodecFactory() { - return codecRegistry; + return this.codecRegistry; } // FIXME: This should be probably part of Binding Runtime context @@ -307,7 +307,7 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto final URI namespace = moduleName.getNamespace(); final Date revision = moduleName.getRevision(); Module module = runtimeContext().getSchemaContext().findModuleByNamespaceAndRevision(namespace, revision); - if(module == null && futureSchema.waitForSchema(namespace,revision)) { + if((module == null) && this.futureSchema.waitForSchema(namespace,revision)) { module = runtimeContext().getSchemaContext().findModuleByNamespaceAndRevision(namespace, revision); } Preconditions.checkState(module != null, "Schema for %s is not available.", modeledClass); @@ -315,9 +315,9 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto } private void waitForSchema(final Collection> binding, final MissingSchemaException e) { - LOG.warn("Blocking thread to wait for schema convergence updates for {} {}", futureSchema.getDuration(), - futureSchema.getUnit()); - if(futureSchema.waitForSchema(binding)) { + LOG.warn("Blocking thread to wait for schema convergence updates for {} {}", this.futureSchema.getDuration(), + this.futureSchema.getUnit()); + if(this.futureSchema.waitForSchema(binding)) { return; } @@ -339,25 +339,25 @@ public final class BindingToNormalizedNodeCodec implements BindingCodecTreeFacto } private BindingRuntimeContext runtimeContext() { - return futureSchema.runtimeContext(); + return this.futureSchema.runtimeContext(); } @Override public BindingCodecTree create(final BindingRuntimeContext context) { - return codecRegistry.create(context); + return this.codecRegistry.create(context); } @Override public BindingCodecTree create(final SchemaContext context, final Class... bindingClasses) { - return codecRegistry.create(context, bindingClasses); + return this.codecRegistry.create(context, bindingClasses); } @Nonnull protected Map.Entry, BindingCodecTreeNode> getSubtreeCodec( final YangInstanceIdentifier domIdentifier) { - final BindingCodecTree currentCodecTree = codecRegistry.getCodecContext(); - final InstanceIdentifier bindingPath = codecRegistry.fromYangInstanceIdentifier(domIdentifier); + final BindingCodecTree currentCodecTree = this.codecRegistry.getCodecContext(); + final InstanceIdentifier bindingPath = this.codecRegistry.fromYangInstanceIdentifier(domIdentifier); Preconditions.checkArgument(bindingPath != null); /** * If we are able to deserialize YANG instance identifier, getSubtreeCodec must