2 * Copyright (c) 2016 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
9 package org.opendaylight.groupbasedpolicy.renderer.vpp.policy;
11 import java.util.Arrays;
12 import java.util.Collection;
13 import java.util.List;
15 import org.junit.Assert;
16 import org.junit.Before;
17 import org.junit.Test;
18 import org.junit.runner.RunWith;
19 import org.mockito.Mockito;
20 import org.mockito.runners.MockitoJUnitRunner;
21 import org.opendaylight.controller.config.yang.config.vpp_provider.impl.VppRenderer;
22 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
23 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
24 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
25 import org.opendaylight.groupbasedpolicy.renderer.vpp.api.BridgeDomainManager;
26 import org.opendaylight.groupbasedpolicy.renderer.vpp.event.RendererPolicyConfEvent;
27 import org.opendaylight.groupbasedpolicy.renderer.vpp.event.VppEndpointConfEvent;
28 import org.opendaylight.groupbasedpolicy.renderer.vpp.iface.InterfaceManager;
29 import org.opendaylight.groupbasedpolicy.renderer.vpp.iface.VppEndpointLocationProvider;
30 import org.opendaylight.groupbasedpolicy.renderer.vpp.iface.VppPathMapper;
31 import org.opendaylight.groupbasedpolicy.renderer.vpp.manager.BridgeDomainManagerImpl;
32 import org.opendaylight.groupbasedpolicy.renderer.vpp.util.KeyFactory;
33 import org.opendaylight.groupbasedpolicy.renderer.vpp.util.MountedDataBrokerProvider;
34 import org.opendaylight.groupbasedpolicy.test.CustomDataBrokerTest;
35 import org.opendaylight.groupbasedpolicy.util.IidFactory;
36 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
37 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.common.endpoint.fields.NetworkContainment;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.common.endpoint.fields.NetworkContainmentBuilder;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.common.endpoint.fields.network.containment.containment.ForwardingContextContainmentBuilder;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.AbsoluteLocation;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.AbsoluteLocationBuilder;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.absolute.location.location.type.ExternalLocationCaseBuilder;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ContextId;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ContractId;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.RuleName;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.SubjectName;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.TenantId;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint_location_provider.rev160419.LocationProviders;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint_location_provider.rev160419.location.providers.LocationProvider;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint_location_provider.rev160419.location.providers.location.provider.ProviderAddressEndpointLocation;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.L2FloodDomain;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.rev160427.AddressType;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.rev160427.ContextType;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.EndpointPolicyParticipation;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.has.rule.group.with.renderer.endpoint.participation.RuleGroupWithRendererEndpointParticipation;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.has.rule.group.with.renderer.endpoint.participation.RuleGroupWithRendererEndpointParticipationBuilder;
59 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.RendererPolicy;
60 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.RendererPolicyBuilder;
61 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.Configuration;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.ConfigurationBuilder;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.Endpoints;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.EndpointsBuilder;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.RendererEndpointsBuilder;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.RuleGroupsBuilder;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocation;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocationBuilder;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocationKey;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.RendererEndpoint;
71 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.RendererEndpointBuilder;
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.renderer.endpoint.PeerEndpointWithPolicyBuilder;
73 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.rule.groups.RuleGroup;
74 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.rule.groups.RuleGroupBuilder;
75 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.resolved.rules.ResolvedRuleBuilder;
76 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.vpp_renderer.rev160425.Config;
77 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.vpp_renderer.rev160425.config.VppEndpoint;
78 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.vpp_renderer.rev160425.config.VppEndpointBuilder;
79 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.vpp_renderer.rev160425.config.VppEndpointKey;
80 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.vpp_renderer.rev160425.config.vpp.endpoint._interface.type.choice.VhostUserCaseBuilder;
81 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceAugmentation;
82 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VxlanVni;
83 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.Interconnection;
84 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.interconnection.BridgeBased;
85 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.vpp.BridgeDomains;
86 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.topology.rev160129.TopologyVbridgeAugment;
87 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vbridge.tunnel.vxlan.rev160429.TunnelTypeVxlan;
88 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
89 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
90 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
91 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
92 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
93 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
94 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
95 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
97 import com.google.common.base.Optional;
98 import com.google.common.util.concurrent.MoreExecutors;
100 @RunWith(MockitoJUnitRunner.class)
101 public class VppRendererPolicyManagerTest extends CustomDataBrokerTest {
103 private static final InstanceIdentifier<RendererPolicy> RENDERER_POLICY_IID =
104 IidFactory.rendererIid(VppRenderer.NAME).child(RendererPolicy.class);
105 private static final ContextId CTX_ID = new ContextId("ctx");
106 private static final AddressEndpointWithLocationKey CLIENT_EP_KEY =
107 new AddressEndpointWithLocationKey("1.1.1.1", AddressType.class, CTX_ID, ContextType.class);
108 private static final AddressEndpointWithLocationKey WEB_EP_KEY =
109 new AddressEndpointWithLocationKey("2.2.2.2", AddressType.class, CTX_ID, ContextType.class);
110 private static final ContextId L2FD_CTX = new ContextId("l2fd");
111 private static final NetworkContainment L2FD_NET_CONT =
112 new NetworkContainmentBuilder().setContainment(new ForwardingContextContainmentBuilder()
113 .setContextType(L2FloodDomain.class).setContextId(L2FD_CTX).build()).build();
114 private final static TopologyKey TOPO_KEY = new TopologyKey(new TopologyId("topo1"));
115 private final static NodeKey NODE_KEY = new NodeKey(new NodeId("node1"));
116 private final static InstanceIdentifier<Node> VPP_NODE_IID = InstanceIdentifier.builder(NetworkTopology.class)
117 .child(Topology.class, TOPO_KEY)
118 .child(Node.class, NODE_KEY)
120 private static final String IFACE_NAME_CLIENT_EP = "interfaceClient";
121 private static final String NODE_CONNECTOR_CLIENT_EP = VppPathMapper.interfaceToRestPath(IFACE_NAME_CLIENT_EP);
122 private static final String IFACE_NAME_WEB_EP = "interfaceWeb";
123 private static final String NODE_CONNECTOR_WEB_EP = VppPathMapper.interfaceToRestPath(IFACE_NAME_WEB_EP);
124 private static final ContractId CONTRACT_ID = new ContractId("contract");
125 private static final TenantId TENANT_ID = new TenantId("tenant");
126 private static final SubjectName SUBJECT_NAME = new SubjectName("subject");
127 private static final RuleName RULE_NAME = new RuleName("rule");
128 private static final RuleGroupWithRendererEndpointParticipation RULE_GROUP_WITH_REND_EP_PART =
129 new RuleGroupWithRendererEndpointParticipationBuilder().setContractId(CONTRACT_ID)
130 .setTenantId(TENANT_ID)
131 .setSubjectName(SUBJECT_NAME)
132 .setRendererEndpointParticipation(EndpointPolicyParticipation.CONSUMER)
134 private static final RuleGroup RULE_GROUP = new RuleGroupBuilder().setContractId(CONTRACT_ID)
135 .setTenantId(TENANT_ID)
136 .setSubjectName(SUBJECT_NAME)
137 .setResolvedRule(Arrays.asList(new ResolvedRuleBuilder().setName(RULE_NAME).build()))
139 // data for InterfaceManager
140 private final static InstanceIdentifier<VppEndpoint> BASIC_VPP_CLIENT_EP_IID =
141 InstanceIdentifier.builder(Config.class)
142 .child(VppEndpoint.class, new VppEndpointKey(CLIENT_EP_KEY.getAddress(), CLIENT_EP_KEY.getAddressType(),
143 CLIENT_EP_KEY.getContextId(), CLIENT_EP_KEY.getContextType()))
145 private final static InstanceIdentifier<VppEndpoint> BASIC_VPP_WEB_EP_IID = InstanceIdentifier.builder(Config.class)
146 .child(VppEndpoint.class, new VppEndpointKey(WEB_EP_KEY.getAddress(), WEB_EP_KEY.getAddressType(),
147 WEB_EP_KEY.getContextId(), WEB_EP_KEY.getContextType()))
149 private final static String SOCKET = "socket";
151 private MountedDataBrokerProvider mountedDataProviderMock;
152 private DataBroker mountPointDataBroker;
153 private DataBroker dataBroker;
155 private BridgeDomainManager bdManager;
156 private InterfaceManager ifaceManager;
157 private ForwardingManager fwManager;
158 private VppRendererPolicyManager vppRendererPolicyManager;
161 public Collection<Class<?>> getClassesFromModules() {
162 return Arrays.asList(Node.class, VppEndpoint.class, Interfaces.class, BridgeDomains.class,
163 LocationProviders.class, L2FloodDomain.class, VxlanVni.class, TopologyVbridgeAugment.class,
164 TunnelTypeVxlan.class);
168 public void init() throws Exception {
169 mountedDataProviderMock = Mockito.mock(MountedDataBrokerProvider.class);
170 mountPointDataBroker = getDataBroker();
171 setup(); // initialize new data broker for ODL data store
172 dataBroker = getDataBroker();
173 Mockito.when(mountedDataProviderMock.getDataBrokerForMountPoint(Mockito.any(InstanceIdentifier.class)))
174 .thenReturn(Optional.of(mountPointDataBroker));
175 ifaceManager = new InterfaceManager(mountedDataProviderMock, dataBroker, MoreExecutors.newDirectExecutorService());
176 bdManager = new BridgeDomainManagerImpl(mountPointDataBroker);
177 fwManager = new ForwardingManager(ifaceManager, bdManager);
178 vppRendererPolicyManager = new VppRendererPolicyManager(fwManager, dataBroker);
182 public void testRendererPolicyChanged_createdClient() throws Exception {
183 storeInterfaceFor(CLIENT_EP_KEY, IFACE_NAME_CLIENT_EP, BASIC_VPP_CLIENT_EP_IID);
185 AddressEndpointWithLocation clientEp = new AddressEndpointWithLocationBuilder().setKey(CLIENT_EP_KEY)
186 .setNetworkContainment(L2FD_NET_CONT)
187 .setAbsoluteLocation(absoluteLocation(VPP_NODE_IID, null, NODE_CONNECTOR_CLIENT_EP))
189 AddressEndpointWithLocation webEp = new AddressEndpointWithLocationBuilder().setKey(WEB_EP_KEY)
190 .setNetworkContainment(L2FD_NET_CONT)
191 .setAbsoluteLocation(absoluteLocation(VPP_NODE_IID, null, NODE_CONNECTOR_WEB_EP))
193 Endpoints endpoints =
194 new EndpointsBuilder().setAddressEndpointWithLocation(Arrays.asList(clientEp, webEp)).build();
195 RendererEndpoint rendererEndpoint = new RendererEndpointBuilder()
196 .setKey(KeyFactory.rendererEndpointKey(CLIENT_EP_KEY))
197 .setPeerEndpointWithPolicy(Arrays.asList(new PeerEndpointWithPolicyBuilder()
198 .setKey(KeyFactory.peerEndpointWithPolicyKey(WEB_EP_KEY))
199 .setRuleGroupWithRendererEndpointParticipation(Arrays.asList(RULE_GROUP_WITH_REND_EP_PART))
202 Configuration configuration = new ConfigurationBuilder().setEndpoints(endpoints)
203 .setRendererEndpoints(
204 new RendererEndpointsBuilder().setRendererEndpoint(Arrays.asList(rendererEndpoint)).build())
205 .setRuleGroups(new RuleGroupsBuilder().setRuleGroup(Arrays.asList(RULE_GROUP)).build())
207 RendererPolicy rendererPolicy =
208 new RendererPolicyBuilder().setVersion(1L).setConfiguration(configuration).build();
209 RendererPolicyConfEvent event = new RendererPolicyConfEvent(RENDERER_POLICY_IID, null, rendererPolicy);
211 vppRendererPolicyManager.rendererPolicyChanged(event);
213 // assert state on data store behind mount point
214 ReadOnlyTransaction rTxMount = mountPointDataBroker.newReadOnlyTransaction();
215 Optional<Interface> potentialIface = rTxMount.read(LogicalDatastoreType.CONFIGURATION, InstanceIdentifier
216 .builder(Interfaces.class).child(Interface.class, new InterfaceKey(IFACE_NAME_CLIENT_EP)).build()).get();
217 Assert.assertTrue(potentialIface.isPresent());
218 Interface iface = potentialIface.get();
219 VppInterfaceAugmentation vppIfaceAug = iface.getAugmentation(VppInterfaceAugmentation.class);
220 Assert.assertNotNull(vppIfaceAug);
221 Interconnection interconnection = vppIfaceAug.getL2().getInterconnection();
222 Assert.assertNotNull(interconnection);
223 Assert.assertTrue(interconnection instanceof BridgeBased);
224 Assert.assertEquals(L2FD_CTX.getValue(), ((BridgeBased) interconnection).getBridgeDomain());
225 // assert state on ODL data store
226 ReadOnlyTransaction rTx = dataBroker.newReadOnlyTransaction();
227 Optional<LocationProvider> optLocationProvider = rTx.read(LogicalDatastoreType.CONFIGURATION,
228 IidFactory.locationProviderIid(VppEndpointLocationProvider.VPP_ENDPOINT_LOCATION_PROVIDER))
230 Assert.assertTrue(optLocationProvider.isPresent());
231 List<ProviderAddressEndpointLocation> epLocs = optLocationProvider.get().getProviderAddressEndpointLocation();
232 Assert.assertNotNull(epLocs);
233 Assert.assertEquals(1, epLocs.size());
234 Assert.assertEquals(absoluteLocation(VPP_NODE_IID, VppPathMapper.bridgeDomainToRestPath(L2FD_CTX.getValue()),
235 NODE_CONNECTOR_CLIENT_EP), epLocs.get(0).getAbsoluteLocation());
239 public void testRendererPolicyChanged_createdClientAndThenWeb() throws Exception {
240 testRendererPolicyChanged_createdClient();
242 storeInterfaceFor(WEB_EP_KEY, IFACE_NAME_WEB_EP, BASIC_VPP_WEB_EP_IID);
244 AddressEndpointWithLocation webEp = new AddressEndpointWithLocationBuilder().setKey(WEB_EP_KEY)
245 .setNetworkContainment(L2FD_NET_CONT)
246 .setAbsoluteLocation(absoluteLocation(VPP_NODE_IID, null, NODE_CONNECTOR_WEB_EP))
248 AddressEndpointWithLocation clientEp = new AddressEndpointWithLocationBuilder().setKey(CLIENT_EP_KEY)
249 .setNetworkContainment(L2FD_NET_CONT)
250 .setAbsoluteLocation(absoluteLocation(VPP_NODE_IID, null, NODE_CONNECTOR_CLIENT_EP))
252 Endpoints endpoints =
253 new EndpointsBuilder().setAddressEndpointWithLocation(Arrays.asList(webEp, clientEp)).build();
254 RendererEndpoint rendererEndpoint = new RendererEndpointBuilder()
255 .setKey(KeyFactory.rendererEndpointKey(WEB_EP_KEY))
256 .setPeerEndpointWithPolicy(Arrays.asList(new PeerEndpointWithPolicyBuilder()
257 .setKey(KeyFactory.peerEndpointWithPolicyKey(CLIENT_EP_KEY))
258 .setRuleGroupWithRendererEndpointParticipation(Arrays.asList(RULE_GROUP_WITH_REND_EP_PART))
261 Configuration configuration = new ConfigurationBuilder().setEndpoints(endpoints)
262 .setRendererEndpoints(
263 new RendererEndpointsBuilder().setRendererEndpoint(Arrays.asList(rendererEndpoint)).build())
264 .setRuleGroups(new RuleGroupsBuilder().setRuleGroup(Arrays.asList(RULE_GROUP)).build())
266 RendererPolicy rendererPolicy =
267 new RendererPolicyBuilder().setVersion(1L).setConfiguration(configuration).build();
268 RendererPolicyConfEvent event = new RendererPolicyConfEvent(RENDERER_POLICY_IID, null, rendererPolicy);
270 vppRendererPolicyManager.rendererPolicyChanged(event);
272 // assert state on data store behind mount point
273 ReadOnlyTransaction rTxMount = mountPointDataBroker.newReadOnlyTransaction();
274 Optional<Interface> potentialIface = rTxMount.read(LogicalDatastoreType.CONFIGURATION, InstanceIdentifier
275 .builder(Interfaces.class).child(Interface.class, new InterfaceKey(IFACE_NAME_WEB_EP)).build()).get();
276 Assert.assertTrue(potentialIface.isPresent());
277 Interface iface = potentialIface.get();
278 VppInterfaceAugmentation vppIfaceAug = iface.getAugmentation(VppInterfaceAugmentation.class);
279 Assert.assertNotNull(vppIfaceAug);
280 Interconnection interconnection = vppIfaceAug.getL2().getInterconnection();
281 Assert.assertNotNull(interconnection);
282 Assert.assertTrue(interconnection instanceof BridgeBased);
283 Assert.assertEquals(L2FD_CTX.getValue(), ((BridgeBased) interconnection).getBridgeDomain());
284 // assert state on ODL data store
285 ReadOnlyTransaction rTx = dataBroker.newReadOnlyTransaction();
286 Optional<LocationProvider> optLocationProvider = rTx.read(LogicalDatastoreType.CONFIGURATION,
287 IidFactory.locationProviderIid(VppEndpointLocationProvider.VPP_ENDPOINT_LOCATION_PROVIDER))
289 Assert.assertTrue(optLocationProvider.isPresent());
290 List<ProviderAddressEndpointLocation> epLocs = optLocationProvider.get().getProviderAddressEndpointLocation();
291 Assert.assertNotNull(epLocs);
292 Assert.assertEquals(2, epLocs.size());
293 if (epLocs.get(0).getAddress().equals(CLIENT_EP_KEY.getAddress())) {
294 Assert.assertEquals(absoluteLocation(VPP_NODE_IID,
295 VppPathMapper.bridgeDomainToRestPath(L2FD_CTX.getValue()), NODE_CONNECTOR_CLIENT_EP),
296 epLocs.get(0).getAbsoluteLocation());
297 Assert.assertEquals(absoluteLocation(VPP_NODE_IID,
298 VppPathMapper.bridgeDomainToRestPath(L2FD_CTX.getValue()), NODE_CONNECTOR_WEB_EP),
299 epLocs.get(1).getAbsoluteLocation());
301 Assert.assertEquals(absoluteLocation(VPP_NODE_IID,
302 VppPathMapper.bridgeDomainToRestPath(L2FD_CTX.getValue()), NODE_CONNECTOR_CLIENT_EP),
303 epLocs.get(1).getAbsoluteLocation());
304 Assert.assertEquals(absoluteLocation(VPP_NODE_IID,
305 VppPathMapper.bridgeDomainToRestPath(L2FD_CTX.getValue()), NODE_CONNECTOR_WEB_EP),
306 epLocs.get(0).getAbsoluteLocation());
310 private void storeInterfaceFor(AddressEndpointWithLocationKey epKey, String ifaceName,
311 InstanceIdentifier<VppEndpoint> vppEpIid) {
312 VppEndpoint vhostEp = new VppEndpointBuilder().setAddress(epKey.getAddress())
313 .setAddressType(epKey.getAddressType())
314 .setContextId(epKey.getContextId())
315 .setContextType(epKey.getContextType())
316 .setVppInterfaceName(ifaceName)
317 .setVppNodePath(VPP_NODE_IID)
318 .setInterfaceTypeChoice(new VhostUserCaseBuilder().setSocket(SOCKET).build())
320 VppEndpointConfEvent vppEpEvent = new VppEndpointConfEvent(vppEpIid, null, vhostEp);
321 ifaceManager.vppEndpointChanged(vppEpEvent);
324 private static AbsoluteLocation absoluteLocation(InstanceIdentifier<?> mountPoint, String node,
325 String nodeConnector) {
326 return new AbsoluteLocationBuilder()
327 .setLocationType(new ExternalLocationCaseBuilder().setExternalNodeMountPoint(mountPoint)
328 .setExternalNode(node)
329 .setExternalNodeConnector(nodeConnector)