openflowplugin/src/test/java/org/opendaylight/openflowplugin/openflow/md/lldp/LLDPSpeakerPopListenerTest.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8
   9 package org.opendaylight.openflowplugin.openflow.md.lldp;
  10
  11 import static org.mockito.Mockito.when;
  12
  13 import org.junit.Before;
  14 import org.junit.Test;
  15 import org.junit.runner.RunWith;
  16 import org.mockito.MockitoAnnotations;
  17 import org.mockito.runners.MockitoJUnitRunner;
  18 import org.opendaylight.openflowplugin.api.OFConstants;
  19 import org.opendaylight.openflowplugin.api.openflow.md.ModelDrivenSwitch;
  20 import org.opendaylight.openflowplugin.api.openflow.md.core.ConnectionConductor;
  21 import org.opendaylight.openflowplugin.api.openflow.md.core.session.SessionContext;
  22 import org.opendaylight.openflowplugin.openflow.md.util.OpenflowPortsUtil;
  23 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev100924.MacAddress;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdated;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdatedBuilder;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.flow.capable.port.StateBuilder;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRef;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdatedBuilder;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorKey;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  37 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  38
  39 /**
  40  * Created by Martin Bobak mbobak@cisco.com on 9/23/14.
  41  */
  42 @RunWith(MockitoJUnitRunner.class)
  43 public class LLDPSpeakerPopListenerTest {
  44
  45     @MockitoAnnotations.Mock
  46     private ModelDrivenSwitch modelDrivenSwitch;
  47     @MockitoAnnotations.Mock
  48     private SessionContext context;
  49     @MockitoAnnotations.Mock
  50     private ConnectionConductor connectionConductor;
  51
  52
  53     @Before
  54     public void setup() {
  55         when(modelDrivenSwitch.getSessionContext()).thenReturn(context);
  56         when(context.getPrimaryConductor()).thenReturn(connectionConductor);
  57         when(connectionConductor.getVersion()).thenReturn(OFConstants.OFP_VERSION_1_3);
  58         OpenflowPortsUtil.init();
  59     }
  60
  61     @Test
  62     /**
  63      * Test method which verifies registration of nodeConnector in LLDPSpeaker.
  64      */
  65     public void TestOnPop() {
  66         LLDPSpeakerPopListener lldpSpeakerPopListener = new LLDPSpeakerPopListener();
  67         NodeConnectorUpdatedBuilder nodeConnectorUpdatedBuilder = new NodeConnectorUpdatedBuilder();
  68         FlowCapableNodeConnectorUpdatedBuilder flowCapableNodeConnectorUpdatedBuilder = new FlowCapableNodeConnectorUpdatedBuilder();
  69
  70         StateBuilder stateBuilder = new StateBuilder();
  71         stateBuilder.setBlocked(false);
  72         stateBuilder.setLinkDown(false);
  73         stateBuilder.setLive(true);
  74         flowCapableNodeConnectorUpdatedBuilder.setState(stateBuilder.build());
  75
  76         flowCapableNodeConnectorUpdatedBuilder.setConfiguration(new PortConfig(true, true, true, false));
  77         flowCapableNodeConnectorUpdatedBuilder.setHardwareAddress(new MacAddress("00:00:00:00:00:00"));
  78         nodeConnectorUpdatedBuilder.addAugmentation(FlowCapableNodeConnectorUpdated.class, flowCapableNodeConnectorUpdatedBuilder.build());
  79         NodeConnectorId nodeConnectorId = new NodeConnectorId("1");
  80         nodeConnectorUpdatedBuilder.setId(nodeConnectorId);
  81         InstanceIdentifier instanceIdentifier = InstanceIdentifier.create(Nodes.class).child(Node.class, new NodeKey(new NodeId("1"))).child(NodeConnector.class, new NodeConnectorKey(nodeConnectorId));
  82         NodeConnectorRef nodeConnectorRef = new NodeConnectorRef(instanceIdentifier);
  83
  84         LLDPSpeaker.getInstance().addModelDrivenSwitch(instanceIdentifier.firstIdentifierOf(Node.class), modelDrivenSwitch);
  85
  86         nodeConnectorUpdatedBuilder.setNodeConnectorRef(nodeConnectorRef);
  87         lldpSpeakerPopListener.onPop(nodeConnectorUpdatedBuilder.build());
  88
  89     }
  90
  91 }