2 * Copyright (c) 2016 Red Hat, 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
8 package org.opendaylight.netvirt.openstack.netvirt.providers;
11 import java.util.concurrent.ExecutorService;
12 import java.util.concurrent.Executors;
13 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
14 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
15 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
16 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
17 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
18 import org.opendaylight.netvirt.utils.mdsal.utils.MdsalUtils;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.netvirt.providers.config.rev160109.*;
20 import org.opendaylight.yangtools.concepts.ListenerRegistration;
21 import org.opendaylight.yangtools.yang.binding.DataObject;
22 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
23 import org.osgi.framework.BundleContext;
24 import org.osgi.framework.ServiceReference;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
28 public class NetvirtProvidersConfigImpl implements AutoCloseable, ConfigInterface, DataChangeListener {
29 private static final Logger LOG = LoggerFactory.getLogger(NetvirtProvidersConfigImpl.class);
30 private final DataBroker dataBroker;
31 private final ListenerRegistration<DataChangeListener> registration;
32 private final ExecutorService executorService = Executors.newFixedThreadPool(1);
33 private final MdsalUtils mdsalUtils;
35 public NetvirtProvidersConfigImpl(final DataBroker dataBroker, final short tableOffset) {
36 this.dataBroker = dataBroker;
37 mdsalUtils = new MdsalUtils(dataBroker);
39 InstanceIdentifier<NetvirtProvidersConfig> path =
40 InstanceIdentifier.builder(NetvirtProvidersConfig.class).build();
41 registration = dataBroker.registerDataChangeListener(LogicalDatastoreType.CONFIGURATION, path, this,
42 AsyncDataBroker.DataChangeScope.SUBTREE);
44 NetvirtProvidersConfigBuilder netvirtProvidersConfigBuilder = new NetvirtProvidersConfigBuilder();
45 NetvirtProvidersConfig netvirtProvidersConfig =
46 mdsalUtils.read(LogicalDatastoreType.CONFIGURATION, path);
47 if (netvirtProvidersConfig != null) {
48 netvirtProvidersConfigBuilder = new NetvirtProvidersConfigBuilder(netvirtProvidersConfig);
50 if (netvirtProvidersConfigBuilder.getTableOffset() == null) {
51 netvirtProvidersConfigBuilder.setTableOffset(tableOffset);
53 boolean result = mdsalUtils.merge(LogicalDatastoreType.CONFIGURATION, path,
54 netvirtProvidersConfigBuilder.build());
56 LOG.info("NetvirtProvidersConfigImpl: dataBroker= {}, registration= {}, tableOffset= {}, result= {}",
57 dataBroker, registration, tableOffset, result);
61 public void close() throws Exception {
63 executorService.shutdown();
67 public void onDataChanged(final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> asyncDataChangeEvent) {
68 executorService.submit(new Runnable() {
72 LOG.info("onDataChanged: {}", asyncDataChangeEvent);
73 processConfigCreate(asyncDataChangeEvent);
74 processConfigUpdate(asyncDataChangeEvent);
79 private void processConfigCreate(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes) {
80 for (Map.Entry<InstanceIdentifier<?>, DataObject> entry : changes.getCreatedData().entrySet()) {
81 if (entry.getValue() instanceof NetvirtProvidersConfig) {
82 NetvirtProvidersConfig netvirtProvidersConfig = (NetvirtProvidersConfig) entry.getValue();
83 applyConfig(netvirtProvidersConfig);
88 private void processConfigUpdate(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes) {
89 for (Map.Entry<InstanceIdentifier<?>, DataObject> entry : changes.getUpdatedData().entrySet()) {
90 if (entry.getValue() instanceof NetvirtProvidersConfig) {
91 LOG.info("processConfigUpdate: {}", entry);
92 NetvirtProvidersConfig netvirtProvidersConfig = (NetvirtProvidersConfig) entry.getValue();
93 applyConfig(netvirtProvidersConfig);
98 private void applyConfig(NetvirtProvidersConfig netvirtProvidersConfig) {
99 LOG.info("processConfigUpdate: {}", netvirtProvidersConfig);
100 if (netvirtProvidersConfig.getTableOffset() != null) {
101 NetvirtProvidersProvider.setTableOffset(netvirtProvidersConfig.getTableOffset());
106 public void setDependencies(BundleContext bundleContext, ServiceReference serviceReference) {
111 public void setDependencies(Object impl) {