2 * Copyright (c) 2015 - 2016 Ericsson India Global Services Pvt Ltd. 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.vpnservice.alivenessmonitor.internal;
10 import java.util.concurrent.ExecutionException;
11 import java.util.concurrent.Future;
13 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
14 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
15 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
16 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesState;
17 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
18 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rpcs.rev151003.GetNodeconnectorIdFromInterfaceInputBuilder;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rpcs.rev151003.GetNodeconnectorIdFromInterfaceInput;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rpcs.rev151003.GetNodeconnectorIdFromInterfaceOutput;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorKey;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
29 import org.opendaylight.yangtools.yang.binding.DataObject;
30 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
31 import org.opendaylight.yangtools.yang.common.RpcResult;
33 import com.google.common.base.Optional;
34 import com.google.common.base.Strings;
36 abstract class AbstractAlivenessProtocolHandler implements AlivenessProtocolHandler {
38 protected ServiceProvider serviceProvider;
39 private InventoryReader inventoryReader;
41 public AbstractAlivenessProtocolHandler(ServiceProvider serviceProvider) {
42 this.serviceProvider = serviceProvider;
43 inventoryReader = new InventoryReader(serviceProvider.getDataBroker());
46 private InstanceIdentifier<NodeConnector> getNodeConnectorId(String interfaceName) {
47 InstanceIdentifier<Interface> id = InstanceIdentifier.builder(Interfaces.class)
48 .child(Interface.class, new InterfaceKey(interfaceName)).build();
50 Optional<Interface> port = read(LogicalDatastoreType.CONFIGURATION, id);
51 if(port.isPresent()) {
52 NodeConnectorId ncId = getNodeConnectorIdFromInterface(interfaceName);
53 NodeId nodeId = getNodeIdFromNodeConnectorId(ncId);
55 InstanceIdentifier<NodeConnector> ncIdentifier =
56 InstanceIdentifier.builder(Nodes.class)
57 .child(Node.class, new NodeKey(nodeId))
58 .child(NodeConnector.class, new NodeConnectorKey(ncId)).build();
64 private NodeConnectorId getNodeConnectorIdFromInterface(String interfaceName) {
65 GetNodeconnectorIdFromInterfaceInput input = new GetNodeconnectorIdFromInterfaceInputBuilder().setIntfName(interfaceName).build();
66 Future<RpcResult<GetNodeconnectorIdFromInterfaceOutput>> output = serviceProvider.getInterfaceManager().getNodeconnectorIdFromInterface(input);
67 RpcResult<GetNodeconnectorIdFromInterfaceOutput> result = null;
69 result = output.get();
70 if(result.isSuccessful()) {
71 GetNodeconnectorIdFromInterfaceOutput ncIdOutput = result.getResult();
72 return ncIdOutput.getNodeconnectorId();
74 } catch(ExecutionException | InterruptedException e) {
75 //TODO: Handle exception
81 private NodeId getNodeIdFromNodeConnectorId(NodeConnectorId ncId) {
82 return new NodeId(ncId.getValue().substring(0,ncId.getValue().lastIndexOf(":")));
85 protected org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface getInterfaceFromOperDS(String interfaceName){
86 InstanceIdentifier.InstanceIdentifierBuilder<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> idBuilder =
87 InstanceIdentifier.builder(InterfacesState.class).child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.class,
88 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey(interfaceName));
89 InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> id = idBuilder.build();
90 Optional<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface> interfaceStateOptional = read(LogicalDatastoreType.OPERATIONAL, id);
91 if(interfaceStateOptional.isPresent()) {
92 return interfaceStateOptional.get();
97 protected byte[] getMacAddress(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface interfaceState, String interfaceName) {
98 String macAddress = interfaceState.getPhysAddress().getValue();
99 if(!Strings.isNullOrEmpty(macAddress)) {
100 return AlivenessMonitorUtil.parseMacAddress(macAddress);
105 private InstanceIdentifier<Interface> getInterfaceIdentifier(InterfaceKey interfaceKey) {
106 InstanceIdentifier.InstanceIdentifierBuilder<Interface> interfaceInstanceIdentifierBuilder =
107 InstanceIdentifier.builder(Interfaces.class).child(Interface.class, interfaceKey);
108 return interfaceInstanceIdentifierBuilder.build();
111 protected Interface getInterfaceFromConfigDS(String interfaceName) {
112 InterfaceKey interfaceKey = new InterfaceKey(interfaceName);
113 InstanceIdentifier<Interface> interfaceId = getInterfaceIdentifier(interfaceKey);
114 Optional<Interface> interfaceOptional = read(LogicalDatastoreType.CONFIGURATION, interfaceId);
115 if (!interfaceOptional.isPresent()) {
119 return interfaceOptional.get();
123 private <T extends DataObject> Optional<T> read(LogicalDatastoreType datastoreType,
124 InstanceIdentifier<T> path) {
126 ReadOnlyTransaction tx = serviceProvider.getDataBroker().newReadOnlyTransaction();
128 Optional<T> result = Optional.absent();
130 result = tx.read(datastoreType, path).get();
131 } catch (Exception e) {
132 throw new RuntimeException(e);