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;
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;
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<IdManagerService> rpcRegistration = getRpcProviderRegistry().addRpcImplementation(IdManagerService.class, idManager);
} catch (Exception e) {
LOG.error("Error initializing services", e);