X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fbinding%2Fimpl%2FDataBrokerImpl.java;h=3cc66c30c10e490d1b652f6357d9b1ef308be3d2;hb=fd517d730dc4e0a46e4efd7e39b5eaa2181c18ca;hp=02c59b2779ccd511975bd4fa8109b1e2700e6d0d;hpb=9468a50a8108ba5834e57b318bad7778cb31df12;p=controller.git diff --git a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/DataBrokerImpl.java b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/DataBrokerImpl.java index 02c59b2779..3cc66c30c1 100644 --- a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/DataBrokerImpl.java +++ b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/sal/binding/impl/DataBrokerImpl.java @@ -1,5 +1,13 @@ +/* + * 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.sal.binding.impl; +import java.util.Set; import java.util.concurrent.Future; import java.util.concurrent.atomic.AtomicLong; @@ -10,12 +18,13 @@ import org.opendaylight.controller.sal.binding.impl.util.BindingAwareDataReaderR import org.opendaylight.controller.sal.common.DataStoreIdentifier; import org.opendaylight.yangtools.yang.binding.DataObject; import org.opendaylight.yangtools.yang.binding.DataRoot; +import org.opendaylight.yangtools.yang.binding.Identifiable; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.opendaylight.yangtools.yang.common.RpcResult; -public class DataBrokerImpl extends AbstractDataBroker, DataObject, DataChangeListener> implements - DataProviderService, AutoCloseable { +public class DataBrokerImpl extends AbstractDataBroker, DataObject, DataChangeListener> // + implements DataProviderService, AutoCloseable { private final AtomicLong nextTransaction = new AtomicLong(); private final AtomicLong createdTransactionsCount = new AtomicLong(); @@ -99,5 +108,20 @@ public class DataBrokerImpl extends AbstractDataBroker key, + Set> paths) { + if (paths.contains(key)) { + return true; + } + for (InstanceIdentifier path : paths) { + if (key.containsWildcarded(path)) { + return true; + } + } + return false; } -} \ No newline at end of file +}