2 * Copyright (c) 2015 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
8 package org.opendaylight.ovsdb.southbound;
10 import java.net.UnknownHostException;
11 import java.util.Map.Entry;
15 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
16 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
17 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope;
18 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
19 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
20 import org.opendaylight.ovsdb.lib.OvsdbClient;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
22 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
23 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
24 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
25 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
26 import org.opendaylight.yangtools.concepts.ListenerRegistration;
27 import org.opendaylight.yangtools.yang.binding.DataObject;
28 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
29 import org.slf4j.Logger;
30 import org.slf4j.LoggerFactory;
32 public class OvsdbNodeDataChangeListener implements DataChangeListener, AutoCloseable {
34 private ListenerRegistration<DataChangeListener> registration;
35 private OvsdbConnectionManager cm;
36 private static final Logger LOG = LoggerFactory.getLogger(OvsdbNodeDataChangeListener.class);
38 OvsdbNodeDataChangeListener(DataBroker db, OvsdbConnectionManager cm) {
39 LOG.info("Registering OvsdbNodeDataChangeListener");
41 InstanceIdentifier<OvsdbNodeAugmentation> path = InstanceIdentifier
42 .create(NetworkTopology.class)
43 .child(Topology.class, new TopologyKey(SouthboundConstants.OVSDB_TOPOLOGY_ID))
45 .augmentation(OvsdbNodeAugmentation.class);
47 db.registerDataChangeListener(LogicalDatastoreType.CONFIGURATION, path, this, DataChangeScope.ONE);
52 public void onDataChanged(
53 AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes) {
54 LOG.info("Received change to ovsdbNode: {}", changes);
55 for (Entry<InstanceIdentifier<?>, DataObject> created : changes.getCreatedData().entrySet()) {
56 // TODO validate we have the correct kind of InstanceIdentifier
57 if (created.getValue() instanceof OvsdbNodeAugmentation) {
59 cm.connect((OvsdbNodeAugmentation) created.getValue());
60 } catch (UnknownHostException e) {
61 LOG.warn("Failed to connect to ovsdbNode", e);
66 Map<InstanceIdentifier<?>, DataObject> originalDataObject = changes.getOriginalData();
67 Set<InstanceIdentifier<?>> iID = changes.getRemovedPaths();
68 for (InstanceIdentifier instanceIdentifier : iID) {
69 if (originalDataObject.get(instanceIdentifier) instanceof OvsdbNodeAugmentation) {
71 cm.disconnect((OvsdbNodeAugmentation) originalDataObject.get(instanceIdentifier));
72 } catch (UnknownHostException e) {
73 LOG.warn("Failed to disconnect ovsdbNode", e);
78 for (Entry<InstanceIdentifier<?>, DataObject> updated : changes.getUpdatedData().entrySet()) {
79 if (updated.getValue() instanceof OvsdbNodeAugmentation) {
80 OvsdbNodeAugmentation value = (OvsdbNodeAugmentation) updated.getValue();
81 OvsdbClient client = cm.getClient(value);
83 for (Entry<InstanceIdentifier<?>, DataObject> original : changes.getOriginalData().entrySet()) {
84 if (original.getValue() instanceof OvsdbNodeAugmentation) {
86 cm.disconnect((OvsdbNodeAugmentation) original.getValue());
88 } catch (UnknownHostException e) {
89 LOG.warn("Failed to disconnect to ovsdbNode", e);
99 public void close() throws Exception {
100 registration.close();