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 package org.opendaylight.openflowplugin.impl.device.listener;
   9
  10 import static org.mockito.ArgumentMatchers.any;
  11 import static org.mockito.Mockito.verify;
  12 import static org.mockito.Mockito.verifyNoMoreInteractions;
  13 import static org.mockito.Mockito.when;
  14
  15 import com.google.common.util.concurrent.Futures;
  16 import java.net.InetSocketAddress;
  17 import org.junit.After;
  18 import org.junit.Before;
  19 import org.junit.Test;
  20 import org.junit.runner.RunWith;
  21 import org.mockito.Mock;
  22 import org.mockito.junit.MockitoJUnitRunner;
  23 import org.opendaylight.openflowjava.protocol.api.connection.ConnectionAdapter;
  24 import org.opendaylight.openflowjava.protocol.api.util.EncodeConstants;
  25 import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceReplyProcessor;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoReplyInput;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoRequestMessageBuilder;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessageBuilder;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ExperimenterMessage;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ExperimenterMessageBuilder;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowRemovedMessage;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowRemovedMessageBuilder;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloMessage;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloMessageBuilder;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.OpenflowProtocolListener;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessage;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessageBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessage;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessageBuilder;
  41 import org.opendaylight.yangtools.yang.common.Uint32;
  42
  43 /**
  44  * openflowplugin-impl
  45  * org.opendaylight.openflowplugin.impl.connection.listener
  46  * test of {@link OpenflowProtocolListenerFullImpl} - lightweight version, using basic ways (TDD).
  47  *
  48  * @author Vaclav Demcak
  49  */
  50 @RunWith(MockitoJUnitRunner.class)
  51 public class OpenflowProtocolListenerFullImplTest {
  52     @Mock
  53     private DeviceReplyProcessor deviceReplyProcessor;
  54     @Mock
  55     private ConnectionAdapter connectionAdapter;
  56
  57     private final Uint32 xid = Uint32.valueOf(42);
  58
  59     private OpenflowProtocolListenerFullImpl ofProtocolListener;
  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         when(connectionAdapter.getRemoteAddress())
  67                 .thenReturn(InetSocketAddress.createUnresolved("ofp-junit.example.org", 6663));
  68         verify(connectionAdapter).setMessageListener(any(OpenflowProtocolListener.class));
  69     }
  70
  71     @After
  72     public void tearDown() {
  73         verifyNoMoreInteractions(connectionAdapter, deviceReplyProcessor);
  74     }
  75
  76     /**
  77      * Test method for
  78      * {@link OpenflowProtocolListenerFullImpl#onEchoRequestMessage(
  79      * org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.EchoRequestMessage)}.
  80      */
  81     @Test
  82     public void testOnEchoRequestMessage() {
  83         when(connectionAdapter.echoReply(any())).thenReturn(Futures.immediateFuture(null));
  84         ofProtocolListener.onEchoRequestMessage(
  85             new EchoRequestMessageBuilder().setVersion(EncodeConstants.OF_VERSION_1_3).setXid(xid).build());
  86
  87         verify(connectionAdapter).echoReply(any(EchoReplyInput.class));
  88     }
  89
  90     /**
  91      * Test method for
  92      * {@link OpenflowProtocolListenerFullImpl#onErrorMessage(
  93      * org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ErrorMessage)}.
  94      */
  95     @Test
  96     public void testOnErrorMessage() {
  97         ErrorMessage errorMessage = new ErrorMessageBuilder()
  98                 .setVersion(EncodeConstants.OF_VERSION_1_3).setXid(xid).build();
  99         ofProtocolListener.onErrorMessage(errorMessage);
 100
 101         verify(deviceReplyProcessor).processReply(any(ErrorMessage.class));
 102     }
 103
 104     /**
 105      * Test method for
 106      * {@link OpenflowProtocolListenerFullImpl#onExperimenterMessage(
 107      * org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.ExperimenterMessage)}.
 108      */
 109     @Test
 110     public void testOnExperimenterMessage() {
 111         ExperimenterMessage experimenterMessage = new ExperimenterMessageBuilder()
 112                 .setVersion(EncodeConstants.OF_VERSION_1_3).setXid(xid).build();
 113         ofProtocolListener.onExperimenterMessage(experimenterMessage);
 114
 115         verify(deviceReplyProcessor).processExperimenterMessage(any());
 116     }
 117
 118     /**
 119      * Test method for
 120      * {@link OpenflowProtocolListenerFullImpl#onFlowRemovedMessage(
 121      * org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.FlowRemovedMessage)}.
 122      */
 123     @Test
 124     public void testOnFlowRemovedMessage() {
 125         FlowRemovedMessage flowRemovedMessage = new FlowRemovedMessageBuilder()
 126                 .setVersion(EncodeConstants.OF_VERSION_1_3).setXid(xid).build();
 127         ofProtocolListener.onFlowRemovedMessage(flowRemovedMessage);
 128
 129         verify(deviceReplyProcessor).processFlowRemovedMessage(any(FlowRemovedMessage.class));
 130     }
 131
 132     /**
 133      * Test method for
 134      * {@link OpenflowProtocolListenerFullImpl#onHelloMessage(
 135      * org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.HelloMessage)}.
 136      */
 137     @Test
 138     public void testOnHelloMessage() {
 139         HelloMessage helloMessage = new HelloMessageBuilder()
 140                 .setVersion(EncodeConstants.OF_VERSION_1_3).setXid(xid).build();
 141         ofProtocolListener.onHelloMessage(helloMessage);
 142
 143         verify(connectionAdapter).getRemoteAddress();
 144         verify(connectionAdapter).disconnect();
 145     }
 146
 147     /**
 148      * Test method for
 149      * {@link OpenflowProtocolListenerFullImpl#onPacketInMessage(
 150      * org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PacketInMessage)}.
 151      */
 152     @Test
 153     public void testOnPacketInMessage() {
 154         PacketInMessage packetInMessage = new PacketInMessageBuilder()
 155                 .setVersion(EncodeConstants.OF_VERSION_1_3).setXid(xid).build();
 156         ofProtocolListener.onPacketInMessage(packetInMessage);
 157
 158         verify(deviceReplyProcessor).processPacketInMessage(any(PacketInMessage.class));
 159     }
 160
 161     /**
 162      * Test method for
 163      * {@link OpenflowProtocolListenerFullImpl#onPortStatusMessage(
 164      * org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.PortStatusMessage)}.
 165      */
 166     @Test
 167     public void testOnPortStatusMessage() {
 168         PortStatusMessage portStatusMessage = new PortStatusMessageBuilder()
 169                 .setVersion(EncodeConstants.OF_VERSION_1_3).setXid(xid).build();
 170         ofProtocolListener.onPortStatusMessage(portStatusMessage);
 171
 172         verify(deviceReplyProcessor).processPortStatusMessage(any(PortStatusMessage.class));
 173     }
 174 }