16 package org.openkilda.messaging.command.flow;
18 import static org.junit.Assert.assertEquals;
19 import static org.junit.Assert.assertTrue;
55 import org.junit.Ignore;
56 import org.junit.Test;
58 import java.io.IOException;
59 import java.util.Arrays;
60 import java.util.Collections;
61 import java.util.HashSet;
62 import java.util.List;
63 import java.util.UUID;
67 private static final String FLOW_NAME =
"test_flow";
68 private static final SwitchId SWITCH_ID =
new SwitchId(
"00:00:00:00:00:00:00:00");
69 private static final String CORRELATION_ID = UUID.randomUUID().toString();
70 private static final long TIMESTAMP = System.currentTimeMillis();
71 private static final int INPUT_PORT = 1;
72 private static final int OUTPUT_PORT = 2;
73 private static final int INPUT_VLAN_ID = 101;
74 private static final int OUTPUT_VLAN_ID = 102;
75 private static final int TRANSIT_VLAN_ID = 103;
76 private static final long BANDWIDTH = 10000L;
77 private static final long COOKIE = 0x1L;
78 private static final long METER_ID = 0L;
83 private static final Destination DESTINATION = null;
87 private static final String requester =
"requester-id";
92 private static final List<PathNode>
nodes = Arrays.asList(
97 private static final Flow flowModel =
new Flow(FLOW_NAME, 1000,
false, COOKIE, FLOW_NAME, String.valueOf(TIMESTAMP),
98 new SwitchId(
"ff:01"),
new SwitchId(
"ff:02"), 10, 20, 100, 200, 1, 1024, path, FLOW_STATUS);
103 SWITCH_ID, INPUT_PORT, OUTPUT_PORT, TRANSIT_VLAN_ID, OUTPUT_VLAN_ID, OUTPUT_VLAN_TYPE);
104 System.out.println(
data);
116 System.out.println(resultData);
117 assertEquals(
data, resultData);
118 assertEquals(
data.hashCode(), resultData.hashCode());
124 INPUT_PORT, OUTPUT_PORT, INPUT_VLAN_ID, TRANSIT_VLAN_ID, OUTPUT_VLAN_TYPE, BANDWIDTH, METER_ID);
125 System.out.println(
data);
137 System.out.println(resultData);
138 assertEquals(
data, resultData);
139 assertEquals(
data.hashCode(), resultData.hashCode());
145 SWITCH_ID, INPUT_PORT, OUTPUT_PORT, TRANSIT_VLAN_ID);
146 System.out.println(
data);
158 System.out.println(resultData);
159 assertEquals(
data, resultData);
160 assertEquals(
data.hashCode(), resultData.hashCode());
166 OUTPUT_PORT, INPUT_VLAN_ID, OUTPUT_VLAN_ID, OUTPUT_VLAN_TYPE, BANDWIDTH, METER_ID);
167 System.out.println(
data);
179 System.out.println(resultData);
180 assertEquals(
data, resultData);
181 assertEquals(
data.hashCode(), resultData.hashCode());
187 System.out.println(
data);
199 System.out.println(resultData);
200 assertEquals(
data, resultData);
201 assertEquals(
data.hashCode(), resultData.hashCode());
202 assertEquals(flowModel.
hashCode(), resultData.getPayload().hashCode());
208 System.out.println(
data);
220 System.out.println(resultData);
221 assertEquals(
data, resultData);
222 assertEquals(
data.hashCode(), resultData.hashCode());
223 assertEquals(flowModel.
hashCode(), resultData.getPayload().hashCode());
229 deleteFlow.setFlowId(flowName);
231 System.out.println(
data);
243 System.out.println(resultData);
244 assertEquals(
data, resultData);
245 assertEquals(
data.hashCode(), resultData.hashCode());
246 assertEquals(deleteFlow.
hashCode(), resultData.getPayload().hashCode());
252 System.out.println(
data);
264 System.out.println(resultData);
265 assertEquals(
data, resultData);
266 assertEquals(
data.hashCode(), resultData.hashCode());
267 assertEquals(FLOW_NAME, resultData.getFlowId());
272 Flow flow =
Flow.builder().flowPath(path).build();
275 System.out.println(
data);
287 System.out.println(resultData);
288 assertEquals(
data, resultData);
289 assertEquals(
data.hashCode(), resultData.hashCode());
290 assertEquals(path, resultData.getPayload().getForward().getFlowPath());
291 assertEquals(path, resultData.getPayload().getReverse().getFlowPath());
297 System.out.println(
data);
309 System.out.println(resultData);
310 assertEquals(
data, resultData);
311 assertEquals(
data.hashCode(), resultData.hashCode());
312 assertEquals(path.hashCode(), resultData.getPayload().hashCode());
318 System.out.println(
data);
330 System.out.println(resultData);
331 assertEquals(
data, resultData);
332 assertEquals(
data.hashCode(), resultData.hashCode());
333 assertEquals(flowIdStatusResponse.hashCode(), resultData.getPayload().hashCode());
339 System.out.println(
data);
351 System.out.println(resultData);
352 assertEquals(
data, resultData);
353 assertEquals(
data.hashCode(), resultData.hashCode());
354 assertEquals(flowModel.
hashCode(), resultData.getPayload().hashCode());
360 System.out.println(
data);
372 System.out.println(resultData);
373 assertEquals(
data, resultData);
374 assertEquals(
data.hashCode(), resultData.hashCode());
375 assertEquals(Collections.singletonList(flowModel.getFlowId()).hashCode(), resultData.getFlowIds().hashCode());
383 assertEquals(SWITCH_ID +
"_" + String.valueOf(INPUT_PORT),
data.getId());
384 System.out.println(
data);
396 System.out.println(resultData);
397 assertEquals(
data, resultData);
398 assertEquals(
data.hashCode(), resultData.hashCode());
399 assertEquals(payload.
hashCode(), resultData.getPath().get(0).hashCode());
405 System.out.println(
data);
417 System.out.println(resultData);
418 assertEquals(
data, resultData);
419 assertEquals(
data.hashCode(), resultData.hashCode());
425 System.out.println(
data);
437 System.out.println(resultData);
438 assertEquals(
data, resultData);
439 assertEquals(
data.hashCode(), resultData.hashCode());
445 System.out.println(
data);
457 System.out.println(resultData);
458 assertEquals(
data, resultData);
459 assertEquals(
data.hashCode(), resultData.hashCode());
465 System.out.println(
data);
475 assertTrue(resultInfo.
getData() != null);
478 System.out.println(resultData);
479 assertEquals(
data, resultData);
480 assertEquals(
data.hashCode(), resultData.hashCode());
487 System.out.println(
data);
497 assertTrue(resultCommand.
getData() != null);
500 System.out.println(resultData);
501 assertEquals(
data, resultData);
502 assertEquals(
data.hashCode(), resultData.hashCode());
508 System.out.println(
data);
518 assertTrue(resultCommand.
getData() != null);
521 System.out.println(resultData);
522 assertEquals(
data, resultData);
523 assertEquals(
data.hashCode(), resultData.hashCode());
529 System.out.println(
data);
539 assertTrue(resultCommand.
getData() != null);
542 System.out.println(resultData);
543 assertEquals(
data, resultData);
544 assertEquals(
data.hashCode(), resultData.hashCode());
550 new HashSet<>(Arrays.asList(sw1, sw2)),
552 Collections.singleton(isl),
554 System.out.println(
data);
564 assertTrue(resultInfo.
getData() != null);
567 System.out.println(resultData);
568 assertEquals(
data, resultData);
569 assertEquals(
data.hashCode(), resultData.hashCode());
void flowCreateRequestTest()
void serializeInstallOneSwitchFlowMessageTest()
void setData(final ErrorData data)
void dumpNetworkCommandTest()
void serialize(Object obj)
void setData(final InfoData data)
void serializeInstallIngressFlowMessageTest()
void flowRerouteCommandTest()
void flowGetBidirectionalRequestTest()
void flowDeleteRequestTest()
void serializeInstallEgressFlowMessageTest()
void flowGetBidirectionalResponseTest()
void serializeInstallTransitFlowMessageTest()
def command(payload, fields)
void flowUpdateRequestTest()
void flowStatusResponseTest()
void dumpNetworkResponseTest()
static final String flowName
void eventSwitchInfoTest()
void flowRerouteResponseTest()