commit f1f39a7d27579ab620e14aee193ef5d84946ea89
author Matteo Scandolo <matteo.scandolo@gmail.com> Tue Nov 24 12:08:11 2020 -0800
committer Matteo Scandolo <teo@opennetworking.org> Wed Nov 25 22:14:18 2020 +0000
tree b4e0f705210ade87fa18d16cdbd59ebc346a1ff8
parent 6c1fb0a2b34e0748fd7ac4007af9b1da6585ffce

[VOL-3631] Parametrizing KV_STORE path for TechProfiles and Onu data

Change-Id: I9598f3aa42d848786eaad89e260a71f9563bfa0c

internal/pkg/onuadaptercore/openonu.go

diff --git a/internal/pkg/onuadaptercore/openonu.go b/internal/pkg/onuadaptercore/openonu.go
index f189d51..16ef7d7 100644
--- a/internal/pkg/onuadaptercore/openonu.go
+++ b/internal/pkg/onuadaptercore/openonu.go
@@ -21,6 +21,7 @@
 	"context"
 	"errors"
 	"fmt"
+	conf "github.com/opencord/voltha-lib-go/v3/pkg/config"
 	"sync"
 	"time"
 
@@ -47,6 +48,7 @@
 	eventProxy                  adapterif.EventProxy
 	kafkaICProxy                kafka.InterContainerProxy
 	kvClient                    kvstore.Client
+	cm                          *conf.ConfigManager
 	config                      *config.AdapterFlags
 	numOnus                     int
 	KVStoreHost                 string
@@ -67,7 +69,7 @@
 //NewOpenONUAC returns a new instance of OpenONU_AC
 func NewOpenONUAC(ctx context.Context, kafkaICProxy kafka.InterContainerProxy,
 	coreProxy adapterif.CoreProxy, adapterProxy adapterif.AdapterProxy,
-	eventProxy adapterif.EventProxy, kvClient kvstore.Client, cfg *config.AdapterFlags) *OpenONUAC {
+	eventProxy adapterif.EventProxy, kvClient kvstore.Client, cfg *config.AdapterFlags, cm *conf.ConfigManager) *OpenONUAC {
 	var openOnuAc OpenONUAC
 	openOnuAc.exitChannel = make(chan int, 1)
 	openOnuAc.deviceHandlers = make(map[string]*deviceHandler)
@@ -75,6 +77,7 @@
 	openOnuAc.lockDeviceHandlersMap = sync.RWMutex{}
 	openOnuAc.kafkaICProxy = kafkaICProxy
 	openOnuAc.config = cfg
+	openOnuAc.cm = cm
 	openOnuAc.numOnus = cfg.OnuNumber
 	openOnuAc.coreProxy = coreProxy
 	openOnuAc.adapterProxy = adapterProxy