VOL-4125: Respond with success/failure to flow insertion according the
operation result in adapter
VOL-4323: Support serialization of flow messages (execute a flow to
completion before picking up another flow)
Change-Id: I934fc68b103042971109923491a3f27aaf885328
diff --git a/internal/pkg/mib/mib_sync.go b/internal/pkg/mib/mib_sync.go
index 871b6de..a26422d 100755
--- a/internal/pkg/mib/mib_sync.go
+++ b/internal/pkg/mib/mib_sync.go
@@ -314,6 +314,16 @@
if !oo.baseDeviceHandler.GetAlarmManagerIsRunning(ctx) {
go oo.baseDeviceHandler.StartAlarmManager(ctx)
}
+
+ for _, uniPort := range *oo.baseDeviceHandler.GetUniEntityMap() {
+ // only if this port was enabled for use by the operator at startup
+ if (1<<uniPort.UniID)&oo.baseDeviceHandler.GetUniPortMask() == (1 << uniPort.UniID) {
+ if !oo.baseDeviceHandler.GetFlowMonitoringIsRunning(uniPort.UniID) {
+ go oo.baseDeviceHandler.PerOnuFlowHandlerRoutine(uniPort.UniID)
+ }
+ }
+ }
+
// no need to reconcile additional data for MibDownloadFsm, LockStateFsm, or UnlockStateFsm
oo.baseDeviceHandler.ReconcileDeviceTechProf(ctx)