openflowplugin-impl/src/test/java/org/opendaylight/openflowplugin/impl/device/listener/OpenflowProtocolListenerFullImplTest.java

   1 /**
   2  * Copyright (c) 2015 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.impl.device.listener;
  10
  11 import org.junit.After;
  12 import org.junit.Before;
  13 import org.junit.Test;
  14 import org.junit.runner.RunWith;
  15 import org.mockito.Matchers;
  16 import org.mockito.Mock;
  17 import org.mockito.Mockito;
  18 import org.mockito.runners.MockitoJUnitRunner;
  19 import org.opendaylight.openflowjava.protocol.api.connection.ConnectionAdapter;
  20 import org.opendaylight.openflowplugin.api.OFConstants;
  21 import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceReplyProcessor;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoReplyInput;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoRequestMessage;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoRequestMessageBuilder;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessageBuilder;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ExperimenterMessage;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ExperimenterMessageBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowRemovedMessage;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowRemovedMessageBuilder;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloMessage;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloMessageBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OpenflowProtocolListener;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessage;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessageBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessage;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessageBuilder;
  38
  39 /**
  40  * openflowplugin-impl
  41  * org.opendaylight.openflowplugin.impl.connection.listener
  42  * <p/>
  43  * test of {@link OpenflowProtocolListenerFullImpl} - lightweight version, using basic ways (TDD)
  44  *
  45  * @author <a href="mailto:vdemcak@cisco.com">Vaclav Demcak</a>
  46  *         <p/>
  47  *         Created: Mar 26, 2015
  48  */
  49 @RunWith(MockitoJUnitRunner.class)
  50 public class OpenflowProtocolListenerFullImplTest {
  51
  52     private OpenflowProtocolListenerFullImpl ofProtocolListener;
  53
  54     @Mock
  55     private DeviceReplyProcessor deviceReplyProcessor;
  56     @Mock
  57     private ConnectionAdapter connectionAdapter;
  58
  59     private final long xid = 42L;
  60
  61     @Before
  62     public void setUp() {
  63         // place for mocking method's general behavior for HandshakeContext and ConnectionContext
  64         ofProtocolListener = new OpenflowProtocolListenerFullImpl(connectionAdapter, deviceReplyProcessor);
  65         connectionAdapter.setMessageListener(ofProtocolListener);
  66         Mockito.verify(connectionAdapter).setMessageListener(Matchers.any(OpenflowProtocolListener.class));
  67     }
  68
  69     @After
  70     public void tearDown() {
  71         Mockito.verifyNoMoreInteractions(connectionAdapter, deviceReplyProcessor);
  72     }
  73
  74     /**
  75      * Test method for {@link OpenflowProtocolListenerFullImpl#onEchoRequestMessage(org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoRequestMessage)}.
  76      */
  77     @Test
  78     public void testOnEchoRequestMessage() {
  79         EchoRequestMessage echoRequestMessage = new EchoRequestMessageBuilder()
  80                 .setVersion(OFConstants.OFP_VERSION_1_3).setXid(xid).build();
  81         ofProtocolListener.onEchoRequestMessage(echoRequestMessage);
  82
  83         Mockito.verify(connectionAdapter).echoReply(Matchers.any(EchoReplyInput.class));
  84     }
  85
  86     /**
  87      * Test method for {@link OpenflowProtocolListenerFullImpl#onErrorMessage(org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage)}.
  88      */
  89     @Test
  90     public void testOnErrorMessage() {
  91         ErrorMessage errorMessage = new ErrorMessageBuilder()
  92                 .setVersion(OFConstants.OFP_VERSION_1_3).setXid(xid).build();
  93         ofProtocolListener.onErrorMessage(errorMessage);
  94
  95         Mockito.verify(deviceReplyProcessor).processReply(Matchers.any(ErrorMessage.class));
  96     }
  97
  98     /**
  99      * Test method for {@link OpenflowProtocolListenerFullImpl#onExperimenterMessage(org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ExperimenterMessage)}.
 100      */
 101     @Test
 102     public void testOnExperimenterMessage() {
 103         ExperimenterMessage experimenterMessage = new ExperimenterMessageBuilder()
 104                 .setVersion(OFConstants.OFP_VERSION_1_3).setXid(xid).build();
 105         ofProtocolListener.onExperimenterMessage(experimenterMessage);
 106         // NOOP
 107     }
 108
 109     /**
 110      * Test method for {@link OpenflowProtocolListenerFullImpl#onFlowRemovedMessage(org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowRemovedMessage)}.
 111      */
 112     @Test
 113     public void testOnFlowRemovedMessage() {
 114         FlowRemovedMessage flowRemovedMessage = new FlowRemovedMessageBuilder()
 115                 .setVersion(OFConstants.OFP_VERSION_1_3).setXid(xid).build();
 116         ofProtocolListener.onFlowRemovedMessage(flowRemovedMessage);
 117
 118         Mockito.verify(deviceReplyProcessor).processFlowRemovedMessage(Matchers.any(FlowRemovedMessage.class));
 119     }
 120
 121     /**
 122      * Test method for {@link OpenflowProtocolListenerFullImpl#onHelloMessage(org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloMessage)}.
 123      */
 124     @Test
 125     public void testOnHelloMessage() {
 126         HelloMessage helloMessage = new HelloMessageBuilder()
 127                 .setVersion(OFConstants.OFP_VERSION_1_3).setXid(xid).build();
 128         ofProtocolListener.onHelloMessage(helloMessage);
 129         // NOOP
 130     }
 131
 132     /**
 133      * Test method for {@link OpenflowProtocolListenerFullImpl#onPacketInMessage(org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessage)}.
 134      */
 135     @Test
 136     public void testOnPacketInMessage() {
 137         PacketInMessage packetInMessage = new PacketInMessageBuilder()
 138                 .setVersion(OFConstants.OFP_VERSION_1_3).setXid(xid).build();
 139         ofProtocolListener.onPacketInMessage(packetInMessage);
 140
 141         Mockito.verify(deviceReplyProcessor).processPacketInMessage(Matchers.any(PacketInMessage.class));
 142     }
 143
 144     /**
 145      * Test method for {@link OpenflowProtocolListenerFullImpl#onPortStatusMessage(org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessage)}.
 146      */
 147     @Test
 148     public void testOnPortStatusMessage() {
 149         PortStatusMessage portStatusMessage = new PortStatusMessageBuilder()
 150                 .setVersion(OFConstants.OFP_VERSION_1_3).setXid(xid).build();
 151         ofProtocolListener.onPortStatusMessage(portStatusMessage);
 152
 153         Mockito.verify(deviceReplyProcessor).processPortStatusMessage(Matchers.any(PortStatusMessage.class));
 154     }
 155
 156 }