2 * Copyright (c) 2015 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.openflowplugin.impl.common;
11 import org.junit.Assert;
12 import org.junit.Before;
13 import org.junit.Test;
14 import org.opendaylight.openflowplugin.api.OFConstants;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.MultipartType;
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.MultipartRequestFlowCase;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestGroupCase;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestMeterCase;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestMeterConfigCase;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestPortStatsCase;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestQueueCase;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.MultipartRequestTableFeaturesCase;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.flow._case.MultipartRequestFlow;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.group._case.MultipartRequestGroup;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.meter._case.MultipartRequestMeter;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.meter.config._case.MultipartRequestMeterConfig;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.port.stats._case.MultipartRequestPortStats;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.queue._case.MultipartRequestQueue;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.multipart.request.multipart.request.body.multipart.request.table.features._case.MultipartRequestTableFeatures;
34 * Test for {@link MultipartRequestInputFactory}.
36 public class MultipartRequestInputFactoryTest {
38 private long xid = 42L;
39 private short ofVersion;
43 public void setUp() throws Exception {
44 ofVersion = OFConstants.OFP_VERSION_1_3;
48 public void testMakeMultipartRequestInput_DESC() throws Exception {
49 MultipartType mpType = MultipartType.OFPMPDESC;
50 final MultipartRequestInput mpRqInput =
51 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
52 checkHeader(mpRqInput, mpType, ofVersion);
56 public void testMakeMultipartRequestInput_FLOW_13() throws Exception {
57 final MultipartType mpType = MultipartType.OFPMPFLOW;
58 final MultipartRequestInput mpRqInput =
59 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
60 checkHeader(mpRqInput, mpType, ofVersion);
61 final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
62 Assert.assertTrue(mpRqBody instanceof MultipartRequestFlowCase);
64 MultipartRequestFlow mpRq = ((MultipartRequestFlowCase) mpRqBody).getMultipartRequestFlow();
65 Assert.assertEquals(OFConstants.OFPTT_ALL, mpRq.getTableId());
66 Assert.assertEquals(OFConstants.OFPP_ANY, mpRq.getOutPort());
67 Assert.assertEquals(OFConstants.OFPG_ANY, mpRq.getOutGroup());
68 Assert.assertEquals(0, mpRq.getCookie().intValue());
69 Assert.assertEquals(0, mpRq.getCookieMask().intValue());
70 Assert.assertNotNull(mpRq.getMatch());
71 Assert.assertNull(mpRq.getMatchV10());
73 final String EMPTY_MATCH_DUMP =
74 "Match [_type=class org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.oxm.rev150225.OxmMatchType, " +
76 Assert.assertEquals(EMPTY_MATCH_DUMP, String.valueOf(mpRq.getMatch()));
80 public void testMakeMultipartRequestInput_FLOW_10() throws Exception {
81 final MultipartType mpType = MultipartType.OFPMPFLOW;
82 ofVersion = OFConstants.OFP_VERSION_1_0;
83 final MultipartRequestInput mpRqInput =
84 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
85 checkHeader(mpRqInput, mpType, ofVersion);
86 final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
87 Assert.assertTrue(mpRqBody instanceof MultipartRequestFlowCase);
89 MultipartRequestFlow mpRq = ((MultipartRequestFlowCase) mpRqBody).getMultipartRequestFlow();
90 Assert.assertEquals(OFConstants.OFPTT_ALL, mpRq.getTableId());
91 Assert.assertEquals(OFConstants.OFPP_ANY, mpRq.getOutPort());
92 Assert.assertEquals(OFConstants.OFPG_ANY, mpRq.getOutGroup());
93 Assert.assertEquals(0, mpRq.getCookie().intValue());
94 Assert.assertEquals(0, mpRq.getCookieMask().intValue());
95 Assert.assertNull(mpRq.getMatch());
96 Assert.assertNotNull(mpRq.getMatchV10());
100 public void testMakeMultipartRequestInput_AGGREGATE() throws Exception {
101 MultipartType mpType = MultipartType.OFPMPAGGREGATE;
102 final MultipartRequestInput mpRqInput =
103 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
104 checkHeader(mpRqInput, mpType, ofVersion);
108 public void testMakeMultipartRequestInput_TABLE() throws Exception {
109 MultipartType mpType = MultipartType.OFPMPTABLE;
110 final MultipartRequestInput mpRqInput =
111 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
112 checkHeader(mpRqInput, mpType, ofVersion);
116 public void testMakeMultipartRequestInput_PORTSTATS() throws Exception {
117 final MultipartType mpType = MultipartType.OFPMPPORTSTATS;
118 final MultipartRequestInput mpRqInput =
119 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
120 checkHeader(mpRqInput, mpType, ofVersion);
121 final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
122 Assert.assertTrue(mpRqBody instanceof MultipartRequestPortStatsCase);
124 MultipartRequestPortStats mpRq = ((MultipartRequestPortStatsCase) mpRqBody).getMultipartRequestPortStats();
125 Assert.assertEquals(OFConstants.OFPP_ANY, mpRq.getPortNo());
129 public void testMakeMultipartRequestInput_QUEUE() throws Exception {
130 final MultipartType mpType = MultipartType.OFPMPQUEUE;
131 final MultipartRequestInput mpRqInput =
132 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
133 checkHeader(mpRqInput, mpType, ofVersion);
134 final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
135 Assert.assertTrue(mpRqBody instanceof MultipartRequestQueueCase);
137 MultipartRequestQueue mpRq = ((MultipartRequestQueueCase) mpRqBody).getMultipartRequestQueue();
138 Assert.assertEquals(OFConstants.OFPP_ANY, mpRq.getPortNo());
139 Assert.assertEquals(OFConstants.OFPQ_ALL, mpRq.getQueueId());
143 public void testMakeMultipartRequestInput_GROUP() throws Exception {
144 final MultipartType mpType = MultipartType.OFPMPGROUP;
145 final MultipartRequestInput mpRqInput =
146 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
147 checkHeader(mpRqInput, mpType, ofVersion);
148 final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
149 Assert.assertTrue(mpRqBody instanceof MultipartRequestGroupCase);
151 MultipartRequestGroup mpRq = ((MultipartRequestGroupCase) mpRqBody).getMultipartRequestGroup();
152 Assert.assertEquals(OFConstants.OFPG_ALL, mpRq.getGroupId().getValue());
156 public void testMakeMultipartRequestInput_GROUPDESC() throws Exception {
157 MultipartType mpType = MultipartType.OFPMPGROUPDESC;
158 final MultipartRequestInput mpRqInput =
159 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
160 checkHeader(mpRqInput, mpType, ofVersion);
164 public void testMakeMultipartRequestInput_GROUPFEATURES() throws Exception {
165 MultipartType mpType = MultipartType.OFPMPGROUPFEATURES;
166 final MultipartRequestInput mpRqInput =
167 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
168 checkHeader(mpRqInput, mpType, ofVersion);
172 public void testMakeMultipartRequestInput_METER() throws Exception {
173 final MultipartType mpType = MultipartType.OFPMPMETER;
174 final MultipartRequestInput mpRqInput =
175 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
176 checkHeader(mpRqInput, mpType, ofVersion);
177 final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
178 Assert.assertTrue(mpRqBody instanceof MultipartRequestMeterCase);
180 MultipartRequestMeter mpRq = ((MultipartRequestMeterCase) mpRqBody).getMultipartRequestMeter();
181 Assert.assertEquals(OFConstants.OFPM_ALL, mpRq.getMeterId().getValue());
185 public void testMakeMultipartRequestInput_METERCONFIG() throws Exception {
186 final MultipartType mpType = MultipartType.OFPMPMETERCONFIG;
187 final MultipartRequestInput mpRqInput =
188 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
189 checkHeader(mpRqInput, mpType, ofVersion);
190 final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
191 Assert.assertTrue(mpRqBody instanceof MultipartRequestMeterConfigCase);
193 MultipartRequestMeterConfig mpRq = ((MultipartRequestMeterConfigCase) mpRqBody).getMultipartRequestMeterConfig();
197 public void testMakeMultipartRequestInput_METERFEATURES() throws Exception {
198 MultipartType mpType = MultipartType.OFPMPMETERFEATURES;
199 final MultipartRequestInput mpRqInput =
200 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
201 checkHeader(mpRqInput, mpType, ofVersion);
205 public void testMakeMultipartRequestInput_TABLEFEATURES() throws Exception {
206 final MultipartType mpType = MultipartType.OFPMPTABLEFEATURES;
207 final MultipartRequestInput mpRqInput =
208 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
209 checkHeader(mpRqInput, mpType, ofVersion);
210 final MultipartRequestBody mpRqBody = mpRqInput.getMultipartRequestBody();
211 Assert.assertTrue(mpRqBody instanceof MultipartRequestTableFeaturesCase);
213 MultipartRequestTableFeatures mpRq = ((MultipartRequestTableFeaturesCase) mpRqBody).getMultipartRequestTableFeatures();
214 Assert.assertNotNull(mpRq);
218 public void testMakeMultipartRequestInput_PORTDESC() throws Exception {
219 MultipartType mpType = MultipartType.OFPMPPORTDESC;
220 final MultipartRequestInput mpRqInput =
221 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
222 checkHeader(mpRqInput, mpType, ofVersion);
226 public void testMakeMultipartRequestInput_EXPERIMENTER() throws Exception {
227 MultipartType mpType = MultipartType.OFPMPEXPERIMENTER;
228 final MultipartRequestInput mpRqInput =
229 MultipartRequestInputFactory.makeMultipartRequestInput(xid, ofVersion, mpType);
230 checkHeader(mpRqInput, mpType, ofVersion);
233 private void checkHeader(MultipartRequestInput mpRqInput, MultipartType mpType, short ofVersion) {
234 Assert.assertFalse(mpRqInput.getFlags().isOFPMPFREQMORE());
235 Assert.assertEquals(ofVersion, mpRqInput.getVersion().shortValue());
236 Assert.assertEquals(mpType, mpRqInput.getType());
237 Assert.assertEquals(xid, mpRqInput.getXid().longValue());