commit ab785f2ba8c2c63fbc51a09cfdd6ba22463dbd3c
author Sridhar Ravindra <sridhar.ravindra@radisys.com> Mon Jul 21 17:20:55 2025 +0530
committer Sridhar Ravindra <sridhar.ravindra@radisys.com> Mon Aug 04 16:31:03 2025 +0530
tree 7d59b6936f33a8cdbf6e519846c3d5ab2104c19f
parent 43b5a910a8a042c8ec094e91a55f04d03aa0308e

[VOL-5464] - Skip ONU device existence check on ONU discovery

Change-Id: I651ed51523c69257e46331c627257487324d9516
Signed-off-by: Sridhar Ravindra <sridhar.ravindra@radisys.com>

internal/pkg/config/config.go

diff --git a/internal/pkg/config/config.go b/internal/pkg/config/config.go
index 0bd4fde..a7dc890 100644
--- a/internal/pkg/config/config.go
+++ b/internal/pkg/config/config.go
@@ -61,6 +61,7 @@
 	defaultMaxBackoffRetryDelay               = 10 * time.Second
 	defaultAdapterEndpoint                    = "adapter-open-olt"
 	defaultCheckOnuDevExistenceAtOnuDiscovery = false
+	defaultForceOnuDiscIndProcessing          = false
 	defaultMaxRetries                         = 10
 )
 
@@ -101,6 +102,7 @@
 	EnableONUStats                     bool
 	EnableGEMStats                     bool
 	CheckOnuDevExistenceAtOnuDiscovery bool
+	ForceOnuDiscIndProcessing          bool
 }
 
 // NewAdapterFlags returns a new RWCore config
@@ -135,6 +137,7 @@
 		MinBackoffRetryDelay:               defaultMinBackoffRetryDelay,
 		MaxBackoffRetryDelay:               defaultMaxBackoffRetryDelay,
 		CheckOnuDevExistenceAtOnuDiscovery: defaultCheckOnuDevExistenceAtOnuDiscovery,
+		ForceOnuDiscIndProcessing:          defaultForceOnuDiscIndProcessing,
 		MaxRetries:                         defaultMaxRetries,
 	}
 	return &adapterFlags
@@ -301,6 +304,10 @@
 		"check_onu_exist_on_discovery",
 		defaultCheckOnuDevExistenceAtOnuDiscovery,
 		"Whether to check for flows only or child device before honoring discovery?")
+	flag.BoolVar(&(so.ForceOnuDiscIndProcessing),
+		"force_onu_disc_processing",
+		defaultForceOnuDiscIndProcessing,
+		"Skip the check for onu device existence on onu discovery")
 
 	flag.Parse()
 	containerName := getContainerInfo()