Change MDS value on on successful response
Move to omci-lib-go version v0.15.4
Change-Id: I4184d26e3006c4b28dcab806e51bc1fc9f2b878e
diff --git a/internal/bbsim/devices/onu.go b/internal/bbsim/devices/onu.go
index 465f2cd..9bfe805 100644
--- a/internal/bbsim/devices/onu.go
+++ b/internal/bbsim/devices/onu.go
@@ -640,15 +640,17 @@
}).Trace("omci-message-decoded")
var responsePkt []byte
+ var errResp error
switch omciMsg.MessageType {
case omci.MibResetRequestType:
- o.MibDataSync = 0
onuLogger.WithFields(log.Fields{
"IntfId": o.PonPortID,
"OnuId": o.ID,
"SerialNumber": o.Sn(),
}).Debug("received-mib-reset-request-resetting-mds")
- responsePkt, _ = omcilib.CreateMibResetResponse(omciMsg.TransactionID)
+ if responsePkt, errResp = omcilib.CreateMibResetResponse(omciMsg.TransactionID); errResp == nil {
+ o.MibDataSync = 0
+ }
case omci.MibUploadRequestType:
responsePkt, _ = omcilib.CreateMibUploadResponse(omciMsg.TransactionID)
case omci.MibUploadNextRequestType:
@@ -656,8 +658,9 @@
case omci.GetRequestType:
responsePkt, _ = omcilib.CreateGetResponse(omciPkt, omciMsg, o.SerialNumber, o.MibDataSync)
case omci.SetRequestType:
- o.MibDataSync++
- responsePkt, _ = omcilib.CreateSetResponse(omciPkt, omciMsg)
+ if responsePkt, errResp = omcilib.CreateSetResponse(omciPkt, omciMsg); errResp == nil {
+ o.MibDataSync++
+ }
msgObj, _ := omcilib.ParseSetRequest(omciPkt)
switch msgObj.EntityClass {
@@ -684,11 +687,13 @@
}
}
case omci.CreateRequestType:
- o.MibDataSync++
- responsePkt, _ = omcilib.CreateCreateResponse(omciPkt, omciMsg)
+ if responsePkt, errResp = omcilib.CreateCreateResponse(omciPkt, omciMsg); errResp == nil {
+ o.MibDataSync++
+ }
case omci.DeleteRequestType:
- o.MibDataSync++
- responsePkt, _ = omcilib.CreateDeleteResponse(omciPkt, omciMsg)
+ if responsePkt, errResp = omcilib.CreateDeleteResponse(omciPkt, omciMsg); errResp == nil {
+ o.MibDataSync++
+ }
case omci.RebootRequestType:
responsePkt, _ = omcilib.CreateRebootResponse(omciPkt, omciMsg)