openflowplugin-impl/src/test/java/org/opendaylight/openflowplugin/impl/common/MultipartRequestInputFactoryTest.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.common;
   9
  10 import org.junit.Assert;
  11 import org.junit.Before;
  12 import org.junit.Test;
  13 import org.opendaylight.openflowplugin.api.OFConstants;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.OxmMatchType;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartRequestInput;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.MultipartRequestBody;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestAggregateCase;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestDescCase;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestExperimenterCase;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestFlowCase;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestGroupCase;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestGroupDescCase;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestGroupFeaturesCase;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestMeterCase;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestMeterConfigCase;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestMeterFeaturesCase;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortDescCase;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortStatsCase;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueueCase;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestTableCase;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestTableFeaturesCase;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.flow._case.MultipartRequestFlow;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.group._case.MultipartRequestGroup;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.meter._case.MultipartRequestMeter;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.meter.config._case.MultipartRequestMeterConfig;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.port.stats._case.MultipartRequestPortStats;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.queue._case.MultipartRequestQueue;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.table.features._case.MultipartRequestTableFeatures;
  40 import org.opendaylight.yangtools.yang.binding.DataContainer;
  41 import org.opendaylight.yangtools.yang.common.Uint32;
  42 import org.opendaylight.yangtools.yang.common.Uint8;
  43
  44 /**
  45  * Test for {@link MultipartRequestInputFactory}.
  46  */
  47 public class MultipartRequestInputFactoryTest {
  48
  49     private final Uint32 xid = Uint32.valueOf(42);
  50     private Uint8 ofVersion;
  51
  52     @Before
  53     public void setUp() {
  54         ofVersion = OFConstants.OFP_VERSION_1_3;
  55     }
  56
  57     @Test
  58     public void testMakeMultipartRequestInput_DESC() {
  59         MultipartType mpType = MultipartType.OFPMPDESC;
  60         final MultipartRequestInput mpRqInput =
  61             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
  62         checkHeader(mpRqInput, mpType);
  63         checkEmptyBody(mpRqInput.getMultipartRequestBody().implementedInterface(), MultipartRequestDescCase.class);
  64     }
  65
  66     @Test
  67     public void testMakeMultipartRequestInput_FLOW_13() {
  68         final MultipartType mpType = MultipartType.OFPMPFLOW;
  69         final MultipartRequestInput mpRqInput =
  70             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
  71         checkHeader(mpRqInput, mpType);
  72         final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
  73         Assert.assertTrue(mpRqBody instanceof MultipartRequestFlowCase);
  74
  75         MultipartRequestFlow mpRq = ((MultipartRequestFlowCase) mpRqBody).getMultipartRequestFlow();
  76         Assert.assertEquals(OFConstants.OFPTT_ALL, mpRq.getTableId());
  77         Assert.assertEquals(OFConstants.OFPP_ANY, mpRq.getOutPort());
  78         Assert.assertEquals(OFConstants.OFPG_ANY, mpRq.getOutGroup());
  79         Assert.assertEquals(0, mpRq.getCookie().intValue());
  80         Assert.assertEquals(0, mpRq.getCookieMask().intValue());
  81         Assert.assertNotNull(mpRq.getMatch());
  82         Assert.assertNull(mpRq.getMatchV10());
  83
  84         Assert.assertEquals(OxmMatchType.VALUE, mpRq.getMatch().getType());
  85     }
  86
  87     @Test
  88     public void testMakeMultipartRequestInput_FLOW_10() {
  89         final MultipartType mpType = MultipartType.OFPMPFLOW;
  90         ofVersion = OFConstants.OFP_VERSION_1_0;
  91         final MultipartRequestInput mpRqInput =
  92             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
  93         checkHeader(mpRqInput, mpType);
  94         final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
  95         Assert.assertTrue(mpRqBody instanceof MultipartRequestFlowCase);
  96
  97         MultipartRequestFlow mpRq = ((MultipartRequestFlowCase) mpRqBody).getMultipartRequestFlow();
  98         Assert.assertEquals(OFConstants.OFPTT_ALL, mpRq.getTableId());
  99         Assert.assertEquals(OFConstants.OFPP_ANY, mpRq.getOutPort());
 100         Assert.assertEquals(OFConstants.OFPG_ANY, mpRq.getOutGroup());
 101         Assert.assertEquals(0, mpRq.getCookie().intValue());
 102         Assert.assertEquals(0, mpRq.getCookieMask().intValue());
 103         Assert.assertNull(mpRq.getMatch());
 104         Assert.assertNotNull(mpRq.getMatchV10());
 105     }
 106
 107     @Test
 108     public void testMakeMultipartRequestInputAggregate() {
 109         MultipartType mpType = MultipartType.OFPMPAGGREGATE;
 110         final MultipartRequestInput mpRqInput =
 111             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 112         checkHeader(mpRqInput, mpType);
 113         checkEmptyBody(mpRqInput.getMultipartRequestBody().implementedInterface(),
 114                 MultipartRequestAggregateCase.class);
 115     }
 116
 117     @Test
 118     public void testMakeMultipartRequestInputTable() {
 119         MultipartType mpType = MultipartType.OFPMPTABLE;
 120         final MultipartRequestInput mpRqInput =
 121             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 122         checkHeader(mpRqInput, mpType);
 123         checkEmptyBody(mpRqInput.getMultipartRequestBody().implementedInterface(), MultipartRequestTableCase.class);
 124     }
 125
 126     @Test
 127     public void testMakeMultipartRequestInputPortStats() {
 128         final MultipartType mpType = MultipartType.OFPMPPORTSTATS;
 129         final MultipartRequestInput mpRqInput =
 130             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 131         checkHeader(mpRqInput, mpType);
 132         final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
 133         Assert.assertTrue(mpRqBody instanceof MultipartRequestPortStatsCase);
 134
 135         MultipartRequestPortStats mpRq = ((MultipartRequestPortStatsCase) mpRqBody).getMultipartRequestPortStats();
 136         Assert.assertEquals(OFConstants.OFPP_ANY, mpRq.getPortNo());
 137     }
 138
 139     @Test
 140     public void testMakeMultipartRequestInputQueue() {
 141         final MultipartType mpType = MultipartType.OFPMPQUEUE;
 142         final MultipartRequestInput mpRqInput =
 143             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 144         checkHeader(mpRqInput, mpType);
 145         final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
 146         Assert.assertTrue(mpRqBody instanceof MultipartRequestQueueCase);
 147
 148         MultipartRequestQueue mpRq = ((MultipartRequestQueueCase) mpRqBody).getMultipartRequestQueue();
 149         Assert.assertEquals(OFConstants.OFPP_ANY, mpRq.getPortNo());
 150         Assert.assertEquals(OFConstants.OFPQ_ALL, mpRq.getQueueId());
 151     }
 152
 153     @Test
 154     public void testMakeMultipartRequestInputGroup() {
 155         final MultipartType mpType = MultipartType.OFPMPGROUP;
 156         final MultipartRequestInput mpRqInput =
 157             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 158         checkHeader(mpRqInput, mpType);
 159         final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
 160         Assert.assertTrue(mpRqBody instanceof MultipartRequestGroupCase);
 161
 162         MultipartRequestGroup mpRq = ((MultipartRequestGroupCase) mpRqBody).getMultipartRequestGroup();
 163         Assert.assertEquals(OFConstants.OFPG_ALL, mpRq.getGroupId().getValue());
 164     }
 165
 166     @Test
 167     public void testMakeMultipartRequestInputGroupDesc() {
 168         MultipartType mpType = MultipartType.OFPMPGROUPDESC;
 169         final MultipartRequestInput mpRqInput =
 170             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 171         checkHeader(mpRqInput, mpType);
 172         checkEmptyBody(mpRqInput.getMultipartRequestBody().implementedInterface(),
 173                 MultipartRequestGroupDescCase.class);
 174     }
 175
 176     @Test
 177     public void testMakeMultipartRequestInputGroupFeatures() {
 178         MultipartType mpType = MultipartType.OFPMPGROUPFEATURES;
 179         final MultipartRequestInput mpRqInput =
 180             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 181         checkHeader(mpRqInput, mpType);
 182         checkEmptyBody(mpRqInput.getMultipartRequestBody().implementedInterface(),
 183                 MultipartRequestGroupFeaturesCase.class);
 184     }
 185
 186     @Test
 187     public void testMakeMultipartRequestInputMeter() {
 188         final MultipartType mpType = MultipartType.OFPMPMETER;
 189         final MultipartRequestInput mpRqInput =
 190             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 191         checkHeader(mpRqInput, mpType);
 192         final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
 193         Assert.assertTrue(mpRqBody instanceof MultipartRequestMeterCase);
 194
 195         MultipartRequestMeter mpRq = ((MultipartRequestMeterCase) mpRqBody).getMultipartRequestMeter();
 196         Assert.assertEquals(OFConstants.OFPM_ALL, mpRq.getMeterId().getValue());
 197     }
 198
 199     @Test
 200     public void testMakeMultipartRequestInputMeterConfig() {
 201         final MultipartType mpType = MultipartType.OFPMPMETERCONFIG;
 202         final MultipartRequestInput mpRqInput =
 203             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 204         checkHeader(mpRqInput, mpType);
 205         final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
 206         Assert.assertTrue(mpRqBody instanceof MultipartRequestMeterConfigCase);
 207
 208         MultipartRequestMeterConfig mpRq =
 209                 ((MultipartRequestMeterConfigCase) mpRqBody).getMultipartRequestMeterConfig();
 210         Assert.assertEquals(OFConstants.OFPM_ALL, mpRq.getMeterId().getValue());
 211     }
 212
 213     @Test
 214     public void testMakeMultipartRequestInputMeterFeatures() {
 215         MultipartType mpType = MultipartType.OFPMPMETERFEATURES;
 216         final MultipartRequestInput mpRqInput =
 217             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 218         checkHeader(mpRqInput, mpType);
 219         checkEmptyBody(mpRqInput.getMultipartRequestBody().implementedInterface(),
 220                 MultipartRequestMeterFeaturesCase.class);
 221     }
 222
 223     @Test
 224     public void testMakeMultipartRequestInputTableFeatures() {
 225         final MultipartType mpType = MultipartType.OFPMPTABLEFEATURES;
 226         final MultipartRequestInput mpRqInput =
 227             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 228         checkHeader(mpRqInput, mpType);
 229         final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
 230         Assert.assertTrue(mpRqBody instanceof MultipartRequestTableFeaturesCase);
 231
 232         MultipartRequestTableFeatures mpRq =
 233                 ((MultipartRequestTableFeaturesCase) mpRqBody).getMultipartRequestTableFeatures();
 234         Assert.assertNotNull(mpRq);
 235     }
 236
 237     @Test
 238     public void testMakeMultipartRequestInputPortDesc() {
 239         MultipartType mpType = MultipartType.OFPMPPORTDESC;
 240         final MultipartRequestInput mpRqInput =
 241             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 242         checkHeader(mpRqInput, mpType);
 243         checkEmptyBody(mpRqInput.getMultipartRequestBody().implementedInterface(),
 244                 MultipartRequestPortDescCase.class);
 245     }
 246
 247     @Test
 248     public void testMakeMultipartRequestInputExperimenter() {
 249         MultipartType mpType = MultipartType.OFPMPEXPERIMENTER;
 250         final MultipartRequestInput mpRqInput =
 251             (MultipartRequestInput) MultipartRequestInputFactory.makeMultipartRequest(xid, ofVersion, mpType, false);
 252         checkHeader(mpRqInput, mpType);
 253         checkEmptyBody(mpRqInput.getMultipartRequestBody().implementedInterface(),
 254                 MultipartRequestExperimenterCase.class);
 255     }
 256
 257     private void checkHeader(final MultipartRequestInput mpRqInput, final MultipartType mpType) {
 258         Assert.assertFalse(mpRqInput.getFlags().getOFPMPFREQMORE());
 259         Assert.assertEquals(ofVersion, mpRqInput.getVersion());
 260         Assert.assertEquals(mpType, mpRqInput.getType());
 261         Assert.assertEquals(xid, mpRqInput.getXid());
 262     }
 263
 264     private static void checkEmptyBody(final Class<? extends DataContainer> mpRqBody, final Class<? extends
 265             MultipartRequestBody> expectedMpRqBodyClass) {
 266         Assert.assertTrue(expectedMpRqBodyClass.isAssignableFrom(mpRqBody));
 267         Assert.assertEquals(expectedMpRqBodyClass, mpRqBody);
 268     }
 269 }