gerrit.opnfv Code Review - onosfw.git/blob

   1 /*
   2  * Copyright 2015 Open Networking Laboratory
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16 package org.onosproject.ovsdb.provider.host;
  17
  18 import static com.google.common.base.Preconditions.checkNotNull;
  19 import static org.onlab.util.Tools.toHex;
  20 import static org.slf4j.LoggerFactory.getLogger;
  21
  22 import java.net.URI;
  23 import java.net.URISyntaxException;
  24
  25 import org.apache.felix.scr.annotations.Activate;
  26 import org.apache.felix.scr.annotations.Component;
  27 import org.apache.felix.scr.annotations.Deactivate;
  28 import org.apache.felix.scr.annotations.Reference;
  29 import org.apache.felix.scr.annotations.ReferenceCardinality;
  30 import org.apache.felix.scr.annotations.Service;
  31 import org.onlab.packet.VlanId;
  32 import org.onosproject.core.CoreService;
  33 import org.onosproject.net.DefaultAnnotations;
  34 import org.onosproject.net.DeviceId;
  35 import org.onosproject.net.Host;
  36 import org.onosproject.net.HostId;
  37 import org.onosproject.net.HostLocation;
  38 import org.onosproject.net.PortNumber;
  39 import org.onosproject.net.SparseAnnotations;
  40 import org.onosproject.net.host.DefaultHostDescription;
  41 import org.onosproject.net.host.HostDescription;
  42 import org.onosproject.net.host.HostProvider;
  43 import org.onosproject.net.host.HostProviderRegistry;
  44 import org.onosproject.net.host.HostProviderService;
  45 import org.onosproject.net.host.HostService;
  46 import org.onosproject.net.provider.AbstractProvider;
  47 import org.onosproject.net.provider.ProviderId;
  48 import org.onosproject.ovsdb.controller.EventSubject;
  49 import org.onosproject.ovsdb.controller.OvsdbController;
  50 import org.onosproject.ovsdb.controller.OvsdbEvent;
  51 import org.onosproject.ovsdb.controller.OvsdbEventListener;
  52 import org.onosproject.ovsdb.controller.OvsdbEventSubject;
  53 import org.slf4j.Logger;
  54
  55 /**
  56  * Provider which uses an ovsdb controller to detect host.
  57  */
  58 @Component(immediate = true)
  59 @Service
  60 public class OvsdbHostProvider extends AbstractProvider implements HostProvider {
  61     private final Logger log = getLogger(getClass());
  62
  63     @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
  64     protected HostProviderRegistry providerRegistry;
  65
  66     @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
  67     protected HostService hostService;
  68     @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
  69     protected CoreService coreService;
  70     @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
  71     protected OvsdbController controller;
  72
  73     private HostProviderService providerService;
  74     private OvsdbEventListener innerEventListener = new InnerOvsdbEventListener();
  75
  76     @Activate
  77     public void activate() {
  78         providerService = providerRegistry.register(this);
  79         controller.addOvsdbEventListener(innerEventListener);
  80         log.info("Started");
  81     }
  82
  83     @Deactivate
  84     public void deactivate() {
  85         providerRegistry.unregister(this);
  86         providerService = null;
  87         log.info("Stopped");
  88     }
  89
  90     public OvsdbHostProvider() {
  91         super(new ProviderId("ovsdb", "org.onosproject.ovsdb.provider.host"));
  92     }
  93
  94     @Override
  95     public void triggerProbe(Host host) {
  96         log.info("Triggering probe on host {}", host);
  97     }
  98
  99     private class InnerOvsdbEventListener implements OvsdbEventListener {
 100
 101         @Override
 102         public void handle(OvsdbEvent<EventSubject> event) {
 103             OvsdbEventSubject subject = null;
 104             if (event.subject() instanceof OvsdbEventSubject) {
 105                 subject = (OvsdbEventSubject) event.subject();
 106             }
 107             checkNotNull(subject, "EventSubject is not null");
 108             // If ifaceid is null,it indicates this is not a vm port.
 109             if (subject.ifaceid() == null) {
 110                 return;
 111             }
 112             switch (event.type()) {
 113             case PORT_ADDED:
 114                 HostId hostId = HostId.hostId(subject.hwAddress(), null);
 115                 DeviceId deviceId = DeviceId.deviceId(uri(subject.dpid().value()));
 116                 PortNumber portNumber = PortNumber.portNumber(subject
 117                         .portNumber().value(), subject.portName().value());
 118                 HostLocation loaction = new HostLocation(deviceId, portNumber,
 119                                                          0L);
 120                 SparseAnnotations annotations = DefaultAnnotations.builder()
 121                         .set("ifaceid", subject.ifaceid().value()).build();
 122                 HostDescription hostDescription = new DefaultHostDescription(
 123                                                                              subject.hwAddress(),
 124                                                                              VlanId.vlanId(),
 125                                                                              loaction,
 126                                                                              annotations);
 127                 providerService.hostDetected(hostId, hostDescription);
 128                 break;
 129             case PORT_REMOVED:
 130                 HostId host = HostId.hostId(subject.hwAddress(), null);
 131                 providerService.hostVanished(host);
 132                 break;
 133             default:
 134                 break;
 135             }
 136
 137         }
 138
 139     }
 140
 141     public URI uri(String value) {
 142         try {
 143             return new URI("of", toHex(Long.valueOf(value)), null);
 144         } catch (URISyntaxException e) {
 145             return null;
 146         }
 147     }
 148 }