package org.opendaylight.protocol.bgp.state;
import com.google.common.primitives.UnsignedInteger;
-import com.google.common.primitives.UnsignedLong;
import java.math.BigDecimal;
-import java.math.BigInteger;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.network.instances.network.instance.protocols.protocol.bgp.neighbors.neighbor.state.messages.Sent;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.openconfig.extensions.rev180329.network.instances.network.instance.protocols.protocol.bgp.neighbors.neighbor.state.messages.SentBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329.rib.TablesKey;
+import org.opendaylight.yangtools.yang.common.Uint16;
import org.opendaylight.yangtools.yang.common.Uint32;
+import org.opendaylight.yangtools.yang.common.Uint64;
/**
* Util for create OpenConfig Neighbor with corresponding openConfig state.
final NeighborGracefulRestartStateAugmentation gracefulRestartState =
new NeighborGracefulRestartStateAugmentationBuilder()
.setLocalRestarting(neighbor.isLocalRestarting())
- .setPeerRestartTime(neighbor.getPeerRestartTime())
+ .setPeerRestartTime(Uint16.valueOf(neighbor.getPeerRestartTime()))
.setMode(neighbor.getMode())
.setPeerRestarting(neighbor.isPeerRestarting()).build();
private static Received buildMessagesReceived(final @NonNull BGPPeerMessagesState neighbor) {
return new ReceivedBuilder()
- .setUPDATE(toBigInteger(neighbor.getUpdateMessagesReceivedCount()))
- .setNOTIFICATION(toBigInteger(neighbor.getNotificationMessagesReceivedCount()))
+ .setUPDATE(Uint64.valueOf(neighbor.getUpdateMessagesReceivedCount()))
+ .setNOTIFICATION(Uint64.valueOf(neighbor.getNotificationMessagesReceivedCount()))
.build();
}
- public static BigInteger toBigInteger(final long updateReceivedCounter) {
- return UnsignedLong.valueOf(updateReceivedCounter).bigIntegerValue();
- }
-
private static Sent buildMessagesSent(final @NonNull BGPPeerMessagesState neighbor) {
return new SentBuilder()
- .setUPDATE(toBigInteger(neighbor.getUpdateMessagesSentCount()))
- .setNOTIFICATION(toBigInteger(neighbor.getNotificationMessagesSentCount()))
+ .setUPDATE(Uint64.valueOf(neighbor.getUpdateMessagesSentCount()))
+ .setNOTIFICATION(Uint64.valueOf(neighbor.getNotificationMessagesSentCount()))
.build();
}
final BGPSessionPreferences preferences = this.registry.getPeerPreferences(remoteIp);
final Uint16 as = openASNumber(preferences.getMyAs().getValue().longValue());
- sendMessage(new OpenBuilder().setMyAsNumber(as).setHoldTimer(preferences.getHoldTime()).setBgpIdentifier(
- preferences.getBgpId()).setBgpParameters(preferences.getParams()).build());
+ sendMessage(new OpenBuilder().setMyAsNumber(as).setHoldTimer(Uint16.valueOf(preferences.getHoldTime()))
+ .setBgpIdentifier(preferences.getBgpId()).setBgpParameters(preferences.getParams()).build());
if (this.state != State.FINISHED) {
this.state = State.OPEN_SENT;
this.pending = this.channel.eventLoop().schedule(() -> {
attBuilder.setLocalPref(new LocalPrefBuilder().setPref(Uint32.valueOf(localPreference)).build());
attBuilder.setOrigin(new OriginBuilder().setValue(BgpOrigin.Igp).build());
attBuilder.setAsPath(new AsPathBuilder().setSegments(Collections.emptyList()).build());
- attBuilder.setUnrecognizedAttributes(Collections.emptyList());
+ attBuilder.setUnrecognizedAttributes(Collections.emptyMap());
return new UpdateBuilder()
.setWithdrawnRoutes(Collections.singletonList(new WithdrawnRoutesBuilder().setPrefix(prefix).build()))
.build();
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.next.hop.c.next.hop.Ipv6NextHopCaseBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.next.hop.c.next.hop.ipv4.next.hop._case.Ipv4NextHopBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.next.hop.c.next.hop.ipv6.next.hop._case.Ipv6NextHopBuilder;
+import org.opendaylight.yangtools.yang.common.Uint16;
import org.opendaylight.yangtools.yang.common.Uint32;
final class PeerUtil {
.addAugmentation(new CParameters1Builder()
.setGracefulRestartCapability(new GracefulRestartCapabilityBuilder()
.setRestartFlags(new GracefulRestartCapability.RestartFlags(false))
- .setRestartTime(restartTime)
+ .setRestartTime(Uint16.valueOf(restartTime))
.setTables(gracefulTables.keySet().stream()
.map(key -> new TablesBuilder()
.setAfi(key.getAfi())