2 * Copyright (c) 2016 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl;
11 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
12 import org.opendaylight.groupbasedpolicy.api.DomainSpecificRegistry;
13 import org.opendaylight.groupbasedpolicy.api.EndpointAugmentor;
14 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.api.EPPolicyTemplateDaoFacade;
15 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.api.EPPolicyTemplateProviderRegistry;
16 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.api.EPToSgtMapper;
17 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.dao.EPForwardingTemplateDaoImpl;
18 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.dao.EPPolicyTemplateDaoFacadeImpl;
19 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.dao.EPPolicyTemplateDaoImpl;
20 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.dao.EpPolicyTemplateValueKeyFactory;
21 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.dao.MasterDatabaseBindingDaoImpl;
22 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.dao.SimpleCachedDaoEPForwardingTemplateImpl;
23 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.dao.SimpleCachedDaoImpl;
24 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.listen.EPForwardingTemplateListenerImpl;
25 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.listen.EPPolicyTemplateListenerImpl;
26 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.listen.MasterDatabaseBindingListenerImpl;
27 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.impl.util.EPTemplateUtil;
28 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.spi.SxpEpProviderProvider;
29 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.BaseEndpointService;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.groupbasedpolicy.sxp.integration.sxp.ep.provider.model.rev160302.sxp.ep.mapper.EndpointForwardingTemplateBySubnet;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.groupbasedpolicy.sxp.integration.sxp.ep.provider.model.rev160302.sxp.ep.mapper.EndpointPolicyTemplateBySgt;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.groupbasedpolicy.sxp.integration.sxp.ep.provider.rev160722.SgtGeneratorConfig;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.sxp.database.rev160308.Sgt;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.sxp.database.rev160308.master.database.fields.MasterDatabaseBinding;
36 import org.slf4j.Logger;
37 import org.slf4j.LoggerFactory;
40 * SxpMapper provider implementation.
42 public class SxpEpProviderProviderImpl implements SxpEpProviderProvider {
44 private static final Logger LOG = LoggerFactory.getLogger(SxpEpProviderProviderImpl.class);
46 private final MasterDatabaseBindingListenerImpl sxpDatabaseListener;
47 private final EPTemplateListener epPolicyTemplateListener;
48 private final EPTemplateListener epForwardingTemplateListener;
49 private final DomainSpecificRegistry domainSpecificRegistry;
50 private final EndpointAugmentor sxpEndpointAugmentor;
51 private final EPPolicyTemplateProviderRegistry epPolicyTemplateRegistry;
52 private final EPToSgtMapper epToSgtMapper;
54 public SxpEpProviderProviderImpl(final DataBroker dataBroker, final BaseEndpointService endpointService,
55 final DomainSpecificRegistry domainSpecificRegistry, final SgtGeneratorConfig sgtGeneratorConfig) {
56 LOG.info("starting SxmMapper ..");
57 this.domainSpecificRegistry = domainSpecificRegistry;
60 final SxpMapperReactor sxpMapperReactor = new SxpMapperReactorImpl(endpointService, dataBroker);
62 // cached dao layer for templates and master-database
63 final SimpleCachedDao<Sgt, EndpointPolicyTemplateBySgt> epPolicyTemplateCachedDao = new SimpleCachedDaoImpl<>();
64 final SimpleCachedDao<IpPrefix, EndpointForwardingTemplateBySubnet> epForwardingTemplateCachedDao =
65 new SimpleCachedDaoEPForwardingTemplateImpl();
66 final SimpleCachedDao<IpPrefix, MasterDatabaseBinding> masterDBBindingCachedDao = new SimpleCachedDaoImpl<>();
68 // reading dao layer for templates and master-database
69 final EpPolicyTemplateValueKeyFactory epPolicyTemplateKeyFactory = new EpPolicyTemplateValueKeyFactory(
70 EPTemplateUtil.createEndpointGroupIdOrdering(), EPTemplateUtil.createConditionNameOrdering());
71 final EPPolicyTemplateDaoImpl epPolicyTemplateDao = new EPPolicyTemplateDaoImpl(dataBroker, epPolicyTemplateCachedDao, epPolicyTemplateKeyFactory);
72 final EPForwardingTemplateDaoImpl epForwardingTemplateDao = new EPForwardingTemplateDaoImpl(dataBroker,
73 epForwardingTemplateCachedDao);
74 final MasterDatabaseBindingDaoImpl masterDBBindingDao = new MasterDatabaseBindingDaoImpl(dataBroker, masterDBBindingCachedDao);
76 // facade for ep-policy-template: reading dao + consumer of ise provider + template generator
77 final SgtGeneratorImpl sgtGeneratorImpl = new SgtGeneratorImpl(sgtGeneratorConfig);
78 final EPPolicyTemplateDaoFacade epPolicyTemplateDaoFacade = new EPPolicyTemplateDaoFacadeImpl(dataBroker,
79 epPolicyTemplateDao, epPolicyTemplateCachedDao, sgtGeneratorImpl);
80 epPolicyTemplateRegistry = new EPPolicyTemplateProviderRegistryImpl();
81 epPolicyTemplateRegistry.addDistributionTarget(epPolicyTemplateDaoFacade);
82 epToSgtMapper = new EPToSgtMapperImpl(epPolicyTemplateDaoFacade);
84 // DS-listeners for templates and master-database
85 sxpDatabaseListener = new MasterDatabaseBindingListenerImpl(dataBroker, sxpMapperReactor, masterDBBindingCachedDao,
86 epPolicyTemplateDaoFacade, epForwardingTemplateDao);
87 epPolicyTemplateListener = new EPPolicyTemplateListenerImpl(dataBroker, sxpMapperReactor, epPolicyTemplateCachedDao,
88 masterDBBindingDao, epForwardingTemplateDao);
89 epForwardingTemplateListener = new EPForwardingTemplateListenerImpl(dataBroker, sxpMapperReactor, epForwardingTemplateCachedDao,
90 masterDBBindingDao, epPolicyTemplateDaoFacade);
92 // sxp-ep-augmentor -> deprecated, will use ep2sxpMapper service
93 sxpEndpointAugmentor = new SxpEndpointAugmentorImpl(epPolicyTemplateDao, epPolicyTemplateKeyFactory);
94 domainSpecificRegistry.getEndpointAugmentorRegistry().register(sxpEndpointAugmentor);
96 LOG.info("started SxmMapper");
100 public EPPolicyTemplateProviderRegistry getEPPolicyTemplateProviderRegistry() {
101 return epPolicyTemplateRegistry;
105 public EPToSgtMapper getEPToSgtMapper() {
106 return epToSgtMapper;
110 public void close() throws Exception {
111 sxpDatabaseListener.close();
112 epPolicyTemplateListener.close();
113 epForwardingTemplateListener.close();
114 epPolicyTemplateRegistry.close();
115 domainSpecificRegistry.getEndpointAugmentorRegistry().unregister(sxpEndpointAugmentor);