VOL-4333: Fix mcast traffic does not flow after olt reboot
- The mcast handler routines has to be restarted once the OLT becomes
reachable again.
Change-Id: I0a39d9b51452c5c1be72568f913dfc541011c083
diff --git a/internal/pkg/core/device_handler.go b/internal/pkg/core/device_handler.go
index bc6ca7c..3dc62b4 100644
--- a/internal/pkg/core/device_handler.go
+++ b/internal/pkg/core/device_handler.go
@@ -643,6 +643,20 @@
//starting the stat collector
go startCollector(ctx, dh)
+ // instantiate the mcast handler routines.
+ for i := range dh.incomingMcastFlowOrGroup {
+ // We land inside the below "if" code path, after the OLT comes back from a reboot, otherwise the routines
+ // are already active when the DeviceHandler module is first instantiated (as part of Adopt_device RPC invocation).
+ if !dh.mcastHandlerRoutineActive[i] {
+ // Spin up a go routine to handling incoming mcast flow/group (add/modify/remove).
+ // There will be MaxNumOfGroupHandlerChannels number of mcastFlowOrGroupChannelHandlerRoutine go routines.
+ // These routines will be blocked on the dh.incomingMcastFlowOrGroup[mcast-group-id modulo MaxNumOfGroupHandlerChannels] channel
+ // for incoming mcast flow/group to be processed serially.
+ dh.mcastHandlerRoutineActive[i] = true
+ go dh.mcastFlowOrGroupChannelHandlerRoutine(i, dh.incomingMcastFlowOrGroup[i], dh.stopMcastHandlerRoutine[i])
+ }
+ }
+
// Synchronous call to update device state - this method is run in its own go routine
if err := dh.coreProxy.DeviceStateUpdate(ctx, dh.device.Id, voltha.ConnectStatus_REACHABLE,
voltha.OperStatus_ACTIVE); err != nil {