apps/sdnip/src/main/java/org/onlab/onos/sdnip/SdnIp.java

package org.onlab.onos.sdnip;

import static org.slf4j.LoggerFactory.getLogger;

import org.apache.felix.scr.annotations.Activate;
import org.apache.felix.scr.annotations.Component;
import org.apache.felix.scr.annotations.Deactivate;
import org.apache.felix.scr.annotations.Reference;
import org.apache.felix.scr.annotations.ReferenceCardinality;
import org.onlab.onos.net.host.HostService;
import org.onlab.onos.net.intent.IntentService;
import org.onlab.onos.sdnip.RouteUpdate.Type;
import org.onlab.onos.sdnip.bgp.BgpSessionManager;
import org.onlab.onos.sdnip.config.SdnIpConfigReader;
import org.onlab.packet.IpAddress;
import org.onlab.packet.IpPrefix;
import org.slf4j.Logger;

/**
 * Placeholder SDN-IP component.
 */
@Component(immediate = true)
public class SdnIp {

    private final Logger log = getLogger(getClass());

    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
    protected IntentService intentService;

    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
    protected HostService hostService;

    private SdnIpConfigReader config;
    private PeerConnectivity peerConnectivity;
    private Router router;
    private BgpSessionManager bgpSessionManager;

    @Activate
    protected void activate() {
        log.debug("SDN-IP started");

        config = new SdnIpConfigReader();
        config.init();

        InterfaceService interfaceService = new HostServiceBasedInterfaceService(hostService);

        peerConnectivity = new PeerConnectivity(config, interfaceService, intentService);
        peerConnectivity.start();

        router = new Router(intentService, hostService, config, interfaceService);
        router.start();

        bgpSessionManager = new BgpSessionManager(router);
        bgpSessionManager.startUp(2000); // TODO

        // TODO need to disable link discovery on external ports

        router.update(new RouteUpdate(Type.UPDATE, new RouteEntry(
                IpPrefix.valueOf("172.16.20.0/24"),
                IpAddress.valueOf("192.168.10.1"))));
    }

    @Deactivate
    protected void deactivate() {
        log.info("Stopped");
    }
}