2 * Copyright (c) 2015 CableLabs 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.unimgr.impl;
11 import java.util.List;
13 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
14 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
15 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
16 import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
17 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
18 import org.opendaylight.controller.sal.binding.api.BindingAwareProvider;
19 import org.opendaylight.unimgr.api.IUnimgrConsoleProvider;
20 import org.opendaylight.unimgr.command.TransactionInvoker;
21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.unimgr.rev151012.Evc;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.unimgr.rev151012.Uni;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.unimgr.rev151012.UniAugmentation;
25 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
26 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopologyBuilder;
27 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
28 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyBuilder;
29 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
30 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
31 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
32 import org.osgi.framework.BundleContext;
33 import org.osgi.framework.FrameworkUtil;
34 import org.osgi.framework.ServiceRegistration;
35 import org.slf4j.Logger;
36 import org.slf4j.LoggerFactory;
38 import com.google.common.base.Optional;
39 import com.google.common.util.concurrent.CheckedFuture;
41 public class UnimgrProvider implements BindingAwareProvider, AutoCloseable, IUnimgrConsoleProvider {
43 private static final Logger LOG = LoggerFactory.getLogger(UnimgrProvider.class);
45 private UnimgrDataChangeListener listener;
46 private TransactionInvoker invoker;
48 private DataBroker dataBroker;
49 private ServiceRegistration<IUnimgrConsoleProvider> unimgrConsoleRegistration;
51 public UnimgrProvider() {
52 LOG.info("Unimgr provider initialized");
56 public void onSessionInitiated(ProviderContext session) {
57 LOG.info("UnimgrProvider Session Initiated");
59 // Retrieve the data broker to create transactions
60 dataBroker = session.getSALService(DataBroker.class);
61 invoker = new TransactionInvoker();
63 // Register the unimgr OSGi CLI
64 BundleContext context = FrameworkUtil.getBundle(this.getClass()).getBundleContext();
65 unimgrConsoleRegistration = context.registerService(IUnimgrConsoleProvider.class,
69 // Register the uni data change listener
70 listener = new UnimgrDataChangeListener(dataBroker, invoker);
72 // Initialize operational and default config data in MD-SAL data store
73 initDatastore(LogicalDatastoreType.CONFIGURATION,
74 UnimgrConstants.UNI_TOPOLOGY_ID);
75 initDatastore(LogicalDatastoreType.OPERATIONAL,
76 UnimgrConstants.UNI_TOPOLOGY_ID);
77 initDatastore(LogicalDatastoreType.CONFIGURATION,
78 UnimgrConstants.EVC_TOPOLOGY_ID);
79 initDatastore(LogicalDatastoreType.OPERATIONAL,
80 UnimgrConstants.EVC_TOPOLOGY_ID);
84 public void close() throws Exception {
85 LOG.info("UnimgrProvider Closed");
86 unimgrConsoleRegistration.unregister();
90 protected void initDatastore(final LogicalDatastoreType type,
92 InstanceIdentifier<Topology> path = InstanceIdentifier
93 .create(NetworkTopology.class)
94 .child(Topology.class,
95 new TopologyKey(topoId));
96 initializeTopology(type);
97 ReadWriteTransaction transaction = dataBroker.newReadWriteTransaction();
98 CheckedFuture<Optional<Topology>, ReadFailedException> unimgrTp = transaction.read(type,
101 if (!unimgrTp.get().isPresent()) {
102 TopologyBuilder tpb = new TopologyBuilder();
103 tpb.setTopologyId(topoId);
104 transaction.put(type, path, tpb.build());
105 transaction.submit();
107 transaction.cancel();
109 } catch (Exception e) {
110 LOG.error("Error initializing unimgr topology", e);
114 private void initializeTopology(LogicalDatastoreType type) {
115 ReadWriteTransaction transaction = dataBroker.newReadWriteTransaction();
116 InstanceIdentifier<NetworkTopology> path = InstanceIdentifier.create(NetworkTopology.class);
117 CheckedFuture<Optional<NetworkTopology>, ReadFailedException> topology = transaction.read(type,path);
119 if (!topology.get().isPresent()) {
120 NetworkTopologyBuilder ntb = new NetworkTopologyBuilder();
121 transaction.put(type,path,ntb.build());
122 transaction.submit();
124 transaction.cancel();
126 } catch (Exception e) {
127 LOG.error("Error initializing unimgr topology {}",e);
132 public boolean addUni(UniAugmentation uniAug) {
133 if (uniAug == null || uniAug.getIpAddress() == null || uniAug.getMacAddress() == null) {
136 return UnimgrUtils.createUniNode(dataBroker, uniAug);
140 public boolean removeUni(IpAddress ipAddress) {
141 // TODO Auto-generated method stub
146 public List<Uni> listUnis(Boolean isConfigurationData) {
147 // TODO Auto-generated method stub
152 public Uni getUni(IpAddress ipAddress) {
153 // TODO Auto-generated method stub
159 public boolean removeEvc(String uuid) {
160 // TODO Auto-generated method stub
165 public boolean addEvc(Evc evc) {
166 // TODO Auto-generated method stub
171 public Evc getEvc(String uuid) {
172 // TODO Auto-generated method stub