/* * Copyright (c) 2015 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 static java.util.Objects.requireNonNull; import org.opendaylight.controller.md.sal.binding.api.ClusteredDataTreeChangeListener; import org.opendaylight.controller.md.sal.binding.api.DataTreeChangeListener; import org.opendaylight.controller.md.sal.binding.api.DataTreeChangeService; import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier; import org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeService; import org.opendaylight.controller.md.sal.dom.api.DOMDataTreeIdentifier; import org.opendaylight.yangtools.concepts.ListenerRegistration; import org.opendaylight.yangtools.yang.binding.DataObject; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; /** * Adapter exposing Binding {@link DataTreeChangeService} and wrapping * {@link DOMDataTreeChangeService} and is responsible for translation * and instantiation of {@link BindingDOMDataTreeChangeListenerAdapter} * adapters. * *

* Each registered {@link DataTreeChangeListener} is wrapped using * adapter and registered directly to DOM service. */ @Deprecated(forRemoval = true) final class BindingDOMDataTreeChangeServiceAdapter implements DataTreeChangeService { private final BindingToNormalizedNodeCodec codec; private final DOMDataTreeChangeService dataTreeChangeService; private BindingDOMDataTreeChangeServiceAdapter(final BindingToNormalizedNodeCodec codec, final DOMDataTreeChangeService dataTreeChangeService) { this.codec = requireNonNull(codec); this.dataTreeChangeService = requireNonNull(dataTreeChangeService); } static DataTreeChangeService create(final BindingToNormalizedNodeCodec codec, final DOMDataTreeChangeService dataTreeChangeService) { return new BindingDOMDataTreeChangeServiceAdapter(codec, dataTreeChangeService); } @Override public > ListenerRegistration registerDataTreeChangeListener(final DataTreeIdentifier treeId, final L listener) { final DOMDataTreeIdentifier domIdentifier = toDomTreeIdentifier(treeId); @SuppressWarnings({ "rawtypes", "unchecked" }) final BindingDOMDataTreeChangeListenerAdapter domListener = listener instanceof ClusteredDataTreeChangeListener ? new BindingClusteredDOMDataTreeChangeListenerAdapter<>( codec, (ClusteredDataTreeChangeListener) listener, treeId.getDatastoreType()) : new BindingDOMDataTreeChangeListenerAdapter<>(codec, listener, treeId.getDatastoreType()); final ListenerRegistration> domReg = dataTreeChangeService.registerDataTreeChangeListener(domIdentifier, domListener); return new BindingDataTreeChangeListenerRegistration<>(listener,domReg); } private DOMDataTreeIdentifier toDomTreeIdentifier(final DataTreeIdentifier treeId) { final YangInstanceIdentifier domPath = codec.toYangInstanceIdentifierBlocking(treeId.getRootIdentifier()); return new DOMDataTreeIdentifier(treeId.getDatastoreType(), domPath); } }