X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fbinding%2Fimpl%2FAbstractForwardedDataBroker.java;h=03b7bae3f50e848146cef9a264ecb479ff404a71;hb=HEAD;hp=273155bcf71a275b7335ad322cde99b92191922a;hpb=5448d6812e386bd56aec7209c4852c586a6163b3;p=controller.git diff --git a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/AbstractForwardedDataBroker.java b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/AbstractForwardedDataBroker.java deleted file mode 100644 index 273155bcf7..0000000000 --- a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/md/sal/binding/impl/AbstractForwardedDataBroker.java +++ /dev/null @@ -1,287 +0,0 @@ -/* - * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. - * - * This program and the accompanying materials are made available under the - * terms of the Eclipse Public License v1.0 which accompanies this distribution, - * and is available at http://www.eclipse.org/legal/epl-v10.html - */ -package org.opendaylight.controller.md.sal.binding.impl; - -import com.google.common.base.Objects; -import com.google.common.base.Optional; - -import java.util.Collections; -import java.util.HashMap; -import java.util.HashSet; -import java.util.Map; -import java.util.Map.Entry; -import java.util.Set; - -import org.opendaylight.controller.md.sal.binding.api.DataChangeListener; -import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope; -import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent; -import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; -import org.opendaylight.controller.md.sal.dom.api.DOMDataBroker; -import org.opendaylight.controller.md.sal.dom.api.DOMDataChangeListener; -import org.opendaylight.controller.sal.binding.impl.connect.dom.BindingIndependentConnector; -import org.opendaylight.controller.sal.binding.impl.forward.DomForwardedBroker; -import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; -import org.opendaylight.controller.sal.core.api.model.SchemaService; -import org.opendaylight.yangtools.concepts.AbstractListenerRegistration; -import org.opendaylight.yangtools.concepts.Delegator; -import org.opendaylight.yangtools.concepts.ListenerRegistration; -import org.opendaylight.yangtools.yang.binding.DataObject; -import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; -import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; -import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; -import org.opendaylight.yangtools.yang.data.impl.codec.DeserializationException; -import org.opendaylight.yangtools.yang.model.api.SchemaContext; -import org.opendaylight.yangtools.yang.model.api.SchemaContextListener; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public abstract class AbstractForwardedDataBroker implements Delegator, DomForwardedBroker, - SchemaContextListener, AutoCloseable { - - private static final Logger LOG = LoggerFactory.getLogger(AbstractForwardedDataBroker.class); - // The Broker to whom we do all forwarding - private final DOMDataBroker domDataBroker; - - private final BindingToNormalizedNodeCodec codec; - private BindingIndependentConnector connector; - private ProviderSession context; - private final ListenerRegistration schemaListenerRegistration; - - protected AbstractForwardedDataBroker(final DOMDataBroker domDataBroker, final BindingToNormalizedNodeCodec codec, - final SchemaService schemaService) { - this.domDataBroker = domDataBroker; - this.codec = codec; - this.schemaListenerRegistration = schemaService.registerSchemaContextListener(this); - } - - protected BindingToNormalizedNodeCodec getCodec() { - return codec; - } - - @Override - public DOMDataBroker getDelegate() { - return domDataBroker; - } - - @Override - public void onGlobalContextUpdated(final SchemaContext ctx) { - // NOOP - } - - public ListenerRegistration registerDataChangeListener(final LogicalDatastoreType store, - final InstanceIdentifier path, final DataChangeListener listener, final DataChangeScope triggeringScope) { - DOMDataChangeListener domDataChangeListener = new TranslatingDataChangeInvoker(store, path, listener, - triggeringScope); - YangInstanceIdentifier domPath = codec.toNormalized(path); - ListenerRegistration domRegistration = domDataBroker.registerDataChangeListener(store, - domPath, domDataChangeListener, triggeringScope); - return new ListenerRegistrationImpl(listener, domRegistration); - } - - protected Map, DataObject> toBinding(final InstanceIdentifier path, - final Map> normalized) { - Map, DataObject> newMap = new HashMap<>(); - - for (Map.Entry> entry : normalized.entrySet()) { - try { - Optional, DataObject>> potential = getCodec().toBinding(entry); - if (potential.isPresent()) { - Entry, DataObject> binding = potential.get(); - newMap.put(binding.getKey(), binding.getValue()); - } - } catch (DeserializationException e) { - LOG.warn("Failed to transform {}, omitting it", entry, e); - } - } - return newMap; - } - - protected Set> toBinding(final InstanceIdentifier path, - final Set normalized) { - Set> hashSet = new HashSet<>(); - for (YangInstanceIdentifier normalizedPath : normalized) { - try { - Optional> potential = getCodec().toBinding(normalizedPath); - if (potential.isPresent()) { - InstanceIdentifier binding = potential.get(); - hashSet.add(binding); - } else if (normalizedPath.getLastPathArgument() instanceof YangInstanceIdentifier.AugmentationIdentifier) { - hashSet.add(path); - } - } catch (DeserializationException e) { - LOG.warn("Failed to transform {}, omitting it", normalizedPath, e); - } - } - return hashSet; - } - - protected Optional toBindingData(final InstanceIdentifier path, final NormalizedNode data) { - if (path.isWildcarded()) { - return Optional.absent(); - } - return (Optional) getCodec().deserializeFunction(path).apply(Optional.> of(data)); - } - - private class TranslatingDataChangeInvoker implements DOMDataChangeListener { - private final DataChangeListener bindingDataChangeListener; - private final LogicalDatastoreType store; - private final InstanceIdentifier path; - private final DataChangeScope triggeringScope; - - public TranslatingDataChangeInvoker(final LogicalDatastoreType store, final InstanceIdentifier path, - final DataChangeListener bindingDataChangeListener, final DataChangeScope triggeringScope) { - this.store = store; - this.path = path; - this.bindingDataChangeListener = bindingDataChangeListener; - this.triggeringScope = triggeringScope; - } - - @Override - public void onDataChanged(final AsyncDataChangeEvent> change) { - bindingDataChangeListener.onDataChanged(new TranslatedDataChangeEvent(change, path)); - } - - @Override - public String toString() { - return bindingDataChangeListener.getClass().getName(); - } - } - - private class TranslatedDataChangeEvent implements AsyncDataChangeEvent, DataObject> { - private final AsyncDataChangeEvent> domEvent; - private final InstanceIdentifier path; - - private Map, DataObject> createdCache; - private Map, DataObject> updatedCache; - private Map, DataObject> originalCache; - private Set> removedCache; - private Optional originalDataCache; - private Optional updatedDataCache; - - public TranslatedDataChangeEvent( - final AsyncDataChangeEvent> change, - final InstanceIdentifier path) { - this.domEvent = change; - this.path = path; - } - - @Override - public Map, DataObject> getCreatedData() { - if (createdCache == null) { - createdCache = Collections.unmodifiableMap(toBinding(path, domEvent.getCreatedData())); - } - return createdCache; - } - - @Override - public Map, DataObject> getUpdatedData() { - if (updatedCache == null) { - updatedCache = Collections.unmodifiableMap(toBinding(path, domEvent.getUpdatedData())); - } - return updatedCache; - - } - - @Override - public Set> getRemovedPaths() { - if (removedCache == null) { - removedCache = Collections.unmodifiableSet(toBinding(path, domEvent.getRemovedPaths())); - } - return removedCache; - } - - @Override - public Map, DataObject> getOriginalData() { - if (originalCache == null) { - originalCache = Collections.unmodifiableMap(toBinding(path, domEvent.getOriginalData())); - } - return originalCache; - - } - - @Override - public DataObject getOriginalSubtree() { - if (originalDataCache == null) { - if (domEvent.getOriginalSubtree() != null) { - originalDataCache = toBindingData(path, domEvent.getOriginalSubtree()); - } else { - originalDataCache = Optional.absent(); - } - } - return originalDataCache.orNull(); - } - - @Override - public DataObject getUpdatedSubtree() { - if (updatedDataCache == null) { - if (domEvent.getUpdatedSubtree() != null) { - updatedDataCache = toBindingData(path, domEvent.getUpdatedSubtree()); - } else { - updatedDataCache = Optional.absent(); - } - } - return updatedDataCache.orNull(); - } - - @Override - public String toString() { - return Objects.toStringHelper(TranslatedDataChangeEvent.class) // - .add("created", getCreatedData()) // - .add("updated", getUpdatedData()) // - .add("removed", getRemovedPaths()) // - .add("dom", domEvent) // - .toString(); - } - } - - private static class ListenerRegistrationImpl extends AbstractListenerRegistration { - private final ListenerRegistration registration; - - public ListenerRegistrationImpl(final DataChangeListener listener, - final ListenerRegistration registration) { - super(listener); - this.registration = registration; - } - - @Override - protected void removeRegistration() { - registration.close(); - } - } - - @Override - public BindingIndependentConnector getConnector() { - return this.connector; - } - - @Override - public ProviderSession getDomProviderContext() { - return this.context; - } - - @Override - public void setConnector(final BindingIndependentConnector connector) { - this.connector = connector; - } - - @Override - public void setDomProviderContext(final ProviderSession domProviderContext) { - this.context = domProviderContext; - } - - @Override - public void startForwarding() { - // NOOP - } - - @Override - public void close() throws Exception { - this.schemaListenerRegistration.close(); - } - -}