blob: 2e713649674aec21c04ba56e826e23162f4023c5 [file] [log] [blame]
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001/*
Joey Armstrong89c812c2024-01-12 19:00:20 -05002 * Copyright 2020-2024 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 Hildebrandtccd390c2020-05-29 13:49:04 +0000309
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +0530310 //create the MIB Template path
311 oo.mibTemplatePath = oo.buildMibTemplatePath()
312
313 if cmnMEDBVal, exist := oo.pOpenOnuAc.FetchEntryFromMibDatabaseMap(ctx, oo.mibTemplatePath); exist {
314 logger.Infow(ctx, "A Common MIB DB Instance exist for this type of ONT", log.Fields{"device-id": oo.deviceID, "mibTemplatePath": oo.mibTemplatePath})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000315 oo.pOpenOnuAc.LockMutexMibTemplateGenerated()
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +0530316 oo.pOnuDB.CommonMeDb = cmnMEDBVal
317
318 if cmnMEDBVal.MIBUploadStatus == devdb.Completed {
319 oo.pOnuDB.CommonMeDb.MeDbLock.Lock()
320 oo.updateOnuSpecificEntries(ctx)
321 oo.pOnuDB.CommonMeDb.MeDbLock.Unlock()
322 fsmMsg = cmn.LoadMibTemplateOk
323 } else {
324 logger.Errorw(ctx, "A previous MIB Upload for this type of ONT has failed, request for a MIB UPload", log.Fields{"device-id": oo.deviceID})
325 oo.pOpenOnuAc.ResetEntryFromMibDatabaseMap(ctx, oo.mibTemplatePath)
326 fsmMsg = cmn.LoadMibTemplateFailed
Holger Hildebrandt441a0172020-12-10 13:57:08 +0000327 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000328 oo.pOpenOnuAc.UnlockMutexMibTemplateGenerated()
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +0530329
330 } else {
331 Value, err := oo.mibTemplateKVStore.Get(log.WithSpanFromContext(context.TODO(), ctx), oo.mibTemplatePath)
332 if err == nil && Value != nil {
333 logger.Infow(ctx, "No Common MIB DB instance exist , creating from Template", log.Fields{"device-id": oo.deviceID, "mibTemplatePath": oo.mibTemplatePath})
334 oo.processMibTemplate(ctx, Value)
335 } else {
336 logger.Infow(ctx, "Neither Common MIB DB Instance nor MIB template exist for this type of ONT", log.Fields{"device-id": oo.deviceID, "mibTemplatePath": oo.mibTemplatePath})
337 oo.pOpenOnuAc.LockMutexMibTemplateGenerated()
338 cmnMEDBValue, _ := oo.pOpenOnuAc.CreateEntryAtMibDatabaseMap(ctx, oo.mibTemplatePath)
339 oo.pOnuDB.CommonMeDb = cmnMEDBValue
340 oo.pOnuDB.CommonMeDb.MeDbLock.Lock()
341 fsmMsg = cmn.LoadMibTemplateFailed
342
343 }
344
Holger Hildebrandt441a0172020-12-10 13:57:08 +0000345 }
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +0530346
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000347 mibSyncMsg := cmn.Message{
348 Type: cmn.TestMsg,
349 Data: cmn.TestMessage{
Holger Hildebrandtccd390c2020-05-29 13:49:04 +0000350 TestMessageVal: fsmMsg,
351 },
352 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000353 oo.PMibUploadFsm.CommChan <- mibSyncMsg
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000354}
355
dbainbri4d3a0dc2020-12-02 00:33:42 +0000356func (oo *OnuDeviceEntry) enterUploadingState(ctx context.Context, e *fsm.Event) {
357 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 +0000358 _ = oo.PDevOmciCC.SendMibUpload(log.WithSpanFromContext(context.TODO(), ctx),
359 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.GetPersIsExtOmciSupported())
mpagenko01499812021-03-25 10:37:12 +0000360 //even though lastTxParameters are currently not used for checking the ResetResponse message we have to ensure
361 // that the lastTxMessageType is correctly set to avoid misinterpreting other responses
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000362 oo.mutexLastTxParamStruct.Lock()
mpagenko01499812021-03-25 10:37:12 +0000363 oo.lastTxParamStruct.lastTxMessageType = omci.MibUploadRequestType
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000364 oo.mutexLastTxParamStruct.Unlock()
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000365}
366
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000367func (oo *OnuDeviceEntry) enterUploadDoneState(ctx context.Context, e *fsm.Event) {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000368 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 +0000369 oo.transferSystemEvent(ctx, cmn.MibDatabaseSync)
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000370 go func() {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000371 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000372 }()
373}
374
375func (oo *OnuDeviceEntry) enterInSyncState(ctx context.Context, e *fsm.Event) {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000376 oo.MutexPersOnuConfig.Lock()
377 oo.SOnuPersistentData.PersMibLastDbSync = uint32(time.Now().Unix())
378 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandte3677f12021-02-05 14:50:56 +0000379 if oo.mibAuditInterval > 0 {
380 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 +0000381 go func() {
Holger Hildebrandte3677f12021-02-05 14:50:56 +0000382 time.Sleep(oo.mibAuditInterval)
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000383 if err := oo.PMibUploadFsm.PFsm.Event(UlEvAuditMib); err != nil {
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000384 logger.Debugw(ctx, "MibSyncFsm: Can't go to state auditing", log.Fields{"device-id": oo.deviceID, "err": err})
385 }
386 }()
387 }
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000388}
389
Holger Hildebrandt9afc1582021-11-30 16:10:19 +0000390func (oo *OnuDeviceEntry) enterVerifyingAndStoringTPsState(ctx context.Context, e *fsm.Event) {
391 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start verifying and storing TPs in State": e.FSM.Current(), "device-id": oo.deviceID})
392
Holger Hildebrandt80f57762022-02-16 10:03:24 +0000393 if oo.getAllStoredTpInstFromParentAdapter(ctx) {
Holger Hildebrandt9afc1582021-11-30 16:10:19 +0000394 logger.Debugw(ctx, "MibSync FSM", log.Fields{"reconciling - verifying TPs successful": e.FSM.Current(), "device-id": oo.deviceID})
395 go func() {
396 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
397 }()
398 } else {
399 logger.Debugw(ctx, "MibSync FSM", log.Fields{"reconciling - verifying TPs not successful": e.FSM.Current(), "device-id": oo.deviceID})
400 oo.baseDeviceHandler.SetReconcilingReasonUpdate(true)
401 go func() {
402 if err := oo.baseDeviceHandler.StorePersistentData(ctx); err != nil {
403 logger.Warnw(ctx, "reconciling - store persistent data error - continue for now as there will be additional write attempts",
404 log.Fields{"device-id": oo.deviceID, "err": err})
405 }
406 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
407 }()
408 }
409}
410
dbainbri4d3a0dc2020-12-02 00:33:42 +0000411func (oo *OnuDeviceEntry) enterExaminingMdsState(ctx context.Context, e *fsm.Event) {
412 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start GetMds processing in State": e.FSM.Current(), "device-id": oo.deviceID})
Praneeth Kumar Nalmas77ab2f32024-04-17 11:14:27 +0530413 oo.pOpenOnuAc.RLockMutexDeviceHandlersMap()
414 dh, _ := oo.pOpenOnuAc.GetDeviceHandler(oo.deviceID)
415 oo.pOpenOnuAc.RUnlockMutexDeviceHandlersMap()
416 if dh.GetSkipOnuConfigEnabled() {
417 go func() {
418 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
419 }()
420 } else {
421 oo.requestMdsValue(ctx)
422 }
423
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000424}
425
dbainbri4d3a0dc2020-12-02 00:33:42 +0000426func (oo *OnuDeviceEntry) enterResynchronizingState(ctx context.Context, e *fsm.Event) {
427 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start MibResync processing in State": e.FSM.Current(), "device-id": oo.deviceID})
428 logger.Debug(ctx, "function not implemented yet")
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000429 // TODOs:
430 // VOL-3805 - Provide exclusive OMCI channel for one FSM
431 // VOL-3785 - New event notifications and corresponding performance counters for openonu-adapter-go
432 // VOL-3792 - Support periodical audit via mib resync
433 // VOL-3793 - ONU-reconcile handling after adapter restart based on mib resync
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000434}
435
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000436func (oo *OnuDeviceEntry) enterExaminingMdsSuccessState(ctx context.Context, e *fsm.Event) {
437 logger.Debugw(ctx, "MibSync FSM",
438 log.Fields{"Start processing on examining MDS success in State": e.FSM.Current(), "device-id": oo.deviceID})
439
440 if oo.getMibFromTemplate(ctx) {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000441 oo.baseDeviceHandler.StartReconciling(ctx, true)
442 oo.baseDeviceHandler.AddAllUniPorts(ctx)
Holger Hildebrandt9afc1582021-11-30 16:10:19 +0000443 _ = oo.baseDeviceHandler.ReasonUpdate(ctx, cmn.DrInitialMibDownloaded, oo.baseDeviceHandler.IsReconcilingReasonUpdate())
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000444 oo.baseDeviceHandler.SetReadyForOmciConfig(true)
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000445
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000446 if !oo.baseDeviceHandler.GetCollectorIsRunning() {
Girish Gowdraf7d82d02022-04-26 16:18:35 -0700447 var waitForOmciProcess sync.WaitGroup
448 waitForOmciProcess.Add(1)
Holger Hildebrandtced74e72021-06-10 14:55:53 +0000449 // Start PM collector routine
Girish Gowdraf7d82d02022-04-26 16:18:35 -0700450 go oo.baseDeviceHandler.StartCollector(ctx, &waitForOmciProcess)
451 waitForOmciProcess.Wait()
Holger Hildebrandtced74e72021-06-10 14:55:53 +0000452 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000453 if !oo.baseDeviceHandler.GetAlarmManagerIsRunning(ctx) {
454 go oo.baseDeviceHandler.StartAlarmManager(ctx)
Holger Hildebrandtced74e72021-06-10 14:55:53 +0000455 }
Girish Gowdrae95687a2021-09-08 16:30:58 -0700456
457 for _, uniPort := range *oo.baseDeviceHandler.GetUniEntityMap() {
458 // only if this port was enabled for use by the operator at startup
459 if (1<<uniPort.UniID)&oo.baseDeviceHandler.GetUniPortMask() == (1 << uniPort.UniID) {
460 if !oo.baseDeviceHandler.GetFlowMonitoringIsRunning(uniPort.UniID) {
461 go oo.baseDeviceHandler.PerOnuFlowHandlerRoutine(uniPort.UniID)
462 }
463 }
464 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000465 oo.MutexPersOnuConfig.RLock()
466 if oo.SOnuPersistentData.PersUniDisableDone {
467 oo.MutexPersOnuConfig.RUnlock()
468 oo.baseDeviceHandler.DisableUniPortStateUpdate(ctx)
Holger Hildebrandt9afc1582021-11-30 16:10:19 +0000469 _ = oo.baseDeviceHandler.ReasonUpdate(ctx, cmn.DrOmciAdminLock, oo.baseDeviceHandler.IsReconcilingReasonUpdate())
Holger Hildebrandtbdc5f002021-04-19 14:46:21 +0000470 } else {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000471 oo.MutexPersOnuConfig.RUnlock()
472 oo.baseDeviceHandler.EnableUniPortStateUpdate(ctx)
Holger Hildebrandtbdc5f002021-04-19 14:46:21 +0000473 }
Holger Hildebrandtb314f442021-11-24 12:03:10 +0000474
475 // no need to reconcile additional data for MibDownloadFsm, LockStateFsm, or UnlockStateFsm
476
477 if oo.baseDeviceHandler.ReconcileDeviceTechProf(ctx) {
478 // start go routine with select() on reconciling flow channel before
479 // starting flow reconciling process to prevent loss of any signal
Holger Hildebrandtf2fcdd42021-12-15 11:42:19 +0000480 syncChannel := make(chan struct{})
481 go func(aSyncChannel chan struct{}) {
Holger Hildebrandtb314f442021-11-24 12:03:10 +0000482 // In multi-ONU/multi-flow environment stopping reconcilement has to be delayed until
483 // we get a signal that the processing of the last step to rebuild the adapter internal
484 // flow data is finished.
485 expiry := oo.baseDeviceHandler.GetReconcileExpiryVlanConfigAbort()
486 oo.setReconcilingFlows(true)
Holger Hildebrandtf2fcdd42021-12-15 11:42:19 +0000487 aSyncChannel <- struct{}{}
Holger Hildebrandtb314f442021-11-24 12:03:10 +0000488 select {
489 case success := <-oo.chReconcilingFlowsFinished:
490 if success {
491 logger.Debugw(ctx, "reconciling flows has been finished in time",
492 log.Fields{"device-id": oo.deviceID})
493 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
494
495 } else {
496 logger.Debugw(ctx, "wait for reconciling flows aborted",
497 log.Fields{"device-id": oo.deviceID})
498 }
499 case <-time.After(expiry):
500 logger.Errorw(ctx, "timeout waiting for reconciling flows to be finished!",
501 log.Fields{"device-id": oo.deviceID, "expiry": expiry})
502 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
503 }
504 oo.setReconcilingFlows(false)
Holger Hildebrandtf2fcdd42021-12-15 11:42:19 +0000505 }(syncChannel)
506 // block further processing until the above Go routine has really started
507 // and is ready to receive values from chReconcilingFlowsFinished
508 <-syncChannel
Holger Hildebrandtb314f442021-11-24 12:03:10 +0000509 oo.baseDeviceHandler.ReconcileDeviceFlowConfig(ctx)
510 }
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000511 } else {
512 logger.Debugw(ctx, "MibSync FSM",
513 log.Fields{"Getting MIB from template not successful": e.FSM.Current(), "device-id": oo.deviceID})
514 go func() {
515 //switch to reconciling with OMCI config
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000516 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
Holger Hildebrandtbe523842021-03-10 10:47:18 +0000517 }()
518 }
519}
520
dbainbri4d3a0dc2020-12-02 00:33:42 +0000521func (oo *OnuDeviceEntry) enterAuditingState(ctx context.Context, e *fsm.Event) {
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000522 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 +0000523 if oo.baseDeviceHandler.CheckAuditStartCondition(ctx, cmn.CUploadFsm) {
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000524 oo.requestMdsValue(ctx)
525 } else {
mpagenkof1fc3862021-02-16 10:09:52 +0000526 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 +0000527 go func() {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000528 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000529 }()
530 }
531}
532
533func (oo *OnuDeviceEntry) enterReAuditingState(ctx context.Context, e *fsm.Event) {
534 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 +0000535 if oo.baseDeviceHandler.CheckAuditStartCondition(ctx, cmn.CUploadFsm) {
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000536 oo.requestMdsValue(ctx)
537 } else {
mpagenkof1fc3862021-02-16 10:09:52 +0000538 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 +0000539 go func() {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000540 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +0000541 }()
542 }
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000543}
544
dbainbri4d3a0dc2020-12-02 00:33:42 +0000545func (oo *OnuDeviceEntry) enterOutOfSyncState(ctx context.Context, e *fsm.Event) {
546 logger.Debugw(ctx, "MibSync FSM", log.Fields{"Start MibReconcile processing in State": e.FSM.Current(), "device-id": oo.deviceID})
547 logger.Debug(ctx, "function not implemented yet")
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000548}
549
dbainbri4d3a0dc2020-12-02 00:33:42 +0000550func (oo *OnuDeviceEntry) processMibSyncMessages(ctx context.Context) {
551 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 -0800552 oo.mutexMibSyncMsgProcessorRunning.Lock()
553 oo.mibSyncMsgProcessorRunning = true
554 oo.mutexMibSyncMsgProcessorRunning.Unlock()
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000555loop:
556 for {
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000557 // case <-ctx.Done():
558 // logger.Info("MibSync Msg", log.Fields{"Message handling canceled via context for device-id": onuDeviceEntry.deviceID})
559 // break loop
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000560 message, ok := <-oo.PMibUploadFsm.CommChan
Himani Chawla4d908332020-08-31 12:30:20 +0530561 if !ok {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000562 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 -0800563 oo.mutexMibSyncMsgProcessorRunning.Lock()
564 oo.mibSyncMsgProcessorRunning = false
565 oo.mutexMibSyncMsgProcessorRunning.Unlock()
Himani Chawla4d908332020-08-31 12:30:20 +0530566 break loop
567 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000568 logger.Debugw(ctx, "MibSync Msg", log.Fields{"Received message on ONU MibSyncChan for device-id": oo.deviceID})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000569
Himani Chawla4d908332020-08-31 12:30:20 +0530570 switch message.Type {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000571 case cmn.TestMsg:
572 msg, _ := message.Data.(cmn.TestMessage)
Holger Hildebrandte7cc6092022-02-01 11:37:03 +0000573 if msg.TestMessageVal == cmn.AbortMessageProcessing {
574 logger.Debugw(ctx, "MibSync Msg abort ProcessMsg", log.Fields{"for device-id": oo.deviceID})
Girish Gowdra37c9d912022-02-08 16:24:57 -0800575 oo.mutexMibSyncMsgProcessorRunning.Lock()
576 oo.mibSyncMsgProcessorRunning = false
577 oo.mutexMibSyncMsgProcessorRunning.Unlock()
Holger Hildebrandte7cc6092022-02-01 11:37:03 +0000578 break loop
579 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000580 oo.handleTestMsg(ctx, msg)
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000581 case cmn.OMCI:
582 msg, _ := message.Data.(cmn.OmciMessage)
dbainbri4d3a0dc2020-12-02 00:33:42 +0000583 oo.handleOmciMessage(ctx, msg)
Himani Chawla4d908332020-08-31 12:30:20 +0530584 default:
dbainbri4d3a0dc2020-12-02 00:33:42 +0000585 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 +0000586 }
587 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000588 logger.Info(ctx, "MibSync Msg", log.Fields{"Stopped handling of MibSyncChan for device-id": oo.deviceID})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000589 // TODO: only this action?
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000590 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000591}
592
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000593func (oo *OnuDeviceEntry) handleTestMsg(ctx context.Context, msg cmn.TestMessage) {
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000594
dbainbri4d3a0dc2020-12-02 00:33:42 +0000595 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 +0000596
597 switch msg.TestMessageVal {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000598 case cmn.LoadMibTemplateFailed:
599 _ = oo.PMibUploadFsm.PFsm.Event(UlEvUploadMib)
600 logger.Debugw(ctx, "MibSync Msg", log.Fields{"state": string(oo.PMibUploadFsm.PFsm.Current())})
601 case cmn.LoadMibTemplateOk:
602 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
603 logger.Debugw(ctx, "MibSync Msg", log.Fields{"state": string(oo.PMibUploadFsm.PFsm.Current())})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +0000604 default:
dbainbri4d3a0dc2020-12-02 00:33:42 +0000605 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 +0000606 }
607}
608
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000609func (oo *OnuDeviceEntry) handleOmciMibResetResponseMessage(ctx context.Context, msg cmn.OmciMessage) {
610 if oo.PMibUploadFsm.PFsm.Is(UlStResettingMib) {
Himani Chawla4d908332020-08-31 12:30:20 +0530611 msgLayer := (*msg.OmciPacket).Layer(omci.LayerTypeMibResetResponse)
612 if msgLayer != nil {
613 msgObj, msgOk := msgLayer.(*omci.MibResetResponse)
614 if msgOk {
nikesh.krishnan1ffb8132023-05-23 03:44:13 +0530615 logger.Infow(ctx, "MibResetResponse Data", log.Fields{"data-fields": msgObj})
Himani Chawla4d908332020-08-31 12:30:20 +0530616 if msgObj.Result == me.Success {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000617 oo.MutexPersOnuConfig.Lock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000618 oo.SOnuPersistentData.PersMibDataSyncAdpt = cmn.MdsDefaultMib
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000619 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandt7e138462023-03-29 12:12:14 +0000620 oo.PDevOmciCC.ResetConfFailMEs()
Himani Chawla4d908332020-08-31 12:30:20 +0530621 // trigger retrieval of VendorId and SerialNumber
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000622 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetVendorAndSerial)
Himani Chawla4d908332020-08-31 12:30:20 +0530623 return
624 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000625 logger.Errorw(ctx, "Omci MibResetResponse Error", log.Fields{"device-id": oo.deviceID, "Error": msgObj.Result})
Himani Chawla4d908332020-08-31 12:30:20 +0530626 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000627 logger.Errorw(ctx, "Omci Msg layer could not be assigned", log.Fields{"device-id": oo.deviceID})
Himani Chawla4d908332020-08-31 12:30:20 +0530628 }
629 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000630 logger.Errorw(ctx, "Omci Msg layer could not be detected", log.Fields{"device-id": oo.deviceID})
Himani Chawla4d908332020-08-31 12:30:20 +0530631 }
632 } else {
mpagenko01499812021-03-25 10:37:12 +0000633 //in case the last request was MdsGetRequest this issue may appear if the ONU was online before and has received the MIB reset
634 // with Sequence number 0x8000 as last request before - so it may still respond to that
635 // 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 +0000636 oo.mutexLastTxParamStruct.Lock()
mpagenko01499812021-03-25 10:37:12 +0000637 if oo.lastTxParamStruct.lastTxMessageType == omci.GetRequestType && oo.lastTxParamStruct.repeatCount == 0 {
638 logger.Debugw(ctx, "MibSync FSM - repeat MdsGetRequest (updated SequenceNumber)", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt3ac49bd2022-02-07 17:46:43 +0000639 requestedAttributes := me.AttributeValueMap{me.OnuData_MibDataSync: ""}
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000640 _, err := oo.PDevOmciCC.SendGetMe(log.WithSpanFromContext(context.TODO(), ctx),
Holger Hildebrandtd930cb22022-06-17 09:24:50 +0000641 me.OnuDataClassID, cmn.OnuDataMeID, requestedAttributes, oo.baseDeviceHandler.GetOmciTimeout(), true, oo.PMibUploadFsm.CommChan, false)
ozgecanetsiab36ed572021-04-01 10:38:48 +0300642 if err != nil {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000643 oo.mutexLastTxParamStruct.Unlock()
ozgecanetsiab36ed572021-04-01 10:38:48 +0300644 logger.Errorw(ctx, "ONUData get failed, aborting MibSync", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000645 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
ozgecanetsiab36ed572021-04-01 10:38:48 +0300646 return
647 }
mpagenko01499812021-03-25 10:37:12 +0000648 //TODO: needs extra handling of timeouts
649 oo.lastTxParamStruct.repeatCount = 1
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000650 oo.mutexLastTxParamStruct.Unlock()
mpagenko01499812021-03-25 10:37:12 +0000651 return
652 }
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000653 oo.mutexLastTxParamStruct.Unlock()
mpagenko01499812021-03-25 10:37:12 +0000654 logger.Errorw(ctx, "unexpected MibResetResponse - ignoring", log.Fields{"device-id": oo.deviceID})
655 //perhaps some still lingering message from some prior activity, let's wait for the real response
656 return
Himani Chawla4d908332020-08-31 12:30:20 +0530657 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000658 logger.Info(ctx, "MibSync Msg", log.Fields{"Stopped handling of MibSyncChan for device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000659 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Himani Chawla4d908332020-08-31 12:30:20 +0530660}
661
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000662func (oo *OnuDeviceEntry) handleOmciMibUploadResponseMessage(ctx context.Context, msg cmn.OmciMessage) {
Himani Chawla4d908332020-08-31 12:30:20 +0530663 msgLayer := (*msg.OmciPacket).Layer(omci.LayerTypeMibUploadResponse)
664 if msgLayer == nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000665 logger.Errorw(ctx, "Omci Msg layer could not be detected", log.Fields{"device-id": oo.deviceID})
Himani Chawla4d908332020-08-31 12:30:20 +0530666 return
667 }
668 msgObj, msgOk := msgLayer.(*omci.MibUploadResponse)
669 if !msgOk {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000670 logger.Errorw(ctx, "Omci Msg layer could not be assigned", log.Fields{"device-id": oo.deviceID})
Himani Chawla4d908332020-08-31 12:30:20 +0530671 return
672 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000673 logger.Debugw(ctx, "MibUploadResponse Data for:", log.Fields{"device-id": oo.deviceID, "data-fields": msgObj})
Himani Chawla4d908332020-08-31 12:30:20 +0530674 /* to be verified / reworked !!! */
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000675 oo.PDevOmciCC.UploadNoOfCmds = msgObj.NumberOfCommands
676 if oo.PDevOmciCC.UploadSequNo < oo.PDevOmciCC.UploadNoOfCmds {
Holger Hildebrandt5458d892022-05-31 09:52:06 +0000677 _ = oo.PDevOmciCC.SendMibUploadNext(log.WithSpanFromContext(context.TODO(), ctx),
678 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.GetPersIsExtOmciSupported())
mpagenko01499812021-03-25 10:37:12 +0000679 //even though lastTxParameters are currently not used for checking the ResetResponse message we have to ensure
680 // that the lastTxMessageType is correctly set to avoid misinterpreting other responses
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000681 oo.mutexLastTxParamStruct.Lock()
mpagenko01499812021-03-25 10:37:12 +0000682 oo.lastTxParamStruct.lastTxMessageType = omci.MibUploadNextRequestType
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000683 oo.mutexLastTxParamStruct.Unlock()
Himani Chawla4d908332020-08-31 12:30:20 +0530684 } else {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000685 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 +0530686 //TODO right action?
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000687 _ = oo.PMibUploadFsm.PFsm.Event(UlEvTimeout)
Himani Chawla4d908332020-08-31 12:30:20 +0530688 }
689}
690
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000691func (oo *OnuDeviceEntry) handleOmciMibUploadNextResponseMessage(ctx context.Context, msg cmn.OmciMessage) {
Himani Chawla4d908332020-08-31 12:30:20 +0530692 msgLayer := (*msg.OmciPacket).Layer(omci.LayerTypeMibUploadNextResponse)
mpagenko7033f4e2021-11-19 18:04:22 +0000693 if msgLayer != nil {
694 msgObj, msgOk := msgLayer.(*omci.MibUploadNextResponse)
695 if !msgOk {
696 logger.Errorw(ctx, "Omci Msg layer could not be assigned", log.Fields{"device-id": oo.deviceID})
697 return
mpagenko836a1fd2021-11-01 16:12:42 +0000698 }
mpagenko7033f4e2021-11-19 18:04:22 +0000699 meName := msgObj.ReportedME.GetName()
700 meClassID := msgObj.ReportedME.GetClassID()
701 meEntityID := msgObj.ReportedME.GetEntityID()
702
703 logger.Debugw(ctx, "MibUploadNextResponse Data for:", log.Fields{"device-id": oo.deviceID, "meName": meName, "data-fields": msgObj})
704
705 if meName == devdb.CUnknownItuG988ManagedEntity || meName == devdb.CUnknownVendorSpecificManagedEntity {
Holger Hildebrandt39080022022-03-16 10:03:17 +0000706 logger.Debugw(ctx, "MibUploadNextResponse contains unknown ME", log.Fields{"device-id": oo.deviceID,
707 "Me-Name": devdb.UnknownMeOrAttribName(meName), "Me-ClassId": meClassID, "Me-InstId": meEntityID,
708 "unknown mask": msgObj.ReportedME.GetAttributeMask(), "unknown attributes": msgObj.BaseLayer.Payload})
709 oo.pOnuDB.PutUnknownMeOrAttrib(ctx, devdb.UnknownMeOrAttribName(meName), meClassID, meEntityID,
710 msgObj.ReportedME.GetAttributeMask(), msgObj.BaseLayer.Payload[devdb.CStartUnknownMeAttribsInBaseLayerPayload:])
mpagenko7033f4e2021-11-19 18:04:22 +0000711 } else {
712 //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
713 if unknownAttrLayer := (*msg.OmciPacket).Layer(omci.LayerTypeUnknownAttributes); unknownAttrLayer != nil {
714 logger.Warnw(ctx, "MibUploadNextResponse contains unknown attributes", log.Fields{"device-id": oo.deviceID})
715 if unknownAttributes, ok := unknownAttrLayer.(*omci.UnknownAttributes); ok {
716 // provide a loop over several ME's here already in preparation of OMCI extended message format
717 for _, unknown := range unknownAttributes.Attributes {
718 unknownAttrClassID := unknown.EntityClass // ClassID
719 unknownAttrInst := unknown.EntityInstance // uint16
720 unknownAttrMask := unknown.AttributeMask // ui
721 unknownAttrBlob := unknown.AttributeData // []byte
722 logger.Warnw(ctx, "unknown attributes detected for", log.Fields{"device-id": oo.deviceID,
723 "Me-ClassId": unknownAttrClassID, "Me-InstId": unknownAttrInst, "unknown mask": unknownAttrMask,
724 "unknown attributes": unknownAttrBlob})
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000725 oo.pOnuDB.PutUnknownMeOrAttrib(ctx, devdb.CUnknownAttributesManagedEntity, unknown.EntityClass, unknown.EntityInstance,
726 unknown.AttributeMask, unknown.AttributeData)
mpagenko7033f4e2021-11-19 18:04:22 +0000727 } // for all included ME's with unknown attributes
728 } else {
729 logger.Errorw(ctx, "unknownAttrLayer could not be decoded", log.Fields{"device-id": oo.deviceID})
730 }
731 }
732 oo.pOnuDB.PutMe(ctx, meClassID, meEntityID, msgObj.ReportedME.GetAttributeValueMap())
733 }
Holger Hildebrandt0edf5b02022-05-04 14:19:43 +0000734 if msg.OmciMsg.DeviceIdentifier == omci.ExtendedIdent {
735 for _, additionalME := range msgObj.AdditionalMEs {
736 meName := additionalME.GetName()
737 meClassID := additionalME.GetClassID()
738 meEntityID := additionalME.GetEntityID()
739 attributes := additionalME.GetAttributeValueMap()
740
741 if meName == devdb.CUnknownItuG988ManagedEntity || meName == devdb.CUnknownVendorSpecificManagedEntity {
742 attribMask := additionalME.GetAttributeMask()
743 logger.Debugw(ctx, "MibUploadNextResponse AdditionalData contains unknown ME", log.Fields{"device-id": oo.deviceID,
744 "Me-Name": devdb.UnknownMeOrAttribName(meName), "Me-ClassId": meClassID, "Me-InstId": meEntityID,
745 "unknown mask": attribMask})
746
747 attribValues := make([]byte, 0)
748 for key, value := range attributes {
749 if key != cmn.CGenericManagedEntityIDName {
750 data, err := me.InterfaceToOctets(value)
751 if err != nil {
752 logger.Infow(ctx, "MibUploadNextResponse unknown ME AdditionalData attrib - could not decode", log.Fields{"device-id": oo.deviceID, "key": key})
753 } else {
754 attribValues = append(attribValues[:], data[:]...)
755 logger.Debugw(ctx, "MibUploadNextResponse unknown ME AdditionalData attrib", log.Fields{"device-id": oo.deviceID, "attribValues": attribValues, "data": data, "key": key})
756 }
757 }
758 }
759 oo.pOnuDB.PutUnknownMeOrAttrib(ctx, devdb.UnknownMeOrAttribName(meName), meClassID, meEntityID, attribMask, attribValues)
760 } else {
761 logger.Debugw(ctx, "MibUploadNextResponse AdditionalData for:", log.Fields{"device-id": oo.deviceID, "meName": meName, "meEntityID": meEntityID, "attributes": attributes})
762 oo.pOnuDB.PutMe(ctx, meClassID, meEntityID, attributes)
763 }
764 }
765 }
mpagenko7033f4e2021-11-19 18:04:22 +0000766 } else {
767 logger.Errorw(ctx, "Omci Msg layer could not be detected", log.Fields{"device-id": oo.deviceID})
768 //as long as omci-lib does not support decoding of table attribute as 'unknown/unspecified' attribute
769 // we have to verify, if this failure is from table attribute and try to go forward with ignoring the complete message
770 errLayer := (*msg.OmciPacket).Layer(gopacket.LayerTypeDecodeFailure)
771 if failure, decodeOk := errLayer.(*gopacket.DecodeFailure); decodeOk {
772 errMsg := failure.String()
773 if !strings.Contains(strings.ToLower(errMsg), "table decode") {
774 //something still unexected happened, needs deeper investigation - stop complete MIB upload process (timeout)
775 return
776 }
777 logger.Warnw(ctx, "Decode issue on received MibUploadNextResponse frame - found table attribute(s) (message ignored)",
778 log.Fields{"device-id": oo.deviceID, "issue": errMsg})
779 }
Himani Chawla4d908332020-08-31 12:30:20 +0530780 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000781 if oo.PDevOmciCC.UploadSequNo < oo.PDevOmciCC.UploadNoOfCmds {
Holger Hildebrandt5458d892022-05-31 09:52:06 +0000782 _ = oo.PDevOmciCC.SendMibUploadNext(log.WithSpanFromContext(context.TODO(), ctx),
783 oo.baseDeviceHandler.GetOmciTimeout(), true, oo.GetPersIsExtOmciSupported())
mpagenko01499812021-03-25 10:37:12 +0000784 //even though lastTxParameters are currently not used for checking the ResetResponse message we have to ensure
785 // that the lastTxMessageType is correctly set to avoid misinterpreting other responses
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000786 oo.mutexLastTxParamStruct.Lock()
mpagenko01499812021-03-25 10:37:12 +0000787 oo.lastTxParamStruct.lastTxMessageType = omci.MibUploadNextRequestType
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000788 oo.mutexLastTxParamStruct.Unlock()
Himani Chawla4d908332020-08-31 12:30:20 +0530789 } else {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000790 oo.pOnuDB.LogMeDb(ctx)
dbainbri4d3a0dc2020-12-02 00:33:42 +0000791 err := oo.createAndPersistMibTemplate(ctx)
Himani Chawla4d908332020-08-31 12:30:20 +0530792 if err != nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000793 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 +0530794 }
795
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +0530796 oo.updateOnuSpecificEntries(ctx)
797 logger.Errorw(ctx, "MibSync - Updtaed the ONU Specific MEs ", log.Fields{"device-id": oo.deviceID})
798
799 cmnMEDB, _ := oo.pOpenOnuAc.FetchEntryFromMibDatabaseMap(ctx, oo.mibTemplatePath)
800 cmnMEDB.MIBUploadStatus = devdb.Completed
801 oo.pOnuDB.CommonMeDb.MeDbLock.Unlock()
802 oo.pOpenOnuAc.SetMibTemplatesGenerated(oo.mibTemplatePath, true)
803 oo.pOpenOnuAc.UnlockMutexMibTemplateGenerated()
804
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000805 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Himani Chawla4d908332020-08-31 12:30:20 +0530806 }
807}
808
Girish Gowdra21bbf052022-02-17 16:08:22 -0800809// nolint: gocyclo
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000810func (oo *OnuDeviceEntry) handleOmciGetResponseMessage(ctx context.Context, msg cmn.OmciMessage) error {
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000811 var err error = nil
mpagenko01499812021-03-25 10:37:12 +0000812
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000813 oo.mutexLastTxParamStruct.RLock()
mpagenko01499812021-03-25 10:37:12 +0000814 if oo.lastTxParamStruct.lastTxMessageType != omci.GetRequestType ||
815 oo.lastTxParamStruct.pLastTxMeInstance == nil {
816 //in case the last request was MibReset this issue may appear if the ONU was online before and has received the MDS GetRequest
817 // with Sequence number 0x8000 as last request before - so it may still respond to that
818 // then we may force the ONU to react on the MIB reset with a new message that uses an increased Sequence number
819 if oo.lastTxParamStruct.lastTxMessageType == omci.MibResetRequestType && oo.lastTxParamStruct.repeatCount == 0 {
820 logger.Debugw(ctx, "MibSync FSM - repeat mibReset (updated SequenceNumber)", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000821 _ = oo.PDevOmciCC.SendMibReset(log.WithSpanFromContext(context.TODO(), ctx), oo.baseDeviceHandler.GetOmciTimeout(), true)
mpagenko01499812021-03-25 10:37:12 +0000822 //TODO: needs extra handling of timeouts
823 oo.lastTxParamStruct.repeatCount = 1
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000824 oo.mutexLastTxParamStruct.RUnlock()
mpagenko01499812021-03-25 10:37:12 +0000825 return nil
826 }
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000827 oo.mutexLastTxParamStruct.RUnlock()
mpagenko01499812021-03-25 10:37:12 +0000828 logger.Warnw(ctx, "unexpected GetResponse - ignoring", log.Fields{"device-id": oo.deviceID})
829 //perhaps some still lingering message from some prior activity, let's wait for the real response
830 return nil
831 }
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000832 oo.mutexLastTxParamStruct.RUnlock()
Himani Chawla4d908332020-08-31 12:30:20 +0530833 msgLayer := (*msg.OmciPacket).Layer(omci.LayerTypeGetResponse)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000834 if msgLayer == nil {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000835 logger.Errorw(ctx, "omci Msg layer could not be detected for GetResponse - handling of MibSyncChan stopped",
836 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000837 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt61b24d02020-11-16 13:36:40 +0000838 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 +0000839 }
840 msgObj, msgOk := msgLayer.(*omci.GetResponse)
841 if !msgOk {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000842 logger.Errorw(ctx, "omci Msg layer could not be assigned for GetResponse - handling of MibSyncChan stopped",
843 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000844 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt61b24d02020-11-16 13:36:40 +0000845 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 +0000846 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000847 logger.Debugw(ctx, "MibSync FSM - GetResponse Data", log.Fields{"device-id": oo.deviceID, "data-fields": msgObj})
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000848 if msgObj.Result == me.Success {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000849 oo.mutexLastTxParamStruct.RLock()
mpagenko01499812021-03-25 10:37:12 +0000850 entityID := oo.lastTxParamStruct.pLastTxMeInstance.GetEntityID()
851 if msgObj.EntityClass == oo.lastTxParamStruct.pLastTxMeInstance.GetClassID() && msgObj.EntityInstance == entityID {
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000852 meAttributes := msgObj.Attributes
mpagenko01499812021-03-25 10:37:12 +0000853 meInstance := oo.lastTxParamStruct.pLastTxMeInstance.GetName()
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000854 logger.Debugf(ctx, "MibSync FSM - GetResponse Data for %s",
855 log.Fields{"device-id": oo.deviceID, "data-fields": msgObj}, meInstance)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000856 switch meInstance {
857 case "OnuG":
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000858 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000859 return oo.handleOmciGetResponseOnuG(ctx, meAttributes)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000860 case "Onu2G":
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000861 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000862 var equipmentID string
863 if onu2GEquipmentID, ok := meAttributes[me.Onu2G_EquipmentId]; ok {
864 equipmentID = cmn.TrimStringFromMeOctet(onu2GEquipmentID)
865 if equipmentID == "" {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000866 logger.Infow(ctx,
867 "MibSync FSM - optional attribute EquipmentID is empty in Onu2G instance - fill with appropriate value",
868 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000869 equipmentID = cEmptyEquipIDString
870 }
871 } else {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000872 logger.Infow(ctx,
873 "MibSync FSM - optional attribute EquipmentID not present in Onu2G instance - fill with appropriate value",
874 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000875 equipmentID = cNotPresentEquipIDString
876 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000877 oo.MutexPersOnuConfig.Lock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000878 oo.SOnuPersistentData.PersEquipmentID = equipmentID
dbainbri4d3a0dc2020-12-02 00:33:42 +0000879 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for Onu2-G - EquipmentId", log.Fields{"device-id": oo.deviceID,
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000880 "onuDeviceEntry.equipmentID": oo.SOnuPersistentData.PersEquipmentID})
881 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000882
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000883 var omccVersion uint8
884 if onu2GOmccVersion, ok := meAttributes[me.Onu2G_OpticalNetworkUnitManagementAndControlChannelOmccVersion]; ok {
885 oo.MutexPersOnuConfig.Lock()
886 omccVersion = onu2GOmccVersion.(uint8)
887 if _, ok := omccVersionSupportsExtendedOmciFormat[omccVersion]; ok {
888 oo.SOnuPersistentData.PersIsExtOmciSupported = omccVersionSupportsExtendedOmciFormat[omccVersion]
Holger Hildebrandtc572e622022-06-22 09:19:17 +0000889 if oo.SOnuPersistentData.PersIsExtOmciSupported && !oo.baseDeviceHandler.GetExtendedOmciSupportEnabled() {
890 logger.Infow(ctx, "MibSync FSM - ONU supports extended OMCI, but support is disabled in the adapter: reset flag",
891 log.Fields{"device-id": oo.deviceID})
892 oo.SOnuPersistentData.PersIsExtOmciSupported = false
893 }
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000894 } else {
895 logger.Infow(ctx, "MibSync FSM - unknown OMCC version in Onu2G instance - disable extended OMCI support",
896 log.Fields{"device-id": oo.deviceID})
897 oo.SOnuPersistentData.PersIsExtOmciSupported = false
898 }
899 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for Onu2-G - OMCC version", log.Fields{"device-id": oo.deviceID,
900 "omccVersion": omccVersion, "isExtOmciSupported": oo.SOnuPersistentData.PersIsExtOmciSupported})
901 oo.MutexPersOnuConfig.Unlock()
902 } else {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000903 logger.Errorw(ctx,
904 "MibSync FSM - mandatory attribute OMCC version not present in Onu2G instance - handling of MibSyncChan stopped!",
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000905 log.Fields{"device-id": oo.deviceID})
906 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000907 return fmt.Errorf(
908 "mibSync FSM - mandatory attribute OMCC version not present in Onu2G instance - handling of MibSyncChan stopped: %s",
909 oo.deviceID)
Holger Hildebrandta6ef0e82022-04-06 13:11:32 +0000910 }
911 oo.MutexPersOnuConfig.RLock()
912 if oo.SOnuPersistentData.PersIsExtOmciSupported {
913 oo.MutexPersOnuConfig.RUnlock()
914 // trigger test of OMCI extended msg format
915 _ = oo.PMibUploadFsm.PFsm.Event(UlEvTestExtOmciSupport)
916 return nil
917 }
918 oo.MutexPersOnuConfig.RUnlock()
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000919 // trigger retrieval of 1st SW-image info
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000920 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetFirstSwVersion)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000921 return nil
922 case "SoftwareImage":
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000923 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000924 if entityID > cmn.SecondSwImageMeID {
mpagenko15ff4a52021-03-02 10:09:20 +0000925 logger.Errorw(ctx, "mibSync FSM - Failed to GetResponse Data for SoftwareImage with expected EntityId",
926 log.Fields{"device-id": oo.deviceID, "entity-ID": entityID})
927 return fmt.Errorf("mibSync FSM - SwResponse Data with unexpected EntityId: %s %x",
928 oo.deviceID, entityID)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000929 }
mpagenko15ff4a52021-03-02 10:09:20 +0000930 // need to use function for go lint complexity
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000931 if !oo.HandleSwImageIndications(ctx, entityID, meAttributes) {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000932 logger.Errorw(ctx,
933 "MibSync FSM - Not all mandatory attributes present in in SoftwareImage 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(
937 "mibSync FSM - Not all mandatory attributes present in in SoftwareImage instance - handling of MibSyncChan stopped: %s",
938 oo.deviceID)
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000939 }
mpagenko15ff4a52021-03-02 10:09:20 +0000940 return nil
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000941 case "IpHostConfigData":
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000942 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000943 oo.MutexPersOnuConfig.Lock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000944 if ipHostConfigMacAddress, ok := meAttributes[me.IpHostConfigData_MacAddress]; ok {
Girish Gowdra21bbf052022-02-17 16:08:22 -0800945 macBytes, _ := me.InterfaceToOctets(ipHostConfigMacAddress)
946 if cmn.OmciMacAddressLen == len(macBytes) {
947 oo.SOnuPersistentData.PersMacAddress = hex.EncodeToString(macBytes[:])
948 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for IpHostConfigData - MacAddress", log.Fields{"device-id": oo.deviceID,
949 "macAddress": oo.SOnuPersistentData.PersMacAddress})
950 } else {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000951 logger.Infow(ctx, "MibSync FSM - MacAddress wrong length - fill macAddress with zeros",
952 log.Fields{"device-id": oo.deviceID, "length": len(macBytes)})
Girish Gowdra21bbf052022-02-17 16:08:22 -0800953 oo.SOnuPersistentData.PersMacAddress = cEmptyMacAddrString
954 }
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000955 } else {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000956 // since ONU creates instances of this ME automatically only when IP host services are available,
957 // processing continues here despite the error
958 logger.Infow(ctx, "MibSync FSM - MacAddress attribute not present in IpHostConfigData instance - fill macAddress with zeros",
959 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000960 oo.SOnuPersistentData.PersMacAddress = cEmptyMacAddrString
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000961 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000962 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000963 // trigger retrieval of mib template
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000964 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetMibTemplate)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000965 return nil
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +0000966 case "OnuData":
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000967 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000968 if onuDataMibDataSync, ok := meAttributes[me.OnuData_MibDataSync]; ok {
969 oo.checkMdsValue(ctx, onuDataMibDataSync.(uint8))
970 } else {
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000971 logger.Errorw(ctx, "MibSync FSM - MibDataSync attribute not present in OnuData instance - handling of MibSyncChan stopped!",
972 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000973 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +0000974 return fmt.Errorf("mibSync FSM - VendorId attribute not present in OnuG instance - handling of MibSyncChan stopped: %s",
975 oo.deviceID)
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +0000976 }
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +0000977 return nil
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000978 default:
979 oo.mutexLastTxParamStruct.RUnlock()
980 logger.Warnw(ctx, "Unsupported ME name received!",
981 log.Fields{"ME name": meInstance, "device-id": oo.deviceID})
982
Himani Chawla4d908332020-08-31 12:30:20 +0530983 }
Matteo Scandolo20ca10c2021-01-21 14:35:45 -0800984 } else {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +0000985 oo.mutexLastTxParamStruct.RUnlock()
986 logger.Warnf(ctx, "MibSync FSM - Received GetResponse Data for %s with wrong classID or entityID ",
987 log.Fields{"device-id": oo.deviceID, "data-fields": msgObj}, msgObj.EntityClass)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000988 }
Himani Chawla4d908332020-08-31 12:30:20 +0530989 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +0000990 if err = oo.handleOmciGetResponseErrors(ctx, msgObj); err == nil {
Holger Hildebrandt80129db2020-11-23 10:49:32 +0000991 return nil
992 }
Himani Chawla4d908332020-08-31 12:30:20 +0530993 }
dbainbri4d3a0dc2020-12-02 00:33:42 +0000994 logger.Info(ctx, "MibSync Msg", log.Fields{"Stopped handling of MibSyncChan for device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +0000995 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
Holger Hildebrandt2fb70892020-10-28 11:53:18 +0000996 return err
Himani Chawla4d908332020-08-31 12:30:20 +0530997}
998
nikesh.krishnan1ffb8132023-05-23 03:44:13 +0530999// HandleSwImageIndications updates onuSwImageIndications with the ONU data just received
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +00001000func (oo *OnuDeviceEntry) HandleSwImageIndications(ctx context.Context, entityID uint16, meAttributes me.AttributeValueMap) bool {
1001
1002 var imageVersion string
1003 var imageIsCommitted, imageIsActive uint8
1004
1005 allMandAttribsPresent := false
1006 if softwareImageIsCommitted, ok := meAttributes[me.SoftwareImage_IsCommitted]; ok {
1007 if softwareImageIsActiveimage, ok := meAttributes[me.SoftwareImage_IsActive]; ok {
1008 if softwareImageVersion, ok := meAttributes[me.SoftwareImage_Version]; ok {
1009 imageVersion = cmn.TrimStringFromMeOctet(softwareImageVersion)
1010 imageIsActive = softwareImageIsActiveimage.(uint8)
1011 imageIsCommitted = softwareImageIsCommitted.(uint8)
1012 allMandAttribsPresent = true
1013 }
1014 }
1015 }
1016 if !allMandAttribsPresent {
1017 logger.Errorw(ctx, "MibSync FSM - Not all mandatory attributes present in SoftwareImage instance - skip processing!", log.Fields{"device-id": oo.deviceID})
1018 return allMandAttribsPresent
1019 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001020 oo.MutexPersOnuConfig.RLock()
mpagenko15ff4a52021-03-02 10:09:20 +00001021 logger.Infow(ctx, "MibSync FSM - GetResponse Data for SoftwareImage",
1022 log.Fields{"device-id": oo.deviceID, "entityID": entityID,
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001023 "version": imageVersion, "isActive": imageIsActive, "isCommitted": imageIsCommitted, "SNR": oo.SOnuPersistentData.PersSerialNumber})
1024 oo.MutexPersOnuConfig.RUnlock()
1025 if cmn.FirstSwImageMeID == entityID {
mpagenko15ff4a52021-03-02 10:09:20 +00001026 //always accept the state of the first image (2nd image info should not yet be available)
Holger Hildebrandt05011352021-06-15 09:40:24 +00001027 oo.mutexOnuSwImageIndications.Lock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001028 if imageIsActive == cmn.SwIsActive {
1029 oo.onuSwImageIndications.ActiveEntityEntry.EntityID = entityID
1030 oo.onuSwImageIndications.ActiveEntityEntry.Valid = true
1031 oo.onuSwImageIndications.ActiveEntityEntry.Version = imageVersion
1032 oo.onuSwImageIndications.ActiveEntityEntry.IsCommitted = imageIsCommitted
mpagenko59498c12021-03-18 14:15:15 +00001033 //as the SW version indication may stem from some ONU Down/up event
1034 //the complementary image state is to be invalidated
1035 // (state of the second image is always expected afterwards or just invalid)
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001036 oo.onuSwImageIndications.InActiveEntityEntry.Valid = false
mpagenko15ff4a52021-03-02 10:09:20 +00001037 } else {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001038 oo.onuSwImageIndications.InActiveEntityEntry.EntityID = entityID
1039 oo.onuSwImageIndications.InActiveEntityEntry.Valid = true
1040 oo.onuSwImageIndications.InActiveEntityEntry.Version = imageVersion
1041 oo.onuSwImageIndications.InActiveEntityEntry.IsCommitted = imageIsCommitted
mpagenko59498c12021-03-18 14:15:15 +00001042 //as the SW version indication may stem form some ONU Down/up event
1043 //the complementary image state is to be invalidated
1044 // (state of the second image is always expected afterwards or just invalid)
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001045 oo.onuSwImageIndications.ActiveEntityEntry.Valid = false
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(UlEvGetSecondSwVersion)
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +00001049 return allMandAttribsPresent
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001050 } else if cmn.SecondSwImageMeID == entityID {
mpagenko15ff4a52021-03-02 10:09:20 +00001051 //2nd image info might conflict with first image info, in which case we priorize first image info!
Holger Hildebrandt05011352021-06-15 09:40:24 +00001052 oo.mutexOnuSwImageIndications.Lock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001053 if imageIsActive == cmn.SwIsActive { //2nd image reported to be active
1054 if oo.onuSwImageIndications.ActiveEntityEntry.Valid {
mpagenko15ff4a52021-03-02 10:09:20 +00001055 //conflict exists - state of first image is left active
1056 logger.Warnw(ctx, "mibSync FSM - both ONU images are reported as active - assuming 2nd to be inactive",
1057 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001058 oo.onuSwImageIndications.InActiveEntityEntry.EntityID = entityID
1059 oo.onuSwImageIndications.InActiveEntityEntry.Valid = true ////to indicate that at least something has been reported
1060 oo.onuSwImageIndications.InActiveEntityEntry.Version = imageVersion
1061 oo.onuSwImageIndications.InActiveEntityEntry.IsCommitted = imageIsCommitted
mpagenko15ff4a52021-03-02 10:09:20 +00001062 } else { //first image inactive, this one active
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001063 oo.onuSwImageIndications.ActiveEntityEntry.EntityID = entityID
1064 oo.onuSwImageIndications.ActiveEntityEntry.Valid = true
1065 oo.onuSwImageIndications.ActiveEntityEntry.Version = imageVersion
1066 oo.onuSwImageIndications.ActiveEntityEntry.IsCommitted = imageIsCommitted
mpagenko15ff4a52021-03-02 10:09:20 +00001067 }
1068 } else { //2nd image reported to be inactive
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001069 if oo.onuSwImageIndications.InActiveEntityEntry.Valid {
mpagenko15ff4a52021-03-02 10:09:20 +00001070 //conflict exists - both images inactive - regard it as ONU failure and assume first image to be active
1071 logger.Warnw(ctx, "mibSync FSM - both ONU images are reported as inactive, defining first to be active",
1072 log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001073 oo.onuSwImageIndications.ActiveEntityEntry.EntityID = cmn.FirstSwImageMeID
1074 oo.onuSwImageIndications.ActiveEntityEntry.Valid = true //to indicate that at least something has been reported
mpagenko15ff4a52021-03-02 10:09:20 +00001075 //copy active commit/version from the previously stored inactive position
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001076 oo.onuSwImageIndications.ActiveEntityEntry.Version = oo.onuSwImageIndications.InActiveEntityEntry.Version
1077 oo.onuSwImageIndications.ActiveEntityEntry.IsCommitted = oo.onuSwImageIndications.InActiveEntityEntry.IsCommitted
mpagenko15ff4a52021-03-02 10:09:20 +00001078 }
1079 //in any case we indicate (and possibly overwrite) the second image indications as inactive
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001080 oo.onuSwImageIndications.InActiveEntityEntry.EntityID = entityID
1081 oo.onuSwImageIndications.InActiveEntityEntry.Valid = true
1082 oo.onuSwImageIndications.InActiveEntityEntry.Version = imageVersion
1083 oo.onuSwImageIndications.InActiveEntityEntry.IsCommitted = imageIsCommitted
mpagenko15ff4a52021-03-02 10:09:20 +00001084 }
Holger Hildebrandt05011352021-06-15 09:40:24 +00001085 oo.mutexOnuSwImageIndications.Unlock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001086 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetMacAddress)
mpagenko15ff4a52021-03-02 10:09:20 +00001087 }
Holger Hildebrandtfdb4bba2022-03-10 12:12:59 +00001088 return allMandAttribsPresent
mpagenko15ff4a52021-03-02 10:09:20 +00001089}
1090
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001091func (oo *OnuDeviceEntry) handleOmciMessage(ctx context.Context, msg cmn.OmciMessage) {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001092 logger.Debugw(ctx, "MibSync Msg", log.Fields{"OmciMessage received for device-id": oo.deviceID,
Andrea Campanella6515c582020-10-05 11:25:00 +02001093 "msgType": msg.OmciMsg.MessageType, "msg": msg})
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001094 //further analysis could be done here based on msg.OmciMsg.Payload, e.g. verification of error code ...
1095 switch msg.OmciMsg.MessageType {
1096 case omci.MibResetResponseType:
dbainbri4d3a0dc2020-12-02 00:33:42 +00001097 oo.handleOmciMibResetResponseMessage(ctx, msg)
Holger Hildebrandtc54939a2020-06-17 08:14:27 +00001098
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001099 case omci.MibUploadResponseType:
dbainbri4d3a0dc2020-12-02 00:33:42 +00001100 oo.handleOmciMibUploadResponseMessage(ctx, msg)
Himani Chawla4d908332020-08-31 12:30:20 +05301101
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001102 case omci.MibUploadNextResponseType:
dbainbri4d3a0dc2020-12-02 00:33:42 +00001103 oo.handleOmciMibUploadNextResponseMessage(ctx, msg)
Holger Hildebrandtccd390c2020-05-29 13:49:04 +00001104
Holger Hildebrandtc54939a2020-06-17 08:14:27 +00001105 case omci.GetResponseType:
Holger Hildebrandt2fb70892020-10-28 11:53:18 +00001106 //TODO: error handling
dbainbri4d3a0dc2020-12-02 00:33:42 +00001107 _ = oo.handleOmciGetResponseMessage(ctx, msg)
Himani Chawla4d908332020-08-31 12:30:20 +05301108
Andrea Campanella6515c582020-10-05 11:25:00 +02001109 default:
Holger Hildebrandtabfef032022-02-25 12:40:20 +00001110 logger.Warnw(ctx, "Unknown Message Type", log.Fields{"device-id": oo.deviceID, "msgType": msg.OmciMsg.MessageType})
Andrea Campanella6515c582020-10-05 11:25:00 +02001111
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001112 }
1113}
1114
Holger Hildebrandt3d3c2c52022-06-08 13:25:43 +00001115func (oo *OnuDeviceEntry) handleOmciGetResponseOnuG(ctx context.Context, meAttributes me.AttributeValueMap) error {
1116 currentState := oo.PMibUploadFsm.PFsm.Current()
1117 if currentState == UlStGettingVendorAndSerial {
1118 if onuGVendorID, ok := meAttributes[me.OnuG_VendorId]; ok {
1119 vendorID := cmn.TrimStringFromMeOctet(onuGVendorID)
1120 if vendorID == "" {
1121 logger.Infow(ctx,
1122 "MibSync FSM - mandatory attribute VendorId is empty in OnuG instance - fill with appropriate value",
1123 log.Fields{"device-id": oo.deviceID})
1124 vendorID = cEmptyVendorIDString
1125 }
1126 oo.MutexPersOnuConfig.Lock()
1127 oo.SOnuPersistentData.PersVendorID = vendorID
1128 oo.MutexPersOnuConfig.Unlock()
1129 } else {
1130 logger.Errorw(ctx,
1131 "MibSync FSM - mandatory attribute VendorId not present in OnuG instance - handling of MibSyncChan stopped!",
1132 log.Fields{"device-id": oo.deviceID})
1133 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
1134 return fmt.Errorf(
1135 "mibSync FSM - mandatory attribute VendorId not present in OnuG instance - handling of MibSyncChan stopped: %s",
1136 oo.deviceID)
1137 }
1138 if onuGSerialNumber, ok := meAttributes[me.OnuG_SerialNumber]; ok {
1139 oo.MutexPersOnuConfig.Lock()
1140 snBytes, _ := me.InterfaceToOctets(onuGSerialNumber)
1141 if cmn.OnugSerialNumberLen == len(snBytes) {
1142 snVendorPart := fmt.Sprintf("%s", snBytes[:4])
1143 snNumberPart := hex.EncodeToString(snBytes[4:])
1144 oo.SOnuPersistentData.PersSerialNumber = snVendorPart + snNumberPart
1145 } else {
1146 logger.Infow(ctx, "MibSync FSM - SerialNumber has wrong length - fill serialNumber with zeros",
1147 log.Fields{"device-id": oo.deviceID, "length": len(snBytes)})
1148 oo.SOnuPersistentData.PersSerialNumber = cEmptySerialNumberString
1149 }
1150 oo.MutexPersOnuConfig.Unlock()
1151 } else {
1152 logger.Errorw(ctx,
1153 "MibSync FSM - mandatory attribute SerialNumber not present in OnuG instance - handling of MibSyncChan stopped!",
1154 log.Fields{"device-id": oo.deviceID})
1155 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
1156 return fmt.Errorf(
1157 "mibSync FSM - mandatory attribute SerialNumber not present in OnuG instance - handling of MibSyncChan stopped: %s",
1158 oo.deviceID)
1159 }
1160 oo.MutexPersOnuConfig.Lock()
1161 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for Onu-G - VendorId/SerialNumber", log.Fields{"device-id": oo.deviceID,
1162 "onuDeviceEntry.vendorID": oo.SOnuPersistentData.PersVendorID,
1163 "onuDeviceEntry.serialNumber": oo.SOnuPersistentData.PersSerialNumber})
1164 oo.MutexPersOnuConfig.Unlock()
1165 // trigger retrieval of Version
1166 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetVersion)
1167 return nil
1168 } else if currentState == UlStGettingVersion {
1169 if onuGVersion, ok := meAttributes[me.OnuG_Version]; ok {
1170 version := cmn.TrimStringFromMeOctet(onuGVersion)
1171 if version == "" {
1172 logger.Infow(ctx, "MibSync FSM - mandatory attribute Version is empty in OnuG instance - fill with appropriate value",
1173 log.Fields{"device-id": oo.deviceID})
1174 version = cEmptyVersionString
1175 }
1176 oo.MutexPersOnuConfig.Lock()
1177 oo.SOnuPersistentData.PersVersion = version
1178 oo.MutexPersOnuConfig.Unlock()
1179 } else {
1180 logger.Errorw(ctx,
1181 "MibSync FSM - mandatory attribute Version not present in OnuG instance - handling of MibSyncChan stopped!",
1182 log.Fields{"device-id": oo.deviceID})
1183 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
1184 return fmt.Errorf(
1185 "mibSync FSM - mandatory attribute Version not present in OnuG instance - handling of MibSyncChan stopped: %s",
1186 oo.deviceID)
1187 }
1188 oo.MutexPersOnuConfig.Lock()
1189 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for Onu-G - Version", log.Fields{"device-id": oo.deviceID,
1190 "onuDeviceEntry.version": oo.SOnuPersistentData.PersVersion})
1191 oo.MutexPersOnuConfig.Unlock()
1192 // trigger retrieval of EquipmentId and OMCC version
1193 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetEquipIDAndOmcc)
1194 return nil
1195 } else {
1196 logger.Errorw(ctx, "MibSync FSM - wrong state OnuG response processing - handling of MibSyncChan stopped!",
1197 log.Fields{"currentState": currentState, "device-id": oo.deviceID})
1198 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
1199 return fmt.Errorf("mibSync FSM - wrong state OnuG response processing - handling of MibSyncChan stopped: %s",
1200 oo.deviceID)
1201 }
1202}
1203
dbainbri4d3a0dc2020-12-02 00:33:42 +00001204func (oo *OnuDeviceEntry) handleOmciGetResponseErrors(ctx context.Context, msgObj *omci.GetResponse) error {
Holger Hildebrandt80129db2020-11-23 10:49:32 +00001205 var err error = nil
dbainbri4d3a0dc2020-12-02 00:33:42 +00001206 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 +00001207 // Up to now the following erroneous results have been seen for different ONU-types to indicate an unsupported ME
1208 if msgObj.Result == me.UnknownInstance || msgObj.Result == me.UnknownEntity || msgObj.Result == me.ProcessingError || msgObj.Result == me.NotSupported {
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001209 oo.mutexLastTxParamStruct.RLock()
1210 if oo.lastTxParamStruct.pLastTxMeInstance != nil {
1211 entityID := oo.lastTxParamStruct.pLastTxMeInstance.GetEntityID()
1212 if msgObj.EntityClass == oo.lastTxParamStruct.pLastTxMeInstance.GetClassID() && msgObj.EntityInstance == entityID {
1213 meInstance := oo.lastTxParamStruct.pLastTxMeInstance.GetName()
1214 switch meInstance {
1215 case "IpHostConfigData":
1216 oo.mutexLastTxParamStruct.RUnlock()
1217 logger.Debugw(ctx, "MibSync FSM - erroneous result for IpHostConfigData received - ONU doesn't support ME - fill macAddress with zeros",
1218 log.Fields{"device-id": oo.deviceID, "data-fields": msgObj})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001219 oo.MutexPersOnuConfig.Lock()
1220 oo.SOnuPersistentData.PersMacAddress = cEmptyMacAddrString
1221 oo.MutexPersOnuConfig.Unlock()
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001222 // trigger retrieval of mib template
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001223 _ = oo.PMibUploadFsm.PFsm.Event(UlEvGetMibTemplate)
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001224 return nil
1225 default:
1226 oo.mutexLastTxParamStruct.RUnlock()
1227 logger.Warnf(ctx, "MibSync FSM - erroneous result for %s received - no exceptional treatment defined", log.Fields{"device-id": oo.deviceID, "data-fields": msgObj}, meInstance)
1228 err = fmt.Errorf("erroneous result for %s received - no exceptional treatment defined: %s", meInstance, oo.deviceID)
1229 }
1230 } else {
1231 oo.mutexLastTxParamStruct.RUnlock()
Holger Hildebrandt80129db2020-11-23 10:49:32 +00001232 }
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001233 } else {
1234 oo.mutexLastTxParamStruct.RUnlock()
1235 logger.Warnw(ctx, "Pointer to last Tx MeInstance is nil!", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt80129db2020-11-23 10:49:32 +00001236 }
1237 } else {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001238 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 +00001239 err = fmt.Errorf("erroneous result in GetResponse Data: %s - %s", msgObj.Result, oo.deviceID)
1240 }
1241 return err
1242}
1243
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001244// IsNewOnu - TODO: add comment
1245func (oo *OnuDeviceEntry) IsNewOnu() bool {
1246 oo.MutexPersOnuConfig.RLock()
1247 defer oo.MutexPersOnuConfig.RUnlock()
1248 return oo.SOnuPersistentData.PersMibLastDbSync == 0
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +00001249}
1250
Himani Chawla6d2ae152020-09-02 13:11:20 +05301251func isSupportedClassID(meClassID me.ClassID) bool {
Holger Hildebrandtccd390c2020-05-29 13:49:04 +00001252 for _, v := range supportedClassIds {
Himani Chawla4d908332020-08-31 12:30:20 +05301253 if v == meClassID {
Holger Hildebrandtccd390c2020-05-29 13:49:04 +00001254 return true
1255 }
1256 }
1257 return false
1258}
1259
dbainbri4d3a0dc2020-12-02 00:33:42 +00001260func (oo *OnuDeviceEntry) mibDbVolatileDict(ctx context.Context) error {
1261 logger.Debug(ctx, "MibVolatileDict- running from default Entry code")
Holger Hildebrandt0f9b88d2020-04-20 13:33:25 +00001262 return errors.New("not_implemented")
1263}
1264
Himani Chawla6d2ae152020-09-02 13:11:20 +05301265// 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 +05301266// 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 +00001267// 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 +00001268func (oo *OnuDeviceEntry) createAndPersistMibTemplate(ctx context.Context) error {
1269 logger.Debugw(ctx, "MibSync - MibTemplate - path name", log.Fields{"path": oo.mibTemplatePath,
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001270 "device-id": oo.deviceID})
divyadesaibbed37c2020-08-28 13:35:20 +05301271
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +05301272 //Fetch the MEs dependent on serial number and MAC address and add them to onuSpecific ME DB
1273 //Modify the serial number and MAC address with generic content in the common DB.
1274 knownAttributeMEDb := oo.pOnuDB.CommonMeDb.MeDb
1275 for firstLevelKey, firstLevelValue := range knownAttributeMEDb {
1276 classID := strconv.Itoa(int(firstLevelKey))
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001277
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +05301278 for secondLevelKey, secondLevelValue := range firstLevelValue {
1279 switch classID {
1280 case "6", "256":
1281 if _, exists := secondLevelValue["SerialNumber"]; exists {
1282 oo.pOnuDB.PutOnuSpeficMe(ctx, firstLevelKey, secondLevelKey, secondLevelValue)
1283 secondLevelValue["SerialNumber"] = "%SERIAL_NUMBER%"
1284 }
1285 case "134":
1286 if _, exists := secondLevelValue["MacAddress"]; exists {
1287 oo.pOnuDB.PutOnuSpeficMe(ctx, firstLevelKey, secondLevelKey, secondLevelValue)
1288 secondLevelValue["MacAddress"] = "%MAC_ADDRESS%"
1289 }
1290 }
1291 }
1292 }
1293
1294 //Create the MIB Template
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001295 currentTime := time.Now()
divyadesaibbed37c2020-08-28 13:35:20 +05301296 templateMap := make(map[string]interface{})
Holger Hildebrandt61b24d02020-11-16 13:36:40 +00001297 templateMap["TemplateName"] = oo.mibTemplatePath
divyadesaibbed37c2020-08-28 13:35:20 +05301298 templateMap["TemplateCreated"] = currentTime.Format("2006-01-02 15:04:05.000000")
1299
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +05301300 firstLevelMap := oo.pOnuDB.CommonMeDb.MeDb
divyadesaibbed37c2020-08-28 13:35:20 +05301301 for firstLevelKey, firstLevelValue := range firstLevelMap {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001302 logger.Debugw(ctx, "MibSync - MibTemplate - firstLevelKey", log.Fields{"firstLevelKey": firstLevelKey})
Himani Chawla26e555c2020-08-31 12:30:20 +05301303 classID := strconv.Itoa(int(firstLevelKey))
divyadesaibbed37c2020-08-28 13:35:20 +05301304
1305 secondLevelMap := make(map[string]interface{})
1306 for secondLevelKey, secondLevelValue := range firstLevelValue {
Holger Hildebrandt8998ed52022-03-23 09:52:37 +00001307 // ManagedEntityId is already key of secondLevelMap - remove this redundant attribute from secondLevelValue
1308 delete(secondLevelValue, cmn.CGenericManagedEntityIDName)
divyadesaibbed37c2020-08-28 13:35:20 +05301309 thirdLevelMap := make(map[string]interface{})
Himani Chawla26e555c2020-08-31 12:30:20 +05301310 entityID := strconv.Itoa(int(secondLevelKey))
divyadesaibbed37c2020-08-28 13:35:20 +05301311 thirdLevelMap["Attributes"] = secondLevelValue
Himani Chawla26e555c2020-08-31 12:30:20 +05301312 secondLevelMap[entityID] = thirdLevelMap
1313 if classID == "6" || classID == "256" {
divyadesaibbed37c2020-08-28 13:35:20 +05301314 forthLevelMap := map[string]interface{}(thirdLevelMap["Attributes"].(me.AttributeValueMap))
1315 delete(forthLevelMap, "SerialNumber")
1316 forthLevelMap["SerialNumber"] = "%SERIAL_NUMBER%"
1317
1318 }
Himani Chawla26e555c2020-08-31 12:30:20 +05301319 if classID == "134" {
divyadesaibbed37c2020-08-28 13:35:20 +05301320 forthLevelMap := map[string]interface{}(thirdLevelMap["Attributes"].(me.AttributeValueMap))
1321 delete(forthLevelMap, "MacAddress")
1322 forthLevelMap["MacAddress"] = "%MAC_ADDRESS%"
1323 }
1324 }
Himani Chawla26e555c2020-08-31 12:30:20 +05301325 templateMap[classID] = secondLevelMap
divyadesaibbed37c2020-08-28 13:35:20 +05301326 }
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +05301327 unknownMeAndAttribMap := oo.pOnuDB.CommonMeDb.UnknownMeAndAttribDb
Holger Hildebrandt39080022022-03-16 10:03:17 +00001328 for unknownMeAndAttribMapKey := range unknownMeAndAttribMap {
1329 templateMap[string(unknownMeAndAttribMapKey)] = unknownMeAndAttribMap[unknownMeAndAttribMapKey]
Holger Hildebrandtf3c7a182021-11-17 13:42:08 +00001330 }
divyadesaibbed37c2020-08-28 13:35:20 +05301331 mibTemplate, err := json.Marshal(&templateMap)
1332 if err != nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001333 logger.Errorw(ctx, "MibSync - MibTemplate - Failed to marshal mibTemplate", log.Fields{"error": err, "device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001334 oo.pOpenOnuAc.SetMibTemplatesGenerated(oo.mibTemplatePath, false)
divyadesaibbed37c2020-08-28 13:35:20 +05301335 return err
1336 }
dbainbri4d3a0dc2020-12-02 00:33:42 +00001337 err = oo.mibTemplateKVStore.Put(log.WithSpanFromContext(context.TODO(), ctx), oo.mibTemplatePath, string(mibTemplate))
divyadesaibbed37c2020-08-28 13:35:20 +05301338 if err != nil {
dbainbri4d3a0dc2020-12-02 00:33:42 +00001339 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 +00001340 oo.pOpenOnuAc.SetMibTemplatesGenerated(oo.mibTemplatePath, false)
divyadesaibbed37c2020-08-28 13:35:20 +05301341 return err
1342 }
dbainbri4d3a0dc2020-12-02 00:33:42 +00001343 logger.Debugw(ctx, "MibSync - MibTemplate - Stored the template to etcd", log.Fields{"device-id": oo.deviceID})
divyadesaibbed37c2020-08-28 13:35:20 +05301344 return nil
1345}
1346
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +00001347func (oo *OnuDeviceEntry) requestMdsValue(ctx context.Context) {
1348 logger.Debugw(ctx, "Request MDS value", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt3ac49bd2022-02-07 17:46:43 +00001349 requestedAttributes := me.AttributeValueMap{me.OnuData_MibDataSync: ""}
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001350 meInstance, err := oo.PDevOmciCC.SendGetMe(log.WithSpanFromContext(context.TODO(), ctx),
Holger Hildebrandtd930cb22022-06-17 09:24:50 +00001351 me.OnuDataClassID, cmn.OnuDataMeID, requestedAttributes, oo.baseDeviceHandler.GetOmciTimeout(), true,
1352 oo.PMibUploadFsm.CommChan, oo.GetPersIsExtOmciSupported())
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +00001353 //accept also nil as (error) return value for writing to LastTx
1354 // - this avoids misinterpretation of new received OMCI messages
ozgecanetsiab36ed572021-04-01 10:38:48 +03001355 if err != nil {
1356 logger.Errorw(ctx, "ONUData get failed, aborting MibSync FSM!", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001357 pMibUlFsm := oo.PMibUploadFsm
ozgecanetsiab36ed572021-04-01 10:38:48 +03001358 if pMibUlFsm != nil {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001359 go func(a_pAFsm *cmn.AdapterFsm) {
1360 _ = oo.PMibUploadFsm.PFsm.Event(UlEvStop)
ozgecanetsiab36ed572021-04-01 10:38:48 +03001361 }(pMibUlFsm)
1362 }
1363 return
1364 }
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001365 oo.mutexLastTxParamStruct.Lock()
mpagenko01499812021-03-25 10:37:12 +00001366 oo.lastTxParamStruct.lastTxMessageType = omci.GetRequestType
1367 oo.lastTxParamStruct.pLastTxMeInstance = meInstance
1368 oo.lastTxParamStruct.repeatCount = 0
Holger Hildebrandt0da7e6f2021-05-12 13:08:43 +00001369 oo.mutexLastTxParamStruct.Unlock()
Holger Hildebrandt0bd45f82021-01-11 13:29:37 +00001370}
1371
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001372func (oo *OnuDeviceEntry) checkMdsValue(ctx context.Context, mibDataSyncOnu uint8) {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001373 oo.MutexPersOnuConfig.RLock()
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001374 logger.Debugw(ctx, "MibSync FSM - GetResponse Data for Onu-Data - MibDataSync", log.Fields{"device-id": oo.deviceID,
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001375 "mibDataSyncOnu": mibDataSyncOnu, "PersMibDataSyncAdpt": oo.SOnuPersistentData.PersMibDataSyncAdpt})
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001376
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001377 mdsValuesAreEqual := oo.SOnuPersistentData.PersMibDataSyncAdpt == mibDataSyncOnu
1378 oo.MutexPersOnuConfig.RUnlock()
1379 if oo.PMibUploadFsm.PFsm.Is(UlStAuditing) {
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001380 if mdsValuesAreEqual {
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001381 logger.Debugw(ctx, "MibSync FSM - mib audit - MDS check ok", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001382 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001383 } else {
1384 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 +00001385 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001386 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001387 } else if oo.PMibUploadFsm.PFsm.Is(UlStReAuditing) {
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001388 if mdsValuesAreEqual {
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001389 logger.Debugw(ctx, "MibSync FSM - mib reaudit - MDS check ok", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001390 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001391 } else {
Holger Hildebrandt80f57762022-02-16 10:03:24 +00001392 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 +00001393 log.Fields{"device-id": oo.deviceID})
1394 oo.SendOnuDeviceEvent(ctx, cmn.OnuMibAuditFailureMds, cmn.OnuMibAuditFailureMdsDesc)
Holger Hildebrandt80f57762022-02-16 10:03:24 +00001395 // To reconcile ONU with active adapter later on, we have to retrieve TP instances from parent adapter.
1396 // In the present use case inconsistencies between TP pathes stored in kv store and TP instances retrieved
1397 // should not occur. Nevertheless, the respective code is inserted to catch the unlikely case.
1398 if !oo.getAllStoredTpInstFromParentAdapter(ctx) {
1399 logger.Debugw(ctx, "MibSync FSM - mib reaudit - inconsistencies between TP pathes stored in kv and parent adapter instances",
1400 log.Fields{"device-id": oo.deviceID})
1401 oo.baseDeviceHandler.SetReconcilingReasonUpdate(true)
1402 go func() {
1403 if err := oo.baseDeviceHandler.StorePersistentData(ctx); err != nil {
1404 logger.Warnw(ctx,
1405 "MibSync FSM - mib reaudit - store persistent data error - continue for now as there will be additional write attempts",
1406 log.Fields{"device-id": oo.deviceID, "err": err})
1407 }
1408 }()
1409 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001410 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001411 }
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001412 } else if oo.PMibUploadFsm.PFsm.Is(UlStExaminingMds) {
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001413 if mdsValuesAreEqual && mibDataSyncOnu != 0 {
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001414 logger.Debugw(ctx, "MibSync FSM - MDS examination ok", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001415 _ = oo.PMibUploadFsm.PFsm.Event(UlEvSuccess)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001416 } else {
1417 logger.Debugw(ctx, "MibSync FSM - MDS examination failed - new provisioning", log.Fields{"device-id": oo.deviceID})
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001418 _ = oo.PMibUploadFsm.PFsm.Event(UlEvMismatch)
Holger Hildebrandt10d98192021-01-27 15:29:31 +00001419 }
1420 } else {
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001421 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 +00001422 }
1423}
mpagenko15ff4a52021-03-02 10:09:20 +00001424
nikesh.krishnan1ffb8132023-05-23 03:44:13 +05301425// GetActiveImageMeID returns the Omci MeId of the active ONU image together with error code for validity
mpagenko15ff4a52021-03-02 10:09:20 +00001426func (oo *OnuDeviceEntry) GetActiveImageMeID(ctx context.Context) (uint16, error) {
Holger Hildebrandt05011352021-06-15 09:40:24 +00001427 oo.mutexOnuSwImageIndications.RLock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001428 if oo.onuSwImageIndications.ActiveEntityEntry.Valid {
1429 value := oo.onuSwImageIndications.ActiveEntityEntry.EntityID
Holger Hildebrandt05011352021-06-15 09:40:24 +00001430 oo.mutexOnuSwImageIndications.RUnlock()
1431 return value, nil
mpagenko15ff4a52021-03-02 10:09:20 +00001432 }
Holger Hildebrandt05011352021-06-15 09:40:24 +00001433 oo.mutexOnuSwImageIndications.RUnlock()
mpagenko15ff4a52021-03-02 10:09:20 +00001434 return 0xFFFF, fmt.Errorf("no valid active image found: %s", oo.deviceID)
1435}
1436
nikesh.krishnan1ffb8132023-05-23 03:44:13 +05301437// GetInactiveImageMeID returns the Omci MeId of the inactive ONU image together with error code for validity
mpagenko15ff4a52021-03-02 10:09:20 +00001438func (oo *OnuDeviceEntry) GetInactiveImageMeID(ctx context.Context) (uint16, error) {
Holger Hildebrandt05011352021-06-15 09:40:24 +00001439 oo.mutexOnuSwImageIndications.RLock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001440 if oo.onuSwImageIndications.InActiveEntityEntry.Valid {
1441 value := oo.onuSwImageIndications.InActiveEntityEntry.EntityID
Holger Hildebrandt05011352021-06-15 09:40:24 +00001442 oo.mutexOnuSwImageIndications.RUnlock()
1443 return value, nil
mpagenko15ff4a52021-03-02 10:09:20 +00001444 }
Holger Hildebrandt05011352021-06-15 09:40:24 +00001445 oo.mutexOnuSwImageIndications.RUnlock()
mpagenko15ff4a52021-03-02 10:09:20 +00001446 return 0xFFFF, fmt.Errorf("no valid inactive image found: %s", oo.deviceID)
1447}
1448
nikesh.krishnan1ffb8132023-05-23 03:44:13 +05301449// IsImageToBeCommitted returns true if the active image is still uncommitted
mpagenko15ff4a52021-03-02 10:09:20 +00001450func (oo *OnuDeviceEntry) IsImageToBeCommitted(ctx context.Context, aImageID uint16) bool {
Holger Hildebrandt05011352021-06-15 09:40:24 +00001451 oo.mutexOnuSwImageIndications.RLock()
Holger Hildebrandt4b5e73f2021-08-19 06:51:21 +00001452 if oo.onuSwImageIndications.ActiveEntityEntry.Valid {
1453 if oo.onuSwImageIndications.ActiveEntityEntry.EntityID == aImageID {
1454 if oo.onuSwImageIndications.ActiveEntityEntry.IsCommitted == cmn.SwIsUncommitted {
Holger Hildebrandt05011352021-06-15 09:40:24 +00001455 oo.mutexOnuSwImageIndications.RUnlock()
mpagenko15ff4a52021-03-02 10:09:20 +00001456 return true
1457 }
1458 }
1459 }
Holger Hildebrandt05011352021-06-15 09:40:24 +00001460 oo.mutexOnuSwImageIndications.RUnlock()
mpagenko15ff4a52021-03-02 10:09:20 +00001461 return false //all other case are treated as 'nothing to commit
1462}
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001463func (oo *OnuDeviceEntry) getMibFromTemplate(ctx context.Context) bool {
1464
1465 oo.mibTemplatePath = oo.buildMibTemplatePath()
Holger Hildebrandtbdc5f002021-04-19 14:46:21 +00001466 logger.Debugw(ctx, "MibSync FSM - get Mib from template", log.Fields{"path": fmt.Sprintf("%s/%s", cBasePathMibTemplateKvStore, oo.mibTemplatePath),
1467 "device-id": oo.deviceID})
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001468
1469 restoredFromMibTemplate := false
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +05301470 oo.pOpenOnuAc.LockMutexMibTemplateGenerated()
1471 defer oo.pOpenOnuAc.UnlockMutexMibTemplateGenerated()
1472 if meDbValue, ok := oo.pOpenOnuAc.FetchEntryFromMibDatabaseMap(ctx, oo.mibTemplatePath); ok {
1473 logger.Infow(ctx, "Found MIB common DB Instance , copy and use", log.Fields{"path": oo.mibTemplatePath, "device-id": oo.deviceID})
1474 oo.pOnuDB.CommonMeDb = meDbValue
1475 oo.updateOnuSpecificEntries(ctx)
1476 restoredFromMibTemplate = true
1477 } else {
1478 //Create a common ME MIB Instance as it doesn't prior exists.
1479 Value, err := oo.mibTemplateKVStore.Get(log.WithSpanFromContext(context.TODO(), ctx), oo.mibTemplatePath)
1480 //Unmarshal the MIB template and create the entry in the ONU Common Device DB
1481 if err == nil {
1482 if Value != nil {
1483 oo.processMibTemplate(ctx, Value)
1484 restoredFromMibTemplate = true
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001485 } else {
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +05301486 logger.Infow(ctx, "No MIB template found", log.Fields{"path": oo.mibTemplatePath, "device-id": oo.deviceID})
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001487 }
1488 } else {
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +05301489 logger.Errorw(ctx, "Get from kvstore operation failed for path",
1490 log.Fields{"path": oo.mibTemplatePath, "device-id": oo.deviceID})
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001491 }
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +05301492
Holger Hildebrandtbe523842021-03-10 10:47:18 +00001493 }
1494 return restoredFromMibTemplate
1495}
Holger Hildebrandtb4563ab2021-04-14 10:27:20 +00001496
Holger Hildebrandt80f57762022-02-16 10:03:24 +00001497func (oo *OnuDeviceEntry) getAllStoredTpInstFromParentAdapter(ctx context.Context) bool {
1498
1499 allTpInstPresent := true
1500 oo.MutexPersOnuConfig.Lock()
1501 oo.MutexReconciledTpInstances.Lock()
1502 for indexUni, uniData := range oo.SOnuPersistentData.PersUniConfig {
1503 uniID := uniData.PersUniID
1504 oo.ReconciledTpInstances[uniID] = make(map[uint8]inter_adapter.TechProfileDownloadMessage)
1505 for tpID, tpPath := range uniData.PersTpPathMap {
1506 if tpPath != "" {
1507 // Request the TP instance from the openolt adapter
1508 iaTechTpInst, err := oo.baseDeviceHandler.GetTechProfileInstanceFromParentAdapter(ctx, uniID, tpPath)
1509 if err == nil && iaTechTpInst != nil {
1510 logger.Debugw(ctx, "reconciling - store Tp instance", log.Fields{"uniID": uniID, "tpID": tpID,
1511 "*iaTechTpInst": iaTechTpInst, "device-id": oo.deviceID})
1512 oo.ReconciledTpInstances[uniID][tpID] = *iaTechTpInst
1513 } else {
1514 // During the absence of the ONU adapter there seem to have been TP specific configurations!
1515 // The no longer available TP and the associated flows must be deleted from the ONU KV store
1516 // and after a MIB reset a new reconciling attempt with OMCI configuration must be started.
1517 allTpInstPresent = false
1518 logger.Infow(ctx, "reconciling - can't get tp instance - delete tp and associated flows",
1519 log.Fields{"tp-id": tpID, "tpPath": tpPath, "uni-id": uniID, "device-id": oo.deviceID, "err": err})
1520 delete(oo.SOnuPersistentData.PersUniConfig[indexUni].PersTpPathMap, tpID)
1521 flowSlice := oo.SOnuPersistentData.PersUniConfig[indexUni].PersFlowParams
1522 for indexFlow, flowData := range flowSlice {
1523 if flowData.VlanRuleParams.TpID == tpID {
1524 if len(flowSlice) == 1 {
1525 flowSlice = []cmn.UniVlanFlowParams{}
1526 } else {
1527 flowSlice = append(flowSlice[:indexFlow], flowSlice[indexFlow+1:]...)
1528 }
1529 oo.SOnuPersistentData.PersUniConfig[indexUni].PersFlowParams = flowSlice
1530 }
1531 }
1532 }
1533 }
1534 }
1535 }
1536 oo.MutexReconciledTpInstances.Unlock()
1537 oo.MutexPersOnuConfig.Unlock()
1538 return allTpInstPresent
1539}
1540
nikesh.krishnan1ffb8132023-05-23 03:44:13 +05301541// CancelProcessing terminates potentially running reconciling processes and stops the FSM
Holger Hildebrandtb4563ab2021-04-14 10:27:20 +00001542func (oo *OnuDeviceEntry) CancelProcessing(ctx context.Context) {
Holger Hildebrandt12609a12022-03-25 13:23:25 +00001543 logger.Debugw(ctx, "CancelProcessing entered", log.Fields{"device-id": oo.deviceID})
mpagenko101ac942021-11-16 15:01:29 +00001544 if oo.isReconcilingFlows() {
Holger Hildebrandtf2fcdd42021-12-15 11:42:19 +00001545 oo.SendChReconcilingFlowsFinished(ctx, false)
Holger Hildebrandtb4563ab2021-04-14 10:27:20 +00001546 }
1547 //the MibSync FSM might be active all the ONU-active time,
1548 // hence it must be stopped unconditionally
Girish Gowdra37c9d912022-02-08 16:24:57 -08001549 oo.mutexMibSyncMsgProcessorRunning.RLock()
1550 defer oo.mutexMibSyncMsgProcessorRunning.RUnlock()
1551 if oo.mibSyncMsgProcessorRunning {
1552 pMibUlFsm := oo.PMibUploadFsm
1553 if pMibUlFsm != nil {
1554 // abort running message processing
1555 fsmAbortMsg := cmn.Message{
1556 Type: cmn.TestMsg,
1557 Data: cmn.TestMessage{
1558 TestMessageVal: cmn.AbortMessageProcessing,
1559 },
1560 }
1561 pMibUlFsm.CommChan <- fsmAbortMsg
1562 _ = pMibUlFsm.PFsm.Event(UlEvStop)
Holger Hildebrandte7cc6092022-02-01 11:37:03 +00001563 }
Holger Hildebrandtb4563ab2021-04-14 10:27:20 +00001564 }
1565}
Praneeth Kumar Nalmas8f8f0c02024-10-22 19:29:09 +05301566
1567// Updates Serial Number and MAC Address in the database
1568func (oo *OnuDeviceEntry) updateOnuSpecificEntries(ctx context.Context) {
1569 knownAttributeMEDb := oo.pOnuDB.CommonMeDb.MeDb
1570
1571 for firstLevelKey, firstLevelValue := range knownAttributeMEDb {
1572 classID := strconv.Itoa(int(firstLevelKey))
1573
1574 for secondLevelKey, secondLevelValue := range firstLevelValue {
1575 switch classID {
1576 case "6", "256":
1577 oo.updateAttribute(ctx, "SerialNumber", secondLevelValue, firstLevelKey, secondLevelKey, oo.SOnuPersistentData.PersSerialNumber)
1578 case "134":
1579 oo.updateAttribute(ctx, "MacAddress", secondLevelValue, firstLevelKey, secondLevelKey, oo.SOnuPersistentData.PersMacAddress)
1580 }
1581 }
1582 }
1583}
1584
1585// Updates a specific attribute in the MIB database
1586func (oo *OnuDeviceEntry) updateAttribute(ctx context.Context, attributeName string, attributesMap me.AttributeValueMap, classID me.ClassID, entityID uint16, newValue interface{}) {
1587 if _, exists := attributesMap[attributeName]; exists {
1588 logger.Infow(ctx, "Updating "+attributeName, log.Fields{"classID": strconv.Itoa(int(classID)), "oldValue": attributesMap[attributeName], "newValue": newValue})
1589 attributeCopy := make(me.AttributeValueMap)
1590 for k, v := range attributesMap {
1591 attributeCopy[k] = v
1592 }
1593 attributeCopy[attributeName] = newValue
1594 oo.pOnuDB.PutOnuSpeficMe(ctx, classID, entityID, attributeCopy)
1595 } else {
1596 logger.Warnw(ctx, attributeName+" key not found", log.Fields{"classID": strconv.Itoa(int(classID))})
1597 }
1598}
1599
1600// Processes the MIB template by replacing tokens and unmarshaling it
1601func (oo *OnuDeviceEntry) processMibTemplate(ctx context.Context, value *kvstore.KVPair) {
1602 mibTmpString, _ := kvstore.ToString(value.Value)
1603 mibTmpString2 := strings.ReplaceAll(mibTmpString, "\x00", "")
1604 mibTmpBytes := []byte(mibTmpString2)
1605
1606 logger.Debugf(ctx, "MibSync FSM - Mib template tokens swapped out: %s", mibTmpBytes)
1607
1608 var firstLevelMap map[string]interface{}
1609 if err := json.Unmarshal(mibTmpBytes, &firstLevelMap); err != nil {
1610 logger.Errorw(ctx, "MibSync FSM - Failed to unmarshal template", log.Fields{"error": err, "device-id": oo.deviceID})
1611 return
1612 }
1613
1614 cmnMEDbValue, _ := oo.pOpenOnuAc.CreateEntryAtMibDatabaseMap(ctx, oo.mibTemplatePath)
1615 oo.populateMibDatabase(ctx, cmnMEDbValue, firstLevelMap)
1616 cmnMEDbValue.MIBUploadStatus = devdb.Completed
1617 oo.pOnuDB.CommonMeDb = cmnMEDbValue
1618}
1619
1620// Populates the MIB database with parsed data
1621func (oo *OnuDeviceEntry) populateMibDatabase(ctx context.Context, cmnMEDbValue *devdb.OnuCmnMEDB, firstLevelMap map[string]interface{}) {
1622 cmnMEDbValue.MeDbLock.Lock()
1623 defer cmnMEDbValue.MeDbLock.Unlock()
1624
1625 logger.Infow(ctx, "Populating MIbDatabase with the template information ", log.Fields{"device-id": oo.deviceID})
1626 for firstLevelKey, firstLevelValue := range firstLevelMap {
1627 if uint16ValidNumber, err := strconv.ParseUint(firstLevelKey, 10, 16); err == nil {
1628 meClassID := me.ClassID(uint16ValidNumber)
1629 if isSupportedClassID(meClassID) {
1630 secondLevelMap := firstLevelValue.(map[string]interface{})
1631 for secondLevelKey, secondLevelValue := range secondLevelMap {
1632 if uint16ValidNumber, err := strconv.ParseUint(secondLevelKey, 10, 16); err == nil {
1633 meEntityID := uint16(uint16ValidNumber)
1634 thirdLevelMap := secondLevelValue.(map[string]interface{})
1635 if attributes, exists := thirdLevelMap["Attributes"].(map[string]interface{}); exists {
1636 if _, found := cmnMEDbValue.MeDb[meClassID]; !found {
1637 cmnMEDbValue.MeDb[meClassID] = make(map[uint16]me.AttributeValueMap)
1638 }
1639 if _, found := cmnMEDbValue.MeDb[meClassID][meEntityID]; !found {
1640 cmnMEDbValue.MeDb[meClassID][meEntityID] = make(me.AttributeValueMap)
1641 }
1642 for attrKey, attrValue := range attributes {
1643 cmnMEDbValue.MeDb[meClassID][meEntityID][attrKey] = attrValue
1644 }
1645 }
1646
1647 }
1648 }
1649 }
1650 }
1651 }
1652}