Skip to content
Snippets Groups Projects
Commit 7f0b66a4 authored by Ryan Izard's avatar Ryan Izard
Browse files

Update unit tests with new cookies

parent edd42759
No related branches found
No related tags found
No related merge requests found
...@@ -41,10 +41,10 @@ public class AppCookieTest { ...@@ -41,10 +41,10 @@ public class AppCookieTest {
@Test @Test
public void testAppCookie(){ public void testAppCookie(){
int user = 0xF123F123; // MSB set long user = 0xF123F123F1234L; // MSB set
int user2 = 0x42; // MSB cleared long user2 = 0x42L; // MSB cleared
U64 expectedCookie11 = U64.of(0xF4200000F123F123L); // app1, user1 U64 expectedCookie11 = U64.of(0xF42F123F123F1234L); // app1, user1
U64 expectedCookie21 = U64.of(0x74300000F123F123L); // app2, user1 U64 expectedCookie21 = U64.of(0x743F123F123F1234L); // app2, user1
U64 expectedCookie12 = U64.of(0xF420000000000042L); // app1, user2 U64 expectedCookie12 = U64.of(0xF420000000000042L); // app1, user2
U64 expectedCookie22 = U64.of(0x7430000000000042L); // app2, user2 U64 expectedCookie22 = U64.of(0x7430000000000042L); // app2, user2
String name = "FooBar"; String name = "FooBar";
......
...@@ -98,9 +98,9 @@ public class FirewallTest extends FloodlightTestCase { ...@@ -98,9 +98,9 @@ public class FirewallTest extends FloodlightTestCase {
static { static {
AppCookie.registerApp(APP_ID, "Firewall"); AppCookie.registerApp(APP_ID, "Firewall");
} }
private static final U64 DENY_BCAST_COOKIE = AppCookie.makeCookie(APP_ID, 0xaaaaaaaa); private static final U64 DENY_BCAST_COOKIE = AppCookie.makeCookie(APP_ID, 0xaaaaaaL);
private static final U64 ALLOW_BCAST_COOKIE = AppCookie.makeCookie(APP_ID, 0x55555555); private static final U64 ALLOW_BCAST_COOKIE = AppCookie.makeCookie(APP_ID, 0x555555L);
private static final U64 RULE_MISS_COOKIE = AppCookie.makeCookie(APP_ID, -1); private static final U64 RULE_MISS_COOKIE = AppCookie.makeCookie(APP_ID, 0xffffffL);
@Override @Override
...@@ -684,10 +684,11 @@ public class FirewallTest extends FloodlightTestCase { ...@@ -684,10 +684,11 @@ public class FirewallTest extends FloodlightTestCase {
@Test @Test
public void cookieAddedSuccessfully() { public void cookieAddedSuccessfully() {
assertEquals("DENY_BCAST_COOKIE app_id is not correct", APP_ID, AppCookie.extractApp(DENY_BCAST_COOKIE)); assertEquals("DENY_BCAST_COOKIE app_id is not correct", APP_ID, AppCookie.extractApp(DENY_BCAST_COOKIE));
assertEquals("DENY_BCAST_COOKIE user_id is not correct", 0xaaaaaaaa, AppCookie.extractUser(DENY_BCAST_COOKIE));
assertEquals("DENY_BCAST_COOKIE user_id is not correct", 0xaaaaaaL, AppCookie.extractUser(DENY_BCAST_COOKIE));
assertEquals("ALLOW_BCAST_COOKIE app_id is not correct", APP_ID, AppCookie.extractApp(DENY_BCAST_COOKIE)); assertEquals("ALLOW_BCAST_COOKIE app_id is not correct", APP_ID, AppCookie.extractApp(DENY_BCAST_COOKIE));
assertEquals("ALLOW_BCAST_COOKIE user_id is not correct", 0x55555555, AppCookie.extractUser(ALLOW_BCAST_COOKIE)); assertEquals("ALLOW_BCAST_COOKIE user_id is not correct", 0x555555L, AppCookie.extractUser(ALLOW_BCAST_COOKIE));
assertEquals("RULE_MISS_COOKIE app_id is not correct", APP_ID, AppCookie.extractApp(DENY_BCAST_COOKIE)); assertEquals("RULE_MISS_COOKIE app_id is not correct", APP_ID, AppCookie.extractApp(DENY_BCAST_COOKIE));
assertEquals("RULE_MISS_COOKIE user_id is not correct", -1, AppCookie.extractUser(RULE_MISS_COOKIE)); assertEquals("RULE_MISS_COOKIE user_id is not correct", 0xffffffL, AppCookie.extractUser(RULE_MISS_COOKIE));
} }
} }
...@@ -173,6 +173,7 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -173,6 +173,7 @@ public class ForwardingTest extends FloodlightTestCase {
linkService.startUp(fmc); linkService.startUp(fmc);
deviceManager.startUp(fmc); deviceManager.startUp(fmc);
forwarding.startUp(fmc); forwarding.startUp(fmc);
Forwarding.flowSetIdRegistry.seedFlowSetIdForUnitTest(3);
entityClassifier.startUp(fmc); entityClassifier.startUp(fmc);
verify(topology); verify(topology);
...@@ -498,7 +499,7 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -498,7 +499,7 @@ public class ForwardingTest extends FloodlightTestCase {
.setActions(actions) .setActions(actions)
.setOutPort(action.getPort()) .setOutPort(action.getPort())
.setBufferId(OFBufferId.NO_BUFFER) .setBufferId(OFBufferId.NO_BUFFER)
.setCookie(U64.of(2L << 52)) .setCookie(U64.of(2L << 52).or(U64.of(4 << Forwarding.FLOWSET_SHIFT)))
.setPriority(1) .setPriority(1)
.build(); .build();
OFFlowMod fm2 = fm1.createBuilder().build(); OFFlowMod fm2 = fm1.createBuilder().build();
...@@ -569,7 +570,7 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -569,7 +570,7 @@ public class ForwardingTest extends FloodlightTestCase {
.setActions(actions) .setActions(actions)
.setOutPort(action.getPort()) .setOutPort(action.getPort())
.setBufferId(OFBufferId.NO_BUFFER) .setBufferId(OFBufferId.NO_BUFFER)
.setCookie(U64.of(2L << 52)) .setCookie(U64.of(2L << 52).or(U64.of(4 << Forwarding.FLOWSET_SHIFT)))
.setPriority(1) .setPriority(1)
.build(); .build();
OFFlowMod fm2 = fm1.createBuilder().build(); OFFlowMod fm2 = fm1.createBuilder().build();
...@@ -637,7 +638,7 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -637,7 +638,7 @@ public class ForwardingTest extends FloodlightTestCase {
.setActions(actions) .setActions(actions)
.setOutPort(OFPort.of(3)) .setOutPort(OFPort.of(3))
.setBufferId(OFBufferId.NO_BUFFER) .setBufferId(OFBufferId.NO_BUFFER)
.setCookie(U64.of(2L<< 52)) .setCookie(U64.of(2L << 52).or(U64.of(4 << Forwarding.FLOWSET_SHIFT)))
.setPriority(1) .setPriority(1)
.build(); .build();
...@@ -694,7 +695,7 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -694,7 +695,7 @@ public class ForwardingTest extends FloodlightTestCase {
.setActions(actions) .setActions(actions)
.setOutPort(OFPort.of(3)) .setOutPort(OFPort.of(3))
.setBufferId(OFBufferId.NO_BUFFER) .setBufferId(OFBufferId.NO_BUFFER)
.setCookie(U64.of(2L<< 52)) .setCookie(U64.of(2L << 52).or(U64.of(4 << Forwarding.FLOWSET_SHIFT)))
.setPriority(1) .setPriority(1)
.build(); .build();
...@@ -753,21 +754,20 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -753,21 +754,20 @@ public class ForwardingTest extends FloodlightTestCase {
.setActions(actions) .setActions(actions)
.setOutPort(OFPort.of(3)) .setOutPort(OFPort.of(3))
.setBufferId(OFBufferId.NO_BUFFER) .setBufferId(OFBufferId.NO_BUFFER)
.setCookie(U64.of(2L << 52)) .setCookie(U64.of(2L << 52).or(U64.of(6 << Forwarding.FLOWSET_SHIFT)))
.setXid(anyLong()) .setXid(anyLong())
.build(); .build();
// Record expected packet-outs/flow-mods // Record expected packet-outs/flow-mods
// We will inject the packet_in 3 times and expect 1 flow mod and // We will inject the packet_in 3 times and expect 1 flow mod and
// 3 packet outs due to flow mod dampening // 3 packet outs due to flow mod dampening
sw1.write(fm1); expect(sw1.write(fm1)).andReturn(true).once();
expectLastCall().times(1);
// Update new expected XID // Update new expected XID
sw1.write(packetOut.createBuilder().setXid(anyLong()).build()); expect(sw1.write(packetOut.createBuilder().setXid(anyLong()).build())).andReturn(true).times(3);
expectLastCall().times(3);
reset(topology); reset(topology);
expect(topology.isBroadcastAllowed(DatapathId.of(anyLong()), OFPort.of(anyShort()))).andReturn(true).anyTimes(); expect(topology.isBroadcastAllowed(DatapathId.of(anyLong()), OFPort.of(anyInt()))).andReturn(true).anyTimes();
expect(topology.isEdge(DatapathId.of(anyLong()), OFPort.of(anyInt()))).andReturn(true).anyTimes();
expect(topology.getClusterId(DatapathId.of(1L))).andReturn(DatapathId.of(1L)).anyTimes(); expect(topology.getClusterId(DatapathId.of(1L))).andReturn(DatapathId.of(1L)).anyTimes();
expect(topology.isAttachmentPointPort(DatapathId.of(1L), OFPort.of(1))).andReturn(true).anyTimes(); expect(topology.isAttachmentPointPort(DatapathId.of(1L), OFPort.of(1))).andReturn(true).anyTimes();
expect(topology.isAttachmentPointPort(DatapathId.of(1L), OFPort.of(3))).andReturn(true).anyTimes(); expect(topology.isAttachmentPointPort(DatapathId.of(1L), OFPort.of(3))).andReturn(true).anyTimes();
...@@ -881,7 +881,7 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -881,7 +881,7 @@ public class ForwardingTest extends FloodlightTestCase {
.setActions(actions) .setActions(actions)
.setOutPort(OFPort.of(3)) .setOutPort(OFPort.of(3))
.setBufferId(OFBufferId.NO_BUFFER) .setBufferId(OFBufferId.NO_BUFFER)
.setCookie(U64.of(2L<< 52)) .setCookie(U64.of(2L << 52).or(U64.of(4 << Forwarding.FLOWSET_SHIFT)))
.setPriority(1) .setPriority(1)
.build(); .build();
...@@ -940,7 +940,7 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -940,7 +940,7 @@ public class ForwardingTest extends FloodlightTestCase {
.setActions(actions) .setActions(actions)
.setOutPort(OFPort.of(3)) .setOutPort(OFPort.of(3))
.setBufferId(OFBufferId.NO_BUFFER) .setBufferId(OFBufferId.NO_BUFFER)
.setCookie(U64.of(2L<< 52 | 0xFFffFFffL)) .setCookie(U64.of(2L << 52).or(U64.of(4 << Forwarding.FLOWSET_SHIFT).or(U64.of(0xFFffFFL))))
.setPriority(1) .setPriority(1)
.build(); .build();
...@@ -995,7 +995,7 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -995,7 +995,7 @@ public class ForwardingTest extends FloodlightTestCase {
Masked<U64> masked_cookie = Masked.of( Masked<U64> masked_cookie = Masked.of(
AppCookie.makeCookie(Forwarding.FORWARDING_APP_ID, (int)4294967295L), AppCookie.makeCookie(Forwarding.FORWARDING_APP_ID, (int)4294967295L),
AppCookie.getAppFieldMask().or(U64.of(0xffffffffL))); AppCookie.getAppFieldMask().or(U64.of(0xffffffL)));
List<OFMessage> msgs_test = new ArrayList<>(); List<OFMessage> msgs_test = new ArrayList<>();
msgs_test.add( factory.buildFlowDelete() msgs_test.add( factory.buildFlowDelete()
.setCookie(masked_cookie.getValue()) .setCookie(masked_cookie.getValue())
...@@ -1015,10 +1015,10 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -1015,10 +1015,10 @@ public class ForwardingTest extends FloodlightTestCase {
List<Masked<U64>> descriptors = new ArrayList<Masked<U64>>(); List<Masked<U64>> descriptors = new ArrayList<Masked<U64>>();
descriptors.add(Masked.of( descriptors.add(Masked.of(
U64.of(0x00000000FFffFFffL), U64.of(0x0000000000ffFFffL),
U64.of(0x00200000FFffFFffL))); // User mask = 0xffFFffFFL which is forwarding.DECISION_MASK/AppCookie.USER_MASK U64.of(0x0020000000ffFFffL))); // User mask = 0xffFFffFFL which is forwarding.DECISION_MASK/AppCookie.USER_MASK
descriptors.add(Masked.of( descriptors.add(Masked.of(
U64.of(0x00000000FFffFFffL), U64.of(0x0000000000ffFFffL),
U64.of(0x0020000000000000L))); U64.of(0x0020000000000000L)));
expect(sw1.getStatus()).andReturn(IOFSwitch.SwitchStatus.MASTER).anyTimes(); expect(sw1.getStatus()).andReturn(IOFSwitch.SwitchStatus.MASTER).anyTimes();
...@@ -1036,7 +1036,7 @@ public class ForwardingTest extends FloodlightTestCase { ...@@ -1036,7 +1036,7 @@ public class ForwardingTest extends FloodlightTestCase {
// Cookies // Cookies
Masked<U64> masked_cookie = Masked.of( AppCookie.makeCookie(Forwarding.FORWARDING_APP_ID, (int)4294967295L), Masked<U64> masked_cookie = Masked.of( AppCookie.makeCookie(Forwarding.FORWARDING_APP_ID, (int)4294967295L),
AppCookie.getAppFieldMask().or(U64.of(0xffffffffL))); AppCookie.getAppFieldMask().or(U64.of(0xffffffL)));
Masked<U64> masked_cookie2 = Masked.of( AppCookie.makeCookie(Forwarding.FORWARDING_APP_ID, 0), Masked<U64> masked_cookie2 = Masked.of( AppCookie.makeCookie(Forwarding.FORWARDING_APP_ID, 0),
AppCookie.getAppFieldMask().or(U64.of(0x0L))); AppCookie.getAppFieldMask().or(U64.of(0x0L)));
// Add cookies to a msg set // Add cookies to a msg set
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment