BUG-353: add remote-as awareness

[bgpcep.git] / bgp / rib-impl / src / main / java / org / opendaylight / protocol / bgp / rib / impl / BGPSessionImpl.java

diff --git a/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPSessionImpl.java b/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPSessionImpl.java
index 3a68dcecc06ea4d70655a006e6c86dddc5ba9fec..e40f60f3d3d086f3e4dbf7a421b464f072d6f799 100644 (file)
--- a/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPSessionImpl.java
+++ b/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/BGPSessionImpl.java
@@ -19,17 +19,21 @@ import java.util.concurrent.TimeUnit;
 
 import javax.annotation.concurrent.GuardedBy;
 
+import org.opendaylight.protocol.bgp.parser.AsNumberUtil;
 import org.opendaylight.protocol.bgp.parser.BGPError;
 import org.opendaylight.protocol.bgp.parser.BGPSession;
 import org.opendaylight.protocol.bgp.parser.BGPSessionListener;
 import org.opendaylight.protocol.bgp.parser.BGPTerminationReason;
 import org.opendaylight.protocol.bgp.parser.BgpTableTypeImpl;
 import org.opendaylight.protocol.framework.AbstractProtocolSession;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.AsNumber;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.Keepalive;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.KeepaliveBuilder;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.Notify;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.NotifyBuilder;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.Open;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.Update;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.BgpParameters;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev130919.open.bgp.parameters.CParameters;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev130919.BgpTableType;
@@ -57,8 +61,6 @@ public class BGPSessionImpl extends AbstractProtocolSession<Notification> implem
 
        private static final Notification KEEP_ALIVE = new KeepaliveBuilder().build();
 
-       private static int holdTimerValue = DEFAULT_HOLD_TIMER_VALUE;
-
        /**
         * Internal session state.
         */
@@ -106,24 +108,29 @@ public class BGPSessionImpl extends AbstractProtocolSession<Notification> implem
        @GuardedBy("this")
        private State state = State.OpenConfirm;
 
-       private final int keepAlive;
 
        private final Set<BgpTableType> tableTypes;
+       private final int holdTimerValue;
+       private final int keepAlive;
+       private final AsNumber asNumber;
+       private final Ipv4Address bgpId;
 
        BGPSessionImpl(final Timer timer, final BGPSessionListener listener, final Channel channel, final Open remoteOpen) {
                this.listener = Preconditions.checkNotNull(listener);
                this.stateTimer = Preconditions.checkNotNull(timer);
                this.channel = Preconditions.checkNotNull(channel);
                this.keepAlive = remoteOpen.getHoldTimer() / 3;
-               holdTimerValue = remoteOpen.getHoldTimer();
+               this.holdTimerValue = remoteOpen.getHoldTimer();
+               this.asNumber = AsNumberUtil.advertizedAsNumber(remoteOpen);
 
                final Set<TablesKey> tts = Sets.newHashSet();
                final Set<BgpTableType> tats = Sets.newHashSet();
                if (remoteOpen.getBgpParameters() != null) {
                        for (final BgpParameters param : remoteOpen.getBgpParameters()) {
-                               if (param instanceof CParameters) {
-                                       final CParameters cp = (CParameters) param;
+                               final CParameters cp = param.getCParameters();
+                               if (cp instanceof MultiprotocolCase) {
                                        final TablesKey tt = new TablesKey(((MultiprotocolCase) cp).getMultiprotocolCapability().getAfi(), ((MultiprotocolCase) cp).getMultiprotocolCapability().getSafi());
+                                       LOG.trace("Added table type to sync {}", tt);
                                        tts.add(tt);
                                        tats.add(new BgpTableTypeImpl(tt.getAfi(), tt.getSafi()));
                                }
@@ -149,6 +156,7 @@ public class BGPSessionImpl extends AbstractProtocolSession<Notification> implem
                                }
                        }, this.keepAlive, TimeUnit.SECONDS);
                }
+               this.bgpId = remoteOpen.getBgpIdentifier();
        }
 
        @Override
@@ -191,6 +199,7 @@ public class BGPSessionImpl extends AbstractProtocolSession<Notification> implem
                } else {
                        // All others are passed up
                        this.listener.onMessage(this, msg);
+                       this.sync.updReceived((Update) msg);
                }
        }
 
@@ -308,4 +317,14 @@ public class BGPSessionImpl extends AbstractProtocolSession<Notification> implem
        public synchronized State getState() {
                return this.state;
        }
+
+       @Override
+       public final byte[] getBgpId() {
+               return this.bgpId.getValue().getBytes();
+       }
+
+       @Override
+       public final AsNumber getAsNumber() {
+               return this.asNumber;
+       }
 }