2 * Copyright (c) 2016, 2017 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.genius.interfacemanager.renderer.ovs.confighelpers;
10 import static org.opendaylight.genius.infra.Datastore.OPERATIONAL;
12 import com.google.common.util.concurrent.ListenableFuture;
13 import java.util.ArrayList;
14 import java.util.List;
15 import java.util.Objects;
16 import javax.inject.Inject;
17 import javax.inject.Singleton;
18 import org.apache.aries.blueprint.annotation.service.Reference;
19 import org.opendaylight.genius.infra.ManagedNewTransactionRunner;
20 import org.opendaylight.genius.infra.ManagedNewTransactionRunnerImpl;
21 import org.opendaylight.genius.interfacemanager.IfmUtil;
22 import org.opendaylight.genius.interfacemanager.commons.InterfaceManagerCommonUtils;
23 import org.opendaylight.genius.interfacemanager.commons.InterfaceMetaUtils;
24 import org.opendaylight.mdsal.binding.api.DataBroker;
25 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
26 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.OperStatus;
27 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceBuilder;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.meta.rev160406._interface.child.info.InterfaceParentEntryKey;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.meta.rev160406._interface.child.info._interface.parent.entry.InterfaceChildEntry;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.meta.rev160406._interface.child.info._interface.parent.entry.InterfaceChildEntryKey;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfL2vlan;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.ParentRefs;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId;
34 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
35 import org.slf4j.Logger;
36 import org.slf4j.LoggerFactory;
39 public class OvsVlanMemberConfigUpdateHelper {
40 private static final Logger LOG = LoggerFactory.getLogger(OvsVlanMemberConfigUpdateHelper.class);
41 private static final Logger EVENT_LOGGER = LoggerFactory.getLogger("GeniusEventLogger");
43 private final ManagedNewTransactionRunner txRunner;
44 private final InterfaceManagerCommonUtils interfaceManagerCommonUtils;
45 private final OvsVlanMemberConfigAddHelper ovsVlanMemberConfigAddHelper;
46 private final OvsVlanMemberConfigRemoveHelper ovsVlanMemberConfigRemoveHelper;
47 private final InterfaceMetaUtils interfaceMetaUtils;
50 public OvsVlanMemberConfigUpdateHelper(@Reference DataBroker dataBroker,
51 InterfaceManagerCommonUtils interfaceManagerCommonUtils,
52 OvsVlanMemberConfigAddHelper ovsVlanMemberConfigAddHelper,
53 OvsVlanMemberConfigRemoveHelper ovsVlanMemberConfigRemoveHelper,
54 InterfaceMetaUtils interfaceMetaUtils) {
55 this.txRunner = new ManagedNewTransactionRunnerImpl(dataBroker);
56 this.interfaceManagerCommonUtils = interfaceManagerCommonUtils;
57 this.ovsVlanMemberConfigAddHelper = ovsVlanMemberConfigAddHelper;
58 this.ovsVlanMemberConfigRemoveHelper = ovsVlanMemberConfigRemoveHelper;
59 this.interfaceMetaUtils = interfaceMetaUtils;
62 public List<ListenableFuture<Void>> updateConfiguration(ParentRefs parentRefsNew, Interface interfaceOld,
63 IfL2vlan ifL2vlanNew, Interface interfaceNew) {
64 LOG.info("updating interface configuration for vlan memeber {} with parent-interface {}", interfaceNew
65 .getName(), parentRefsNew.getParentInterface());
66 EVENT_LOGGER.debug("IFM-OVSVlanMemberConfig,UPDATE Parent {},Child {}", parentRefsNew.getParentInterface(),
67 interfaceNew.getName());
68 List<ListenableFuture<Void>> futures = new ArrayList<>();
69 ParentRefs parentRefsOld = interfaceOld.augmentation(ParentRefs.class);
71 InterfaceParentEntryKey interfaceParentEntryKey = new InterfaceParentEntryKey(
72 parentRefsOld.getParentInterface());
73 InterfaceChildEntryKey interfaceChildEntryKey = new InterfaceChildEntryKey(interfaceOld.getName());
74 InterfaceChildEntry interfaceChildEntry = interfaceMetaUtils
75 .getInterfaceChildEntryFromConfigDS(interfaceParentEntryKey, interfaceChildEntryKey);
77 if (interfaceChildEntry == null) {
78 futures.addAll(ovsVlanMemberConfigAddHelper.addConfiguration(interfaceNew.augmentation(ParentRefs.class),
83 IfL2vlan ifL2vlanOld = interfaceOld.augmentation(IfL2vlan.class);
84 if (ifL2vlanOld == null || ifL2vlanNew.getL2vlanMode() != ifL2vlanOld.getL2vlanMode()) {
85 LOG.error("Configuration Error. Vlan Mode Change of Vlan Trunk Member {} as new trunk member: {} is "
86 + "not allowed.", interfaceOld, interfaceNew);
90 if (vlanIdModified(ifL2vlanOld.getVlanId(), ifL2vlanNew.getVlanId())
91 || !Objects.equals(parentRefsOld.getParentInterface(), parentRefsNew.getParentInterface())) {
92 LOG.info("vlan-id modified for interface {}", interfaceNew.getName());
93 futures.addAll(ovsVlanMemberConfigRemoveHelper.removeConfiguration(parentRefsOld, interfaceOld));
94 futures.addAll(ovsVlanMemberConfigAddHelper.addConfiguration(parentRefsNew, interfaceNew));
98 if (Objects.equals(interfaceNew.isEnabled(), interfaceOld.isEnabled())) {
102 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
103 .interfaces.rev140508.interfaces.state.Interface pifState = interfaceManagerCommonUtils.getInterfaceState(
104 parentRefsNew.getParentInterface());
105 if (pifState != null) {
106 OperStatus operStatus = interfaceNew.isEnabled() ? pifState.getOperStatus() : OperStatus.Down;
107 LOG.info("admin-state modified for interface {}", interfaceNew.getName());
108 futures.add(txRunner.callWithNewWriteOnlyTransactionAndSubmit(OPERATIONAL, tx -> {
109 InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces
110 .rev140508.interfaces.state.Interface>
111 ifStateId = IfmUtil.buildStateInterfaceId(interfaceNew.getName());
112 InterfaceBuilder ifaceBuilder = new InterfaceBuilder();
113 ifaceBuilder.setOperStatus(operStatus);
114 ifaceBuilder.withKey(IfmUtil.getStateInterfaceKeyFromName(interfaceNew.getName()));
116 tx.merge(ifStateId, ifaceBuilder.build());
123 public static boolean vlanIdModified(VlanId vlanIdOld, VlanId vlanIdNew) {
124 return !Objects.equals(vlanIdOld, vlanIdNew);