X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fdom%2Fbroker%2FProviderContextImpl.java;h=0c46c67948a7c41abc8a9a5e0091884b73c11368;hb=refs%2Fchanges%2F30%2F16630%2F12;hp=5e8c0e82538b4d2beacddd3366571ac2a734f7c5;hpb=b80124e3f7b11cf2f5e5bd4a6b033d855ff4d0d4;p=controller.git diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/ProviderContextImpl.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/ProviderContextImpl.java index 5e8c0e8253..0c46c67948 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/ProviderContextImpl.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/ProviderContextImpl.java @@ -7,73 +7,19 @@ */ package org.opendaylight.controller.sal.dom.broker; -import java.util.HashSet; -import java.util.Set; - import org.opendaylight.controller.sal.core.api.Broker.ProviderSession; -import org.opendaylight.controller.sal.core.api.Broker.RoutedRpcRegistration; -import org.opendaylight.controller.sal.core.api.Broker.RpcRegistration; import org.opendaylight.controller.sal.core.api.Provider; -import org.opendaylight.controller.sal.core.api.RpcImplementation; -import org.opendaylight.controller.sal.core.api.RpcRegistrationListener; -import org.opendaylight.yangtools.concepts.ListenerRegistration; -import org.opendaylight.yangtools.yang.common.QName; -import org.osgi.framework.BundleContext; class ProviderContextImpl extends ConsumerContextImpl implements ProviderSession { - private final Set registrations = new HashSet<>(); private final Provider provider; - public ProviderContextImpl(final Provider provider, final BundleContext ctx) { - super(null, ctx); + public ProviderContextImpl(final Provider provider, final BrokerImpl broker) { + super(null, broker); this.provider = provider; } - @Override - public RpcRegistrationWrapper addRpcImplementation(final QName rpcType, - final RpcImplementation implementation) throws IllegalArgumentException { - final RpcRegistration origReg = getBroker().getRouter() - .addRpcImplementation(rpcType, implementation); - final RpcRegistrationWrapper newReg = new RpcRegistrationWrapper( - origReg); - registrations.add(newReg); - return newReg; - } - - protected boolean removeRpcImplementation(final RpcRegistrationWrapper implToRemove) { - return registrations.remove(implToRemove); - } - @Override public void close() { - for (final RpcRegistrationWrapper reg : registrations) { - reg.close(); - } - } - - @Override - public RoutedRpcRegistration addMountedRpcImplementation( - final QName rpcType, final RpcImplementation implementation) { - throw new UnsupportedOperationException( - "TODO: auto-generated method stub"); - } - - @Override - public RoutedRpcRegistration addRoutedRpcImplementation( - final QName rpcType, final RpcImplementation implementation) { - throw new UnsupportedOperationException( - "TODO: auto-generated method stub"); - } - - @Override - public Set getSupportedRpcs() { - return getBroker().getRouter().getSupportedRpcs(); - } - - @Override - public ListenerRegistration addRpcRegistrationListener( - final RpcRegistrationListener listener) { - return getBroker().getRouter().addRpcRegistrationListener(listener); } /**