Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 1 | # |
| 2 | # Copyright 2018 the original author or authors. |
| 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 | |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 17 | from voltha.extensions.alarms.device_alarms import DeviceAlarms |
| 18 | from voltha.extensions.alarms.simulator.simulate_alarms \ |
| 19 | import AdapterAlarmSimulator |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 20 | from voltha.extensions.alarms.olt.olt_los_alarm import OltLosAlarm |
| 21 | from voltha.extensions.alarms.onu.onu_dying_gasp_alarm import OnuDyingGaspAlarm |
| 22 | from voltha.extensions.alarms.onu.onu_los_alarm import OnuLosAlarm |
| 23 | from voltha.extensions.alarms.onu.onu_lopc_miss_alarm import OnuLopcMissAlarm |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 24 | from voltha.extensions.alarms.onu.onu_lopc_mic_error_alarm \ |
| 25 | import OnuLopcMicErrorAlarm |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 26 | from voltha.extensions.alarms.onu.onu_lob_alarm import OnuLobAlarm |
| 27 | |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 28 | from voltha.extensions.alarms.onu.onu_startup_alarm import OnuStartupAlarm |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 29 | from voltha.extensions.alarms.onu.onu_signal_degrade_alarm \ |
| 30 | import OnuSignalDegradeAlarm |
| 31 | from voltha.extensions.alarms.onu.onu_signal_fail_alarm \ |
| 32 | import OnuSignalFailAlarm |
| 33 | from voltha.extensions.alarms.onu.onu_window_drift_alarm \ |
| 34 | import OnuWindowDriftAlarm |
| 35 | from voltha.extensions.alarms.onu.onu_activation_fail_alarm \ |
| 36 | import OnuActivationFailAlarm |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 37 | |
| 38 | |
| 39 | class OpenOltAlarmMgr(object): |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 40 | def __init__(self, log, platform, data_model): |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 41 | self.log = log |
Shad Ansari | cd20a6d | 2018-10-02 14:36:33 +0000 | [diff] [blame] | 42 | self.platform = platform |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 43 | self.data_model = data_model |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 44 | """ |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 45 | The following is added to reduce the continual posting of OLT LOS |
| 46 | alarming to Kafka. Set enable_alarm_suppress = true to enable |
| 47 | otherwise the current openolt bal will send continuous olt los alarm |
| 48 | cleared messages ONU disc raised counter is place holder for a future |
| 49 | addition |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 50 | """ |
| 51 | self.enable_alarm_suppress = True |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 52 | # Keep count of alarms to limit. |
| 53 | self.alarm_suppress = {"olt_los_clear": 0, "onu_disc_raised": []} |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 54 | try: |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 55 | self.alarms = DeviceAlarms(self.data_model) |
Scott Baker | a173789 | 2018-09-11 17:56:26 -0700 | [diff] [blame] | 56 | self.simulator = AdapterAlarmSimulator(self.alarms) |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 57 | except Exception as initerr: |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 58 | self.log.exception("alarmhandler-init-error", |
| 59 | errmsg=initerr.message) |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 60 | raise Exception(initerr) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 61 | |
| 62 | def process_alarms(self, alarm_ind): |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 63 | try: |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 64 | self.log.debug('alarm-indication', alarm=alarm_ind) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 65 | if alarm_ind.HasField('los_ind'): |
| 66 | self.los_indication(alarm_ind.los_ind) |
| 67 | elif alarm_ind.HasField('dying_gasp_ind'): |
| 68 | self.dying_gasp_indication(alarm_ind.dying_gasp_ind) |
| 69 | elif alarm_ind.HasField('onu_alarm_ind'): |
| 70 | self.onu_alarm_indication(alarm_ind.onu_alarm_ind) |
| 71 | elif alarm_ind.HasField('onu_startup_fail_ind'): |
| 72 | self.onu_startup_failure_indication( |
| 73 | alarm_ind.onu_startup_fail_ind) |
| 74 | elif alarm_ind.HasField('onu_signal_degrade_ind'): |
| 75 | self.onu_signal_degrade_indication( |
| 76 | alarm_ind.onu_signal_degrade_ind) |
| 77 | elif alarm_ind.HasField('onu_drift_of_window_ind'): |
| 78 | self.onu_drift_of_window_indication( |
| 79 | alarm_ind.onu_drift_of_window_ind) |
| 80 | elif alarm_ind.HasField('onu_loss_omci_ind'): |
| 81 | self.onu_loss_omci_indication(alarm_ind.onu_loss_omci_ind) |
| 82 | elif alarm_ind.HasField('onu_signals_fail_ind'): |
| 83 | self.onu_signals_failure_indication( |
| 84 | alarm_ind.onu_signals_fail_ind) |
| 85 | elif alarm_ind.HasField('onu_tiwi_ind'): |
| 86 | self.onu_transmission_interference_warning( |
| 87 | alarm_ind.onu_tiwi_ind) |
| 88 | elif alarm_ind.HasField('onu_activation_fail_ind'): |
| 89 | self.onu_activation_failure_indication( |
| 90 | alarm_ind.onu_activation_fail_ind) |
| 91 | elif alarm_ind.HasField('onu_processing_error_ind'): |
| 92 | self.onu_processing_error_indication( |
| 93 | alarm_ind.onu_processing_error_ind) |
| 94 | else: |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 95 | self.log.warn('unknown alarm type', alarm=alarm_ind) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 96 | |
| 97 | except Exception as e: |
| 98 | self.log.error('sorting of alarm went wrong', error=e, |
| 99 | alarm=alarm_ind) |
| 100 | |
Scott Baker | d319095 | 2018-09-04 15:47:28 -0700 | [diff] [blame] | 101 | def simulate_alarm(self, alarm): |
Scott Baker | a173789 | 2018-09-11 17:56:26 -0700 | [diff] [blame] | 102 | self.simulator.simulate_alarm(alarm) |
Scott Baker | d319095 | 2018-09-04 15:47:28 -0700 | [diff] [blame] | 103 | |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 104 | def los_indication(self, los_ind): |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 105 | |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 106 | try: |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 107 | self.log.debug('los indication received', los_ind=los_ind, |
| 108 | int_id=los_ind.intf_id, status=los_ind.status) |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 109 | try: |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 110 | port_type_name \ |
| 111 | = self.platform.intf_id_to_port_type_name(los_ind.intf_id) |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 112 | if los_ind.status == 1 or los_ind.status == "on": |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 113 | # Zero out the suppression counter on OLT_LOS raise |
| 114 | self.alarm_suppress['olt_los_clear'] = 0 |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 115 | OltLosAlarm(self.alarms, intf_id=los_ind.intf_id, |
| 116 | port_type_name=port_type_name).raise_alarm() |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 117 | else: |
Shad Ansari | cd20a6d | 2018-10-02 14:36:33 +0000 | [diff] [blame] | 118 | """ |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 119 | Check if there has been more that one los clear |
| 120 | following a previous los |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 121 | """ |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 122 | if (self.alarm_suppress['olt_los_clear'] == 0 |
| 123 | and self.enable_alarm_suppress): |
| 124 | OltLosAlarm( |
| 125 | self.alarms, intf_id=los_ind.intf_id, |
| 126 | port_type_name=port_type_name).clear_alarm() |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 127 | self.alarm_suppress['olt_los_clear'] += 1 |
| 128 | |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 129 | except Exception as alarm_err: |
| 130 | self.log.error('los-indication', errmsg=alarm_err.message) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 131 | except Exception as e: |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 132 | self.log.error('los-indication', errmsg=e.message) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 133 | |
| 134 | def dying_gasp_indication(self, dying_gasp_ind): |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 135 | try: |
| 136 | alarm_dgi = dying_gasp_ind |
| 137 | onu_id = alarm_dgi.onu_id |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 138 | self.log.debug('openolt-alarmindication-dispatch-dying-gasp', |
| 139 | int_id=alarm_dgi.intf_id, |
| 140 | onu_id=onu_id, status=alarm_dgi.status) |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 141 | try: |
| 142 | """ |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 143 | Get the specific onu device information for the onu generating |
| 144 | the alarm. Extract the id. In the future extract the serial |
| 145 | number as well |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 146 | """ |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 147 | # FIXME - Include ONU serial number in alarm |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 148 | if dying_gasp_ind.status == 1 or dying_gasp_ind.status == "on": |
| 149 | OnuDyingGaspAlarm(self.alarms, dying_gasp_ind.intf_id, |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 150 | onu_id).raise_alarm() |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 151 | else: |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 152 | OnuDyingGaspAlarm(self.alarms, dying_gasp_ind.intf_id, |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 153 | onu_id).clear_alarm() |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 154 | except Exception as alarm_err: |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 155 | self.log.exception('dying-gasp-indication', |
| 156 | errmsg=alarm_err.message) |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 157 | |
| 158 | except Exception as e: |
| 159 | self.log.error('dying_gasp_indication', error=e) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 160 | |
| 161 | def onu_alarm_indication(self, onu_alarm_ind): |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 162 | """ |
| 163 | LOB = Los of burst |
| 164 | LOPC = Loss of PLOAM miss channel |
| 165 | |
| 166 | :param onu_alarm_ind: Alarm indication which currently contains |
| 167 | onu_id: |
| 168 | los_status: |
| 169 | lob_status: |
| 170 | lopc_miss_status: |
| 171 | lopc_mic_error_status: |
| 172 | :return: |
| 173 | """ |
| 174 | self.log.info('onu-alarm-indication') |
| 175 | |
| 176 | try: |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 177 | self.log.debug( |
| 178 | 'onu alarm indication received', |
| 179 | los_status=onu_alarm_ind.los_status, |
| 180 | onu_intf_id=onu_alarm_ind.onu_id, |
| 181 | lob_status=onu_alarm_ind.lob_status, |
| 182 | lopc_miss_status=onu_alarm_ind.lopc_miss_status, |
| 183 | lopc_mic_error_status=onu_alarm_ind.lopc_mic_error_status, |
| 184 | intf_id=onu_alarm_ind.intf_id) |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 185 | |
| 186 | try: |
| 187 | """ |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 188 | Get the specific onu device information for the onu |
| 189 | generating the alarm. Extract the id. In the future |
| 190 | extract the serial number as well |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 191 | """ |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 192 | # FIXME - Include ONU serial number in alarm |
| 193 | if (onu_alarm_ind.los_status == 1 |
| 194 | or onu_alarm_ind.los_status == "on"): |
| 195 | OnuLosAlarm(self.alarms, onu_id=onu_alarm_ind.onu_id, |
| 196 | intf_id=onu_alarm_ind.intf_id).raise_alarm() |
| 197 | elif (onu_alarm_ind.los_status == 0 |
| 198 | or onu_alarm_ind.los_status == "off"): |
| 199 | OnuLosAlarm(self.alarms, onu_id=onu_alarm_ind.onu_id, |
| 200 | intf_id=onu_alarm_ind.intf_id).clear_alarm() |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 201 | else: # No Change |
| 202 | pass |
| 203 | |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 204 | if (onu_alarm_ind.lopc_miss_status == 1 |
| 205 | or onu_alarm_ind.lopc_miss_status == "on"): |
| 206 | OnuLopcMissAlarm( |
| 207 | self.alarms, onu_id=onu_alarm_ind.onu_id, |
| 208 | intf_id=onu_alarm_ind.intf_id).raise_alarm() |
| 209 | elif (onu_alarm_ind.lopc_miss_status == 0 |
| 210 | or onu_alarm_ind.lopc_miss_status == "off"): |
| 211 | OnuLopcMissAlarm( |
| 212 | self.alarms, onu_id=onu_alarm_ind.onu_id, |
| 213 | intf_id=onu_alarm_ind.intf_id).clear_alarm() |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 214 | else: # No Change |
| 215 | pass |
| 216 | |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 217 | if (onu_alarm_ind.lopc_mic_error_status == 1 |
| 218 | or onu_alarm_ind.lopc_mic_error_status == "on"): |
| 219 | OnuLopcMicErrorAlarm( |
| 220 | self.alarms, onu_id=onu_alarm_ind.onu_id, |
| 221 | intf_id=onu_alarm_ind.intf_id).raise_alarm() |
| 222 | elif (onu_alarm_ind.lopc_mic_error_status == 0 |
| 223 | or onu_alarm_ind.lopc_mic_error_status == "off"): |
| 224 | OnuLopcMicErrorAlarm( |
| 225 | self.alarms, onu_id=onu_alarm_ind.onu_id, |
| 226 | intf_id=onu_alarm_ind.intf_id).clear_alarm() |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 227 | else: # No Change |
| 228 | pass |
| 229 | |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 230 | if (onu_alarm_ind.lob_status == 1 |
| 231 | or onu_alarm_ind.lob_status == "on"): |
| 232 | OnuLobAlarm( |
| 233 | self.alarms, onu_id=onu_alarm_ind.onu_id, |
| 234 | intf_id=onu_alarm_ind.intf_id).raise_alarm() |
| 235 | elif (onu_alarm_ind.lob_status == 0 |
| 236 | or onu_alarm_ind.lob_status == "off"): |
| 237 | OnuLobAlarm( |
| 238 | self.alarms, onu_id=onu_alarm_ind.onu_id, |
| 239 | intf_id=onu_alarm_ind.intf_id).clear_alarm() |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 240 | else: # No Change |
| 241 | pass |
| 242 | except Exception as alarm_err: |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 243 | self.log.exception('onu-alarm-indication', |
| 244 | errmsg=alarm_err.message) |
mzadig | e4ad1d2 | 2018-07-27 15:27:22 -0400 | [diff] [blame] | 245 | |
| 246 | except Exception as e: |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 247 | self.log.exception('onu-alarm-indication', errmsg=e.message) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 248 | |
| 249 | def onu_startup_failure_indication(self, onu_startup_fail_ind): |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 250 | """ |
| 251 | Current protobuf indicator: |
| 252 | message OnuStartupFailureIndication { |
| 253 | fixed32 intf_id = 1; |
| 254 | fixed32 onu_id = 2; |
| 255 | string status = 3; |
| 256 | } |
| 257 | |
| 258 | :param onu_startup_fail_ind: |
| 259 | :return: |
| 260 | """ |
| 261 | try: |
| 262 | ind = onu_startup_fail_ind |
| 263 | label = "onu-startup-failure-indication" |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 264 | self.log.debug(label + " received", onu_startup_fail_ind=ind, |
| 265 | int_id=ind.intf_id, onu_id=ind.onu_id, |
| 266 | status=ind.status) |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 267 | try: |
| 268 | if ind.status == 1 or ind.status == "on": |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 269 | OnuStartupAlarm(self.alarms, intf_id=ind.intf_id, |
| 270 | onu_id=ind.onu_id).raise_alarm() |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 271 | else: |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 272 | OnuStartupAlarm(self.alarms, intf_id=ind.intf_id, |
| 273 | onu_id=ind.onu_id).clear_alarm() |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 274 | except Exception as alarm_err: |
| 275 | self.log.exception(label, errmsg=alarm_err.message) |
| 276 | |
| 277 | except Exception as e: |
| 278 | self.log.exception(label, errmsg=e.message) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 279 | |
| 280 | def onu_signal_degrade_indication(self, onu_signal_degrade_ind): |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 281 | """ |
| 282 | Current protobuf indicator: |
| 283 | OnuSignalDegradeIndication { |
| 284 | fixed32 intf_id = 1; |
| 285 | fixed32 onu_id = 2; |
| 286 | string status = 3; |
| 287 | fixed32 inverse_bit_error_rate = 4; |
| 288 | } |
| 289 | :param onu_signal_degrade_ind: |
| 290 | :return: |
| 291 | """ |
| 292 | try: |
| 293 | ind = onu_signal_degrade_ind |
| 294 | label = "onu-signal-degrade-indication" |
| 295 | self.log.debug(label + ' received', |
| 296 | onu_startup_fail_ind=ind, |
| 297 | int_id=ind.intf_id, |
| 298 | onu_id=ind.onu_id, |
| 299 | inverse_bit_error_rate=ind.inverse_bit_error_rate, |
| 300 | status=ind.status) |
| 301 | try: |
| 302 | if ind.status == 1 or ind.status == "on": |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 303 | OnuSignalDegradeAlarm( |
| 304 | self.alarms, intf_id=ind.intf_id, onu_id=ind.onu_id, |
| 305 | inverse_bit_error_rate=ind.inverse_bit_error_rate) \ |
| 306 | .raise_alarm() |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 307 | else: |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 308 | OnuSignalDegradeAlarm( |
| 309 | self.alarms, intf_id=ind.intf_id, onu_id=ind.onu_id, |
| 310 | inverse_bit_error_rate=ind.inverse_bit_error_rate) \ |
| 311 | .clear_alarm() |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 312 | except Exception as alarm_err: |
| 313 | self.log.exception(label, errmsg=alarm_err.message) |
| 314 | |
| 315 | except Exception as e: |
| 316 | self.log.exception(label, errmsg=e.message) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 317 | |
| 318 | def onu_drift_of_window_indication(self, onu_drift_of_window_ind): |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 319 | """ |
| 320 | Current protobuf indicator: |
| 321 | OnuDriftOfWindowIndication { |
| 322 | fixed32 intf_id = 1; |
| 323 | fixed32 onu_id = 2; |
| 324 | string status = 3; |
| 325 | fixed32 drift = 4; |
| 326 | fixed32 new_eqd = 5; |
| 327 | } |
| 328 | |
| 329 | :param onu_drift_of_window_ind: |
| 330 | :return: |
| 331 | """ |
| 332 | try: |
| 333 | ind = onu_drift_of_window_ind |
| 334 | label = "onu-window-drift-indication" |
| 335 | |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 336 | self.log.debug(label + ' received', |
| 337 | onu_drift_of_window_ind=ind, |
| 338 | int_id=ind.intf_id, |
| 339 | onu_id=ind.onu_id, |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 340 | drift=ind.drift, |
| 341 | new_eqd=ind.new_eqd, |
| 342 | status=ind.status) |
| 343 | try: |
| 344 | if ind.status == 1 or ind.status == "on": |
| 345 | OnuWindowDriftAlarm(self.alarms, intf_id=ind.intf_id, |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 346 | onu_id=ind.onu_id, |
| 347 | drift=ind.drift, |
| 348 | new_eqd=ind.new_eqd).raise_alarm() |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 349 | else: |
| 350 | OnuWindowDriftAlarm(self.alarms, intf_id=ind.intf_id, |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 351 | onu_id=ind.onu_id, |
| 352 | drift=ind.drift, |
| 353 | new_eqd=ind.new_eqd).clear_alarm() |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 354 | except Exception as alarm_err: |
| 355 | self.log.exception(label, errmsg=alarm_err.message) |
| 356 | |
| 357 | except Exception as e: |
| 358 | self.log.exception(label, errmsg=e.message) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 359 | |
| 360 | def onu_loss_omci_indication(self, onu_loss_omci_ind): |
| 361 | self.log.info('not implemented yet') |
| 362 | |
| 363 | def onu_signals_failure_indication(self, onu_signals_fail_ind): |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 364 | """ |
| 365 | Current protobuf indicator: |
| 366 | OnuSignalsFailureIndication { |
| 367 | fixed32 intf_id = 1; |
| 368 | fixed32 onu_id = 2; |
| 369 | string status = 3; |
| 370 | fixed32 inverse_bit_error_rate = 4; |
| 371 | } |
| 372 | |
| 373 | :param onu_signals_fail_ind: |
| 374 | :return: |
| 375 | """ |
| 376 | try: |
| 377 | ind = onu_signals_fail_ind |
| 378 | label = "onu-signal-failure-indication" |
| 379 | |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 380 | self.log.debug(label + ' received', |
| 381 | onu_startup_fail_ind=ind, |
| 382 | int_id=ind.intf_id, |
| 383 | onu_id=ind.onu_id, |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 384 | inverse_bit_error_rate=ind.inverse_bit_error_rate, |
| 385 | status=ind.status) |
| 386 | try: |
| 387 | if ind.status == 1 or ind.status == "on": |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 388 | OnuSignalFailAlarm( |
| 389 | self.alarms, intf_id=ind.intf_id, |
| 390 | onu_id=ind.onu_id, |
| 391 | inverse_bit_error_rate=ind.inverse_bit_error_rate) \ |
| 392 | .raise_alarm() |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 393 | else: |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 394 | OnuSignalFailAlarm( |
| 395 | self.alarms, intf_id=ind.intf_id, onu_id=ind.onu_id, |
| 396 | inverse_bit_error_rate=ind.inverse_bit_error_rate) \ |
| 397 | .clear_alarm() |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 398 | except Exception as alarm_err: |
| 399 | self.log.exception(label, errmsg=alarm_err.message) |
| 400 | |
| 401 | except Exception as e: |
| 402 | self.log.exception(label, errmsg=e.message) |
| 403 | |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 404 | def onu_transmission_interference_warning(self, onu_tiwi_ind): |
| 405 | self.log.info('not implemented yet') |
| 406 | |
| 407 | def onu_activation_failure_indication(self, onu_activation_fail_ind): |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 408 | """ |
| 409 | |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 410 | No status is currently passed with this alarm. Consequently it will |
| 411 | always just raise |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 412 | :param onu_activation_fail_ind: |
| 413 | :return: |
| 414 | """ |
| 415 | try: |
| 416 | ind = onu_activation_fail_ind |
| 417 | label = "onu-activation-failure-indication" |
| 418 | |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 419 | onu_device_id, onu_serial_number \ |
| 420 | = self.resolve_onudev_id_onudev_serialnum( |
| 421 | self.resolve_onu_id(ind.onu_id, port_intf_id=ind.intf_id)) |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 422 | |
| 423 | self.log.debug(label + ' received', |
| 424 | onu_startup_fail_ind=ind, |
| 425 | int_id=ind.intf_id, |
| 426 | onu_id=ind.onu_id, |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 427 | onu_serial_number=onu_serial_number) |
| 428 | try: |
| 429 | |
| 430 | OnuActivationFailAlarm(self.alarms, intf_id=ind.intf_id, |
Shad Ansari | 8d06864 | 2019-02-28 23:09:03 -0800 | [diff] [blame] | 431 | onu_id=ind.onu_id).raise_alarm() |
mzadig | b486c07 | 2018-08-08 11:34:51 -0400 | [diff] [blame] | 432 | except Exception as alarm_err: |
| 433 | self.log.exception(label, errmsg=alarm_err.message) |
| 434 | |
| 435 | except Exception as e: |
| 436 | self.log.exception(label, errmsg=e.message) |
Nicolas Palpacuer | 16138de | 2018-07-03 14:35:18 -0400 | [diff] [blame] | 437 | |
| 438 | def onu_processing_error_indication(self, onu_processing_error_ind): |
mzadig | 7cda5ff | 2018-07-10 16:37:28 -0400 | [diff] [blame] | 439 | self.log.info('not implemented yet') |