blob: f227cdf680571111b6ec35c9f2b027aa5ada2996 [file] [log] [blame]
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001/*
Joey Armstronge8c091f2023-01-17 16:56:26 -05002 * Copyright 2020-2023 Open Networking Foundation (ONF) and the ONF Contributors
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00003 *
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
nikesh.krishnan1ffb8132023-05-23 03:44:13 +053017// Package mib provides the utilities for managing the onu mib
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +000018package mib
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +000019
20import (
21 "context"
Holger Hildebrandtc54939a2020-06-17 08:14:27 +000022 "encoding/hex"
Holger Hildebrandtccd390c2020-05-29 13:49:04 +000023 "encoding/json"
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +000024 "errors"
Holger Hildebrandtccd390c2020-05-29 13:49:04 +000025 "fmt"
26 "strconv"
mpagenko3af1f032020-06-10 08:53:41 +000027 "strings"
Girish Gowdraf7d82d02022-04-26 16:18:35 -070028 "sync"
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +000029
30 "github.com/looplab/fsm"
31
divyadesaibbed37c2020-08-28 13:35:20 +053032 "time"
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +000033
mpagenko7033f4e2021-11-19 18:04:22 +000034 "github.com/google/gopacket"
mpagenko836a1fd2021-11-01 16:12:42 +000035 "github.com/opencord/omci-lib-go/v2"
36 me "github.com/opencord/omci-lib-go/v2/generated"
khenaidoo7d3c5582021-08-11 18:09:44 -040037 "github.com/opencord/voltha-lib-go/v7/pkg/db/kvstore"
38 "github.com/opencord/voltha-lib-go/v7/pkg/log"
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +000039 cmn "github.com/opencord/voltha-openonu-adapter-go/internal/pkg/common"
40 devdb "github.com/opencord/voltha-openonu-adapter-go/internal/pkg/devdb"
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +000041 otst "github.com/opencord/voltha-openonu-adapter-go/internal/pkg/omcitst"
Holger Hildebrandt9afc1582021-11-30 16:10:19 +000042 "github.com/opencord/voltha-protos/v5/go/inter_adapter"
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +000043)
44
mpagenko01499812021-03-25 10:37:12 +000045type sLastTxMeParameter struct {
46 lastTxMessageType omci.MessageType
47 pLastTxMeInstance *me.ManagedEntity
48 repeatCount uint8
49}
50
Holger Hildebrandtccd390c2020-05-29 13:49:04 +000051var supportedClassIds = []me.ClassID{
52 me.CardholderClassID, // 5
53 me.CircuitPackClassID, // 6
54 me.SoftwareImageClassID, // 7
55 me.PhysicalPathTerminationPointEthernetUniClassID, // 11
ozgecanetsia124d9732021-09-16 14:31:57 +030056 me.PhysicalPathTerminationPointPotsUniClassID, // 53
Holger Hildebrandtccd390c2020-05-29 13:49:04 +000057 me.OltGClassID, // 131
58 me.OnuPowerSheddingClassID, // 133
59 me.IpHostConfigDataClassID, // 134
60 me.OnuGClassID, // 256
61 me.Onu2GClassID, // 257
62 me.TContClassID, // 262
63 me.AniGClassID, // 263
64 me.UniGClassID, // 264
65 me.PriorityQueueClassID, // 277
66 me.TrafficSchedulerClassID, // 278
67 me.VirtualEthernetInterfacePointClassID, // 329
68 me.EnhancedSecurityControlClassID, // 332
69 me.OnuDynamicPowerManagementControlClassID, // 336
70 // 347 // definitions for ME "IPv6 host config data" are currently missing in omci-lib-go!
71}
72
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +000073var omccVersionSupportsExtendedOmciFormat = map[uint8]bool{
74 0x80: false,
75 0x81: false,
76 0x82: false,
77 0x83: false,
78 0x84: false,
79 0x85: false,
80 0x86: false,
81 0xA0: false,
82 0xA1: false,
83 0xA2: false,
84 0xA3: false,
85 0x96: true,
86 0xB0: true,
87 0xB1: true,
88 0xB2: true,
89 0xB3: true,
90 0xB4: true,
91}
92
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +000093var fsmMsg cmn.TestMessageType
Holger Hildebrandtccd390c2020-05-29 13:49:04 +000094
dbainbri4d3a0dc2020-12-02 00:33:42 +000095func (oo *OnuDeviceEntry) enterStartingState(ctx context.Context, e *fsm.Event) {
96 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start processing MibSync-msgs in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +000097 oo.pOnuDB = devdb.NewOnuDeviceDB(log.WithSpanFromContext(context.TODO(), ctx), oo.deviceID)
dbainbri4d3a0dc2020-12-02 00:33:42 +000098 go oo.processMibSyncMessages(ctx)
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +000099}
100
dbainbri4d3a0dc2020-12-02 00:33:42 +0000101func (oo *OnuDeviceEntry) enterResettingMibState(ctx context.Context, e *fsm.Event) {
102 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start MibTemplate processing in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000103
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000104 if (!oo.IsNewOnu() && !oo.baseDeviceHandler.IsReconciling()) || //use case: re-auditing failed
105 oo.baseDeviceHandler.IsSkipOnuConfigReconciling() { //use case: reconciling without omci-config failed
106 oo.baseDeviceHandler.PrepareReconcilingWithActiveAdapter(ctx)
107 oo.devState = cmn.DeviceStatusInit
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000108 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000109 logger.Debugw(ctx, "MibSync FSM", log.Fields{"send mibReset in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000110 oo.mutexLastTxParamStruct.Lock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000111 _ = oo.PDevOmciCC.SendMibReset(log.WithSpanFromContext(context.TODO(), ctx), oo.baseDeviceHandler.GetOmciTimeout(), true)
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000112 //TODO: needs to handle timeouts
mpagenko01499812021-03-25 10:37:12 +0000113 //even though lastTxParameters are currently not used for checking the ResetResponse message we have to ensure
114 // that the lastTxMessageType is correctly set to avoid misinterpreting other responses
115 oo.lastTxParamStruct.lastTxMessageType = omci.MibResetRequestType
116 oo.lastTxParamStruct.repeatCount = 0
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000117 oo.mutexLastTxParamStruct.Unlock()
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000118}
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000119
dbainbri4d3a0dc2020-12-02 00:33:42 +0000120func (oo *OnuDeviceEntry) enterGettingVendorAndSerialState(ctx context.Context, e *fsm.Event) {
121 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start getting VendorId and SerialNumber in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt3ac49bd2022-02-07 17:46:43 +0000122 requestedAttributes := me.AttributeValueMap{me.OnuG_VendorId: "", me.OnuG_SerialNumber: 0}
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000123 oo.mutexLastTxParamStruct.Lock()
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000124 meInstance, err := oo.PDevOmciCC.SendGetMe(log.WithSpanFromContext(context.TODO(), ctx), me.OnuGClassID, cmn.OnugMeID, requestedAttributes,
Holger Hildebrandtd930cb22022-06-17 09:24:50 +0000125 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.PMibUploadFsm.CommChan, false)
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000126 //accept also nil as (error) return value for writing to LastTx
127 // - this avoids misinterpretation of new received OMCI messages
ozgecanetsiab36ed572021-04-01 10:38:48 +0300128 if err != nil {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000129 oo.mutexLastTxParamStruct.Unlock()
ozgecanetsiab36ed572021-04-01 10:38:48 +0300130 logger.Errorw(ctx, "ONU-G get failed, aborting MibSync FSM", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000131 pMibUlFsm := oo.PMibUploadFsm
ozgecanetsiab36ed572021-04-01 10:38:48 +0300132 if pMibUlFsm != nil {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000133 go func(a_pAFsm *cmn.AdapterFsm) {
134 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
ozgecanetsiab36ed572021-04-01 10:38:48 +0300135 }(pMibUlFsm)
136 }
137 return
138 }
mpagenko01499812021-03-25 10:37:12 +0000139 oo.lastTxParamStruct.lastTxMessageType = omci.GetRequestType
140 oo.lastTxParamStruct.pLastTxMeInstance = meInstance
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000141 oo.mutexLastTxParamStruct.Unlock()
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000142}
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000143
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000144func (oo *OnuDeviceEntry) enterGettingVersionState(ctx context.Context, e *fsm.Event) {
145 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start getting Version in State": e.FSM.Current(), "device-id": oo.deviceID})
146 requestedAttributes := me.AttributeValueMap{me.OnuG_Version: ""}
147 oo.mutexLastTxParamStruct.Lock()
148 meInstance, err := oo.PDevOmciCC.SendGetMe(log.WithSpanFromContext(context.TODO(), ctx), me.OnuGClassID, cmn.OnugMeID,
Holger Hildebrandtd930cb22022-06-17 09:24:50 +0000149 requestedAttributes, oo.baseDeviceHandler.GetOmciTimeout(), true, oo.PMibUploadFsm.CommChan, false)
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000150 //accept also nil as (error) return value for writing to LastTx
151 // - this avoids misinterpretation of new received OMCI messages
152 if err != nil {
153 oo.mutexLastTxParamStruct.Unlock()
154 logger.Errorw(ctx, "ONU-G get failed, aborting MibSync FSM", log.Fields{"device-id": oo.deviceID})
155 pMibUlFsm := oo.PMibUploadFsm
156 if pMibUlFsm != nil {
157 go func(a_pAFsm *cmn.AdapterFsm) {
158 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
159 }(pMibUlFsm)
160 }
161 return
162 }
163 oo.lastTxParamStruct.lastTxMessageType = omci.GetRequestType
164 oo.lastTxParamStruct.pLastTxMeInstance = meInstance
165 oo.mutexLastTxParamStruct.Unlock()
166}
167
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000168func (oo *OnuDeviceEntry) enterGettingEquipIDAndOmccVersState(ctx context.Context, e *fsm.Event) {
169 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start getting EquipmentId and OMCC version in State": e.FSM.Current(), "device-id": oo.deviceID})
170 requestedAttributes := me.AttributeValueMap{me.Onu2G_EquipmentId: "", me.Onu2G_OpticalNetworkUnitManagementAndControlChannelOmccVersion: 0}
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000171 oo.mutexLastTxParamStruct.Lock()
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000172 meInstance, err := oo.PDevOmciCC.SendGetMe(log.WithSpanFromContext(context.TODO(), ctx), me.Onu2GClassID, cmn.Onu2gMeID, requestedAttributes,
Holger Hildebrandtd930cb22022-06-17 09:24:50 +0000173 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.PMibUploadFsm.CommChan, false)
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000174 //accept also nil as (error) return value for writing to LastTx
175 // - this avoids misinterpretation of new received OMCI messages
ozgecanetsiab36ed572021-04-01 10:38:48 +0300176 if err != nil {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000177 oo.mutexLastTxParamStruct.Unlock()
ozgecanetsiab36ed572021-04-01 10:38:48 +0300178 logger.Errorw(ctx, "ONU2-G get failed, aborting MibSync FSM!", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000179 pMibUlFsm := oo.PMibUploadFsm
ozgecanetsiab36ed572021-04-01 10:38:48 +0300180 if pMibUlFsm != nil {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000181 go func(a_pAFsm *cmn.AdapterFsm) {
182 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
ozgecanetsiab36ed572021-04-01 10:38:48 +0300183 }(pMibUlFsm)
184 }
185 return
186 }
mpagenko01499812021-03-25 10:37:12 +0000187 oo.lastTxParamStruct.lastTxMessageType = omci.GetRequestType
188 oo.lastTxParamStruct.pLastTxMeInstance = meInstance
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000189 oo.mutexLastTxParamStruct.Unlock()
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000190}
191
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000192func (oo *OnuDeviceEntry) enterTestingExtOmciSupportState(ctx context.Context, e *fsm.Event) {
193 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start testing extended OMCI msg in State": e.FSM.Current(), "device-id": oo.deviceID})
194 omciVerify := otst.NewOmciTestRequest(log.WithSpanFromContext(context.TODO(), ctx),
195 oo.deviceID, oo.PDevOmciCC, true, true, true)
196 verifyExec := make(chan bool)
197 omciVerify.PerformOmciTest(log.WithSpanFromContext(context.TODO(), ctx), verifyExec)
198
199 // If verification of test message in extended OMCI format fails, reset ONU capability to OMCI baseline format
200 select {
201 case <-time.After(((cmn.CDefaultRetries+1)*otst.CTestRequestOmciTimeout + 1) * time.Second):
202 logger.Warnw(ctx, "testing extended OMCI msg format timed out - reset to baseline format", log.Fields{"device-id": oo.deviceID})
203 oo.MutexPersOnuConfig.Lock()
204 oo.SOnuPersistentData.PersIsExtOmciSupported = false
205 oo.MutexPersOnuConfig.Unlock()
206 case success := <-verifyExec:
207 if success {
208 logger.Debugw(ctx, "testing extended OMCI msg format succeeded", log.Fields{"device-id": oo.deviceID})
209 } else {
210 logger.Warnw(ctx, "testing extended OMCI msg format failed - reset to baseline format", log.Fields{"device-id": oo.deviceID, "result": success})
211 oo.MutexPersOnuConfig.Lock()
212 oo.SOnuPersistentData.PersIsExtOmciSupported = false
213 oo.MutexPersOnuConfig.Unlock()
214 }
215 }
216 pMibUlFsm := oo.PMibUploadFsm
217 if pMibUlFsm != nil {
218 go func(a_pAFsm *cmn.AdapterFsm) {
219 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetFirstSwVersion)
220 }(pMibUlFsm)
221 }
222}
223
dbainbri4d3a0dc2020-12-02 00:33:42 +0000224func (oo *OnuDeviceEntry) enterGettingFirstSwVersionState(ctx context.Context, e *fsm.Event) {
225 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start getting IsActive and Version of first SW-image in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt3ac49bd2022-02-07 17:46:43 +0000226 requestedAttributes := me.AttributeValueMap{me.SoftwareImage_IsCommitted: 0, me.SoftwareImage_IsActive: 0, me.SoftwareImage_Version: ""}
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000227 oo.mutexLastTxParamStruct.Lock()
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000228 meInstance, err := oo.PDevOmciCC.SendGetMe(log.WithSpanFromContext(context.TODO(), ctx), me.SoftwareImageClassID, cmn.FirstSwImageMeID, requestedAttributes,
Holger Hildebrandtd930cb22022-06-17 09:24:50 +0000229 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.PMibUploadFsm.CommChan, oo.GetPersIsExtOmciSupported())
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000230 //accept also nil as (error) return value for writing to LastTx
231 // - this avoids misinterpretation of new received OMCI messages
ozgecanetsiab36ed572021-04-01 10:38:48 +0300232 if err != nil {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000233 oo.mutexLastTxParamStruct.Unlock()
ozgecanetsiab36ed572021-04-01 10:38:48 +0300234 logger.Errorw(ctx, "SoftwareImage get failed, aborting MibSync FSM", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000235 pMibUlFsm := oo.PMibUploadFsm
ozgecanetsiab36ed572021-04-01 10:38:48 +0300236 if pMibUlFsm != nil {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000237 go func(a_pAFsm *cmn.AdapterFsm) {
238 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
ozgecanetsiab36ed572021-04-01 10:38:48 +0300239 }(pMibUlFsm)
240 }
241 return
242 }
mpagenko01499812021-03-25 10:37:12 +0000243 oo.lastTxParamStruct.lastTxMessageType = omci.GetRequestType
244 oo.lastTxParamStruct.pLastTxMeInstance = meInstance
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000245 oo.mutexLastTxParamStruct.Unlock()
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000246}
247
dbainbri4d3a0dc2020-12-02 00:33:42 +0000248func (oo *OnuDeviceEntry) enterGettingSecondSwVersionState(ctx context.Context, e *fsm.Event) {
249 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start getting IsActive and Version of second SW-image in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt3ac49bd2022-02-07 17:46:43 +0000250 requestedAttributes := me.AttributeValueMap{me.SoftwareImage_IsCommitted: 0, me.SoftwareImage_IsActive: 0, me.SoftwareImage_Version: ""}
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000251 oo.mutexLastTxParamStruct.Lock()
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000252 meInstance, err := oo.PDevOmciCC.SendGetMe(log.WithSpanFromContext(context.TODO(), ctx), me.SoftwareImageClassID, cmn.SecondSwImageMeID, requestedAttributes,
Holger Hildebrandtd930cb22022-06-17 09:24:50 +0000253 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.PMibUploadFsm.CommChan, oo.GetPersIsExtOmciSupported())
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000254 //accept also nil as (error) return value for writing to LastTx
255 // - this avoids misinterpretation of new received OMCI messages
ozgecanetsiab36ed572021-04-01 10:38:48 +0300256 if err != nil {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000257 oo.mutexLastTxParamStruct.Unlock()
ozgecanetsiab36ed572021-04-01 10:38:48 +0300258 logger.Errorw(ctx, "SoftwareImage get failed, aborting MibSync FSM", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000259 pMibUlFsm := oo.PMibUploadFsm
ozgecanetsiab36ed572021-04-01 10:38:48 +0300260 if pMibUlFsm != nil {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000261 go func(a_pAFsm *cmn.AdapterFsm) {
262 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
ozgecanetsiab36ed572021-04-01 10:38:48 +0300263 }(pMibUlFsm)
264 }
265 return
266 }
mpagenko01499812021-03-25 10:37:12 +0000267 oo.lastTxParamStruct.lastTxMessageType = omci.GetRequestType
268 oo.lastTxParamStruct.pLastTxMeInstance = meInstance
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000269 oo.mutexLastTxParamStruct.Unlock()
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000270}
271
dbainbri4d3a0dc2020-12-02 00:33:42 +0000272func (oo *OnuDeviceEntry) enterGettingMacAddressState(ctx context.Context, e *fsm.Event) {
273 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start getting MacAddress in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt3ac49bd2022-02-07 17:46:43 +0000274 requestedAttributes := me.AttributeValueMap{me.IpHostConfigData_MacAddress: ""}
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000275 oo.mutexLastTxParamStruct.Lock()
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000276 meInstance, err := oo.PDevOmciCC.SendGetMe(log.WithSpanFromContext(context.TODO(), ctx), me.IpHostConfigDataClassID, cmn.IPHostConfigDataMeID, requestedAttributes,
Holger Hildebrandtd930cb22022-06-17 09:24:50 +0000277 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.PMibUploadFsm.CommChan, oo.GetPersIsExtOmciSupported())
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000278 //accept also nil as (error) return value for writing to LastTx
279 // - this avoids misinterpretation of new received OMCI messages
ozgecanetsiab36ed572021-04-01 10:38:48 +0300280 if err != nil {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000281 oo.mutexLastTxParamStruct.Unlock()
ozgecanetsiab36ed572021-04-01 10:38:48 +0300282 logger.Errorw(ctx, "IpHostConfigData get failed, aborting MibSync FSM", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000283 pMibUlFsm := oo.PMibUploadFsm
ozgecanetsiab36ed572021-04-01 10:38:48 +0300284 if pMibUlFsm != nil {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000285 go func(a_pAFsm *cmn.AdapterFsm) {
286 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
ozgecanetsiab36ed572021-04-01 10:38:48 +0300287 }(pMibUlFsm)
288 }
289 return
290 }
mpagenko01499812021-03-25 10:37:12 +0000291 oo.lastTxParamStruct.lastTxMessageType = omci.GetRequestType
292 oo.lastTxParamStruct.pLastTxMeInstance = meInstance
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000293 oo.mutexLastTxParamStruct.Unlock()
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000294}
295
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000296func (oo *OnuDeviceEntry) enterGettingMibTemplateState(ctx context.Context, e *fsm.Event) {
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000297
Holger Hildebrandt05011352021-06-15 09:40:24 +0000298 oo.mutexOnuSwImageIndications.RLock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000299 if oo.onuSwImageIndications.ActiveEntityEntry.Valid {
300 oo.MutexPersOnuConfig.Lock()
301 oo.SOnuPersistentData.PersActiveSwVersion = oo.onuSwImageIndications.ActiveEntityEntry.Version
302 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandt05011352021-06-15 09:40:24 +0000303 oo.mutexOnuSwImageIndications.RUnlock()
mpagenko15ff4a52021-03-02 10:09:20 +0000304 } else {
Holger Hildebrandt05011352021-06-15 09:40:24 +0000305 oo.mutexOnuSwImageIndications.RUnlock()
mpagenko15ff4a52021-03-02 10:09:20 +0000306 logger.Errorw(ctx, "get-mib-template: no active SW version found, working with empty SW version, which might be untrustworthy",
307 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandtc54939a2020-06-17 08:14:27 +0000308 }
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000309 if oo.getMibFromTemplate(ctx) {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000310 logger.Debug(ctx, "MibSync FSM - valid MEs stored from template")
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000311 oo.pOnuDB.LogMeDb(ctx)
312 fsmMsg = cmn.LoadMibTemplateOk
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000313 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000314 logger.Debug(ctx, "MibSync FSM - no valid MEs stored from template - perform MIB-upload!")
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000315 fsmMsg = cmn.LoadMibTemplateFailed
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000316
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000317 oo.pOpenOnuAc.LockMutexMibTemplateGenerated()
318 if mibTemplateIsGenerated, exist := oo.pOpenOnuAc.GetMibTemplatesGenerated(oo.mibTemplatePath); exist {
Holger Hildebrandt441a0172020-12-10 13:57:08 +0000319 if mibTemplateIsGenerated {
320 logger.Debugw(ctx,
321 "MibSync FSM - template was successfully generated before, but doesn't exist or isn't usable anymore - reset flag in map",
322 log.Fields{"path": oo.mibTemplatePath, "device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000323 oo.pOpenOnuAc.SetMibTemplatesGenerated(oo.mibTemplatePath, false)
Holger Hildebrandt441a0172020-12-10 13:57:08 +0000324 }
325 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000326 oo.pOpenOnuAc.UnlockMutexMibTemplateGenerated()
Holger Hildebrandt441a0172020-12-10 13:57:08 +0000327 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000328 mibSyncMsg := cmn.Message{
329 Type: cmn.TestMsg,
330 Data: cmn.TestMessage{
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000331 TestMessageVal: fsmMsg,
332 },
333 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000334 oo.PMibUploadFsm.CommChan <- mibSyncMsg
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000335}
336
dbainbri4d3a0dc2020-12-02 00:33:42 +0000337func (oo *OnuDeviceEntry) enterUploadingState(ctx context.Context, e *fsm.Event) {
338 logger.Debugw(ctx, "MibSync FSM", log.Fields{"send MibUpload in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt5458d892022-05-31 09:52:06 +0000339 _ = oo.PDevOmciCC.SendMibUpload(log.WithSpanFromContext(context.TODO(), ctx),
340 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.GetPersIsExtOmciSupported())
mpagenko01499812021-03-25 10:37:12 +0000341 //even though lastTxParameters are currently not used for checking the ResetResponse message we have to ensure
342 // that the lastTxMessageType is correctly set to avoid misinterpreting other responses
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000343 oo.mutexLastTxParamStruct.Lock()
mpagenko01499812021-03-25 10:37:12 +0000344 oo.lastTxParamStruct.lastTxMessageType = omci.MibUploadRequestType
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000345 oo.mutexLastTxParamStruct.Unlock()
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000346}
347
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000348func (oo *OnuDeviceEntry) enterUploadDoneState(ctx context.Context, e *fsm.Event) {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000349 logger.Debugw(ctx, "MibSync FSM", log.Fields{"send notification to core in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000350 oo.transferSystemEvent(ctx, cmn.MibDatabaseSync)
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000351 go func() {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000352 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000353 }()
354}
355
356func (oo *OnuDeviceEntry) enterInSyncState(ctx context.Context, e *fsm.Event) {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000357 oo.MutexPersOnuConfig.Lock()
358 oo.SOnuPersistentData.PersMibLastDbSync = uint32(time.Now().Unix())
359 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandte3677f12021-02-05 14:50:56 +0000360 if oo.mibAuditInterval > 0 {
361 logger.Debugw(ctx, "MibSync FSM", log.Fields{"trigger next Audit in State": e.FSM.Current(), "oo.mibAuditInterval": oo.mibAuditInterval, "device-id": oo.deviceID})
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000362 go func() {
Holger Hildebrandte3677f12021-02-05 14:50:56 +0000363 time.Sleep(oo.mibAuditInterval)
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000364 if err := oo.PMibUploadFsm.PFsm.Event(UlEvAuditMib); err != nil {
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000365 logger.Debugw(ctx, "MibSyncFsm: Can't go to state auditing", log.Fields{"device-id": oo.deviceID, "err": err})
366 }
367 }()
368 }
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000369}
370
Holger Hildebrandt9afc1582021-11-30 16:10:19 +0000371func (oo *OnuDeviceEntry) enterVerifyingAndStoringTPsState(ctx context.Context, e *fsm.Event) {
372 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start verifying and storing TPs in State": e.FSM.Current(), "device-id": oo.deviceID})
373
Holger Hildebrandt80f57762022-02-16 10:03:24 +0000374 if oo.getAllStoredTpInstFromParentAdapter(ctx) {
Holger Hildebrandt9afc1582021-11-30 16:10:19 +0000375 logger.Debugw(ctx, "MibSync FSM", log.Fields{"reconciling - verifying TPs successful": e.FSM.Current(), "device-id": oo.deviceID})
376 go func() {
377 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
378 }()
379 } else {
380 logger.Debugw(ctx, "MibSync FSM", log.Fields{"reconciling - verifying TPs not successful": e.FSM.Current(), "device-id": oo.deviceID})
381 oo.baseDeviceHandler.SetReconcilingReasonUpdate(true)
382 go func() {
383 if err := oo.baseDeviceHandler.StorePersistentData(ctx); err != nil {
384 logger.Warnw(ctx, "reconciling - store persistent data error - continue for now as there will be additional write attempts",
385 log.Fields{"device-id": oo.deviceID, "err": err})
386 }
387 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
388 }()
389 }
390}
391
dbainbri4d3a0dc2020-12-02 00:33:42 +0000392func (oo *OnuDeviceEntry) enterExaminingMdsState(ctx context.Context, e *fsm.Event) {
393 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start GetMds processing in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000394 oo.requestMdsValue(ctx)
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000395}
396
dbainbri4d3a0dc2020-12-02 00:33:42 +0000397func (oo *OnuDeviceEntry) enterResynchronizingState(ctx context.Context, e *fsm.Event) {
398 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start MibResync processing in State": e.FSM.Current(), "device-id": oo.deviceID})
399 logger.Debug(ctx, "function not implemented yet")
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000400 // TODOs:
401 // VOL-3805 - Provide exclusive OMCI channel for one FSM
402 // VOL-3785 - New event notifications and corresponding performance counters for openonu-adapter-go
403 // VOL-3792 - Support periodical audit via mib resync
404 // VOL-3793 - ONU-reconcile handling after adapter restart based on mib resync
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000405}
406
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000407func (oo *OnuDeviceEntry) enterExaminingMdsSuccessState(ctx context.Context, e *fsm.Event) {
408 logger.Debugw(ctx, "MibSync FSM",
409 log.Fields{"Start processing on examining MDS success in State": e.FSM.Current(), "device-id": oo.deviceID})
410
411 if oo.getMibFromTemplate(ctx) {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000412 oo.baseDeviceHandler.StartReconciling(ctx, true)
413 oo.baseDeviceHandler.AddAllUniPorts(ctx)
Holger Hildebrandt9afc1582021-11-30 16:10:19 +0000414 _ = oo.baseDeviceHandler.ReasonUpdate(ctx, cmn.DrInitialMibDownloaded, oo.baseDeviceHandler.IsReconcilingReasonUpdate())
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000415 oo.baseDeviceHandler.SetReadyForOmciConfig(true)
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000416
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000417 if !oo.baseDeviceHandler.GetCollectorIsRunning() {
Girish Gowdraf7d82d02022-04-26 16:18:35 -0700418 var waitForOmciProcess sync.WaitGroup
419 waitForOmciProcess.Add(1)
Holger Hildebrandtced74e72021-06-10 14:55:53 +0000420 // Start PM collector routine
Girish Gowdraf7d82d02022-04-26 16:18:35 -0700421 go oo.baseDeviceHandler.StartCollector(ctx, &waitForOmciProcess)
422 waitForOmciProcess.Wait()
Holger Hildebrandtced74e72021-06-10 14:55:53 +0000423 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000424 if !oo.baseDeviceHandler.GetAlarmManagerIsRunning(ctx) {
425 go oo.baseDeviceHandler.StartAlarmManager(ctx)
Holger Hildebrandtced74e72021-06-10 14:55:53 +0000426 }
Girish Gowdrae95687a2021-09-08 16:30:58 -0700427
428 for _, uniPort := range *oo.baseDeviceHandler.GetUniEntityMap() {
429 // only if this port was enabled for use by the operator at startup
430 if (1<<uniPort.UniID)&oo.baseDeviceHandler.GetUniPortMask() == (1 << uniPort.UniID) {
431 if !oo.baseDeviceHandler.GetFlowMonitoringIsRunning(uniPort.UniID) {
432 go oo.baseDeviceHandler.PerOnuFlowHandlerRoutine(uniPort.UniID)
433 }
434 }
435 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000436 oo.MutexPersOnuConfig.RLock()
437 if oo.SOnuPersistentData.PersUniDisableDone {
438 oo.MutexPersOnuConfig.RUnlock()
439 oo.baseDeviceHandler.DisableUniPortStateUpdate(ctx)
Holger Hildebrandt9afc1582021-11-30 16:10:19 +0000440 _ = oo.baseDeviceHandler.ReasonUpdate(ctx, cmn.DrOmciAdminLock, oo.baseDeviceHandler.IsReconcilingReasonUpdate())
Holger Hildebrandtbdc5f002021-04-19 14:46:21 +0000441 } else {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000442 oo.MutexPersOnuConfig.RUnlock()
443 oo.baseDeviceHandler.EnableUniPortStateUpdate(ctx)
Holger Hildebrandtbdc5f002021-04-19 14:46:21 +0000444 }
Holger Hildebrandtb314f442021-11-24 12:03:10 +0000445
446 // no need to reconcile additional data for MibDownloadFsm, LockStateFsm, or UnlockStateFsm
447
448 if oo.baseDeviceHandler.ReconcileDeviceTechProf(ctx) {
449 // start go routine with select() on reconciling flow channel before
450 // starting flow reconciling process to prevent loss of any signal
Holger Hildebrandtf2fcdd42021-12-15 11:42:19 +0000451 syncChannel := make(chan struct{})
452 go func(aSyncChannel chan struct{}) {
Holger Hildebrandtb314f442021-11-24 12:03:10 +0000453 // In multi-ONU/multi-flow environment stopping reconcilement has to be delayed until
454 // we get a signal that the processing of the last step to rebuild the adapter internal
455 // flow data is finished.
456 expiry := oo.baseDeviceHandler.GetReconcileExpiryVlanConfigAbort()
457 oo.setReconcilingFlows(true)
Holger Hildebrandtf2fcdd42021-12-15 11:42:19 +0000458 aSyncChannel <- struct{}{}
Holger Hildebrandtb314f442021-11-24 12:03:10 +0000459 select {
460 case success := <-oo.chReconcilingFlowsFinished:
461 if success {
462 logger.Debugw(ctx, "reconciling flows has been finished in time",
463 log.Fields{"device-id": oo.deviceID})
464 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
465
466 } else {
467 logger.Debugw(ctx, "wait for reconciling flows aborted",
468 log.Fields{"device-id": oo.deviceID})
469 }
470 case <-time.After(expiry):
471 logger.Errorw(ctx, "timeout waiting for reconciling flows to be finished!",
472 log.Fields{"device-id": oo.deviceID, "expiry": expiry})
473 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
474 }
475 oo.setReconcilingFlows(false)
Holger Hildebrandtf2fcdd42021-12-15 11:42:19 +0000476 }(syncChannel)
477 // block further processing until the above Go routine has really started
478 // and is ready to receive values from chReconcilingFlowsFinished
479 <-syncChannel
Holger Hildebrandtb314f442021-11-24 12:03:10 +0000480 oo.baseDeviceHandler.ReconcileDeviceFlowConfig(ctx)
481 }
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000482 } else {
483 logger.Debugw(ctx, "MibSync FSM",
484 log.Fields{"Getting MIB from template not successful": e.FSM.Current(), "device-id": oo.deviceID})
485 go func() {
486 //switch to reconciling with OMCI config
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000487 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000488 }()
489 }
490}
491
dbainbri4d3a0dc2020-12-02 00:33:42 +0000492func (oo *OnuDeviceEntry) enterAuditingState(ctx context.Context, e *fsm.Event) {
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000493 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start MibAudit processing in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000494 if oo.baseDeviceHandler.CheckAuditStartCondition(ctx, cmn.CUploadFsm) {
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000495 oo.requestMdsValue(ctx)
496 } else {
mpagenkof1fc3862021-02-16 10:09:52 +0000497 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Configuration is ongoing or missing - skip auditing!": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000498 go func() {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000499 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000500 }()
501 }
502}
503
504func (oo *OnuDeviceEntry) enterReAuditingState(ctx context.Context, e *fsm.Event) {
505 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start retest MdsValue processing in State": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000506 if oo.baseDeviceHandler.CheckAuditStartCondition(ctx, cmn.CUploadFsm) {
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000507 oo.requestMdsValue(ctx)
508 } else {
mpagenkof1fc3862021-02-16 10:09:52 +0000509 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Configuration is ongoing or missing - skip re-auditing!": e.FSM.Current(), "device-id": oo.deviceID})
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000510 go func() {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000511 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000512 }()
513 }
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000514}
515
dbainbri4d3a0dc2020-12-02 00:33:42 +0000516func (oo *OnuDeviceEntry) enterOutOfSyncState(ctx context.Context, e *fsm.Event) {
517 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start MibReconcile processing in State": e.FSM.Current(), "device-id": oo.deviceID})
518 logger.Debug(ctx, "function not implemented yet")
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000519}
520
dbainbri4d3a0dc2020-12-02 00:33:42 +0000521func (oo *OnuDeviceEntry) processMibSyncMessages(ctx context.Context) {
522 logger.Debugw(ctx, "MibSync Msg", log.Fields{"Start routine to process OMCI-messages for device-id": oo.deviceID})
Girish Gowdra37c9d912022-02-08 16:24:57 -0800523 oo.mutexMibSyncMsgProcessorRunning.Lock()
524 oo.mibSyncMsgProcessorRunning = true
525 oo.mutexMibSyncMsgProcessorRunning.Unlock()
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000526loop:
527 for {
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000528 // case <-ctx.Done():
529 // logger.Info("MibSync Msg", log.Fields{"Message handling canceled via context for device-id": onuDeviceEntry.deviceID})
530 // break loop
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000531 message, ok := <-oo.PMibUploadFsm.CommChan
Himani Chawla4d908332020-08-31 12:30:20 +0530532 if !ok {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000533 logger.Info(ctx, "MibSync Msg", log.Fields{"Message couldn't be read from channel for device-id": oo.deviceID})
Girish Gowdra37c9d912022-02-08 16:24:57 -0800534 oo.mutexMibSyncMsgProcessorRunning.Lock()
535 oo.mibSyncMsgProcessorRunning = false
536 oo.mutexMibSyncMsgProcessorRunning.Unlock()
Himani Chawla4d908332020-08-31 12:30:20 +0530537 break loop
538 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000539 logger.Debugw(ctx, "MibSync Msg", log.Fields{"Received message on ONU MibSyncChan for device-id": oo.deviceID})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000540
Himani Chawla4d908332020-08-31 12:30:20 +0530541 switch message.Type {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000542 case cmn.TestMsg:
543 msg, _ := message.Data.(cmn.TestMessage)
Holger Hildebrandte7cc6092022-02-01 11:37:03 +0000544 if msg.TestMessageVal == cmn.AbortMessageProcessing {
545 logger.Debugw(ctx, "MibSync Msg abort ProcessMsg", log.Fields{"for device-id": oo.deviceID})
Girish Gowdra37c9d912022-02-08 16:24:57 -0800546 oo.mutexMibSyncMsgProcessorRunning.Lock()
547 oo.mibSyncMsgProcessorRunning = false
548 oo.mutexMibSyncMsgProcessorRunning.Unlock()
Holger Hildebrandte7cc6092022-02-01 11:37:03 +0000549 break loop
550 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000551 oo.handleTestMsg(ctx, msg)
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000552 case cmn.OMCI:
553 msg, _ := message.Data.(cmn.OmciMessage)
dbainbri4d3a0dc2020-12-02 00:33:42 +0000554 oo.handleOmciMessage(ctx, msg)
Himani Chawla4d908332020-08-31 12:30:20 +0530555 default:
dbainbri4d3a0dc2020-12-02 00:33:42 +0000556 logger.Warn(ctx, "MibSync Msg", log.Fields{"Unknown message type received for device-id": oo.deviceID, "message.Type": message.Type})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000557 }
558 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000559 logger.Info(ctx, "MibSync Msg", log.Fields{"Stopped handling of MibSyncChan for device-id": oo.deviceID})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000560 // TODO: only this action?
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000561 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000562}
563
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000564func (oo *OnuDeviceEntry) handleTestMsg(ctx context.Context, msg cmn.TestMessage) {
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000565
dbainbri4d3a0dc2020-12-02 00:33:42 +0000566 logger.Debugw(ctx, "MibSync Msg", log.Fields{"TestMessage received for device-id": oo.deviceID, "msg.TestMessageVal": msg.TestMessageVal})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000567
568 switch msg.TestMessageVal {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000569 case cmn.LoadMibTemplateFailed:
570 _ = oo.PMibUploadFsm.PFsm.Event(UlEvUploadMib)
571 logger.Debugw(ctx, "MibSync Msg", log.Fields{"state": string(oo.PMibUploadFsm.PFsm.Current())})
572 case cmn.LoadMibTemplateOk:
573 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
574 logger.Debugw(ctx, "MibSync Msg", log.Fields{"state": string(oo.PMibUploadFsm.PFsm.Current())})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000575 default:
dbainbri4d3a0dc2020-12-02 00:33:42 +0000576 logger.Warn(ctx, "MibSync Msg", log.Fields{"Unknown message type received for device-id": oo.deviceID, "msg.TestMessageVal": msg.TestMessageVal})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000577 }
578}
579
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000580func (oo *OnuDeviceEntry) handleOmciMibResetResponseMessage(ctx context.Context, msg cmn.OmciMessage) {
581 if oo.PMibUploadFsm.PFsm.Is(UlStResettingMib) {
Himani Chawla4d908332020-08-31 12:30:20 +0530582 msgLayer := (*msg.OmciPacket).Layer(omci.LayerTypeMibResetResponse)
583 if msgLayer != nil {
584 msgObj, msgOk := msgLayer.(*omci.MibResetResponse)
585 if msgOk {
nikesh.krishnan1ffb8132023-05-23 03:44:13 +0530586 logger.Infow(ctx, "MibResetResponse Data", log.Fields{"data-fields": msgObj})
Himani Chawla4d908332020-08-31 12:30:20 +0530587 if msgObj.Result == me.Success {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000588 oo.MutexPersOnuConfig.Lock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000589 oo.SOnuPersistentData.PersMibDataSyncAdpt = cmn.MdsDefaultMib
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000590 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandt7e138462023-03-29 12:12:14 +0000591 oo.PDevOmciCC.ResetConfFailMEs()
Himani Chawla4d908332020-08-31 12:30:20 +0530592 // trigger retrieval of VendorId and SerialNumber
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000593 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetVendorAndSerial)
Himani Chawla4d908332020-08-31 12:30:20 +0530594 return
595 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000596 logger.Errorw(ctx, "Omci MibResetResponse Error", log.Fields{"device-id": oo.deviceID, "Error": msgObj.Result})
Himani Chawla4d908332020-08-31 12:30:20 +0530597 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000598 logger.Errorw(ctx, "Omci Msg layer could not be assigned", log.Fields{"device-id": oo.deviceID})
Himani Chawla4d908332020-08-31 12:30:20 +0530599 }
600 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000601 logger.Errorw(ctx, "Omci Msg layer could not be detected", log.Fields{"device-id": oo.deviceID})
Himani Chawla4d908332020-08-31 12:30:20 +0530602 }
603 } else {
mpagenko01499812021-03-25 10:37:12 +0000604 //in case the last request was MdsGetRequest this issue may appear if the ONU was online before and has received the MIB reset
605 // with Sequence number 0x8000 as last request before - so it may still respond to that
606 // then we may force the ONU to react on the MdsGetRequest with a new message that uses an increased Sequence number
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000607 oo.mutexLastTxParamStruct.Lock()
mpagenko01499812021-03-25 10:37:12 +0000608 if oo.lastTxParamStruct.lastTxMessageType == omci.GetRequestType && oo.lastTxParamStruct.repeatCount == 0 {
609 logger.Debugw(ctx, "MibSync FSM - repeat MdsGetRequest (updated SequenceNumber)", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt3ac49bd2022-02-07 17:46:43 +0000610 requestedAttributes := me.AttributeValueMap{me.OnuData_MibDataSync: ""}
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000611 _, err := oo.PDevOmciCC.SendGetMe(log.WithSpanFromContext(context.TODO(), ctx),
Holger Hildebrandtd930cb22022-06-17 09:24:50 +0000612 me.OnuDataClassID, cmn.OnuDataMeID, requestedAttributes, oo.baseDeviceHandler.GetOmciTimeout(), true, oo.PMibUploadFsm.CommChan, false)
ozgecanetsiab36ed572021-04-01 10:38:48 +0300613 if err != nil {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000614 oo.mutexLastTxParamStruct.Unlock()
ozgecanetsiab36ed572021-04-01 10:38:48 +0300615 logger.Errorw(ctx, "ONUData get failed, aborting MibSync", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000616 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
ozgecanetsiab36ed572021-04-01 10:38:48 +0300617 return
618 }
mpagenko01499812021-03-25 10:37:12 +0000619 //TODO: needs extra handling of timeouts
620 oo.lastTxParamStruct.repeatCount = 1
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000621 oo.mutexLastTxParamStruct.Unlock()
mpagenko01499812021-03-25 10:37:12 +0000622 return
623 }
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000624 oo.mutexLastTxParamStruct.Unlock()
mpagenko01499812021-03-25 10:37:12 +0000625 logger.Errorw(ctx, "unexpected MibResetResponse - ignoring", log.Fields{"device-id": oo.deviceID})
626 //perhaps some still lingering message from some prior activity, let's wait for the real response
627 return
Himani Chawla4d908332020-08-31 12:30:20 +0530628 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000629 logger.Info(ctx, "MibSync Msg", log.Fields{"Stopped handling of MibSyncChan for device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000630 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Himani Chawla4d908332020-08-31 12:30:20 +0530631}
632
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000633func (oo *OnuDeviceEntry) handleOmciMibUploadResponseMessage(ctx context.Context, msg cmn.OmciMessage) {
Himani Chawla4d908332020-08-31 12:30:20 +0530634 msgLayer := (*msg.OmciPacket).Layer(omci.LayerTypeMibUploadResponse)
635 if msgLayer == nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000636 logger.Errorw(ctx, "Omci Msg layer could not be detected", log.Fields{"device-id": oo.deviceID})
Himani Chawla4d908332020-08-31 12:30:20 +0530637 return
638 }
639 msgObj, msgOk := msgLayer.(*omci.MibUploadResponse)
640 if !msgOk {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000641 logger.Errorw(ctx, "Omci Msg layer could not be assigned", log.Fields{"device-id": oo.deviceID})
Himani Chawla4d908332020-08-31 12:30:20 +0530642 return
643 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000644 logger.Debugw(ctx, "MibUploadResponse Data for:", log.Fields{"device-id": oo.deviceID, "data-fields": msgObj})
Himani Chawla4d908332020-08-31 12:30:20 +0530645 /* to be verified / reworked !!! */
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000646 oo.PDevOmciCC.UploadNoOfCmds = msgObj.NumberOfCommands
647 if oo.PDevOmciCC.UploadSequNo < oo.PDevOmciCC.UploadNoOfCmds {
Holger Hildebrandt5458d892022-05-31 09:52:06 +0000648 _ = oo.PDevOmciCC.SendMibUploadNext(log.WithSpanFromContext(context.TODO(), ctx),
649 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.GetPersIsExtOmciSupported())
mpagenko01499812021-03-25 10:37:12 +0000650 //even though lastTxParameters are currently not used for checking the ResetResponse message we have to ensure
651 // that the lastTxMessageType is correctly set to avoid misinterpreting other responses
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000652 oo.mutexLastTxParamStruct.Lock()
mpagenko01499812021-03-25 10:37:12 +0000653 oo.lastTxParamStruct.lastTxMessageType = omci.MibUploadNextRequestType
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000654 oo.mutexLastTxParamStruct.Unlock()
Himani Chawla4d908332020-08-31 12:30:20 +0530655 } else {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000656 logger.Errorw(ctx, "Invalid number of commands received for:", log.Fields{"device-id": oo.deviceID, "UploadNoOfCmds": oo.PDevOmciCC.UploadNoOfCmds})
Himani Chawla4d908332020-08-31 12:30:20 +0530657 //TODO right action?
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000658 _ = oo.PMibUploadFsm.PFsm.Event(UlEvTimeout)
Himani Chawla4d908332020-08-31 12:30:20 +0530659 }
660}
661
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000662func (oo *OnuDeviceEntry) handleOmciMibUploadNextResponseMessage(ctx context.Context, msg cmn.OmciMessage) {
Himani Chawla4d908332020-08-31 12:30:20 +0530663 msgLayer := (*msg.OmciPacket).Layer(omci.LayerTypeMibUploadNextResponse)
mpagenko7033f4e2021-11-19 18:04:22 +0000664 if msgLayer != nil {
665 msgObj, msgOk := msgLayer.(*omci.MibUploadNextResponse)
666 if !msgOk {
667 logger.Errorw(ctx, "Omci Msg layer could not be assigned", log.Fields{"device-id": oo.deviceID})
668 return
mpagenko836a1fd2021-11-01 16:12:42 +0000669 }
mpagenko7033f4e2021-11-19 18:04:22 +0000670 meName := msgObj.ReportedME.GetName()
671 meClassID := msgObj.ReportedME.GetClassID()
672 meEntityID := msgObj.ReportedME.GetEntityID()
673
674 logger.Debugw(ctx, "MibUploadNextResponse Data for:", log.Fields{"device-id": oo.deviceID, "meName": meName, "data-fields": msgObj})
675
676 if meName == devdb.CUnknownItuG988ManagedEntity || meName == devdb.CUnknownVendorSpecificManagedEntity {
Holger Hildebrandt39080022022-03-16 10:03:17 +0000677 logger.Debugw(ctx, "MibUploadNextResponse contains unknown ME", log.Fields{"device-id": oo.deviceID,
678 "Me-Name": devdb.UnknownMeOrAttribName(meName), "Me-ClassId": meClassID, "Me-InstId": meEntityID,
679 "unknown mask": msgObj.ReportedME.GetAttributeMask(), "unknown attributes": msgObj.BaseLayer.Payload})
680 oo.pOnuDB.PutUnknownMeOrAttrib(ctx, devdb.UnknownMeOrAttribName(meName), meClassID, meEntityID,
681 msgObj.ReportedME.GetAttributeMask(), msgObj.BaseLayer.Payload[devdb.CStartUnknownMeAttribsInBaseLayerPayload:])
mpagenko7033f4e2021-11-19 18:04:22 +0000682 } else {
683 //with relaxed decoding set in the OMCI-LIB we have the chance to detect if there are some unknown attributes appended which we cannot decode
684 if unknownAttrLayer := (*msg.OmciPacket).Layer(omci.LayerTypeUnknownAttributes); unknownAttrLayer != nil {
685 logger.Warnw(ctx, "MibUploadNextResponse contains unknown attributes", log.Fields{"device-id": oo.deviceID})
686 if unknownAttributes, ok := unknownAttrLayer.(*omci.UnknownAttributes); ok {
687 // provide a loop over several ME's here already in preparation of OMCI extended message format
688 for _, unknown := range unknownAttributes.Attributes {
689 unknownAttrClassID := unknown.EntityClass // ClassID
690 unknownAttrInst := unknown.EntityInstance // uint16
691 unknownAttrMask := unknown.AttributeMask // ui
692 unknownAttrBlob := unknown.AttributeData // []byte
693 logger.Warnw(ctx, "unknown attributes detected for", log.Fields{"device-id": oo.deviceID,
694 "Me-ClassId": unknownAttrClassID, "Me-InstId": unknownAttrInst, "unknown mask": unknownAttrMask,
695 "unknown attributes": unknownAttrBlob})
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000696 oo.pOnuDB.PutUnknownMeOrAttrib(ctx, devdb.CUnknownAttributesManagedEntity, unknown.EntityClass, unknown.EntityInstance,
697 unknown.AttributeMask, unknown.AttributeData)
mpagenko7033f4e2021-11-19 18:04:22 +0000698 } // for all included ME's with unknown attributes
699 } else {
700 logger.Errorw(ctx, "unknownAttrLayer could not be decoded", log.Fields{"device-id": oo.deviceID})
701 }
702 }
703 oo.pOnuDB.PutMe(ctx, meClassID, meEntityID, msgObj.ReportedME.GetAttributeValueMap())
704 }
Holger Hildebrandt0edf5b02022-05-04 14:19:43 +0000705 if msg.OmciMsg.DeviceIdentifier == omci.ExtendedIdent {
706 for _, additionalME := range msgObj.AdditionalMEs {
707 meName := additionalME.GetName()
708 meClassID := additionalME.GetClassID()
709 meEntityID := additionalME.GetEntityID()
710 attributes := additionalME.GetAttributeValueMap()
711
712 if meName == devdb.CUnknownItuG988ManagedEntity || meName == devdb.CUnknownVendorSpecificManagedEntity {
713 attribMask := additionalME.GetAttributeMask()
714 logger.Debugw(ctx, "MibUploadNextResponse AdditionalData contains unknown ME", log.Fields{"device-id": oo.deviceID,
715 "Me-Name": devdb.UnknownMeOrAttribName(meName), "Me-ClassId": meClassID, "Me-InstId": meEntityID,
716 "unknown mask": attribMask})
717
718 attribValues := make([]byte, 0)
719 for key, value := range attributes {
720 if key != cmn.CGenericManagedEntityIDName {
721 data, err := me.InterfaceToOctets(value)
722 if err != nil {
723 logger.Infow(ctx, "MibUploadNextResponse unknown ME AdditionalData attrib - could not decode", log.Fields{"device-id": oo.deviceID, "key": key})
724 } else {
725 attribValues = append(attribValues[:], data[:]...)
726 logger.Debugw(ctx, "MibUploadNextResponse unknown ME AdditionalData attrib", log.Fields{"device-id": oo.deviceID, "attribValues": attribValues, "data": data, "key": key})
727 }
728 }
729 }
730 oo.pOnuDB.PutUnknownMeOrAttrib(ctx, devdb.UnknownMeOrAttribName(meName), meClassID, meEntityID, attribMask, attribValues)
731 } else {
732 logger.Debugw(ctx, "MibUploadNextResponse AdditionalData for:", log.Fields{"device-id": oo.deviceID, "meName": meName, "meEntityID": meEntityID, "attributes": attributes})
733 oo.pOnuDB.PutMe(ctx, meClassID, meEntityID, attributes)
734 }
735 }
736 }
mpagenko7033f4e2021-11-19 18:04:22 +0000737 } else {
738 logger.Errorw(ctx, "Omci Msg layer could not be detected", log.Fields{"device-id": oo.deviceID})
739 //as long as omci-lib does not support decoding of table attribute as 'unknown/unspecified' attribute
740 // we have to verify, if this failure is from table attribute and try to go forward with ignoring the complete message
741 errLayer := (*msg.OmciPacket).Layer(gopacket.LayerTypeDecodeFailure)
742 if failure, decodeOk := errLayer.(*gopacket.DecodeFailure); decodeOk {
743 errMsg := failure.String()
744 if !strings.Contains(strings.ToLower(errMsg), "table decode") {
745 //something still unexected happened, needs deeper investigation - stop complete MIB upload process (timeout)
746 return
747 }
748 logger.Warnw(ctx, "Decode issue on received MibUploadNextResponse frame - found table attribute(s) (message ignored)",
749 log.Fields{"device-id": oo.deviceID, "issue": errMsg})
750 }
Himani Chawla4d908332020-08-31 12:30:20 +0530751 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000752 if oo.PDevOmciCC.UploadSequNo < oo.PDevOmciCC.UploadNoOfCmds {
Holger Hildebrandt5458d892022-05-31 09:52:06 +0000753 _ = oo.PDevOmciCC.SendMibUploadNext(log.WithSpanFromContext(context.TODO(), ctx),
754 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.GetPersIsExtOmciSupported())
mpagenko01499812021-03-25 10:37:12 +0000755 //even though lastTxParameters are currently not used for checking the ResetResponse message we have to ensure
756 // that the lastTxMessageType is correctly set to avoid misinterpreting other responses
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000757 oo.mutexLastTxParamStruct.Lock()
mpagenko01499812021-03-25 10:37:12 +0000758 oo.lastTxParamStruct.lastTxMessageType = omci.MibUploadNextRequestType
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000759 oo.mutexLastTxParamStruct.Unlock()
Himani Chawla4d908332020-08-31 12:30:20 +0530760 } else {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000761 oo.pOnuDB.LogMeDb(ctx)
dbainbri4d3a0dc2020-12-02 00:33:42 +0000762 err := oo.createAndPersistMibTemplate(ctx)
Himani Chawla4d908332020-08-31 12:30:20 +0530763 if err != nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000764 logger.Errorw(ctx, "MibSync - MibTemplate - Failed to create and persist the mib template", log.Fields{"error": err, "device-id": oo.deviceID})
Himani Chawla4d908332020-08-31 12:30:20 +0530765 }
766
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000767 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Himani Chawla4d908332020-08-31 12:30:20 +0530768 }
769}
770
Girish Gowdra21bbf052022-02-17 16:08:22 -0800771// nolint: gocyclo
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000772func (oo *OnuDeviceEntry) handleOmciGetResponseMessage(ctx context.Context, msg cmn.OmciMessage) error {
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000773 var err error = nil
mpagenko01499812021-03-25 10:37:12 +0000774
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000775 oo.mutexLastTxParamStruct.RLock()
mpagenko01499812021-03-25 10:37:12 +0000776 if oo.lastTxParamStruct.lastTxMessageType != omci.GetRequestType ||
777 oo.lastTxParamStruct.pLastTxMeInstance == nil {
778 //in case the last request was MibReset this issue may appear if the ONU was online before and has received the MDS GetRequest
779 // with Sequence number 0x8000 as last request before - so it may still respond to that
780 // then we may force the ONU to react on the MIB reset with a new message that uses an increased Sequence number
781 if oo.lastTxParamStruct.lastTxMessageType == omci.MibResetRequestType && oo.lastTxParamStruct.repeatCount == 0 {
782 logger.Debugw(ctx, "MibSync FSM - repeat mibReset (updated SequenceNumber)", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000783 _ = oo.PDevOmciCC.SendMibReset(log.WithSpanFromContext(context.TODO(), ctx), oo.baseDeviceHandler.GetOmciTimeout(), true)
mpagenko01499812021-03-25 10:37:12 +0000784 //TODO: needs extra handling of timeouts
785 oo.lastTxParamStruct.repeatCount = 1
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000786 oo.mutexLastTxParamStruct.RUnlock()
mpagenko01499812021-03-25 10:37:12 +0000787 return nil
788 }
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000789 oo.mutexLastTxParamStruct.RUnlock()
mpagenko01499812021-03-25 10:37:12 +0000790 logger.Warnw(ctx, "unexpected GetResponse - ignoring", log.Fields{"device-id": oo.deviceID})
791 //perhaps some still lingering message from some prior activity, let's wait for the real response
792 return nil
793 }
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000794 oo.mutexLastTxParamStruct.RUnlock()
Himani Chawla4d908332020-08-31 12:30:20 +0530795 msgLayer := (*msg.OmciPacket).Layer(omci.LayerTypeGetResponse)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000796 if msgLayer == nil {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000797 logger.Errorw(ctx, "omci Msg layer could not be detected for GetResponse - handling of MibSyncChan stopped",
798 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000799 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt61b24d02020-11-16 13:36:40 +0000800 return fmt.Errorf("omci Msg layer could not be detected for GetResponse - handling of MibSyncChan stopped: %s", oo.deviceID)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000801 }
802 msgObj, msgOk := msgLayer.(*omci.GetResponse)
803 if !msgOk {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000804 logger.Errorw(ctx, "omci Msg layer could not be assigned for GetResponse - handling of MibSyncChan stopped",
805 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000806 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt61b24d02020-11-16 13:36:40 +0000807 return fmt.Errorf("omci Msg layer could not be assigned for GetResponse - handling of MibSyncChan stopped: %s", oo.deviceID)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000808 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000809 logger.Debugw(ctx, "MibSync FSM - GetResponse Data", log.Fields{"device-id": oo.deviceID, "data-fields": msgObj})
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000810 if msgObj.Result == me.Success {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000811 oo.mutexLastTxParamStruct.RLock()
mpagenko01499812021-03-25 10:37:12 +0000812 entityID := oo.lastTxParamStruct.pLastTxMeInstance.GetEntityID()
813 if msgObj.EntityClass == oo.lastTxParamStruct.pLastTxMeInstance.GetClassID() && msgObj.EntityInstance == entityID {
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000814 meAttributes := msgObj.Attributes
mpagenko01499812021-03-25 10:37:12 +0000815 meInstance := oo.lastTxParamStruct.pLastTxMeInstance.GetName()
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000816 logger.Debugf(ctx, "MibSync FSM - GetResponse Data for %s",
817 log.Fields{"device-id": oo.deviceID, "data-fields": msgObj}, meInstance)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000818 switch meInstance {
819 case "OnuG":
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000820 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000821 return oo.handleOmciGetResponseOnuG(ctx, meAttributes)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000822 case "Onu2G":
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000823 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000824 var equipmentID string
825 if onu2GEquipmentID, ok := meAttributes[me.Onu2G_EquipmentId]; ok {
826 equipmentID = cmn.TrimStringFromMeOctet(onu2GEquipmentID)
827 if equipmentID == "" {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000828 logger.Infow(ctx,
829 "MibSync FSM - optional attribute EquipmentID is empty in Onu2G instance - fill with appropriate value",
830 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000831 equipmentID = cEmptyEquipIDString
832 }
833 } else {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000834 logger.Infow(ctx,
835 "MibSync FSM - optional attribute EquipmentID not present in Onu2G instance - fill with appropriate value",
836 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000837 equipmentID = cNotPresentEquipIDString
838 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000839 oo.MutexPersOnuConfig.Lock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000840 oo.SOnuPersistentData.PersEquipmentID = equipmentID
dbainbri4d3a0dc2020-12-02 00:33:42 +0000841 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for Onu2-G - EquipmentId", log.Fields{"device-id": oo.deviceID,
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000842 "onuDeviceEntry.equipmentID": oo.SOnuPersistentData.PersEquipmentID})
843 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000844
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000845 var omccVersion uint8
846 if onu2GOmccVersion, ok := meAttributes[me.Onu2G_OpticalNetworkUnitManagementAndControlChannelOmccVersion]; ok {
847 oo.MutexPersOnuConfig.Lock()
848 omccVersion = onu2GOmccVersion.(uint8)
849 if _, ok := omccVersionSupportsExtendedOmciFormat[omccVersion]; ok {
850 oo.SOnuPersistentData.PersIsExtOmciSupported = omccVersionSupportsExtendedOmciFormat[omccVersion]
Holger Hildebrandtc572e622022-06-22 09:19:17 +0000851 if oo.SOnuPersistentData.PersIsExtOmciSupported && !oo.baseDeviceHandler.GetExtendedOmciSupportEnabled() {
852 logger.Infow(ctx, "MibSync FSM - ONU supports extended OMCI, but support is disabled in the adapter: reset flag",
853 log.Fields{"device-id": oo.deviceID})
854 oo.SOnuPersistentData.PersIsExtOmciSupported = false
855 }
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000856 } else {
857 logger.Infow(ctx, "MibSync FSM - unknown OMCC version in Onu2G instance - disable extended OMCI support",
858 log.Fields{"device-id": oo.deviceID})
859 oo.SOnuPersistentData.PersIsExtOmciSupported = false
860 }
861 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for Onu2-G - OMCC version", log.Fields{"device-id": oo.deviceID,
862 "omccVersion": omccVersion, "isExtOmciSupported": oo.SOnuPersistentData.PersIsExtOmciSupported})
863 oo.MutexPersOnuConfig.Unlock()
864 } else {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000865 logger.Errorw(ctx,
866 "MibSync FSM - mandatory attribute OMCC version not present in Onu2G instance - handling of MibSyncChan stopped!",
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000867 log.Fields{"device-id": oo.deviceID})
868 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000869 return fmt.Errorf(
870 "mibSync FSM - mandatory attribute OMCC version not present in Onu2G instance - handling of MibSyncChan stopped: %s",
871 oo.deviceID)
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000872 }
873 oo.MutexPersOnuConfig.RLock()
874 if oo.SOnuPersistentData.PersIsExtOmciSupported {
875 oo.MutexPersOnuConfig.RUnlock()
876 // trigger test of OMCI extended msg format
877 _ = oo.PMibUploadFsm.PFsm.Event(UlEvTestExtOmciSupport)
878 return nil
879 }
880 oo.MutexPersOnuConfig.RUnlock()
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000881 // trigger retrieval of 1st SW-image info
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000882 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetFirstSwVersion)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000883 return nil
884 case "SoftwareImage":
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000885 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000886 if entityID > cmn.SecondSwImageMeID {
mpagenko15ff4a52021-03-02 10:09:20 +0000887 logger.Errorw(ctx, "mibSync FSM - Failed to GetResponse Data for SoftwareImage with expected EntityId",
888 log.Fields{"device-id": oo.deviceID, "entity-ID": entityID})
889 return fmt.Errorf("mibSync FSM - SwResponse Data with unexpected EntityId: %s %x",
890 oo.deviceID, entityID)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000891 }
mpagenko15ff4a52021-03-02 10:09:20 +0000892 // need to use function for go lint complexity
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000893 if !oo.HandleSwImageIndications(ctx, entityID, meAttributes) {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000894 logger.Errorw(ctx,
895 "MibSync FSM - Not all mandatory attributes present in in SoftwareImage instance - handling of MibSyncChan stopped!",
896 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000897 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000898 return fmt.Errorf(
899 "mibSync FSM - Not all mandatory attributes present in in SoftwareImage instance - handling of MibSyncChan stopped: %s",
900 oo.deviceID)
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000901 }
mpagenko15ff4a52021-03-02 10:09:20 +0000902 return nil
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000903 case "IpHostConfigData":
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000904 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000905 oo.MutexPersOnuConfig.Lock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000906 if ipHostConfigMacAddress, ok := meAttributes[me.IpHostConfigData_MacAddress]; ok {
Girish Gowdra21bbf052022-02-17 16:08:22 -0800907 macBytes, _ := me.InterfaceToOctets(ipHostConfigMacAddress)
908 if cmn.OmciMacAddressLen == len(macBytes) {
909 oo.SOnuPersistentData.PersMacAddress = hex.EncodeToString(macBytes[:])
910 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for IpHostConfigData - MacAddress", log.Fields{"device-id": oo.deviceID,
911 "macAddress": oo.SOnuPersistentData.PersMacAddress})
912 } else {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000913 logger.Infow(ctx, "MibSync FSM - MacAddress wrong length - fill macAddress with zeros",
914 log.Fields{"device-id": oo.deviceID, "length": len(macBytes)})
Girish Gowdra21bbf052022-02-17 16:08:22 -0800915 oo.SOnuPersistentData.PersMacAddress = cEmptyMacAddrString
916 }
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000917 } else {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000918 // since ONU creates instances of this ME automatically only when IP host services are available,
919 // processing continues here despite the error
920 logger.Infow(ctx, "MibSync FSM - MacAddress attribute not present in IpHostConfigData instance - fill macAddress with zeros",
921 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000922 oo.SOnuPersistentData.PersMacAddress = cEmptyMacAddrString
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000923 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000924 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000925 // trigger retrieval of mib template
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000926 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetMibTemplate)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000927 return nil
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +0000928 case "OnuData":
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000929 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000930 if onuDataMibDataSync, ok := meAttributes[me.OnuData_MibDataSync]; ok {
931 oo.checkMdsValue(ctx, onuDataMibDataSync.(uint8))
932 } else {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000933 logger.Errorw(ctx, "MibSync FSM - MibDataSync attribute not present in OnuData instance - handling of MibSyncChan stopped!",
934 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000935 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000936 return fmt.Errorf("mibSync FSM - VendorId attribute not present in OnuG instance - handling of MibSyncChan stopped: %s",
937 oo.deviceID)
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000938 }
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +0000939 return nil
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000940 default:
941 oo.mutexLastTxParamStruct.RUnlock()
942 logger.Warnw(ctx, "Unsupported ME name received!",
943 log.Fields{"ME name": meInstance, "device-id": oo.deviceID})
944
Himani Chawla4d908332020-08-31 12:30:20 +0530945 }
Matteo Scandolo20ca10c2021-01-21 14:35:45 -0800946 } else {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000947 oo.mutexLastTxParamStruct.RUnlock()
948 logger.Warnf(ctx, "MibSync FSM - Received GetResponse Data for %s with wrong classID or entityID ",
949 log.Fields{"device-id": oo.deviceID, "data-fields": msgObj}, msgObj.EntityClass)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000950 }
Himani Chawla4d908332020-08-31 12:30:20 +0530951 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000952 if err = oo.handleOmciGetResponseErrors(ctx, msgObj); err == nil {
Holger Hildebrandt80129db2020-11-23 10:49:32 +0000953 return nil
954 }
Himani Chawla4d908332020-08-31 12:30:20 +0530955 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000956 logger.Info(ctx, "MibSync Msg", log.Fields{"Stopped handling of MibSyncChan for device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000957 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000958 return err
Himani Chawla4d908332020-08-31 12:30:20 +0530959}
960
nikesh.krishnan1ffb8132023-05-23 03:44:13 +0530961// HandleSwImageIndications updates onuSwImageIndications with the ONU data just received
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000962func (oo *OnuDeviceEntry) HandleSwImageIndications(ctx context.Context, entityID uint16, meAttributes me.AttributeValueMap) bool {
963
964 var imageVersion string
965 var imageIsCommitted, imageIsActive uint8
966
967 allMandAttribsPresent := false
968 if softwareImageIsCommitted, ok := meAttributes[me.SoftwareImage_IsCommitted]; ok {
969 if softwareImageIsActiveimage, ok := meAttributes[me.SoftwareImage_IsActive]; ok {
970 if softwareImageVersion, ok := meAttributes[me.SoftwareImage_Version]; ok {
971 imageVersion = cmn.TrimStringFromMeOctet(softwareImageVersion)
972 imageIsActive = softwareImageIsActiveimage.(uint8)
973 imageIsCommitted = softwareImageIsCommitted.(uint8)
974 allMandAttribsPresent = true
975 }
976 }
977 }
978 if !allMandAttribsPresent {
979 logger.Errorw(ctx, "MibSync FSM - Not all mandatory attributes present in SoftwareImage instance - skip processing!", log.Fields{"device-id": oo.deviceID})
980 return allMandAttribsPresent
981 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000982 oo.MutexPersOnuConfig.RLock()
mpagenko15ff4a52021-03-02 10:09:20 +0000983 logger.Infow(ctx, "MibSync FSM - GetResponse Data for SoftwareImage",
984 log.Fields{"device-id": oo.deviceID, "entityID": entityID,
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000985 "version": imageVersion, "isActive": imageIsActive, "isCommitted": imageIsCommitted, "SNR": oo.SOnuPersistentData.PersSerialNumber})
986 oo.MutexPersOnuConfig.RUnlock()
987 if cmn.FirstSwImageMeID == entityID {
mpagenko15ff4a52021-03-02 10:09:20 +0000988 //always accept the state of the first image (2nd image info should not yet be available)
Holger Hildebrandt05011352021-06-15 09:40:24 +0000989 oo.mutexOnuSwImageIndications.Lock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000990 if imageIsActive == cmn.SwIsActive {
991 oo.onuSwImageIndications.ActiveEntityEntry.EntityID = entityID
992 oo.onuSwImageIndications.ActiveEntityEntry.Valid = true
993 oo.onuSwImageIndications.ActiveEntityEntry.Version = imageVersion
994 oo.onuSwImageIndications.ActiveEntityEntry.IsCommitted = imageIsCommitted
mpagenko59498c12021-03-18 14:15:15 +0000995 //as the SW version indication may stem from some ONU Down/up event
996 //the complementary image state is to be invalidated
997 // (state of the second image is always expected afterwards or just invalid)
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000998 oo.onuSwImageIndications.InActiveEntityEntry.Valid = false
mpagenko15ff4a52021-03-02 10:09:20 +0000999 } else {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001000 oo.onuSwImageIndications.InActiveEntityEntry.EntityID = entityID
1001 oo.onuSwImageIndications.InActiveEntityEntry.Valid = true
1002 oo.onuSwImageIndications.InActiveEntityEntry.Version = imageVersion
1003 oo.onuSwImageIndications.InActiveEntityEntry.IsCommitted = imageIsCommitted
mpagenko59498c12021-03-18 14:15:15 +00001004 //as the SW version indication may stem form some ONU Down/up event
1005 //the complementary image state is to be invalidated
1006 // (state of the second image is always expected afterwards or just invalid)
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001007 oo.onuSwImageIndications.ActiveEntityEntry.Valid = false
mpagenko15ff4a52021-03-02 10:09:20 +00001008 }
Holger Hildebrandt05011352021-06-15 09:40:24 +00001009 oo.mutexOnuSwImageIndications.Unlock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001010 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetSecondSwVersion)
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +00001011 return allMandAttribsPresent
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001012 } else if cmn.SecondSwImageMeID == entityID {
mpagenko15ff4a52021-03-02 10:09:20 +00001013 //2nd image info might conflict with first image info, in which case we priorize first image info!
Holger Hildebrandt05011352021-06-15 09:40:24 +00001014 oo.mutexOnuSwImageIndications.Lock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001015 if imageIsActive == cmn.SwIsActive { //2nd image reported to be active
1016 if oo.onuSwImageIndications.ActiveEntityEntry.Valid {
mpagenko15ff4a52021-03-02 10:09:20 +00001017 //conflict exists - state of first image is left active
1018 logger.Warnw(ctx, "mibSync FSM - both ONU images are reported as active - assuming 2nd to be inactive",
1019 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001020 oo.onuSwImageIndications.InActiveEntityEntry.EntityID = entityID
1021 oo.onuSwImageIndications.InActiveEntityEntry.Valid = true ////to indicate that at least something has been reported
1022 oo.onuSwImageIndications.InActiveEntityEntry.Version = imageVersion
1023 oo.onuSwImageIndications.InActiveEntityEntry.IsCommitted = imageIsCommitted
mpagenko15ff4a52021-03-02 10:09:20 +00001024 } else { //first image inactive, this one active
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001025 oo.onuSwImageIndications.ActiveEntityEntry.EntityID = entityID
1026 oo.onuSwImageIndications.ActiveEntityEntry.Valid = true
1027 oo.onuSwImageIndications.ActiveEntityEntry.Version = imageVersion
1028 oo.onuSwImageIndications.ActiveEntityEntry.IsCommitted = imageIsCommitted
mpagenko15ff4a52021-03-02 10:09:20 +00001029 }
1030 } else { //2nd image reported to be inactive
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001031 if oo.onuSwImageIndications.InActiveEntityEntry.Valid {
mpagenko15ff4a52021-03-02 10:09:20 +00001032 //conflict exists - both images inactive - regard it as ONU failure and assume first image to be active
1033 logger.Warnw(ctx, "mibSync FSM - both ONU images are reported as inactive, defining first to be active",
1034 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001035 oo.onuSwImageIndications.ActiveEntityEntry.EntityID = cmn.FirstSwImageMeID
1036 oo.onuSwImageIndications.ActiveEntityEntry.Valid = true //to indicate that at least something has been reported
mpagenko15ff4a52021-03-02 10:09:20 +00001037 //copy active commit/version from the previously stored inactive position
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001038 oo.onuSwImageIndications.ActiveEntityEntry.Version = oo.onuSwImageIndications.InActiveEntityEntry.Version
1039 oo.onuSwImageIndications.ActiveEntityEntry.IsCommitted = oo.onuSwImageIndications.InActiveEntityEntry.IsCommitted
mpagenko15ff4a52021-03-02 10:09:20 +00001040 }
1041 //in any case we indicate (and possibly overwrite) the second image indications as inactive
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001042 oo.onuSwImageIndications.InActiveEntityEntry.EntityID = entityID
1043 oo.onuSwImageIndications.InActiveEntityEntry.Valid = true
1044 oo.onuSwImageIndications.InActiveEntityEntry.Version = imageVersion
1045 oo.onuSwImageIndications.InActiveEntityEntry.IsCommitted = imageIsCommitted
mpagenko15ff4a52021-03-02 10:09:20 +00001046 }
Holger Hildebrandt05011352021-06-15 09:40:24 +00001047 oo.mutexOnuSwImageIndications.Unlock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001048 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetMacAddress)
mpagenko15ff4a52021-03-02 10:09:20 +00001049 }
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +00001050 return allMandAttribsPresent
mpagenko15ff4a52021-03-02 10:09:20 +00001051}
1052
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001053func (oo *OnuDeviceEntry) handleOmciMessage(ctx context.Context, msg cmn.OmciMessage) {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001054 logger.Debugw(ctx, "MibSync Msg", log.Fields{"OmciMessage received for device-id": oo.deviceID,
Andrea Campanella6515c582020-10-05 11:25:00 +02001055 "msgType": msg.OmciMsg.MessageType, "msg": msg})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001056 //further analysis could be done here based on msg.OmciMsg.Payload, e.g. verification of error code ...
1057 switch msg.OmciMsg.MessageType {
1058 case omci.MibResetResponseType:
dbainbri4d3a0dc2020-12-02 00:33:42 +00001059 oo.handleOmciMibResetResponseMessage(ctx, msg)
Holger Hildebrandtc54939a2020-06-17 08:14:27 +00001060
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001061 case omci.MibUploadResponseType:
dbainbri4d3a0dc2020-12-02 00:33:42 +00001062 oo.handleOmciMibUploadResponseMessage(ctx, msg)
Himani Chawla4d908332020-08-31 12:30:20 +05301063
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001064 case omci.MibUploadNextResponseType:
dbainbri4d3a0dc2020-12-02 00:33:42 +00001065 oo.handleOmciMibUploadNextResponseMessage(ctx, msg)
Holger Hildebrandtccd390c2020-05-29 13:49:04 +00001066
Holger Hildebrandtc54939a2020-06-17 08:14:27 +00001067 case omci.GetResponseType:
Holger Hildebrandt2fb70892020-10-28 11:53:18 +00001068 //TODO: error handling
dbainbri4d3a0dc2020-12-02 00:33:42 +00001069 _ = oo.handleOmciGetResponseMessage(ctx, msg)
Himani Chawla4d908332020-08-31 12:30:20 +05301070
Andrea Campanella6515c582020-10-05 11:25:00 +02001071 default:
Holger Hildebrandtabfef032022-02-25 12:40:20 +00001072 logger.Warnw(ctx, "Unknown Message Type", log.Fields{"device-id": oo.deviceID, "msgType": msg.OmciMsg.MessageType})
Andrea Campanella6515c582020-10-05 11:25:00 +02001073
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001074 }
1075}
1076
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +00001077func (oo *OnuDeviceEntry) handleOmciGetResponseOnuG(ctx context.Context, meAttributes me.AttributeValueMap) error {
1078 currentState := oo.PMibUploadFsm.PFsm.Current()
1079 if currentState == UlStGettingVendorAndSerial {
1080 if onuGVendorID, ok := meAttributes[me.OnuG_VendorId]; ok {
1081 vendorID := cmn.TrimStringFromMeOctet(onuGVendorID)
1082 if vendorID == "" {
1083 logger.Infow(ctx,
1084 "MibSync FSM - mandatory attribute VendorId is empty in OnuG instance - fill with appropriate value",
1085 log.Fields{"device-id": oo.deviceID})
1086 vendorID = cEmptyVendorIDString
1087 }
1088 oo.MutexPersOnuConfig.Lock()
1089 oo.SOnuPersistentData.PersVendorID = vendorID
1090 oo.MutexPersOnuConfig.Unlock()
1091 } else {
1092 logger.Errorw(ctx,
1093 "MibSync FSM - mandatory attribute VendorId not present in OnuG instance - handling of MibSyncChan stopped!",
1094 log.Fields{"device-id": oo.deviceID})
1095 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
1096 return fmt.Errorf(
1097 "mibSync FSM - mandatory attribute VendorId not present in OnuG instance - handling of MibSyncChan stopped: %s",
1098 oo.deviceID)
1099 }
1100 if onuGSerialNumber, ok := meAttributes[me.OnuG_SerialNumber]; ok {
1101 oo.MutexPersOnuConfig.Lock()
1102 snBytes, _ := me.InterfaceToOctets(onuGSerialNumber)
1103 if cmn.OnugSerialNumberLen == len(snBytes) {
1104 snVendorPart := fmt.Sprintf("%s", snBytes[:4])
1105 snNumberPart := hex.EncodeToString(snBytes[4:])
1106 oo.SOnuPersistentData.PersSerialNumber = snVendorPart + snNumberPart
1107 } else {
1108 logger.Infow(ctx, "MibSync FSM - SerialNumber has wrong length - fill serialNumber with zeros",
1109 log.Fields{"device-id": oo.deviceID, "length": len(snBytes)})
1110 oo.SOnuPersistentData.PersSerialNumber = cEmptySerialNumberString
1111 }
1112 oo.MutexPersOnuConfig.Unlock()
1113 } else {
1114 logger.Errorw(ctx,
1115 "MibSync FSM - mandatory attribute SerialNumber not present in OnuG instance - handling of MibSyncChan stopped!",
1116 log.Fields{"device-id": oo.deviceID})
1117 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
1118 return fmt.Errorf(
1119 "mibSync FSM - mandatory attribute SerialNumber not present in OnuG instance - handling of MibSyncChan stopped: %s",
1120 oo.deviceID)
1121 }
1122 oo.MutexPersOnuConfig.Lock()
1123 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for Onu-G - VendorId/SerialNumber", log.Fields{"device-id": oo.deviceID,
1124 "onuDeviceEntry.vendorID": oo.SOnuPersistentData.PersVendorID,
1125 "onuDeviceEntry.serialNumber": oo.SOnuPersistentData.PersSerialNumber})
1126 oo.MutexPersOnuConfig.Unlock()
1127 // trigger retrieval of Version
1128 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetVersion)
1129 return nil
1130 } else if currentState == UlStGettingVersion {
1131 if onuGVersion, ok := meAttributes[me.OnuG_Version]; ok {
1132 version := cmn.TrimStringFromMeOctet(onuGVersion)
1133 if version == "" {
1134 logger.Infow(ctx, "MibSync FSM - mandatory attribute Version is empty in OnuG instance - fill with appropriate value",
1135 log.Fields{"device-id": oo.deviceID})
1136 version = cEmptyVersionString
1137 }
1138 oo.MutexPersOnuConfig.Lock()
1139 oo.SOnuPersistentData.PersVersion = version
1140 oo.MutexPersOnuConfig.Unlock()
1141 } else {
1142 logger.Errorw(ctx,
1143 "MibSync FSM - mandatory attribute Version not present in OnuG instance - handling of MibSyncChan stopped!",
1144 log.Fields{"device-id": oo.deviceID})
1145 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
1146 return fmt.Errorf(
1147 "mibSync FSM - mandatory attribute Version not present in OnuG instance - handling of MibSyncChan stopped: %s",
1148 oo.deviceID)
1149 }
1150 oo.MutexPersOnuConfig.Lock()
1151 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for Onu-G - Version", log.Fields{"device-id": oo.deviceID,
1152 "onuDeviceEntry.version": oo.SOnuPersistentData.PersVersion})
1153 oo.MutexPersOnuConfig.Unlock()
1154 // trigger retrieval of EquipmentId and OMCC version
1155 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetEquipIDAndOmcc)
1156 return nil
1157 } else {
1158 logger.Errorw(ctx, "MibSync FSM - wrong state OnuG response processing - handling of MibSyncChan stopped!",
1159 log.Fields{"currentState": currentState, "device-id": oo.deviceID})
1160 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
1161 return fmt.Errorf("mibSync FSM - wrong state OnuG response processing - handling of MibSyncChan stopped: %s",
1162 oo.deviceID)
1163 }
1164}
1165
dbainbri4d3a0dc2020-12-02 00:33:42 +00001166func (oo *OnuDeviceEntry) handleOmciGetResponseErrors(ctx context.Context, msgObj *omci.GetResponse) error {
Holger Hildebrandt80129db2020-11-23 10:49:32 +00001167 var err error = nil
dbainbri4d3a0dc2020-12-02 00:33:42 +00001168 logger.Debugf(ctx, "MibSync FSM - erroneous result in GetResponse Data: %s", log.Fields{"device-id": oo.deviceID, "data-fields": msgObj}, msgObj.Result)
Holger Hildebrandt80129db2020-11-23 10:49:32 +00001169 // Up to now the following erroneous results have been seen for different ONU-types to indicate an unsupported ME
1170 if msgObj.Result == me.UnknownInstance || msgObj.Result == me.UnknownEntity || msgObj.Result == me.ProcessingError || msgObj.Result == me.NotSupported {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001171 oo.mutexLastTxParamStruct.RLock()
1172 if oo.lastTxParamStruct.pLastTxMeInstance != nil {
1173 entityID := oo.lastTxParamStruct.pLastTxMeInstance.GetEntityID()
1174 if msgObj.EntityClass == oo.lastTxParamStruct.pLastTxMeInstance.GetClassID() && msgObj.EntityInstance == entityID {
1175 meInstance := oo.lastTxParamStruct.pLastTxMeInstance.GetName()
1176 switch meInstance {
1177 case "IpHostConfigData":
1178 oo.mutexLastTxParamStruct.RUnlock()
1179 logger.Debugw(ctx, "MibSync FSM - erroneous result for IpHostConfigData received - ONU doesn't support ME - fill macAddress with zeros",
1180 log.Fields{"device-id": oo.deviceID, "data-fields": msgObj})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001181 oo.MutexPersOnuConfig.Lock()
1182 oo.SOnuPersistentData.PersMacAddress = cEmptyMacAddrString
1183 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001184 // trigger retrieval of mib template
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001185 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetMibTemplate)
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001186 return nil
1187 default:
1188 oo.mutexLastTxParamStruct.RUnlock()
1189 logger.Warnf(ctx, "MibSync FSM - erroneous result for %s received - no exceptional treatment defined", log.Fields{"device-id": oo.deviceID, "data-fields": msgObj}, meInstance)
1190 err = fmt.Errorf("erroneous result for %s received - no exceptional treatment defined: %s", meInstance, oo.deviceID)
1191 }
1192 } else {
1193 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandt80129db2020-11-23 10:49:32 +00001194 }
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001195 } else {
1196 oo.mutexLastTxParamStruct.RUnlock()
1197 logger.Warnw(ctx, "Pointer to last Tx MeInstance is nil!", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt80129db2020-11-23 10:49:32 +00001198 }
1199 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001200 logger.Errorf(ctx, "MibSync FSM - erroneous result in GetResponse Data: %s", log.Fields{"device-id": oo.deviceID, "data-fields": msgObj}, msgObj.Result)
Holger Hildebrandt80129db2020-11-23 10:49:32 +00001201 err = fmt.Errorf("erroneous result in GetResponse Data: %s - %s", msgObj.Result, oo.deviceID)
1202 }
1203 return err
1204}
1205
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001206// IsNewOnu - TODO: add comment
1207func (oo *OnuDeviceEntry) IsNewOnu() bool {
1208 oo.MutexPersOnuConfig.RLock()
1209 defer oo.MutexPersOnuConfig.RUnlock()
1210 return oo.SOnuPersistentData.PersMibLastDbSync == 0
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +00001211}
1212
Himani Chawla6d2ae152020-09-02 13:11:20 +05301213func isSupportedClassID(meClassID me.ClassID) bool {
Holger Hildebrandtccd390c2020-05-29 13:49:04 +00001214 for _, v := range supportedClassIds {
Himani Chawla4d908332020-08-31 12:30:20 +05301215 if v == meClassID {
Holger Hildebrandtccd390c2020-05-29 13:49:04 +00001216 return true
1217 }
1218 }
1219 return false
1220}
1221
dbainbri4d3a0dc2020-12-02 00:33:42 +00001222func (oo *OnuDeviceEntry) mibDbVolatileDict(ctx context.Context) error {
1223 logger.Debug(ctx, "MibVolatileDict- running from default Entry code")
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001224 return errors.New("not_implemented")
1225}
1226
Himani Chawla6d2ae152020-09-02 13:11:20 +05301227// createAndPersistMibTemplate method creates a mib template for the device id when operator enables the ONU device for the first time.
divyadesaibbed37c2020-08-28 13:35:20 +05301228// We are creating a placeholder for "SerialNumber" for ME Class ID 6 and 256 and "MacAddress" for ME Class ID 134 in the template
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001229// and then storing the template into etcd "service/voltha/omci_mibs/go_templates/verdor_id/equipment_id/software_version" path.
dbainbri4d3a0dc2020-12-02 00:33:42 +00001230func (oo *OnuDeviceEntry) createAndPersistMibTemplate(ctx context.Context) error {
1231 logger.Debugw(ctx, "MibSync - MibTemplate - path name", log.Fields{"path": oo.mibTemplatePath,
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001232 "device-id": oo.deviceID})
divyadesaibbed37c2020-08-28 13:35:20 +05301233
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001234 oo.pOpenOnuAc.LockMutexMibTemplateGenerated()
1235 if mibTemplateIsGenerated, exist := oo.pOpenOnuAc.GetMibTemplatesGenerated(oo.mibTemplatePath); exist {
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001236 if mibTemplateIsGenerated {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001237 logger.Debugw(ctx, "MibSync - MibTemplate - another thread has already started to generate it - skip",
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001238 log.Fields{"path": oo.mibTemplatePath, "device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001239 oo.pOpenOnuAc.UnlockMutexMibTemplateGenerated()
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001240 return nil
1241 }
dbainbri4d3a0dc2020-12-02 00:33:42 +00001242 logger.Debugw(ctx, "MibSync - MibTemplate - previous generation attempt seems to be failed - try again",
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001243 log.Fields{"path": oo.mibTemplatePath, "device-id": oo.deviceID})
1244 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001245 logger.Debugw(ctx, "MibSync - MibTemplate - first ONU-instance of this kind - start generation",
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001246 log.Fields{"path": oo.mibTemplatePath, "device-id": oo.deviceID})
1247 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001248 oo.pOpenOnuAc.SetMibTemplatesGenerated(oo.mibTemplatePath, true)
1249 oo.pOpenOnuAc.UnlockMutexMibTemplateGenerated()
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001250
1251 currentTime := time.Now()
divyadesaibbed37c2020-08-28 13:35:20 +05301252 templateMap := make(map[string]interface{})
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001253 templateMap["TemplateName"] = oo.mibTemplatePath
divyadesaibbed37c2020-08-28 13:35:20 +05301254 templateMap["TemplateCreated"] = currentTime.Format("2006-01-02 15:04:05.000000")
1255
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001256 firstLevelMap := oo.pOnuDB.MeDb
divyadesaibbed37c2020-08-28 13:35:20 +05301257 for firstLevelKey, firstLevelValue := range firstLevelMap {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001258 logger.Debugw(ctx, "MibSync - MibTemplate - firstLevelKey", log.Fields{"firstLevelKey": firstLevelKey})
Himani Chawla26e555c2020-08-31 12:30:20 +05301259 classID := strconv.Itoa(int(firstLevelKey))
divyadesaibbed37c2020-08-28 13:35:20 +05301260
1261 secondLevelMap := make(map[string]interface{})
1262 for secondLevelKey, secondLevelValue := range firstLevelValue {
Holger Hildebrandt8998ed52022-03-23 09:52:37 +00001263 // ManagedEntityId is already key of secondLevelMap - remove this redundant attribute from secondLevelValue
1264 delete(secondLevelValue, cmn.CGenericManagedEntityIDName)
divyadesaibbed37c2020-08-28 13:35:20 +05301265 thirdLevelMap := make(map[string]interface{})
Himani Chawla26e555c2020-08-31 12:30:20 +05301266 entityID := strconv.Itoa(int(secondLevelKey))
divyadesaibbed37c2020-08-28 13:35:20 +05301267 thirdLevelMap["Attributes"] = secondLevelValue
Himani Chawla26e555c2020-08-31 12:30:20 +05301268 secondLevelMap[entityID] = thirdLevelMap
1269 if classID == "6" || classID == "256" {
divyadesaibbed37c2020-08-28 13:35:20 +05301270 forthLevelMap := map[string]interface{}(thirdLevelMap["Attributes"].(me.AttributeValueMap))
1271 delete(forthLevelMap, "SerialNumber")
1272 forthLevelMap["SerialNumber"] = "%SERIAL_NUMBER%"
1273
1274 }
Himani Chawla26e555c2020-08-31 12:30:20 +05301275 if classID == "134" {
divyadesaibbed37c2020-08-28 13:35:20 +05301276 forthLevelMap := map[string]interface{}(thirdLevelMap["Attributes"].(me.AttributeValueMap))
1277 delete(forthLevelMap, "MacAddress")
1278 forthLevelMap["MacAddress"] = "%MAC_ADDRESS%"
1279 }
1280 }
Himani Chawla26e555c2020-08-31 12:30:20 +05301281 templateMap[classID] = secondLevelMap
divyadesaibbed37c2020-08-28 13:35:20 +05301282 }
Holger Hildebrandt39080022022-03-16 10:03:17 +00001283 unknownMeAndAttribMap := oo.pOnuDB.UnknownMeAndAttribDb
1284 for unknownMeAndAttribMapKey := range unknownMeAndAttribMap {
1285 templateMap[string(unknownMeAndAttribMapKey)] = unknownMeAndAttribMap[unknownMeAndAttribMapKey]
Holger Hildebrandtf3c7a182021-11-17 13:42:08 +00001286 }
divyadesaibbed37c2020-08-28 13:35:20 +05301287 mibTemplate, err := json.Marshal(&templateMap)
1288 if err != nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001289 logger.Errorw(ctx, "MibSync - MibTemplate - Failed to marshal mibTemplate", log.Fields{"error": err, "device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001290 oo.pOpenOnuAc.LockMutexMibTemplateGenerated()
1291 oo.pOpenOnuAc.SetMibTemplatesGenerated(oo.mibTemplatePath, false)
1292 oo.pOpenOnuAc.UnlockMutexMibTemplateGenerated()
divyadesaibbed37c2020-08-28 13:35:20 +05301293 return err
1294 }
dbainbri4d3a0dc2020-12-02 00:33:42 +00001295 err = oo.mibTemplateKVStore.Put(log.WithSpanFromContext(context.TODO(), ctx), oo.mibTemplatePath, string(mibTemplate))
divyadesaibbed37c2020-08-28 13:35:20 +05301296 if err != nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001297 logger.Errorw(ctx, "MibSync - MibTemplate - Failed to store template in etcd", log.Fields{"error": err, "device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001298 oo.pOpenOnuAc.LockMutexMibTemplateGenerated()
1299 oo.pOpenOnuAc.SetMibTemplatesGenerated(oo.mibTemplatePath, false)
1300 oo.pOpenOnuAc.UnlockMutexMibTemplateGenerated()
divyadesaibbed37c2020-08-28 13:35:20 +05301301 return err
1302 }
dbainbri4d3a0dc2020-12-02 00:33:42 +00001303 logger.Debugw(ctx, "MibSync - MibTemplate - Stored the template to etcd", log.Fields{"device-id": oo.deviceID})
divyadesaibbed37c2020-08-28 13:35:20 +05301304 return nil
1305}
1306
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +00001307func (oo *OnuDeviceEntry) requestMdsValue(ctx context.Context) {
1308 logger.Debugw(ctx, "Request MDS value", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt3ac49bd2022-02-07 17:46:43 +00001309 requestedAttributes := me.AttributeValueMap{me.OnuData_MibDataSync: ""}
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001310 meInstance, err := oo.PDevOmciCC.SendGetMe(log.WithSpanFromContext(context.TODO(), ctx),
Holger Hildebrandtd930cb22022-06-17 09:24:50 +00001311 me.OnuDataClassID, cmn.OnuDataMeID, requestedAttributes, oo.baseDeviceHandler.GetOmciTimeout(), true,
1312 oo.PMibUploadFsm.CommChan, oo.GetPersIsExtOmciSupported())
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +00001313 //accept also nil as (error) return value for writing to LastTx
1314 // - this avoids misinterpretation of new received OMCI messages
ozgecanetsiab36ed572021-04-01 10:38:48 +03001315 if err != nil {
1316 logger.Errorw(ctx, "ONUData get failed, aborting MibSync FSM!", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001317 pMibUlFsm := oo.PMibUploadFsm
ozgecanetsiab36ed572021-04-01 10:38:48 +03001318 if pMibUlFsm != nil {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001319 go func(a_pAFsm *cmn.AdapterFsm) {
1320 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
ozgecanetsiab36ed572021-04-01 10:38:48 +03001321 }(pMibUlFsm)
1322 }
1323 return
1324 }
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001325 oo.mutexLastTxParamStruct.Lock()
mpagenko01499812021-03-25 10:37:12 +00001326 oo.lastTxParamStruct.lastTxMessageType = omci.GetRequestType
1327 oo.lastTxParamStruct.pLastTxMeInstance = meInstance
1328 oo.lastTxParamStruct.repeatCount = 0
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001329 oo.mutexLastTxParamStruct.Unlock()
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +00001330}
1331
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001332func (oo *OnuDeviceEntry) checkMdsValue(ctx context.Context, mibDataSyncOnu uint8) {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001333 oo.MutexPersOnuConfig.RLock()
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001334 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for Onu-Data - MibDataSync", log.Fields{"device-id": oo.deviceID,
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001335 "mibDataSyncOnu": mibDataSyncOnu, "PersMibDataSyncAdpt": oo.SOnuPersistentData.PersMibDataSyncAdpt})
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001336
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001337 mdsValuesAreEqual := oo.SOnuPersistentData.PersMibDataSyncAdpt == mibDataSyncOnu
1338 oo.MutexPersOnuConfig.RUnlock()
1339 if oo.PMibUploadFsm.PFsm.Is(UlStAuditing) {
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001340 if mdsValuesAreEqual {
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001341 logger.Debugw(ctx, "MibSync FSM - mib audit - MDS check ok", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001342 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001343 } else {
1344 logger.Warnw(ctx, "MibSync FSM - mib audit - MDS check failed for the first time!", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001345 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001346 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001347 } else if oo.PMibUploadFsm.PFsm.Is(UlStReAuditing) {
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001348 if mdsValuesAreEqual {
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001349 logger.Debugw(ctx, "MibSync FSM - mib reaudit - MDS check ok", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001350 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001351 } else {
Holger Hildebrandt80f57762022-02-16 10:03:24 +00001352 logger.Errorw(ctx, "MibSync FSM - mib reaudit - MDS check failed for the second time - send ONU device event and reconcile!",
Holger Hildebrandtc56febd2022-02-09 13:23:30 +00001353 log.Fields{"device-id": oo.deviceID})
1354 oo.SendOnuDeviceEvent(ctx, cmn.OnuMibAuditFailureMds, cmn.OnuMibAuditFailureMdsDesc)
Holger Hildebrandt80f57762022-02-16 10:03:24 +00001355 // To reconcile ONU with active adapter later on, we have to retrieve TP instances from parent adapter.
1356 // In the present use case inconsistencies between TP pathes stored in kv store and TP instances retrieved
1357 // should not occur. Nevertheless, the respective code is inserted to catch the unlikely case.
1358 if !oo.getAllStoredTpInstFromParentAdapter(ctx) {
1359 logger.Debugw(ctx, "MibSync FSM - mib reaudit - inconsistencies between TP pathes stored in kv and parent adapter instances",
1360 log.Fields{"device-id": oo.deviceID})
1361 oo.baseDeviceHandler.SetReconcilingReasonUpdate(true)
1362 go func() {
1363 if err := oo.baseDeviceHandler.StorePersistentData(ctx); err != nil {
1364 logger.Warnw(ctx,
1365 "MibSync FSM - mib reaudit - store persistent data error - continue for now as there will be additional write attempts",
1366 log.Fields{"device-id": oo.deviceID, "err": err})
1367 }
1368 }()
1369 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001370 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001371 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001372 } else if oo.PMibUploadFsm.PFsm.Is(UlStExaminingMds) {
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001373 if mdsValuesAreEqual && mibDataSyncOnu != 0 {
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001374 logger.Debugw(ctx, "MibSync FSM - MDS examination ok", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001375 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001376 } else {
1377 logger.Debugw(ctx, "MibSync FSM - MDS examination failed - new provisioning", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001378 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001379 }
1380 } else {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001381 logger.Warnw(ctx, "wrong state for MDS evaluation!", log.Fields{"state": oo.PMibUploadFsm.PFsm.Current(), "device-id": oo.deviceID})
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001382 }
1383}
mpagenko15ff4a52021-03-02 10:09:20 +00001384
nikesh.krishnan1ffb8132023-05-23 03:44:13 +05301385// GetActiveImageMeID returns the Omci MeId of the active ONU image together with error code for validity
mpagenko15ff4a52021-03-02 10:09:20 +00001386func (oo *OnuDeviceEntry) GetActiveImageMeID(ctx context.Context) (uint16, error) {
Holger Hildebrandt05011352021-06-15 09:40:24 +00001387 oo.mutexOnuSwImageIndications.RLock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001388 if oo.onuSwImageIndications.ActiveEntityEntry.Valid {
1389 value := oo.onuSwImageIndications.ActiveEntityEntry.EntityID
Holger Hildebrandt05011352021-06-15 09:40:24 +00001390 oo.mutexOnuSwImageIndications.RUnlock()
1391 return value, nil
mpagenko15ff4a52021-03-02 10:09:20 +00001392 }
Holger Hildebrandt05011352021-06-15 09:40:24 +00001393 oo.mutexOnuSwImageIndications.RUnlock()
mpagenko15ff4a52021-03-02 10:09:20 +00001394 return 0xFFFF, fmt.Errorf("no valid active image found: %s", oo.deviceID)
1395}
1396
nikesh.krishnan1ffb8132023-05-23 03:44:13 +05301397// GetInactiveImageMeID returns the Omci MeId of the inactive ONU image together with error code for validity
mpagenko15ff4a52021-03-02 10:09:20 +00001398func (oo *OnuDeviceEntry) GetInactiveImageMeID(ctx context.Context) (uint16, error) {
Holger Hildebrandt05011352021-06-15 09:40:24 +00001399 oo.mutexOnuSwImageIndications.RLock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001400 if oo.onuSwImageIndications.InActiveEntityEntry.Valid {
1401 value := oo.onuSwImageIndications.InActiveEntityEntry.EntityID
Holger Hildebrandt05011352021-06-15 09:40:24 +00001402 oo.mutexOnuSwImageIndications.RUnlock()
1403 return value, nil
mpagenko15ff4a52021-03-02 10:09:20 +00001404 }
Holger Hildebrandt05011352021-06-15 09:40:24 +00001405 oo.mutexOnuSwImageIndications.RUnlock()
mpagenko15ff4a52021-03-02 10:09:20 +00001406 return 0xFFFF, fmt.Errorf("no valid inactive image found: %s", oo.deviceID)
1407}
1408
nikesh.krishnan1ffb8132023-05-23 03:44:13 +05301409// IsImageToBeCommitted returns true if the active image is still uncommitted
mpagenko15ff4a52021-03-02 10:09:20 +00001410func (oo *OnuDeviceEntry) IsImageToBeCommitted(ctx context.Context, aImageID uint16) bool {
Holger Hildebrandt05011352021-06-15 09:40:24 +00001411 oo.mutexOnuSwImageIndications.RLock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001412 if oo.onuSwImageIndications.ActiveEntityEntry.Valid {
1413 if oo.onuSwImageIndications.ActiveEntityEntry.EntityID == aImageID {
1414 if oo.onuSwImageIndications.ActiveEntityEntry.IsCommitted == cmn.SwIsUncommitted {
Holger Hildebrandt05011352021-06-15 09:40:24 +00001415 oo.mutexOnuSwImageIndications.RUnlock()
mpagenko15ff4a52021-03-02 10:09:20 +00001416 return true
1417 }
1418 }
1419 }
Holger Hildebrandt05011352021-06-15 09:40:24 +00001420 oo.mutexOnuSwImageIndications.RUnlock()
mpagenko15ff4a52021-03-02 10:09:20 +00001421 return false //all other case are treated as 'nothing to commit
1422}
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001423func (oo *OnuDeviceEntry) getMibFromTemplate(ctx context.Context) bool {
1424
1425 oo.mibTemplatePath = oo.buildMibTemplatePath()
Holger Hildebrandtbdc5f002021-04-19 14:46:21 +00001426 logger.Debugw(ctx, "MibSync FSM - get Mib from template", log.Fields{"path": fmt.Sprintf("%s/%s", cBasePathMibTemplateKvStore, oo.mibTemplatePath),
1427 "device-id": oo.deviceID})
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001428
1429 restoredFromMibTemplate := false
1430 Value, err := oo.mibTemplateKVStore.Get(log.WithSpanFromContext(context.TODO(), ctx), oo.mibTemplatePath)
1431 if err == nil {
1432 if Value != nil {
1433 logger.Debugf(ctx, "MibSync FSM - Mib template read: Key: %s, Value: %s %s", Value.Key, Value.Value)
1434
1435 // swap out tokens with specific data
1436 mibTmpString, _ := kvstore.ToString(Value.Value)
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001437 oo.MutexPersOnuConfig.RLock()
1438 mibTmpString2 := strings.Replace(mibTmpString, "%SERIAL_NUMBER%", oo.SOnuPersistentData.PersSerialNumber, -1)
1439 mibTmpString = strings.Replace(mibTmpString2, "%MAC_ADDRESS%", oo.SOnuPersistentData.PersMacAddress, -1)
praneeth kumar nalmas90125bc2023-10-13 12:33:19 +05301440 mibTmpString2 = strings.ReplaceAll(mibTmpString, "\x00", "")
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001441 oo.MutexPersOnuConfig.RUnlock()
praneeth kumar nalmas90125bc2023-10-13 12:33:19 +05301442 mibTmpBytes := []byte(mibTmpString2)
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001443 logger.Debugf(ctx, "MibSync FSM - Mib template tokens swapped out: %s", mibTmpBytes)
1444
1445 var firstLevelMap map[string]interface{}
1446 if err = json.Unmarshal(mibTmpBytes, &firstLevelMap); err != nil {
1447 logger.Errorw(ctx, "MibSync FSM - Failed to unmarshal template", log.Fields{"error": err, "device-id": oo.deviceID})
1448 } else {
1449 for firstLevelKey, firstLevelValue := range firstLevelMap {
1450 //logger.Debugw(ctx, "MibSync FSM - firstLevelKey", log.Fields{"firstLevelKey": firstLevelKey})
1451 if uint16ValidNumber, err := strconv.ParseUint(firstLevelKey, 10, 16); err == nil {
1452 meClassID := me.ClassID(uint16ValidNumber)
1453 //logger.Debugw(ctx, "MibSync FSM - firstLevelKey is a number in uint16-range", log.Fields{"uint16ValidNumber": uint16ValidNumber})
1454 if isSupportedClassID(meClassID) {
1455 //logger.Debugw(ctx, "MibSync FSM - firstLevelKey is a supported classID", log.Fields{"meClassID": meClassID})
1456 secondLevelMap := firstLevelValue.(map[string]interface{})
1457 for secondLevelKey, secondLevelValue := range secondLevelMap {
1458 //logger.Debugw(ctx, "MibSync FSM - secondLevelKey", log.Fields{"secondLevelKey": secondLevelKey})
1459 if uint16ValidNumber, err := strconv.ParseUint(secondLevelKey, 10, 16); err == nil {
1460 meEntityID := uint16(uint16ValidNumber)
1461 //logger.Debugw(ctx, "MibSync FSM - secondLevelKey is a number and a valid EntityId", log.Fields{"meEntityID": meEntityID})
1462 thirdLevelMap := secondLevelValue.(map[string]interface{})
1463 for thirdLevelKey, thirdLevelValue := range thirdLevelMap {
1464 if thirdLevelKey == "Attributes" {
1465 //logger.Debugw(ctx, "MibSync FSM - thirdLevelKey refers to attributes", log.Fields{"thirdLevelKey": thirdLevelKey})
1466 attributesMap := thirdLevelValue.(map[string]interface{})
1467 //logger.Debugw(ctx, "MibSync FSM - attributesMap", log.Fields{"attributesMap": attributesMap})
1468 oo.pOnuDB.PutMe(ctx, meClassID, meEntityID, attributesMap)
1469 restoredFromMibTemplate = true
1470 }
1471 }
1472 }
1473 }
1474 }
1475 }
1476 }
1477 }
1478 } else {
nikesh.krishnan1ffb8132023-05-23 03:44:13 +05301479 logger.Infow(ctx, "No MIB template found", log.Fields{"path": oo.mibTemplatePath, "device-id": oo.deviceID})
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001480 }
1481 } else {
1482 logger.Errorf(ctx, "Get from kvstore operation failed for path",
1483 log.Fields{"path": oo.mibTemplatePath, "device-id": oo.deviceID})
1484 }
1485 return restoredFromMibTemplate
1486}
Holger Hildebrandtb4563ab2021-04-14 10:27:20 +00001487
Holger Hildebrandt80f57762022-02-16 10:03:24 +00001488func (oo *OnuDeviceEntry) getAllStoredTpInstFromParentAdapter(ctx context.Context) bool {
1489
1490 allTpInstPresent := true
1491 oo.MutexPersOnuConfig.Lock()
1492 oo.MutexReconciledTpInstances.Lock()
1493 for indexUni, uniData := range oo.SOnuPersistentData.PersUniConfig {
1494 uniID := uniData.PersUniID
1495 oo.ReconciledTpInstances[uniID] = make(map[uint8]inter_adapter.TechProfileDownloadMessage)
1496 for tpID, tpPath := range uniData.PersTpPathMap {
1497 if tpPath != "" {
1498 // Request the TP instance from the openolt adapter
1499 iaTechTpInst, err := oo.baseDeviceHandler.GetTechProfileInstanceFromParentAdapter(ctx, uniID, tpPath)
1500 if err == nil && iaTechTpInst != nil {
1501 logger.Debugw(ctx, "reconciling - store Tp instance", log.Fields{"uniID": uniID, "tpID": tpID,
1502 "*iaTechTpInst": iaTechTpInst, "device-id": oo.deviceID})
1503 oo.ReconciledTpInstances[uniID][tpID] = *iaTechTpInst
1504 } else {
1505 // During the absence of the ONU adapter there seem to have been TP specific configurations!
1506 // The no longer available TP and the associated flows must be deleted from the ONU KV store
1507 // and after a MIB reset a new reconciling attempt with OMCI configuration must be started.
1508 allTpInstPresent = false
1509 logger.Infow(ctx, "reconciling - can't get tp instance - delete tp and associated flows",
1510 log.Fields{"tp-id": tpID, "tpPath": tpPath, "uni-id": uniID, "device-id": oo.deviceID, "err": err})
1511 delete(oo.SOnuPersistentData.PersUniConfig[indexUni].PersTpPathMap, tpID)
1512 flowSlice := oo.SOnuPersistentData.PersUniConfig[indexUni].PersFlowParams
1513 for indexFlow, flowData := range flowSlice {
1514 if flowData.VlanRuleParams.TpID == tpID {
1515 if len(flowSlice) == 1 {
1516 flowSlice = []cmn.UniVlanFlowParams{}
1517 } else {
1518 flowSlice = append(flowSlice[:indexFlow], flowSlice[indexFlow+1:]...)
1519 }
1520 oo.SOnuPersistentData.PersUniConfig[indexUni].PersFlowParams = flowSlice
1521 }
1522 }
1523 }
1524 }
1525 }
1526 }
1527 oo.MutexReconciledTpInstances.Unlock()
1528 oo.MutexPersOnuConfig.Unlock()
1529 return allTpInstPresent
1530}
1531
nikesh.krishnan1ffb8132023-05-23 03:44:13 +05301532// CancelProcessing terminates potentially running reconciling processes and stops the FSM
Holger Hildebrandtb4563ab2021-04-14 10:27:20 +00001533func (oo *OnuDeviceEntry) CancelProcessing(ctx context.Context) {
Holger Hildebrandt12609a12022-03-25 13:23:25 +00001534 logger.Debugw(ctx, "CancelProcessing entered", log.Fields{"device-id": oo.deviceID})
mpagenko101ac942021-11-16 15:01:29 +00001535 if oo.isReconcilingFlows() {
Holger Hildebrandtf2fcdd42021-12-15 11:42:19 +00001536 oo.SendChReconcilingFlowsFinished(ctx, false)
Holger Hildebrandtb4563ab2021-04-14 10:27:20 +00001537 }
1538 //the MibSync FSM might be active all the ONU-active time,
1539 // hence it must be stopped unconditionally
Girish Gowdra37c9d912022-02-08 16:24:57 -08001540 oo.mutexMibSyncMsgProcessorRunning.RLock()
1541 defer oo.mutexMibSyncMsgProcessorRunning.RUnlock()
1542 if oo.mibSyncMsgProcessorRunning {
1543 pMibUlFsm := oo.PMibUploadFsm
1544 if pMibUlFsm != nil {
1545 // abort running message processing
1546 fsmAbortMsg := cmn.Message{
1547 Type: cmn.TestMsg,
1548 Data: cmn.TestMessage{
1549 TestMessageVal: cmn.AbortMessageProcessing,
1550 },
1551 }
1552 pMibUlFsm.CommChan <- fsmAbortMsg
1553 _ = pMibUlFsm.PFsm.Event(UlEvStop)
Holger Hildebrandte7cc6092022-02-01 11:37:03 +00001554 }
Holger Hildebrandtb4563ab2021-04-14 10:27:20 +00001555 }
1556}