X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=idmanager%2Fidmanager-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fidmanager%2FIdManagerServiceProvider.java;h=b027da1cda4348e3422b046e8b43cba5b1ebcd2a;hb=refs%2Fchanges%2F93%2F30693%2F3;hp=ab016b1ef26322334da7a603544b827eba04fde6;hpb=f5efefc2ace32941e3da0878578ddd00abf5ab06;p=vpnservice.git diff --git a/idmanager/idmanager-impl/src/main/java/org/opendaylight/idmanager/IdManagerServiceProvider.java b/idmanager/idmanager-impl/src/main/java/org/opendaylight/idmanager/IdManagerServiceProvider.java index ab016b1e..b027da1c 100644 --- a/idmanager/idmanager-impl/src/main/java/org/opendaylight/idmanager/IdManagerServiceProvider.java +++ b/idmanager/idmanager-impl/src/main/java/org/opendaylight/idmanager/IdManagerServiceProvider.java @@ -15,6 +15,7 @@ import org.opendaylight.controller.sal.binding.api.BindingAwareProvider; import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.IdManagerService; +import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.lockmanager.rev150819.LockManagerService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -22,9 +23,10 @@ import org.slf4j.LoggerFactory; public class IdManagerServiceProvider implements BindingAwareProvider, AutoCloseable { - private static final Logger LOG = LoggerFactory.getLogger(IdManagerServiceProvider.class); - private IdManager idManager; - private RpcProviderRegistry rpcProviderRegistry; + private static final Logger LOG = LoggerFactory.getLogger(IdManagerServiceProvider.class); + private IdManager idManager; + private RpcProviderRegistry rpcProviderRegistry; + private LockManagerService lockManager; public RpcProviderRegistry getRpcProviderRegistry() { return rpcProviderRegistry; @@ -34,12 +36,17 @@ public class IdManagerServiceProvider implements BindingAwareProvider, this.rpcProviderRegistry = rpcProviderRegistry; } - @Override + public void setLockManager(LockManagerService lockManager) { + this.lockManager = lockManager; + } + + @Override public void onSessionInitiated(ProviderContext session){ LOG.info("IDManagerserviceProvider Session Initiated"); try { final DataBroker dataBroker = session.getSALService(DataBroker.class); idManager = new IdManager(dataBroker); + idManager.setLockManager(lockManager); final BindingAwareBroker.RpcRegistration rpcRegistration = getRpcProviderRegistry().addRpcImplementation(IdManagerService.class, idManager); } catch (Exception e) { LOG.error("Error initializing services", e);