X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fteststub%2FcontrolRmr.go;h=18b821e5bb947eb0457a9650329ddeb4625b8341;hb=cc7d9e0cf982acb7448e23e8c8d16b9aaaf133fb;hp=f47bafa670d692036421ec921a84e5c3e5a379ff;hpb=c2a6b3a80ba41f292e0fa31334e53ab278d103fe;p=ric-plt%2Fsubmgr.git diff --git a/pkg/teststub/controlRmr.go b/pkg/teststub/controlRmr.go index f47bafa..18b821e 100644 --- a/pkg/teststub/controlRmr.go +++ b/pkg/teststub/controlRmr.go @@ -20,8 +20,6 @@ package teststub import ( "fmt" - "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" - "os" "testing" ) @@ -30,6 +28,8 @@ import ( //----------------------------------------------------------------------------- type RmrControl struct { TestWrapper + RmrSrcId + RmrRtgSvc syncChan chan struct{} } @@ -42,14 +42,15 @@ func (tc *RmrControl) WaitCB() { <-tc.syncChan } -func (tc *RmrControl) Init(desc string, rtfile string, port string) { +func (tc *RmrControl) Init(desc string, srcId RmrSrcId, rtgSvc RmrRtgSvc) { tc.TestWrapper.Init(desc) - os.Setenv("RMR_SEED_RT", rtfile) - os.Setenv("RMR_SRC_ID", "localhost:"+port) - //os.Setenv("RMR_RTG_SVC", "localhost:"+port) - xapp.Logger.Info("Using rt file %s", os.Getenv("RMR_SEED_RT")) - xapp.Logger.Info("Using src id %s", os.Getenv("RMR_SRC_ID")) - //xapp.Logger.Info("Using rtg svc %s", os.Getenv("RMR_RTG_SVC")) + + tc.RmrSrcId = srcId + tc.RmrSrcId.Enable() + + tc.RmrRtgSvc = rtgSvc + tc.RmrRtgSvc.Enable() + tc.syncChan = make(chan struct{}) }