import com.google.common.base.Optional;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
-
import java.net.Inet4Address;
import java.net.Inet6Address;
import java.net.InetAddress;
import org.slf4j.LoggerFactory;
public class BgpUtil {
+
private static final Logger LOG = LoggerFactory.getLogger(BgpUtil.class);
+
private static DataBroker dataBroker;
+
public static final int PERIODICITY = 500;
public static final int BATCH_SIZE = 1000;
+
public static Integer batchSize;
public static Integer batchInterval;
private static BlockingQueue<ActionableResource> bgpResourcesBufferQ = new LinkedBlockingQueue<>();
- /** get a translation from prefix ipv6 to afi<br>.
- * "ffff::1/128" sets afi as 2 because is an IPv6 value
- * @param argPrefix ip address as ipv4 or ipv6
- * @return afi 1 for AFI_IP 2 for AFI_IPV6
- */
+ /**
+ * get a translation from prefix ipv6 to afi<br>.
+ * "ffff::1/128" sets afi as 2 because is an IPv6 value
+ * @param argPrefix ip address as ipv4 or ipv6
+ * @return afi 1 for AFI_IP 2 for AFI_IPV6
+ */
public static int getAFItranslatedfromPrefix(String argPrefix) {
int retValue = af_afi.AFI_IP.getValue();//default afiValue is 1 (= ipv4)
String prefixOnly;
.child(VpnInstanceOpDataEntry.class, new VpnInstanceOpDataEntryKey(rd)).build();
}
- static String getElanNamefromRd(DataBroker broker, String rd) {
+ private static String getElanNamefromRd(DataBroker broker, String rd) {
InstanceIdentifier<EvpnRdToNetwork> id = getEvpnRdToNetworkIdentifier(rd);
Optional<EvpnRdToNetwork> evpnRdToNetworkOpData = MDSALUtil.read(broker,
LogicalDatastoreType.CONFIGURATION, id);
return null;
}
- public static InstanceIdentifier<EvpnRdToNetwork> getEvpnRdToNetworkIdentifier(String rd) {
+ private static InstanceIdentifier<EvpnRdToNetwork> getEvpnRdToNetworkIdentifier(String rd) {
return InstanceIdentifier.builder(EvpnRdToNetworks.class)
.child(EvpnRdToNetwork.class, new EvpnRdToNetworkKey(rd)).build();
}
BgpUtil.delete(dataBroker, LogicalDatastoreType.CONFIGURATION, externalTepsId);
}
- public static InstanceIdentifier<ExternalTeps> getExternalTepsIdentifier(String elanInstanceName, String tepIp) {
+ private static InstanceIdentifier<ExternalTeps> getExternalTepsIdentifier(String elanInstanceName, String tepIp) {
IpAddress tepAdress = tepIp == null ? null : new IpAddress(tepIp.toCharArray());
return InstanceIdentifier.builder(ElanInstances.class).child(ElanInstance.class,
new ElanInstanceKey(elanInstanceName)).child(ExternalTeps.class,
return vpnInstanceOpData != null ? vpnInstanceOpData.getVpnInstanceName() : null;
}
}
-