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%2FConsumerContextImpl.java;h=00cc8dc51ea694e1c931f2c7ead8626531e5475f;hb=e2607370f5ac443a5a2f1f00f693f82a0b57161d;hp=721b1e5f0986b940b1094b2646b40243e5426831;hpb=753515e8868a1a15982d3f2697439f522f273db5;p=controller.git diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/ConsumerContextImpl.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/ConsumerContextImpl.java index 721b1e5f09..00cc8dc51e 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/ConsumerContextImpl.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/ConsumerContextImpl.java @@ -11,26 +11,24 @@ import com.google.common.base.Optional; import com.google.common.base.Preconditions; import com.google.common.collect.ClassToInstanceMap; import com.google.common.collect.MutableClassToInstanceMap; +import java.util.Collection; +import javax.annotation.concurrent.GuardedBy; import org.opendaylight.controller.sal.core.api.Broker.ConsumerSession; import org.opendaylight.controller.sal.core.api.BrokerService; import org.opendaylight.controller.sal.core.api.Consumer; import org.opendaylight.controller.sal.dom.broker.osgi.AbstractBrokerServiceProxy; import org.opendaylight.controller.sal.dom.broker.osgi.ProxyFactory; -import javax.annotation.concurrent.GuardedBy; -import java.util.Collection; - class ConsumerContextImpl implements ConsumerSession { - private final ClassToInstanceMap instantiatedServices = MutableClassToInstanceMap - .create(); + private final ClassToInstanceMap instantiatedServices = MutableClassToInstanceMap.create(); private final Consumer consumer; private BrokerImpl broker = null; @GuardedBy("this") private boolean closed = false; - public ConsumerContextImpl(final Consumer provider, final BrokerImpl brokerImpl) { + ConsumerContextImpl(final Consumer provider, final BrokerImpl brokerImpl) { broker = brokerImpl; consumer = provider; } @@ -43,8 +41,8 @@ class ConsumerContextImpl implements ConsumerSession { return localProxy; } final Optional serviceImpl = broker.getGlobalService(service); - if(serviceImpl.isPresent()) { - final T ret = ProxyFactory.createProxy(null,serviceImpl.get()); + if (serviceImpl.isPresent()) { + final T ret = ProxyFactory.createProxy(null, serviceImpl.get()); instantiatedServices.putInstance(service, ret); return ret; } else { @@ -78,21 +76,25 @@ class ConsumerContextImpl implements ConsumerSession { } /** + * Gets broker. + * * @return the broker */ - protected final BrokerImpl getBrokerChecked() { + protected final BrokerImpl getBrokerChecked() { checkNotClosed(); return broker; } /** + * Gets consumer. + * * @return the _consumer */ public Consumer getConsumer() { return consumer; } - protected final void checkNotClosed() { + protected final void checkNotClosed() { Preconditions.checkState(!closed, "Session is closed."); } }