blob: 686afcf89cea36780b7e021a29abc4cf388d0ffc [file] [log] [blame]
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -08001# Copyright 2017-present Open Networking Foundation
2#
3# Licensed under the Apache License, Version 2.0 (the "License");
4# you may not use this file except in compliance with the License.
5# You may obtain a copy of the License at
6#
7# http://www.apache.org/licenses/LICENSE-2.0
8#
9# Unless required by applicable law or agreed to in writing, software
10# distributed under the License is distributed on an "AS IS" BASIS,
11# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12# See the License for the specific language governing permissions and
13# limitations under the License.
14
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080015from time import sleep
Matteo Scandolod44ca992018-05-17 15:02:10 -070016
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080017import requests
Matteo Scandolod44ca992018-05-17 15:02:10 -070018from multistructlog import create_logger
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080019from requests.auth import HTTPBasicAuth
Scott Baker47b47302019-01-30 16:55:07 -080020from xossynchronizer.steps.syncstep import SyncStep, DeferredException
21from xossynchronizer.modelaccessor import OLTDevice, model_accessor
Matteo Scandolod44ca992018-05-17 15:02:10 -070022from xosconfig import Config
23
24import os, sys
25sys.path.append(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
26
Matteo Scandolof6337eb2018-04-05 15:58:37 -070027from helpers import Helpers
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080028
29log = create_logger(Config().get('logging'))
30
31class SyncOLTDevice(SyncStep):
32 provides = [OLTDevice]
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080033 observes = OLTDevice
34
Matteo Scandolo096a3cf2018-06-20 13:56:13 -070035 max_attempt = 120 # we give 10 minutes to the OLT to activate
36
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080037 @staticmethod
Matteo Scandolof6337eb2018-04-05 15:58:37 -070038 def get_ids_from_logical_device(o):
Luca Preteca974c82018-05-01 18:06:16 -070039 voltha = Helpers.get_voltha_info(o.volt_service)
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080040
Luca Preteca974c82018-05-01 18:06:16 -070041 request = requests.get("%s:%d/api/v1/logical_devices" % (voltha['url'], voltha['port']))
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080042
Luca Preteca974c82018-05-01 18:06:16 -070043 if request.status_code != 200:
44 raise Exception("Failed to retrieve logical devices from VOLTHA: %s" % request.text)
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080045
Luca Preteca974c82018-05-01 18:06:16 -070046 response = request.json()
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080047
Luca Preteca974c82018-05-01 18:06:16 -070048 for ld in response["items"]:
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080049 if ld["root_device_id"] == o.device_id:
Matteo Scandolof6337eb2018-04-05 15:58:37 -070050 o.of_id = ld["id"]
Luca Preteca974c82018-05-01 18:06:16 -070051 o.dp_id = "of:%s" % (Helpers.datapath_id_to_hex(ld["datapath_id"])) # Convert to hex
Matteo Scandolof6337eb2018-04-05 15:58:37 -070052 return o
53
Matteo Scandolo2c144932018-05-04 14:06:24 -070054 raise Exception("Can't find a logical_device for OLT device id: %s" % o.device_id)
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080055
Matteo Scandolo2c144932018-05-04 14:06:24 -070056 def pre_provision_olt_device(self, model):
57 log.info("Pre-provisioning OLT device in VOLTHA", object=str(model), **model.tologdict())
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -080058
Matteo Scandolo2c144932018-05-04 14:06:24 -070059 voltha = Helpers.get_voltha_info(model.volt_service)
Luca Preteca974c82018-05-01 18:06:16 -070060
Matteo Scandolo2c144932018-05-04 14:06:24 -070061 data = {
Matteo Scandolo2ed64b92018-06-18 10:32:56 -070062 "type": model.device_type
Matteo Scandolo2c144932018-05-04 14:06:24 -070063 }
64
Matteo Scandolo2ed64b92018-06-18 10:32:56 -070065 if hasattr(model, "host") and hasattr(model, "port"):
66 data["host_and_port"] = "%s:%s" % (model.host, model.port)
67 elif hasattr(model, "mac_address"):
68 data["mac_address"] = model.mac_address
Matteo Scandolo2c144932018-05-04 14:06:24 -070069
70 log.info("Pushing OLT to Voltha", data=data)
71
72 request = requests.post("%s:%d/api/v1/devices" % (voltha['url'], voltha['port']), json=data)
73
74 if request.status_code != 200:
75 raise Exception("Failed to add OLT device: %s" % request.text)
76
77 log.info("Add device response", text=request.text)
78
79 res = request.json()
80
81 log.info("Add device json res", res=res)
82
Scott Baker09798d82019-01-17 08:34:59 -080083 # TODO(smbaker): Potential partial failure. If device is created in Voltha but synchronizer crashes before the
84 # model is saved, then synchronizer will continue to try to preprovision and fail due to preexisting
85 # device.
86
Matteo Scandolo2c144932018-05-04 14:06:24 -070087 if not res['id']:
88 raise Exception(
89 'VOLTHA Device Id is empty. This probably means that the OLT device is already provisioned in VOLTHA')
90 else:
Matteo Scandolod6fce512018-10-16 10:35:29 -070091 model.device_id = res['id']
92 model.serial_number = res['serial_number']
Andy Bavier00c573c2019-02-08 16:19:11 -070093 model.save_changed_fields()
Matteo Scandolo2c144932018-05-04 14:06:24 -070094
95 def activate_olt(self, model):
96
Matteo Scandolo096a3cf2018-06-20 13:56:13 -070097 attempted = 0
98
Matteo Scandolo2c144932018-05-04 14:06:24 -070099 voltha = Helpers.get_voltha_info(model.volt_service)
100
101 # Enable device
102 request = requests.post("%s:%d/api/v1/devices/%s/enable" % (voltha['url'], voltha['port'], model.device_id))
103
104 if request.status_code != 200:
105 raise Exception("Failed to enable OLT device: %s" % request.text)
106
Matteo Scandolo096a3cf2018-06-20 13:56:13 -0700107 model.backend_status = "Waiting for device to be activated"
Andy Bavier00c573c2019-02-08 16:19:11 -0700108 model.save_changed_fields(always_update_timestamp=False) # we don't want to kickoff a new loop
Matteo Scandolo096a3cf2018-06-20 13:56:13 -0700109
Matteo Scandolo2c144932018-05-04 14:06:24 -0700110 # Read state
111 request = requests.get("%s:%d/api/v1/devices/%s" % (voltha['url'], voltha['port'], model.device_id)).json()
Matteo Scandolo096a3cf2018-06-20 13:56:13 -0700112 while request['oper_status'] == "ACTIVATING" and attempted < self.max_attempt:
Matteo Scandolo2c144932018-05-04 14:06:24 -0700113 log.info("Waiting for OLT device %s (%s) to activate" % (model.name, model.device_id))
114 sleep(5)
115 request = requests.get("%s:%d/api/v1/devices/%s" % (voltha['url'], voltha['port'], model.device_id)).json()
Matteo Scandolo096a3cf2018-06-20 13:56:13 -0700116 attempted = attempted + 1
117
Matteo Scandolo2c144932018-05-04 14:06:24 -0700118 model.oper_status = request['oper_status']
Matteo Scandolo45876652018-10-16 16:03:17 -0700119 model.serial_number = request['serial_number']
Matteo Scandolo2c144932018-05-04 14:06:24 -0700120
Matteo Scandolo096a3cf2018-06-20 13:56:13 -0700121 if model.oper_status != "ACTIVE":
122 raise Exception("It was not possible to activate OLTDevice with id %s" % model.id)
123
Matteo Scandolo2c144932018-05-04 14:06:24 -0700124 # Find the of_id of the device
Scott Baker09798d82019-01-17 08:34:59 -0800125 self.get_ids_from_logical_device(model)
Andy Bavier00c573c2019-02-08 16:19:11 -0700126 model.save_changed_fields()
Matteo Scandolo2c144932018-05-04 14:06:24 -0700127
Scott Baker09798d82019-01-17 08:34:59 -0800128 def deactivate_olt(self, model):
129 voltha = Helpers.get_voltha_info(model.volt_service)
130
131 # Disable device
132 request = requests.post("%s:%d/api/v1/devices/%s/disable" % (voltha['url'], voltha['port'], model.device_id))
133
134 if request.status_code != 200:
135 raise Exception("Failed to disable OLT device: %s" % request.text)
Matteo Scandolo2c144932018-05-04 14:06:24 -0700136
Matteo Scandoloa79395f2018-10-08 13:34:49 -0700137 def configure_onos(self, model):
138
139 log.info("Adding OLT device in onos-voltha", object=str(model), **model.tologdict())
140
141 onos_voltha = Helpers.get_onos_voltha_info(model.volt_service)
142 onos_voltha_basic_auth = HTTPBasicAuth(onos_voltha['user'], onos_voltha['pass'])
143
144 # Add device info to onos-voltha
145 data = {
146 "devices": {
147 model.dp_id: {
148 "basic": {
149 "name": model.name
150 }
151 }
152 }
153 }
154
155 log.info("Calling ONOS", data=data)
156
157 url = "%s:%d/onos/v1/network/configuration/" % (onos_voltha['url'], onos_voltha['port'])
158 request = requests.post(url, json=data, auth=onos_voltha_basic_auth)
159
160 if request.status_code != 200:
161 log.error(request.text)
162 raise Exception("Failed to add OLT device %s into ONOS" % model.name)
163 else:
164 try:
165 print request.json()
166 except Exception:
167 print request.text
Matteo Scandoloa79395f2018-10-08 13:34:49 -0700168
Matteo Scandolo2c144932018-05-04 14:06:24 -0700169 def sync_record(self, model):
170 log.info("Synching device", object=str(model), **model.tologdict())
171
Scott Baker09798d82019-01-17 08:34:59 -0800172 if model.admin_state not in ["ENABLED", "DISABLED"]:
173 raise Exception("OLT Device %s admin_state has invalid value %s" % (model.id, model.admin_state))
174
Matteo Scandolo2c144932018-05-04 14:06:24 -0700175 # If the device has feedback_state is already present in voltha
Scott Baker09798d82019-01-17 08:34:59 -0800176 if not model.device_id and not model.oper_status and not model.of_id:
Matteo Scandolo2c144932018-05-04 14:06:24 -0700177 log.info("Pushing OLT device to VOLTHA", object=str(model), **model.tologdict())
Scott Baker09798d82019-01-17 08:34:59 -0800178 self.pre_provision_olt_device(model)
179 model.oper_status = "UNKNOWN" # fall-though to activate OLT
Matteo Scandolo2c144932018-05-04 14:06:24 -0700180 else:
181 log.info("OLT device already exists in VOLTHA", object=str(model), **model.tologdict())
182
Scott Baker09798d82019-01-17 08:34:59 -0800183 # Reconcile admin_state and oper_status, activating or deactivating the OLT as necessary.
184
185 if model.oper_status != "ACTIVE" and model.admin_state == "ENABLED":
186 self.activate_olt(model)
187 elif model.oper_status == "ACTIVE" and model.admin_state == "DISABLED":
188 self.deactivate_olt(model)
189
190 if model.admin_state == "ENABLED":
191 # If we were not able to reconcile ENABLE/ACTIVE, then throw an exception and do not proceed to onos
192 # configuration.
193 if model.oper_status != "ACTIVE":
194 raise Exception("It was not possible to activate OLTDevice with id %s" % model.id)
195
196 # At this point OLT is enabled and active. Configure ONOS.
197 self.configure_onos(model)
Matteo Scandoloa79395f2018-10-08 13:34:49 -0700198
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700199 def delete_record(self, model):
200 log.info("Deleting OLT device", object=str(model), **model.tologdict())
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800201
Matteo Scandolo6be6ee92018-05-24 15:07:51 -0700202 voltha = Helpers.get_voltha_info(model.volt_service)
Luca Preteca974c82018-05-01 18:06:16 -0700203
Matteo Scandolo563891c2018-08-21 11:56:32 -0700204 if not model.device_id or model.backend_code == 2:
205 # NOTE if the device was not synchronized, just remove it from the data model
206 log.warning("OLTDevice %s has no device_id, it was never saved in VOLTHA" % model.name)
207 return
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800208 else:
Scott Baker22b46c52018-11-15 15:15:29 -0800209 try:
210 # Disable the OLT device
211 request = requests.post("%s:%d/api/v1/devices/%s/disable" % (voltha['url'], voltha['port'], model.device_id))
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800212
Scott Baker22b46c52018-11-15 15:15:29 -0800213 if request.status_code != 200:
214 log.error("Failed to disable OLT device in VOLTHA: %s - %s" % (model.name, model.device_id), rest_response=request.text, rest_status_code=request.status_code)
215 raise Exception("Failed to disable OLT device in VOLTHA")
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800216
Scott Baker22b46c52018-11-15 15:15:29 -0800217 # NOTE [teo] wait some time after the disable to let VOLTHA doing its things
218 i = 0
219 for i in list(reversed(range(10))):
220 sleep(1)
221 log.info("Deleting the OLT in %s seconds" % i)
Matteo Scandolof7ebb112018-09-18 16:17:22 -0700222
Scott Baker22b46c52018-11-15 15:15:29 -0800223 # Delete the OLT device
224 request = requests.delete("%s:%d/api/v1/devices/%s/delete" % (voltha['url'], voltha['port'], model.device_id))
Matteo Scandolo4a8b4d62018-03-06 17:18:46 -0800225
Scott Baker22b46c52018-11-15 15:15:29 -0800226 if request.status_code != 200:
227 log.error("Failed to delete OLT device from VOLTHA: %s - %s" % (model.name, model.device_id), rest_response=request.text, rest_status_code=request.status_code)
228 raise Exception("Failed to delete OLT device from VOLTHA")
229 except requests.ConnectionError:
230 log.warning("ConnectionError when contacting Voltha in OLT delete step", name=model.name, device_id=model.device_id)