2 * Copyright (c) 2014 Contextream, 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
8 package org.opendaylight.lispflowmapping.implementation.util;
10 import java.net.Inet4Address;
11 import java.net.Inet6Address;
12 import java.net.InetAddress;
13 import java.net.UnknownHostException;
14 import java.nio.ByteBuffer;
16 import org.apache.commons.lang3.exception.ExceptionUtils;
17 import org.opendaylight.lispflowmapping.lisp.util.LispAFIConvertor;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.LispAFIAddress;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.lcafsegmentaddress.AddressBuilder;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.lcafsegmentaddress.Address;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.lispaddress.lispaddresscontainer.address.ipv4.Ipv4Address;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.lispaddress.lispaddresscontainer.address.ipv6.Ipv6Address;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.lispaddress.lispaddresscontainer.address.lcafsegment.LcafSegmentAddr;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.lfm.control.plane.rev150314.lispaddress.lispaddresscontainer.address.lcafsegment.LcafSegmentAddrBuilder;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
28 public class MaskUtil {
29 private static final Logger LOG = LoggerFactory.getLogger(MaskUtil.class);
30 public static boolean isMaskable(LispAFIAddress address) {
31 if (address instanceof Ipv4Address || address instanceof Ipv6Address
32 || address instanceof LcafSegmentAddr) {
38 public static LispAFIAddress normalize(LispAFIAddress address, int mask) {
40 if (address instanceof Ipv4Address) {
41 return LispAFIConvertor.asIPAfiAddress(normalizeIP(Inet4Address.getByName(((Ipv4Address) address)
42 .getIpv4Address().getValue()), mask).getHostAddress());
43 } else if (address instanceof Ipv6Address) {
44 return LispAFIConvertor.asIPv6AfiAddress(normalizeIP(Inet6Address.getByName(((Ipv6Address) address)
45 .getIpv6Address().getValue()), mask).getHostAddress());
46 } else if (address instanceof LcafSegmentAddr) {
47 LcafSegmentAddr segAddr = (LcafSegmentAddr) address;
48 Address normalizedAddr = new AddressBuilder().setPrimitiveAddress(LispAFIConvertor.toPrimitive(
49 normalizeIpAddress(LispAFIConvertor.toAFIfromPrimitive(segAddr.getAddress()
50 .getPrimitiveAddress()), mask))).build();
51 return new LcafSegmentAddrBuilder(segAddr).setAddress(normalizedAddr).build();
53 } catch (UnknownHostException e) {
54 LOG.trace("Failed to normalize " + address + ": " + ExceptionUtils.getStackTrace(e));
60 private static LispAFIAddress normalizeIpAddress(LispAFIAddress address, int mask) throws UnknownHostException {
61 if (address instanceof Ipv4Address) {
62 return LispAFIConvertor.asIPAfiAddress(normalizeIP(Inet4Address.getByName(((Ipv4Address) address)
63 .getIpv4Address().getValue()), mask).getHostAddress());
64 } else if (address instanceof Ipv6Address) {
65 return LispAFIConvertor.asIPv6AfiAddress(normalizeIP(Inet6Address.getByName(((Ipv6Address) address)
66 .getIpv6Address().getValue()), mask).getHostAddress());
68 throw new UnknownHostException("Address + " + address + " not an IPv4 or IPv6 address");
71 private static InetAddress normalizeIP(InetAddress address, int mask) throws UnknownHostException {
72 ByteBuffer byteRepresentation = ByteBuffer.wrap(address.getAddress());
74 for (int i = 0; i < byteRepresentation.array().length; i++) {
76 byteRepresentation.put(i, (byte) (b & byteRepresentation.get(i)));
79 byteRepresentation.put(i, (byte) ((byte) (b << (8 - mask)) & byteRepresentation.get(i)));
81 byteRepresentation.put(i, (byte) (0 & byteRepresentation.get(i)));
86 return InetAddress.getByAddress(byteRepresentation.array());
89 public static int getMaxMask(LispAFIAddress address) {
90 if (address instanceof Ipv4Address) {
93 if (address instanceof Ipv6Address) {
99 public static byte getMaxMaskForAfi(int afi) {
102 } else if (afi == 2){