import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.util.Arrays;
+import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.ArgumentCaptor;
-import org.mockito.InjectMocks;
-import org.mockito.Mock;
import org.mockito.Mockito;
import org.mockito.runners.MockitoJUnitRunner;
-import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService;
+import org.opendaylight.lispflowmapping.lisp.util.LispAddressStringifier;
import org.opendaylight.lispflowmapping.lisp.util.LispAddressUtil;
+import org.opendaylight.lispflowmapping.southbound.LispSouthboundPlugin;
import org.opendaylight.lispflowmapping.southbound.lisp.exception.LispMalformedPacketException;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.inet.binary.types.rev160303.Ipv4AddressBinary;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.binary.address.types.rev160504.Ipv4BinaryAfi;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.binary.address.types.rev160504.augmented.lisp.address
- .address.Ipv4BinaryBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.binary.address.types.rev160504.augmented.lisp.address.address.Ipv4BinaryBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.XtrReplyMapping;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.XtrRequestMapping;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.eid.container.Eid;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.eid.list.EidItem;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.eid.list.EidItemBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.eid.list.EidItemKey;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.maprequest.ItrRloc;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.maprequest.ItrRlocBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.maprequest.ItrRlocKey;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.maprequest.SourceEidBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.maprequestnotification.MapRequest;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.maprequestnotification.MapRequestBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.rloc.container.Rloc;
import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.lisp.proto.rev151105.rloc.container.RlocBuilder;
@RunWith(MockitoJUnitRunner.class)
public class LispXtrSouthboundHandlerTest {
- @Mock(name = "notificationPublishService") private static NotificationPublishService notificationPublishServiceMock;
- @InjectMocks private static LispXtrSouthboundHandler handler;
-
private static final String IPV4_STRING_1 = "1.2.3.4";
private static final String IPV4_STRING_2 = "127.0.0.1";
private static final String IPV4_STRING_PREFIX = "/32";
private static final int LISP_MAP_REPLY_PACKET_LENGTH = 40;
private static final int PORT = 9999;
- /**
+ /*
* SRC: 127.0.0.1:58560 to 127.0.0.1:4342
* LISP(Type = 8 - Encapsulated)
* IP: 192.168.136.10 -> 153.16.254.1
* Record 1: 127.0.0.1/32
*/
private static final String MAP_REQUEST_PACKET_STRING =
- "0000 00 00 00 00 00 00 00 00 00 00 00 00 08 00 45 00 " +
- "0010 00 58 00 00 40 00 40 11 3c 93 7f 00 00 01 7f 00 " +
- "0020 00 01 e4 c0 10 f6 00 44 fe 57 80 00 00 00 45 00 " +
- "0030 00 3c d4 31 00 00 ff 11 56 f3 7f 00 00 02 99 10 " +
- "0040 fe 01 dd b4 10 f6 00 24 ef 3a 10 00 00 01 3d 8d " +
- "0050 2a cd 39 c8 d6 08 00 01 01 02 03 04 00 01 7f 00 " +
- "0060 00 02 00 20 00 01 7f 00 00 01 ac 4a 06 7d";
+ "0000 00 00 00 00 00 00 00 00 00 00 00 00 08 00 45 00 "
+ + "0010 00 58 00 00 40 00 40 11 3c 93 7f 00 00 01 7f 00 "
+ + "0020 00 01 e4 c0 10 f6 00 44 fe 57 80 00 00 00 45 00 "
+ + "0030 00 3c d4 31 00 00 ff 11 56 f3 7f 00 00 02 99 10 "
+ + "0040 fe 01 dd b4 10 f6 00 24 ef 3a 10 00 00 01 3d 8d "
+ + "0050 2a cd 39 c8 d6 08 00 01 01 02 03 04 00 01 7f 00 "
+ + "0060 00 02 00 20 00 01 7f 00 00 01 ac 4a 06 7d";
private static final String MAP_REQUEST_PACKET_STRING_MALFORMED =
- "0000 00 00 00 00 00 00 00 00 00 00 00 00 08 00 45 00 " +
- "0010 00 58 00 00 40 00 40 11 3c 93 7f 00 00 01 7f 00 " +
- "0020 00 01 e4 c0 10 f6 00 44 fe 57 80 00 00 00 45 00 " +
- "0030 00 3c d4 31 00 00 ff 11 56 f3 7f 00 00 02 99 10 " +
- "0040 fe 01 dd b4 10 f6 00 24 ef 3a 10 00 00 01 3d 8d " +
- "0050 2a cd 39 c8 d6 08 00 01 01 02 03 04 00 00 00 00 " +
- "0060 00 00 00 20 00 01 7f 00 00 01 ac 4a 06 7d";
-
- /**
+ "0000 00 00 00 00 00 00 00 00 00 00 00 00 08 00 45 00 "
+ + "0010 00 58 00 00 40 00 40 11 3c 93 7f 00 00 01 7f 00 "
+ + "0020 00 01 e4 c0 10 f6 00 44 fe 57 80 00 00 00 45 00 "
+ + "0030 00 3c d4 31 00 00 ff 11 56 f3 7f 00 00 02 99 10 "
+ + "0040 fe 01 dd b4 10 f6 00 24 ef 3a 10 00 00 01 3d 8d "
+ + "0050 2a cd 39 c8 d6 08 00 01 01 02 03 04 00 00 00 00 "
+ + "0060 00 00 00 20 00 01 7f 00 00 01 ac 4a 06 7d";
+
+ /*
* SRC: 127.0.0.1:58560 to 127.0.0.1:4342
* LISP(Type = 8 - Encapsulated)
* IP: 192.168.136.10 -> 153.16.254.1
* Locator Record 1: 127.0.0.1/32
*/
private static final String MAP_REPLY_PACKET_STRING =
- "0000 00 00 00 00 00 00 00 00 00 00 00 00 08 00 45 00 " +
- "0010 00 58 00 00 40 00 40 11 3c 93 7f 00 00 01 7f 00 " +
- "0020 00 01 e4 c0 10 f6 00 44 fe 57 80 00 00 00 45 00 " +
- "0030 00 3c d4 31 00 00 ff 11 56 f3 7f 00 00 02 99 10 " +
- "0040 fe 01 dd b4 10 f6 00 24 ef 3a 28 00 00 01 3d 8d " +
- "0050 2a cd 39 c8 d6 08 ff ff ff ff 01 20 10 00 00 00 " +
- "0060 00 01 01 02 03 04 00 00 00 00 00 00 00 01 fe fe " +
- "0070 fe fe 0d e3 70 40";
+ "0000 00 00 00 00 00 00 00 00 00 00 00 00 08 00 45 00 "
+ + "0010 00 58 00 00 40 00 40 11 3c 93 7f 00 00 01 7f 00 "
+ + "0020 00 01 e4 c0 10 f6 00 44 fe 57 80 00 00 00 45 00 "
+ + "0030 00 3c d4 31 00 00 ff 11 56 f3 7f 00 00 02 99 10 "
+ + "0040 fe 01 dd b4 10 f6 00 24 ef 3a 28 00 00 01 3d 8d "
+ + "0050 2a cd 39 c8 d6 08 ff ff ff ff 01 20 10 00 00 00 "
+ + "0060 00 01 01 02 03 04 00 00 00 00 00 00 00 01 fe fe "
+ + "0070 fe fe 0d e3 70 40";
+
+ private LispSouthboundPlugin lispSbPluginMock;
+ private LispXtrSouthboundHandler handler;
+
+ @Before
+ public void initTest() {
+ lispSbPluginMock = Mockito.mock(LispSouthboundPlugin.class);
+ handler = new LispXtrSouthboundHandler(lispSbPluginMock);
+ }
/**
* Tests {@link LispXtrSouthboundHandler#handlePacket} method with Map-Request.
- *
- * @throws InterruptedException
*/
@Test
public void handlePacketTest_withMapRequest() throws InterruptedException {
handler.handlePacket(extractLispPacket(MAP_REQUEST_PACKET_STRING, HEADER_LENGTH,
LISP_MAP_REQUEST_PACKET_LENGTH));
- Mockito.verify(notificationPublishServiceMock).putNotification(captor.capture());
+ Mockito.verify(lispSbPluginMock).sendNotificationIfPossible(captor.capture());
assertEquals(expectedRequest, captor.getValue().getMapRequest());
}
- /**
- * Tests {@link LispXtrSouthboundHandler#handlePacket} method with Map-Request, null NotificationPublishService.
- *
- * @throws InterruptedException
- */
- @Test
- public void handlePacketTest_withMapRequest_withNullNotifPublishService() throws InterruptedException {
- final LispXtrSouthboundHandler handler = new LispXtrSouthboundHandler();
- handler.handlePacket(extractLispPacket(MAP_REQUEST_PACKET_STRING, HEADER_LENGTH,
- LISP_MAP_REQUEST_PACKET_LENGTH));
- Mockito.verifyZeroInteractions(notificationPublishServiceMock);
- }
-
/**
* Tests {@link LispXtrSouthboundHandler#handlePacket} method with Map-Request, no Itr Rlocs.
- *
- * @throws InterruptedException
*/
@Test(expected = LispMalformedPacketException.class)
public void handlePacketTest__withMapRequest_withNoItrRloc() throws InterruptedException {
/**
* Tests {@link LispXtrSouthboundHandler#handlePacket} method with Map-Reply.
- *
- * @throws InterruptedException
*/
@Test
public void handlePacketTest_withMapReply() throws InterruptedException {
handler.handlePacket(extractLispPacket(MAP_REPLY_PACKET_STRING, HEADER_LENGTH,
LISP_MAP_REPLY_PACKET_LENGTH));
- Mockito.verify(notificationPublishServiceMock).putNotification(captor.capture());
+ Mockito.verify(lispSbPluginMock).sendNotificationIfPossible(captor.capture());
assertNotNull(captor.getValue().getMapReply());
}
- /**
- * Tests {@link LispXtrSouthboundHandler#handlePacket} method with Map-Reply over channelRead0 method.
- *
- * @throws Exception
- */
- @Test
- public void handlePacketTest_withMapReply_withNullNotifPublishService() throws Exception {
- final LispXtrSouthboundHandler handler = new LispXtrSouthboundHandler();
- handler.channelRead0(Mockito.mock(ChannelHandlerContext.class),
- extractLispPacket(MAP_REPLY_PACKET_STRING, HEADER_LENGTH, LISP_MAP_REPLY_PACKET_LENGTH));
-
- Mockito.verifyZeroInteractions(notificationPublishServiceMock);
- }
-
/**
* Tests {@link LispXtrSouthboundHandler#channelReadComplete} method.
- *
- * @throws Exception
*/
@Test
public void channelReadCompleteTest() throws Exception {
// This map-notification packet is not valid! Don't use it anywhere else.
String mapNotificationPacket =
- "0000 00 00 00 00 00 00 00 00 00 00 00 00 08 00 45 00 " +
- "0010 00 58 00 00 40 00 40 11 3c 93 7f 00 00 01 7f 00 " +
- "0020 00 01 e4 c0 10 f6 00 44 fe 57 80 00 00 00 45 00 " +
- "0030 00 3c d4 31 00 00 ff 11 56 f3 7f 00 00 02 99 10 " +
- "0040 fe 01 dd b4 10 f6 00 24 ef 3a 40 00 00 01 3d 8d " +
- "0050 2a cd 39 c8 d6 08 ff ff ff ff 01 20 10 00 00 00 " +
- "0060 00 01 01 02 03 04 00 00 00 00 00 00 00 01 fe fe " +
- "0070 fe fe 0d e3 70 40";
+ "0000 00 00 00 00 00 00 00 00 00 00 00 00 08 00 45 00 "
+ + "0010 00 58 00 00 40 00 40 11 3c 93 7f 00 00 01 7f 00 "
+ + "0020 00 01 e4 c0 10 f6 00 44 fe 57 80 00 00 00 45 00 "
+ + "0030 00 3c d4 31 00 00 ff 11 56 f3 7f 00 00 02 99 10 "
+ + "0040 fe 01 dd b4 10 f6 00 24 ef 3a 40 00 00 01 3d 8d "
+ + "0050 2a cd 39 c8 d6 08 ff ff ff ff 01 20 10 00 00 00 "
+ + "0060 00 01 01 02 03 04 00 00 00 00 00 00 00 01 fe fe "
+ + "0070 fe fe 0d e3 70 40";
handler.exceptionCaught(Mockito.mock(ChannelHandlerContext.class), Mockito.mock(Throwable.class));
- handler.setNotificationProvider(notificationPublishServiceMock);
handler.handlePacket(extractLispPacket(mapNotificationPacket, HEADER_LENGTH, LISP_MAP_REPLY_PACKET_LENGTH));
}
}
private static MapRequestBuilder getDefaultMapRequestBuilder() {
- final ItrRloc itrRloc = new ItrRlocBuilder()
- .setRloc(new RlocBuilder()
- .setAddressType(Ipv4BinaryAfi.class)
- .setAddress(new Ipv4BinaryBuilder()
- .setIpv4Binary(new Ipv4AddressBinary(new byte[]{127, 0, 0, 2})).build())
- .build())
+ final Rloc rloc = new RlocBuilder()
+ .setAddressType(Ipv4BinaryAfi.class)
+ .setAddress(new Ipv4BinaryBuilder()
+ .setIpv4Binary(new Ipv4AddressBinary(new byte[]{127, 0, 0, 2})).build())
.build();
+ final ItrRloc itrRloc = new ItrRlocBuilder()
+ .withKey(new ItrRlocKey(LispAddressStringifier.getString(rloc)))
+ .setRloc(rloc).build();
+ final Eid eid = LispAddressUtil.asIpv4PrefixBinaryEid(IPV4_STRING_2 + IPV4_STRING_PREFIX);
final EidItem eidItem = new EidItemBuilder()
- .setEid(LispAddressUtil.asIpv4PrefixBinaryEid(IPV4_STRING_2 + IPV4_STRING_PREFIX)).build();
+ .withKey(new EidItemKey(IPV4_STRING_2 + IPV4_STRING_PREFIX))
+ .setEid(eid).build();
return new MapRequestBuilder()
.setItrRloc(Lists.newArrayList(itrRloc))
.setSmr(false)
.setSmrInvoked(false);
}
-}
+}
\ No newline at end of file
Code Review / lispflowmapping.git / blobdiff