[onosfw.git] /

/*\r
 * Copyright 2015 Open Networking Laboratory\r
 *\r
 * Licensed under the Apache License, Version 2.0 (the "License");\r
 * you may not use this file except in compliance with the License.\r
 * You may obtain a copy of the License at\r
 *\r
 *     http://www.apache.org/licenses/LICENSE-2.0\r
 *\r
 * Unless required by applicable law or agreed to in writing, software\r
 * distributed under the License is distributed on an "AS IS" BASIS,\r
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
 * See the License for the specific language governing permissions and\r
 * limitations under the License.\r
 */\r
package org.onosproject.ovsdb.provider.host;\r
\r
import static com.google.common.base.Preconditions.checkNotNull;\r
import static org.onlab.util.Tools.toHex;\r
import static org.slf4j.LoggerFactory.getLogger;\r
\r
import java.net.URI;\r
import java.net.URISyntaxException;\r
\r
import org.apache.felix.scr.annotations.Activate;\r
import org.apache.felix.scr.annotations.Component;\r
import org.apache.felix.scr.annotations.Deactivate;\r
import org.apache.felix.scr.annotations.Reference;\r
import org.apache.felix.scr.annotations.ReferenceCardinality;\r
import org.apache.felix.scr.annotations.Service;\r
import org.onlab.packet.VlanId;\r
import org.onosproject.core.CoreService;\r
import org.onosproject.net.DefaultAnnotations;\r
import org.onosproject.net.DeviceId;\r
import org.onosproject.net.Host;\r
import org.onosproject.net.HostId;\r
import org.onosproject.net.HostLocation;\r
import org.onosproject.net.PortNumber;\r
import org.onosproject.net.SparseAnnotations;\r
import org.onosproject.net.host.DefaultHostDescription;\r
import org.onosproject.net.host.HostDescription;\r
import org.onosproject.net.host.HostProvider;\r
import org.onosproject.net.host.HostProviderRegistry;\r
import org.onosproject.net.host.HostProviderService;\r
import org.onosproject.net.host.HostService;\r
import org.onosproject.net.provider.AbstractProvider;\r
import org.onosproject.net.provider.ProviderId;\r
import org.onosproject.ovsdb.controller.EventSubject;\r
import org.onosproject.ovsdb.controller.OvsdbController;\r
import org.onosproject.ovsdb.controller.OvsdbEvent;\r
import org.onosproject.ovsdb.controller.OvsdbEventListener;\r
import org.onosproject.ovsdb.controller.OvsdbEventSubject;\r
import org.slf4j.Logger;\r
\r
/**\r
 * Provider which uses an ovsdb controller to detect host.\r
 */\r
@Component(immediate = true)\r
@Service\r
public class OvsdbHostProvider extends AbstractProvider implements HostProvider {\r
    private final Logger log = getLogger(getClass());\r
\r
    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)\r
    protected HostProviderRegistry providerRegistry;\r
\r
    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)\r
    protected HostService hostService;\r
    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)\r
    protected CoreService coreService;\r
    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)\r
    protected OvsdbController controller;\r
\r
    private HostProviderService providerService;\r
    private OvsdbEventListener innerEventListener = new InnerOvsdbEventListener();\r
\r
    @Activate\r
    public void activate() {\r
        providerService = providerRegistry.register(this);\r
        controller.addOvsdbEventListener(innerEventListener);\r
        log.info("Started");\r
    }\r
\r
    @Deactivate\r
    public void deactivate() {\r
        providerRegistry.unregister(this);\r
        providerService = null;\r
        log.info("Stopped");\r
    }\r
\r
    public OvsdbHostProvider() {\r
        super(new ProviderId("ovsdb", "org.onosproject.ovsdb.provider.host"));\r
    }\r
\r
    @Override\r
    public void triggerProbe(Host host) {\r
        log.info("Triggering probe on host {}", host);\r
    }\r
\r
    private class InnerOvsdbEventListener implements OvsdbEventListener {\r
\r
        @Override\r
        public void handle(OvsdbEvent<EventSubject> event) {\r
            OvsdbEventSubject subject = null;\r
            if (event.subject() instanceof OvsdbEventSubject) {\r
                subject = (OvsdbEventSubject) event.subject();\r
            }\r
            checkNotNull(subject, "EventSubject is not null");\r
            // If ifaceid is null,it indicates this is not a vm port.\r
            if (subject.ifaceid() == null) {\r
                return;\r
            }\r
            switch (event.type()) {\r
            case PORT_ADDED:\r
                HostId hostId = HostId.hostId(subject.hwAddress(), null);\r
                DeviceId deviceId = DeviceId.deviceId(uri(subject.dpid().value()));\r
                PortNumber portNumber = PortNumber.portNumber(subject\r
                        .portNumber().value(), subject.portName().value());\r
                HostLocation loaction = new HostLocation(deviceId, portNumber,\r
                                                         0L);\r
                SparseAnnotations annotations = DefaultAnnotations.builder()\r
                        .set("ifaceid", subject.ifaceid().value()).build();\r
                HostDescription hostDescription = new DefaultHostDescription(\r
                                                                             subject.hwAddress(),\r
                                                                             VlanId.vlanId(),\r
                                                                             loaction,\r
                                                                             annotations);\r
                providerService.hostDetected(hostId, hostDescription);\r
                break;\r
            case PORT_REMOVED:\r
                HostId host = HostId.hostId(subject.hwAddress(), null);\r
                providerService.hostVanished(host);\r
                break;\r
            default:\r
                break;\r
            }\r
\r
        }\r
\r
    }\r
\r
    public URI uri(String value) {\r
        try {\r
            return new URI("of", toHex(Long.valueOf(value)), null);\r
        } catch (URISyntaxException e) {\r
            return null;\r
        }\r
    }\r
}\r