BgpManager commit for:

[vpnservice.git] / bgpmanager / bgpmanager-impl / src / main / java / org / opendaylight / bgpmanager / thrift / server / implementation / BgpUpdateHandler.java

diff --git a/bgpmanager/bgpmanager-impl/src/main/java/org/opendaylight/bgpmanager/thrift/server/implementation/BgpUpdateHandler.java b/bgpmanager/bgpmanager-impl/src/main/java/org/opendaylight/bgpmanager/thrift/server/implementation/BgpUpdateHandler.java
index 8688070930c8301bae8530b9921a9d8cc9701cc4..d0825d9ded0f62e356ba49d7db903e2df952b86e 100644 (file)
--- a/bgpmanager/bgpmanager-impl/src/main/java/org/opendaylight/bgpmanager/thrift/server/implementation/BgpUpdateHandler.java
+++ b/bgpmanager/bgpmanager-impl/src/main/java/org/opendaylight/bgpmanager/thrift/server/implementation/BgpUpdateHandler.java
@@ -1,35 +1,49 @@
 package org.opendaylight.bgpmanager.thrift.server.implementation;
 
+import org.opendaylight.bgpmanager.BgpManager;
+import org.opendaylight.bgpmanager.FibDSWriter;
 import org.opendaylight.bgpmanager.thrift.gen.BgpUpdater;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.util.*;
-
 class BgpUpdateHandler implements BgpUpdater.Iface {
 
     private static final Logger logger = LoggerFactory.getLogger(BgpUpdateHandler.class);
+    private BgpManager bgpManager;
+    private FibDSWriter fibDSWriter;
+
+    public BgpUpdateHandler(BgpManager bgpMgr, FibDSWriter dsWriter) {
+        bgpManager = bgpMgr;
+        fibDSWriter = dsWriter;
+
+        //Test
+        onUpdatePushRoute("5", "10.1.1.2", 32, "1.2.3.4", 200);
+        onUpdatePushRoute("5", "10.1.1.3", 32, "1.2.3.5", 400);
+        onUpdatePushRoute("10", "10.10.0.10", 32, "5.4.3.2", 600);
+        onUpdateWithdrawRoute("5", "10.1.1.3", 32);
 
-    public BgpUpdateHandler() {}
+
+    }
 
     public void onUpdatePushRoute(String rd, String prefix, int plen,
                                 String nexthop, int label) {
+
        logger.info("Route add ** " + rd + " ** " + prefix + "/" + plen
                + " ** " + nexthop + " ** " + label);
         //Write to FIB in Data Store
+        fibDSWriter.addFibEntryToDS(rd, prefix + "/" + plen, nexthop, label);
 
    }
 
    public void onUpdateWithdrawRoute(String rd, String prefix, int plen) {
        logger.info("Route del ** " + rd + " ** " + prefix + "/" + plen);
-       //Write to FIB in Data Store
+       fibDSWriter.removeFibEntryFromDS(rd, prefix + "/" + plen);
 
    }
 
    public void onStartConfigResyncNotification() {
        logger.info("BGP (re)started");
-
-        //Reconfigure BGP
+       bgpManager.reInitConn();
    }
 
 }