[VOL-3144] verification of explicit device/port disable/enable config processing
Signed-off-by: mpagenko <michael.pagenkopf@adtran.com>
Change-Id: I34dc2bf54755a1dd948da7258bf269de0c76fb7b
diff --git a/VERSION b/VERSION
index 47b798c..c2c8de7 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-0.1.12-dev132
+0.1.12-dev133
diff --git a/internal/pkg/onuadaptercore/device_handler.go b/internal/pkg/onuadaptercore/device_handler.go
index f8bf361..f34395f 100644
--- a/internal/pkg/onuadaptercore/device_handler.go
+++ b/internal/pkg/onuadaptercore/device_handler.go
@@ -250,7 +250,8 @@
}
onuOperstate := onuIndication.GetOperState()
- logger.Debugw("inter-adapter-recv-onu-ind", log.Fields{"OnuId": onuIndication.GetOnuId(),
+ logger.Debugw("inter-adapter-recv-onu-ind", log.Fields{"device-id": dh.deviceID,
+ "OnuId": onuIndication.GetOnuId(),
"AdminState": onuIndication.GetAdminState(), "OperState": onuOperstate,
"SNR": onuIndication.GetSerialNumber()})
@@ -550,21 +551,31 @@
func (dh *deviceHandler) disableDevice(device *voltha.Device) {
logger.Debugw("disable-device", log.Fields{"device-id": device.Id, "SerialNumber": device.SerialNumber})
- //admin-lock reason can also be used uniquely for setting the DeviceState accordingly - inblock
- //state checking to prevent unneeded processing (eg. on ONU 'unreachable' and 'down')
+ //admin-lock reason can also be used uniquely for setting the DeviceState accordingly
+ // - inblock state checking to prevent possibly unneeded processing (on command repitition)
if dh.deviceReason != "omci-admin-lock" {
+ //running FSM's are stopped/reset here to avoid indirect stucking
+ // due to blocked OMCI transmission on disabled state
+ // but with possibly aborted FSM's there might be complications as the expected state
+ // after some re-enable would then be quite undefined
+ // maybe after re-enabling some additional checks would be required to possibly enforce new
+ // (reconcile-like) config (which would require some indication from 'aborted' FSM's first)
+ // for now let's assume no running FSM is active at this time point here ... -> TODO!!!
+ if err := dh.resetFsms(); err != nil {
+ logger.Errorw("error-disableDevice at FSM stop",
+ log.Fields{"device-id": dh.deviceID, "error": err})
+ // abort: system behavior is just unstable ...
+ return
+ }
+
// disable UNI ports/ONU
- // *** should generate UniAdminStateDone event - unrelated to DeviceProcStatusUpdate!!
- // here the result of the processing is not checked (trusted in background) *****
+ // *** should generate UniDisableStateDone event - used to disable the port(s) on success
if dh.pLockStateFsm == nil {
- dh.createUniLockFsm(true, UniAdminStateDone)
+ dh.createUniLockFsm(true, UniDisableStateDone)
} else { //LockStateFSM already init
- dh.pLockStateFsm.setSuccessEvent(UniAdminStateDone)
+ dh.pLockStateFsm.setSuccessEvent(UniDisableStateDone)
dh.runUniLockFsm(true)
}
- dh.disableUniPortStateUpdate()
- //VOL-3493/VOL-3495: postpone setting of deviceReason, conn- and operStatus until all omci-related communication regarding
- //device disabling has finished successfully
}
}
@@ -572,34 +583,14 @@
func (dh *deviceHandler) reEnableDevice(device *voltha.Device) {
logger.Debugw("reenable-device", log.Fields{"device-id": device.Id, "SerialNumber": device.SerialNumber})
- // TODO!!! ConnectStatus and OperStatus to be set here could be more accurate, for now just ...(like python code)
- logger.Debugw("call DeviceStateUpdate upon re-enable", log.Fields{"ConnectStatus": voltha.ConnectStatus_REACHABLE,
- "OperStatus": voltha.OperStatus_ACTIVE, "device-id": dh.deviceID})
- if err := dh.coreProxy.DeviceStateUpdate(context.TODO(), dh.deviceID, voltha.ConnectStatus_REACHABLE,
- voltha.OperStatus_ACTIVE); err != nil {
- //TODO with VOL-3045/VOL-3046: return the error and stop further processing
- logger.Errorw("error-updating-device-state", log.Fields{"device-id": dh.deviceID, "error": err})
- }
-
- // DeviceReason to update acc.to modified py code as per beginning of Sept 2020
- if err := dh.coreProxy.DeviceReasonUpdate(context.TODO(), dh.deviceID, "onu-reenabled"); err != nil {
- //TODO with VOL-3045/VOL-3046: return the error and stop further processing
- logger.Errorw("error-updating-reason-state", log.Fields{"device-id": dh.deviceID, "error": err})
- }
- dh.deviceReason = "onu-reenabled"
-
// enable ONU/UNI ports
- // *** should generate UniAdminStateDone event - unrelated to DeviceProcStatusUpdate!!
- // here the result of the processing is not checked (trusted in background) *****
+ // *** should generate UniEnableStateDone event - used to disable the port(s) on success
if dh.pUnlockStateFsm == nil {
- dh.createUniLockFsm(false, UniAdminStateDone)
+ dh.createUniLockFsm(false, UniEnableStateDone)
} else { //UnlockStateFSM already init
- dh.pUnlockStateFsm.setSuccessEvent(UniAdminStateDone)
+ dh.pUnlockStateFsm.setSuccessEvent(UniEnableStateDone)
dh.runUniLockFsm(false)
}
- //TODO this should be moved according to the discussion here
- // https://gerrit.opencord.org/c/voltha-openonu-adapter-go/+/21066
- dh.enableUniPortStateUpdate()
}
func (dh *deviceHandler) reconcileDeviceOnuInd() {
@@ -1109,7 +1100,7 @@
verifyExec := make(chan bool)
omciVerify := newOmciTestRequest(context.TODO(),
dh.device.Id, pDevEntry.PDevOmciCC,
- true, true) //eclusive and allowFailure (anyway not yet checked)
+ true, true) //exclusive and allowFailure (anyway not yet checked)
omciVerify.performOmciTest(context.TODO(), verifyExec)
/* give the handler some time here to wait for the OMCi verification result
@@ -1244,64 +1235,25 @@
//state checking to prevent unneeded processing (eg. on ONU 'unreachable' and 'down')
if dh.deviceReason != "stopping-openomci" {
logger.Debugw("updateInterface-started - stopping-device", log.Fields{"device-id": dh.deviceID})
- //stop all running SM processing - make use of the DH-state as mirrored in the deviceReason
+ //stop all running FSM processing - make use of the DH-state as mirrored in the deviceReason
+ //here no conflict with aborted FSM's should arise as a complete OMCI initialization is assumed on ONU-Up
+ //but that might change with some simple MDS check on ONU-Up treatment -> attention!!!
+ if err := dh.resetFsms(); err != nil {
+ logger.Errorw("error-updateInterface at FSM stop",
+ log.Fields{"device-id": dh.deviceID, "error": err})
+ // abort: system behavior is just unstable ...
+ return err
+ }
+
+ //deviceEntry stop without omciCC reset here, regarding the OMCI_CC still valid for this ONU
+ // - in contrary to disableDevice - compare with processUniDisableStateDoneEvent
+ //stop the device entry which resets the attached omciCC
pDevEntry := dh.getOnuDeviceEntry(false)
if pDevEntry == nil {
logger.Errorw("No valid OnuDevice -aborting", log.Fields{"device-id": dh.deviceID})
return fmt.Errorf("no valid OnuDevice: %s", dh.deviceID)
}
-
- switch dh.deviceReason {
- case "starting-openomci":
- { //MIBSync FSM may run
- pMibUlFsm := pDevEntry.pMibUploadFsm.pFsm
- if pMibUlFsm != nil {
- _ = pMibUlFsm.Event(ulEvStop) //TODO!! verify if MibSyncFsm stop-processing is sufficient (to allow it again afterwards)
- }
- }
- case "discovery-mibsync-complete":
- { //MibDownload may run
- pMibDlFsm := pDevEntry.pMibDownloadFsm.pFsm
- if pMibDlFsm != nil {
- _ = pMibDlFsm.Event(dlEvReset)
- }
- }
- default:
- {
- //port lock/unlock FSM's may be active
- if dh.pUnlockStateFsm != nil {
- _ = dh.pUnlockStateFsm.pAdaptFsm.pFsm.Event(uniEvReset)
- }
- if dh.pLockStateFsm != nil {
- _ = dh.pLockStateFsm.pAdaptFsm.pFsm.Event(uniEvReset)
- }
- //techProfile related PonAniConfigFsm FSM may be active
- // maybe encapsulated as OnuTP method - perhaps later in context of module splitting
- if dh.pOnuTP.pAniConfigFsm != nil {
- _ = dh.pOnuTP.pAniConfigFsm.pAdaptFsm.pFsm.Event(aniEvReset)
- }
- for _, uniPort := range dh.uniEntityMap {
- //reset the TechProfileConfig Done state for all (active) UNI's
- dh.pOnuTP.setConfigDone(uniPort.uniID, false)
- // reset the possibly existing VlanConfigFsm
- if pVlanFilterFsm, exist := dh.UniVlanConfigFsmMap[uniPort.uniID]; exist {
- //VlanFilterFsm exists and was already started
- pVlanFilterStatemachine := pVlanFilterFsm.pAdaptFsm.pFsm
- if pVlanFilterStatemachine != nil {
- _ = pVlanFilterStatemachine.Event(vlanEvReset)
- }
- }
- }
- }
- //TODO!!! care about PM/Alarm processing once started
- }
- //TODO: from here the deviceHandler FSM itself may be stuck in some of the initial states
- // (mainly the still separate 'Event states')
- // so it is questionable, how this is resolved after some possible re-enable
- // assumption there is obviously, that the system may continue with some 'after "mib-download-done" state'
-
- //stop/remove(?) the device entry
- _ = pDevEntry.stop(context.TODO()) //maybe some more sophisticated context treatment should be used here?
+ _ = pDevEntry.stop(context.TODO(), false)
//TODO!!! remove existing traffic profiles
/* from py code, if TP's exist, remove them - not yet implemented
@@ -1340,6 +1292,60 @@
return nil
}
+func (dh *deviceHandler) resetFsms() error {
+ //all possible FSM's are stopped or reset here to ensure their transition to 'disabled'
+ //it is not sufficient to stop/reset the latest running FSM as done in previous versions
+ // as after down/up procedures all FSM's might be active/ongoing (in theory)
+ // and using the stop/reset event should never harm
+
+ pDevEntry := dh.getOnuDeviceEntry(false)
+ if pDevEntry == nil {
+ logger.Errorw("No valid OnuDevice -aborting", log.Fields{"device-id": dh.deviceID})
+ return fmt.Errorf("no valid OnuDevice: %s", dh.deviceID)
+ }
+
+ //the MibSync FSM might be active all the ONU-active time,
+ // hence it must be stopped unconditionally
+ pMibUlFsm := pDevEntry.pMibUploadFsm.pFsm
+ if pMibUlFsm != nil {
+ _ = pMibUlFsm.Event(ulEvStop) //TODO!! verify if MibSyncFsm stop-processing is sufficient (to allow it again afterwards)
+ }
+ //MibDownload may run
+ pMibDlFsm := pDevEntry.pMibDownloadFsm.pFsm
+ if pMibDlFsm != nil {
+ _ = pMibDlFsm.Event(dlEvReset)
+ }
+ //port lock/unlock FSM's may be active
+ if dh.pUnlockStateFsm != nil {
+ _ = dh.pUnlockStateFsm.pAdaptFsm.pFsm.Event(uniEvReset)
+ }
+ if dh.pLockStateFsm != nil {
+ _ = dh.pLockStateFsm.pAdaptFsm.pFsm.Event(uniEvReset)
+ }
+ //techProfile related PonAniConfigFsm FSM may be active
+ if dh.pOnuTP != nil {
+ // should always be the case here
+ // FSM stop maybe encapsulated as OnuTP method - perhaps later in context of module splitting
+ if dh.pOnuTP.pAniConfigFsm != nil {
+ _ = dh.pOnuTP.pAniConfigFsm.pAdaptFsm.pFsm.Event(aniEvReset)
+ }
+ for _, uniPort := range dh.uniEntityMap {
+ //reset the TechProfileConfig Done state for all (active) UNI's
+ dh.pOnuTP.setConfigDone(uniPort.uniID, false)
+ // reset the possibly existing VlanConfigFsm
+ if pVlanFilterFsm, exist := dh.UniVlanConfigFsmMap[uniPort.uniID]; exist {
+ //VlanFilterFsm exists and was already started
+ pVlanFilterStatemachine := pVlanFilterFsm.pAdaptFsm.pFsm
+ if pVlanFilterStatemachine != nil {
+ _ = pVlanFilterStatemachine.Event(vlanEvReset)
+ }
+ }
+ }
+ }
+ //TODO!!! care about PM/Alarm processing once started
+ return nil
+}
+
func (dh *deviceHandler) processMibDatabaseSyncEvent(devEvent OnuDeviceEvent) {
logger.Debugw("MibInSync event received", log.Fields{"device-id": dh.deviceID})
if !dh.reconciling {
@@ -1472,7 +1478,7 @@
}
func (dh *deviceHandler) processUniUnlockStateDoneEvent(devEvent OnuDeviceEvent) {
- go dh.enableUniPortStateUpdate() //cmp python yield self.enable_ports()
+ dh.enableUniPortStateUpdate() //cmp python yield self.enable_ports()
if !dh.reconciling {
logger.Infow("UniUnlockStateDone event: Sending OnuUp event", log.Fields{"device-id": dh.deviceID})
@@ -1486,6 +1492,59 @@
}
}
+func (dh *deviceHandler) processUniDisableStateDoneEvent(devEvent OnuDeviceEvent) {
+ logger.Debugw("DeviceStateUpdate upon disable", log.Fields{"ConnectStatus": voltha.ConnectStatus_REACHABLE,
+ "OperStatus": voltha.OperStatus_UNKNOWN, "device-id": dh.deviceID})
+ if err := dh.coreProxy.DeviceStateUpdate(context.TODO(),
+ dh.deviceID, voltha.ConnectStatus_REACHABLE, voltha.OperStatus_UNKNOWN); err != nil {
+ //TODO with VOL-3045/VOL-3046: return the error and stop further processing
+ logger.Errorw("error-updating-device-state", log.Fields{"device-id": dh.deviceID, "error": err})
+ }
+
+ logger.Debugw("DeviceReasonUpdate upon re-enable", log.Fields{
+ "reason": "omci-admin-lock", "device-id": dh.deviceID})
+ // DeviceReason to update acc.to modified py code as per beginning of Sept 2020
+ if err := dh.coreProxy.DeviceReasonUpdate(context.TODO(), dh.deviceID, "omci-admin-lock"); err != nil {
+ //TODO with VOL-3045/VOL-3046: return the error and stop further processing
+ logger.Errorw("error-updating-reason-state", log.Fields{"device-id": dh.deviceID, "error": err})
+ }
+ dh.deviceReason = "omci-admin-lock"
+
+ //transfer the modified logical uni port state
+ dh.disableUniPortStateUpdate()
+
+ //stop the device entry which resets the attached omciCC
+ pDevEntry := dh.getOnuDeviceEntry(false)
+ if pDevEntry == nil {
+ logger.Errorw("No valid OnuDevice -aborting", log.Fields{"device-id": dh.deviceID})
+ return
+ }
+ _ = pDevEntry.stop(context.TODO(), true) //stop deviceEntry with omciCC reset
+ //maybe some more sophisticated context treatment should be used here?
+}
+
+func (dh *deviceHandler) processUniEnableStateDoneEvent(devEvent OnuDeviceEvent) {
+ logger.Debugw("DeviceStateUpdate upon re-enable", log.Fields{"ConnectStatus": voltha.ConnectStatus_REACHABLE,
+ "OperStatus": voltha.OperStatus_ACTIVE, "device-id": dh.deviceID})
+ if err := dh.coreProxy.DeviceStateUpdate(context.TODO(), dh.deviceID, voltha.ConnectStatus_REACHABLE,
+ voltha.OperStatus_ACTIVE); err != nil {
+ //TODO with VOL-3045/VOL-3046: return the error and stop further processing
+ logger.Errorw("error-updating-device-state", log.Fields{"device-id": dh.deviceID, "error": err})
+ }
+
+ logger.Debugw("DeviceReasonUpdate upon re-enable", log.Fields{
+ "reason": "onu-reenabled", "device-id": dh.deviceID})
+ // DeviceReason to update acc.to modified py code as per beginning of Sept 2020
+ if err := dh.coreProxy.DeviceReasonUpdate(context.TODO(), dh.deviceID, "onu-reenabled"); err != nil {
+ //TODO with VOL-3045/VOL-3046: return the error and stop further processing
+ logger.Errorw("error-updating-reason-state", log.Fields{"device-id": dh.deviceID, "error": err})
+ }
+ dh.deviceReason = "onu-reenabled"
+
+ //transfer the modified logical uni port state
+ dh.enableUniPortStateUpdate()
+}
+
func (dh *deviceHandler) processOmciAniConfigDoneEvent(devEvent OnuDeviceEvent) {
logger.Debugw("OmciAniConfigDone event received", log.Fields{"device-id": dh.deviceID})
// attention: the device reason update is done based on ONU-UNI-Port related activity
@@ -1561,6 +1620,16 @@
dh.processUniUnlockStateDoneEvent(devEvent)
}
+ case UniEnableStateDone:
+ {
+ dh.processUniEnableStateDoneEvent(devEvent)
+
+ }
+ case UniDisableStateDone:
+ {
+ dh.processUniDisableStateDoneEvent(devEvent)
+
+ }
case OmciAniConfigDone:
{
dh.processOmciAniConfigDoneEvent(devEvent)
diff --git a/internal/pkg/onuadaptercore/omci_cc.go b/internal/pkg/onuadaptercore/omci_cc.go
index 8a02b44..ad09d16 100644
--- a/internal/pkg/onuadaptercore/omci_cc.go
+++ b/internal/pkg/onuadaptercore/omci_cc.go
@@ -140,6 +140,37 @@
return &omciCC
}
+//stop stops/resets the omciCC
+func (oo *omciCC) stop(ctx context.Context) error {
+ logger.Debugw("omciCC-stopping", log.Fields{"for device-id": oo.deviceID})
+ //reseting all internal data, which might also be helpful for discarding any lingering tx/rx requests
+ oo.mutexTxQueue.Lock()
+ oo.txQueue.Init() // clear the tx queue
+ oo.mutexTxQueue.Unlock()
+ oo.mutexRxSchedMap.Lock()
+ for k := range oo.rxSchedulerMap {
+ delete(oo.rxSchedulerMap, k) //clear the scheduler map
+ }
+ oo.mutexRxSchedMap.Unlock()
+ oo.mutexHpTid.Lock()
+ oo.hpTid = 0x8000 //reset the high prio transactionId
+ oo.mutexHpTid.Unlock()
+ oo.mutexTid.Lock()
+ oo.tid = 1 //reset the low prio transactionId
+ oo.mutexTid.Unlock()
+ //reset control values
+ oo.uploadSequNo = 0
+ oo.uploadNoOfCmds = 0
+ //reset the stats counter - which might be topic of discussion ...
+ oo.txFrames = 0
+ oo.txOnuFrames = 0
+ oo.rxFrames = 0
+ oo.rxOnuFrames = 0
+ oo.rxOnuDiscards = 0
+
+ return nil
+}
+
// Rx handler for omci messages
func (oo *omciCC) receiveOnuMessage(ctx context.Context, omciMsg *omci.OMCI) error {
logger.Debugw("rx-onu-autonomous-message", log.Fields{"omciMsgType": omciMsg.MessageType,
@@ -488,21 +519,21 @@
func (oo *omciCC) getNextTid(highPriority bool) uint16 {
var next uint16
if highPriority {
- oo.mutexTid.Lock()
+ oo.mutexHpTid.Lock()
next = oo.hpTid
oo.hpTid++
if oo.hpTid < 0x8000 {
oo.hpTid = 0x8000
}
- oo.mutexTid.Unlock()
+ oo.mutexHpTid.Unlock()
} else {
- oo.mutexHpTid.Lock()
+ oo.mutexTid.Lock()
next = oo.tid
oo.tid++
if oo.tid >= 0x8000 {
oo.tid = 1
}
- oo.mutexHpTid.Unlock()
+ oo.mutexTid.Unlock()
}
return next
}
diff --git a/internal/pkg/onuadaptercore/onu_device_entry.go b/internal/pkg/onuadaptercore/onu_device_entry.go
index aa2d5f0..0e8ad16 100644
--- a/internal/pkg/onuadaptercore/onu_device_entry.go
+++ b/internal/pkg/onuadaptercore/onu_device_entry.go
@@ -129,16 +129,18 @@
UniLockStateDone OnuDeviceEvent = 4
// UniUnlockStateDone - Uni ports admin set to unlock
UniUnlockStateDone OnuDeviceEvent = 5
- // UniAdminStateDone - Uni ports admin set done - general
- UniAdminStateDone OnuDeviceEvent = 6
+ // UniDisableStateDone - Uni ports admin set to lock based on device disable
+ UniDisableStateDone OnuDeviceEvent = 6
+ // UniEnableStateDone - Uni ports admin set to unlock based on device re-enable
+ UniEnableStateDone OnuDeviceEvent = 7
// PortLinkUp - Port link state change
- PortLinkUp OnuDeviceEvent = 7
+ PortLinkUp OnuDeviceEvent = 8
// PortLinkDw - Port link state change
- PortLinkDw OnuDeviceEvent = 8
+ PortLinkDw OnuDeviceEvent = 9
// OmciAniConfigDone - AniSide config according to TechProfile done
- OmciAniConfigDone OnuDeviceEvent = 9
+ OmciAniConfigDone OnuDeviceEvent = 10
// OmciVlanFilterDone - Omci Vlan config according to flowConfig done
- OmciVlanFilterDone OnuDeviceEvent = 10
+ OmciVlanFilterDone OnuDeviceEvent = 11
// Add other events here as needed (alarms separate???)
)
@@ -223,7 +225,6 @@
baseDeviceHandler *deviceHandler
coreProxy adapterif.CoreProxy
adapterProxy adapterif.AdapterProxy
- started bool
PDevOmciCC *omciCC
pOnuDB *onuDeviceDB
mibTemplateKVStore *db.Backend
@@ -263,7 +264,6 @@
supportedFsmsPtr *OmciDeviceFsms) *OnuDeviceEntry {
logger.Infow("init-onuDeviceEntry", log.Fields{"device-id": deviceID})
var onuDeviceEntry OnuDeviceEntry
- onuDeviceEntry.started = false
onuDeviceEntry.deviceID = deviceID
onuDeviceEntry.baseDeviceHandler = deviceHandler
onuDeviceEntry.coreProxy = coreProxy
@@ -433,37 +433,37 @@
//start starts (logs) the omci agent
func (oo *OnuDeviceEntry) start(ctx context.Context) error {
- logger.Info("starting-OnuDeviceEntry")
-
- oo.PDevOmciCC = newOmciCC(ctx, oo, oo.deviceID, oo.baseDeviceHandler,
- oo.coreProxy, oo.adapterProxy)
+ logger.Infow("OnuDeviceEntry-starting", log.Fields{"for device-id": oo.deviceID})
if oo.PDevOmciCC == nil {
- logger.Errorw("Could not create devOmciCc - abort", log.Fields{"for device-id": oo.deviceID})
- return fmt.Errorf("could not create devOmciCc %s", oo.deviceID)
+ oo.PDevOmciCC = newOmciCC(ctx, oo, oo.deviceID, oo.baseDeviceHandler,
+ oo.coreProxy, oo.adapterProxy)
+ if oo.PDevOmciCC == nil {
+ logger.Errorw("Could not create devOmciCc - abort", log.Fields{"for device-id": oo.deviceID})
+ return fmt.Errorf("could not create devOmciCc %s", oo.deviceID)
+ }
}
-
- oo.started = true
- logger.Infow("OnuDeviceEntry-started", log.Fields{"for device-id": oo.deviceID})
return nil
}
-//stop terminates the session
-func (oo *OnuDeviceEntry) stop(ctx context.Context) error {
- logger.Infow("stopping-OnuDeviceEntry", log.Fields{"for device-id": oo.deviceID})
- oo.started = false
- //oo.exitChannel <- 1
- // maybe also the omciCC should be stopped here - for now not as no real processing is expected here - maybe needs consolidation
- logger.Infow("OnuDeviceEntry-stopped", log.Fields{"for device-id": oo.deviceID})
+//stop stops/resets the omciCC
+func (oo *OnuDeviceEntry) stop(ctx context.Context, abResetOmciCC bool) error {
+ logger.Debugw("OnuDeviceEntry-stopping", log.Fields{"for device-id": oo.deviceID})
+ if abResetOmciCC && (oo.PDevOmciCC != nil) {
+ _ = oo.PDevOmciCC.stop(ctx)
+ }
+ //to allow for all event notifications again when re-using the device and omciCC
+ oo.devState = DeviceStatusInit
return nil
}
func (oo *OnuDeviceEntry) reboot(ctx context.Context) error {
- logger.Infow("reboot-OnuDeviceEntry", log.Fields{"for device-id": oo.deviceID})
- if err := oo.PDevOmciCC.sendReboot(context.TODO(), ConstDefaultOmciTimeout, true, oo.omciRebootMessageReceivedChannel); err != nil {
- logger.Errorw("onu didn't reboot", log.Fields{"for device-id": oo.deviceID})
- return err
+ logger.Debugw("OnuDeviceEntry-rebooting", log.Fields{"for device-id": oo.deviceID})
+ if oo.PDevOmciCC != nil {
+ if err := oo.PDevOmciCC.sendReboot(ctx, ConstDefaultOmciTimeout, true, oo.omciRebootMessageReceivedChannel); err != nil {
+ logger.Errorw("onu didn't reboot", log.Fields{"for device-id": oo.deviceID})
+ return err
+ }
}
- logger.Infow("OnuDeviceEntry-reboot", log.Fields{"for device-id": oo.deviceID})
return nil
}
diff --git a/internal/pkg/onuadaptercore/uniportadmin.go b/internal/pkg/onuadaptercore/uniportadmin.go
index ea2ed16..8a0428e 100644
--- a/internal/pkg/onuadaptercore/uniportadmin.go
+++ b/internal/pkg/onuadaptercore/uniportadmin.go
@@ -27,7 +27,6 @@
"github.com/opencord/omci-lib-go"
me "github.com/opencord/omci-lib-go/generated"
"github.com/opencord/voltha-lib-go/v3/pkg/log"
- "github.com/opencord/voltha-protos/v3/go/voltha"
//ic "github.com/opencord/voltha-protos/v3/go/inter_container"
//"github.com/opencord/voltha-protos/v3/go/openflow_13"
)
@@ -219,30 +218,6 @@
//use DeviceHandler event notification directly, no need/support to update DeviceEntryState for lock/unlock
oFsm.pOmciCC.pBaseDeviceHandler.deviceProcStatusUpdate(oFsm.requestEvent)
- //VOL-3493/VOL-3495: postpone setting of deviceReason, conn- and operStatus until all omci-related communication regarding
- //device disabling has finished successfully
- if oFsm.adminState {
- if err := oFsm.pDeviceHandler.coreProxy.DeviceReasonUpdate(context.TODO(),
- oFsm.pDeviceHandler.deviceID, "omci-admin-lock"); err != nil {
- //TODO with VOL-3045/VOL-3046: return the error and stop further processing
- logger.Errorw("error-updating-reason-state", log.Fields{"device-id": oFsm.pDeviceHandler.deviceID, "error": err})
- }
- oFsm.pDeviceHandler.deviceReason = "omci-admin-lock"
- //ConnState is reachable given the fact that no cable was pulled and it can be re-enabled through OMCI.
- logger.Debugw("call DeviceStateUpdate", log.Fields{"ConnectStatus": voltha.ConnectStatus_REACHABLE,
- "OperStatus": voltha.OperStatus_UNKNOWN, "device-id": oFsm.pDeviceHandler.deviceID, "reason": oFsm.pDeviceHandler.deviceReason})
- if err := oFsm.pDeviceHandler.coreProxy.DeviceReasonUpdate(context.TODO(), oFsm.pDeviceHandler.deviceID,
- oFsm.pDeviceHandler.deviceReason); err != nil {
- //TODO with VOL-3045/VOL-3046: return the error and stop further processing
- logger.Errorw("error-updating-device-reason", log.Fields{"device-id": oFsm.pDeviceHandler.deviceID, "error": err})
- }
- if err := oFsm.pDeviceHandler.coreProxy.DeviceStateUpdate(context.TODO(), oFsm.pDeviceHandler.deviceID,
- voltha.ConnectStatus_REACHABLE, voltha.OperStatus_UNKNOWN); err != nil {
- //TODO with VOL-3045/VOL-3046: return the error and stop further processing
- logger.Errorw("error-updating-device-state", log.Fields{"device-id": oFsm.pDeviceHandler.deviceID, "error": err})
- }
- }
-
//let's reset the state machine in order to release all resources now
pLockStateAFsm := oFsm.pAdaptFsm
if pLockStateAFsm != nil {