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%2Fsal%2Fbinding%2Fimpl%2FDataBrokerImpl.java;h=d4cfb563f633cb1f21a0a6055010a9a98bfd19b7;hp=7a1ca11fb67b918e55403c9edada58fc2844ed3d;hb=fc5234235d2eec5d79fff466fe0c07a8259e1c3f;hpb=d2f2d5a34ccd0a715ab6ea7c1f5ac61f16f6e6cc 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 7a1ca11fb6..d4cfb563f6 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,93 +1,178 @@ +/* + * 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.concurrent.ExecutorService; -import java.util.concurrent.Future; +import java.util.Map; +import java.util.Map.Entry; +import java.util.Set; +import java.util.concurrent.atomic.AtomicLong; +import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler; import org.opendaylight.controller.md.sal.common.api.data.DataReader; +import org.opendaylight.controller.md.sal.common.impl.routing.AbstractDataReadRouter; import org.opendaylight.controller.md.sal.common.impl.service.AbstractDataBroker; import org.opendaylight.controller.sal.binding.api.data.DataChangeListener; import org.opendaylight.controller.sal.binding.api.data.DataProviderService; -import org.opendaylight.controller.sal.binding.impl.util.BindingAwareDataReaderRouter; -import org.opendaylight.controller.sal.common.DataStoreIdentifier; import org.opendaylight.yangtools.concepts.Registration; import org.opendaylight.yangtools.yang.binding.DataObject; -import org.opendaylight.yangtools.yang.binding.DataRoot; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; -import org.opendaylight.yangtools.yang.common.RpcResult; +import org.opendaylight.yangtools.yang.binding.util.DataObjectReadingUtil; +import com.google.common.base.Predicate; +import com.google.common.collect.ImmutableList; +import com.google.common.collect.ImmutableMap; +import com.google.common.collect.ImmutableMap.Builder; +import com.google.common.collect.Maps; -public class DataBrokerImpl extends AbstractDataBroker, DataObject, DataChangeListener> implements - DataProviderService { +public class DataBrokerImpl extends + AbstractDataBroker, DataObject, DataChangeListener> // + implements DataProviderService, AutoCloseable { - public DataBrokerImpl() { - setDataReadRouter(new BindingAwareDataReaderRouter()); + private final static class ContainsWildcarded implements Predicate> { + + private final InstanceIdentifier key; + + public ContainsWildcarded(final InstanceIdentifier key) { + this.key = key; + } + + @Override + public boolean apply(final InstanceIdentifier input) { + return key.containsWildcarded(input); + } } - @Override - public DataTransactionImpl beginTransaction() { - return new DataTransactionImpl(this); + private final static class IsContainedWildcarded implements Predicate> { + + private final InstanceIdentifier key; + + public IsContainedWildcarded(final InstanceIdentifier key) { + this.key = key; + } + + @Override + public boolean apply(final InstanceIdentifier input) { + return input.containsWildcarded(key); + } } - @Override - public T getData(DataStoreIdentifier store, Class rootType) { - // TODO Auto-generated method stub - return null; + private final AtomicLong nextTransaction = new AtomicLong(); + private final AtomicLong createdTransactionsCount = new AtomicLong(); + private final DelegatingDataReadRouter router = new DelegatingDataReadRouter(); + private DataCommitHandler, DataObject> rootCommitHandler; + + public DataBrokerImpl() { + setDataReadRouter(router); } - @Override - public T getData(DataStoreIdentifier store, T filter) { - // TODO Auto-generated method stub - return null; + public void setDataReadDelegate(final DataReader, DataObject> delegate) { + router.setDelegate(delegate); } - @Override - public T getCandidateData(DataStoreIdentifier store, Class rootType) { - // TODO Auto-generated method stub - return null; + public AtomicLong getCreatedTransactionsCount() { + return createdTransactionsCount; } @Override - public T getCandidateData(DataStoreIdentifier store, T filter) { - // TODO Auto-generated method stub - return null; + public DataTransactionImpl beginTransaction() { + String transactionId = "BA-" + nextTransaction.getAndIncrement(); + createdTransactionsCount.getAndIncrement(); + return new DataTransactionImpl(transactionId, this); } @Override - public RpcResult editCandidateData(DataStoreIdentifier store, DataRoot changeSet) { - // TODO Auto-generated method stub - return null; + public void close() { + } @Override - public Future> commit(DataStoreIdentifier store) { - // TODO Auto-generated method stub - return null; + protected Predicate> createContainsPredicate( + final InstanceIdentifier key) { + return new ContainsWildcarded(key); } @Override - public DataObject getData(InstanceIdentifier data) { - // TODO Auto-generated method stub - return null; + protected Predicate> createIsContainedPredicate( + final InstanceIdentifier key) { + return new IsContainedWildcarded(key); } + @SuppressWarnings({ "unchecked", "rawtypes" }) @Override - public DataObject getConfigurationData(InstanceIdentifier data) { - // TODO Auto-generated method stub - return null; + protected Map, DataObject> deepGetBySubpath( + final Map, DataObject> dataSet, + final InstanceIdentifier path) { + Builder, DataObject> builder = ImmutableMap.builder(); + Map, DataObject> potential = Maps.filterKeys(dataSet, + createIsContainedPredicate(path)); + for (Entry, DataObject> entry : potential.entrySet()) { + try { + builder.putAll(DataObjectReadingUtil.readData(entry.getValue(), (InstanceIdentifier) entry.getKey(), + path)); + } catch (Exception e) { + // FIXME : Log exception; + } + } + return builder.build(); + } - @Override - public void registerChangeListener(InstanceIdentifier path, DataChangeListener changeListener) { - // TODO Auto-generated method stub - + public class DelegatingDataReadRouter extends + AbstractDataReadRouter, DataObject> { + + private DataReader, DataObject> delegate; + + @Override + public DataObject readConfigurationData(final InstanceIdentifier path) { + return delegate.readConfigurationData(path); + } + + public void setDelegate(final DataReader, DataObject> delegate) { + this.delegate = delegate; + } + + @Override + public DataObject readOperationalData(final InstanceIdentifier path) { + return delegate.readOperationalData(path); + } + + @Override + protected DataObject merge(final InstanceIdentifier path, final Iterable data) { + throw new UnsupportedOperationException("Not supported"); + } + + @Override + public Registration registerConfigurationReader( + final InstanceIdentifier path, + final DataReader, DataObject> reader) { + throw new UnsupportedOperationException("Not supported"); + } + + @Override + public Registration registerOperationalReader( + final InstanceIdentifier path, + final DataReader, DataObject> reader) { + throw new UnsupportedOperationException("Not supported"); + } } @Override - public void unregisterChangeListener(InstanceIdentifier path, - DataChangeListener changeListener) { - // TODO Auto-generated method stub - + protected ImmutableList, DataObject>> affectedCommitHandlers( + final Set> paths) { + ImmutableList.Builder, DataObject>> handlersBuilder = ImmutableList.builder(); + return handlersBuilder // + .add(rootCommitHandler) // + .addAll(super.affectedCommitHandlers(paths)) // + .build(); } - - -} \ No newline at end of file + + public void setRootCommitHandler(final DataCommitHandler, DataObject> commitHandler) { + rootCommitHandler = commitHandler; + } + +}