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.providers.device;
  17
  18 import static com.google.common.base.Preconditions.checkNotNull;
  19 import static org.slf4j.LoggerFactory.getLogger;
  20
  21 import java.net.URI;
  22
  23 import org.apache.felix.scr.annotations.Activate;
  24 import org.apache.felix.scr.annotations.Component;
  25 import org.apache.felix.scr.annotations.Deactivate;
  26 import org.apache.felix.scr.annotations.Reference;
  27 import org.apache.felix.scr.annotations.ReferenceCardinality;
  28 import org.apache.felix.scr.annotations.Service;
  29 import org.onlab.packet.ChassisId;
  30 import org.onosproject.net.DefaultAnnotations;
  31 import org.onosproject.net.Device;
  32 import org.onosproject.net.DeviceId;
  33 import org.onosproject.net.MastershipRole;
  34 import org.onosproject.net.SparseAnnotations;
  35 import org.onosproject.net.device.DefaultDeviceDescription;
  36 import org.onosproject.net.device.DeviceDescription;
  37 import org.onosproject.net.device.DeviceProvider;
  38 import org.onosproject.net.device.DeviceProviderRegistry;
  39 import org.onosproject.net.device.DeviceProviderService;
  40 import org.onosproject.net.device.DeviceService;
  41 import org.onosproject.net.provider.AbstractProvider;
  42 import org.onosproject.net.provider.ProviderId;
  43 import org.onosproject.ovsdb.controller.OvsdbController;
  44 import org.onosproject.ovsdb.controller.OvsdbNodeId;
  45 import org.onosproject.ovsdb.controller.OvsdbNodeListener;
  46 import org.slf4j.Logger;
  47
  48 /**
  49  * Provider which uses an ovsdb controller to detect device.
  50  */
  51 @Component(immediate = true)
  52 @Service
  53 public class OvsdbDeviceProvider extends AbstractProvider
  54         implements DeviceProvider {
  55     private final Logger log = getLogger(getClass());
  56
  57     @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
  58     protected DeviceProviderRegistry providerRegistry;
  59
  60     @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
  61     protected DeviceService deviceService;
  62     @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
  63     protected OvsdbController controller;
  64
  65     private DeviceProviderService providerService;
  66     private OvsdbNodeListener innerNodeListener = new InnerOvsdbNodeListener();
  67     protected static final String ISNOTNULL = "OvsdbNodeId is not null";
  68     private static final String UNKNOWN = "unknown";
  69
  70     @Activate
  71     public void activate() {
  72         providerService = providerRegistry.register(this);
  73         controller.addNodeListener(innerNodeListener);
  74         log.info("Started");
  75     }
  76
  77     @Deactivate
  78     public void deactivate() {
  79         providerRegistry.unregister(this);
  80         providerService = null;
  81         log.info("Stopped");
  82     }
  83
  84     public OvsdbDeviceProvider() {
  85         super(new ProviderId("ovsdb", "org.onosproject.ovsdb.provider.device"));
  86     }
  87
  88     @Override
  89     public void triggerProbe(DeviceId deviceId) {
  90         // TODO: This will be implemented later.
  91         log.info("Triggering probe on device {}", deviceId);
  92     }
  93
  94     @Override
  95     public void roleChanged(DeviceId deviceId, MastershipRole newRole) {
  96         // TODO: This will be implemented later.
  97     }
  98
  99     @Override
 100     public boolean isReachable(DeviceId deviceId) {
 101         return true;
 102     }
 103
 104     private class InnerOvsdbNodeListener implements OvsdbNodeListener {
 105
 106         @Override
 107         public void nodeAdded(OvsdbNodeId nodeId) {
 108             checkNotNull(nodeId, ISNOTNULL);
 109             DeviceId deviceId = DeviceId.deviceId(nodeId.toString());
 110             URI uri = URI.create(nodeId.toString());
 111             ChassisId cid = new ChassisId();
 112             String ipAddress = nodeId.getIpAddress();
 113             SparseAnnotations annotations = DefaultAnnotations.builder()
 114                     .set("ipaddress", ipAddress).build();
 115             DeviceDescription deviceDescription = new DefaultDeviceDescription(
 116                                                                                uri,
 117                                                                                Device.Type.CONTROLLER,
 118                                                                                UNKNOWN, UNKNOWN,
 119                                                                                UNKNOWN, UNKNOWN,
 120                                                                                cid,
 121                                                                                annotations);
 122             providerService.deviceConnected(deviceId, deviceDescription);
 123
 124         }
 125
 126         @Override
 127         public void nodeRemoved(OvsdbNodeId nodeId) {
 128             checkNotNull(nodeId, ISNOTNULL);
 129             DeviceId deviceId = DeviceId.deviceId(nodeId.toString());
 130             providerService.deviceDisconnected(deviceId);
 131
 132         }
 133     }
 134 }