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_ise_adapter.impl;
11 import org.opendaylight.controller.md.sal.binding.api.ClusteredDataTreeChangeListener;
12 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
13 import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;
14 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
15 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker;
16 import org.opendaylight.controller.sal.binding.api.BindingAwareProvider;
17 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.api.EPPolicyTemplateProvider;
18 import org.opendaylight.groupbasedpolicy.sxp.ep.provider.spi.SxpEpProviderProvider;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.groupbasedpolicy.sxp.integration.sxp.ise.adapter.model.rev160630.GbpSxpIseAdapter;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.groupbasedpolicy.sxp.integration.sxp.ise.adapter.model.rev160630.gbp.sxp.ise.adapter.IseSourceConfig;
21 import org.opendaylight.yangtools.concepts.ListenerRegistration;
22 import org.opendaylight.yangtools.concepts.ObjectRegistration;
23 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
27 import com.google.common.base.Preconditions;
30 * Purpose: main provider of gbp-ise adapter (for reading sgts and generating EndpointPolicyTemplates)
32 public class GbpIseAdapterProvider implements AutoCloseable, BindingAwareProvider {
34 private static final Logger LOG = LoggerFactory.getLogger(GbpIseAdapterProvider.class);
36 private final DataBroker dataBroker;
37 private final SxpEpProviderProvider sxpEpProvider;
38 private ListenerRegistration<ClusteredDataTreeChangeListener<IseSourceConfig>> registration;
39 private ObjectRegistration<EPPolicyTemplateProvider> epPolicyTemplateProviderRegistration;
41 public GbpIseAdapterProvider(final DataBroker dataBroker, final BindingAwareBroker broker,
42 final SxpEpProviderProvider sxpEpProvider) {
43 this.dataBroker = Preconditions.checkNotNull(dataBroker, "provided dataBroker must not be null");
44 this.sxpEpProvider = Preconditions.checkNotNull(sxpEpProvider, "provided sxp-ep-provider must not be null");
46 broker.registerProvider(this);
50 public void close() throws Exception {
51 if (registration != null) {
52 LOG.info("closing GbpIseAdapterProvider");
56 if (epPolicyTemplateProviderRegistration != null) {
57 LOG.info("closing EPPolicyTemplateProvider");
58 epPolicyTemplateProviderRegistration.close();
59 epPolicyTemplateProviderRegistration = null;
64 public void onSessionInitiated(final BindingAwareBroker.ProviderContext providerContext) {
65 LOG.info("Starting GbpIseAdapterProvider ..");
67 // setup template provider pipeline
68 final EPPolicyTemplateProviderFacade templateProviderFacade = new EPPolicyTemplateProviderIseImpl();
69 epPolicyTemplateProviderRegistration = sxpEpProvider.getEPPolicyTemplateProviderRegistry()
70 .registerTemplateProvider(templateProviderFacade);
72 // setup harvesting and processing pipeline
73 final SgtInfoProcessor epgGenerator = new SgtToEpgGeneratorImpl(dataBroker);
74 final SgtInfoProcessor templateGenerator = new SgtToEPTemplateGeneratorImpl(dataBroker);
75 final GbpIseSgtHarvester gbpIseSgtHarvester = new GbpIseSgtHarvesterImpl(epgGenerator, templateGenerator);
76 final GbpIseConfigListenerImpl gbpIseConfigListener = new GbpIseConfigListenerImpl(
77 dataBroker, gbpIseSgtHarvester, templateProviderFacade);
79 // build data-tree path
80 final DataTreeIdentifier<IseSourceConfig> dataTreePath = new DataTreeIdentifier<>(
81 LogicalDatastoreType.CONFIGURATION,
82 InstanceIdentifier.create(GbpSxpIseAdapter.class).child(IseSourceConfig.class));
84 // register config listener
85 registration = dataBroker.registerDataTreeChangeListener(dataTreePath,
86 gbpIseConfigListener);