X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Fxapp.go;fp=pkg%2Fxapp%2Fxapp.go;h=439c1778ab0834bf89037441ce75be2fa4266369;hb=432205b7cef58be0d23d3ead15b4e131a3a91893;hp=d08e1cffc55b8ae40dedf0f7fef11199d9dce289;hpb=d598befb5dc17414206c06a0c263d7922571ed95;p=ric-plt%2Fxapp-frame.git

diff --git a/pkg/xapp/xapp.go b/pkg/xapp/xapp.go
index d08e1cf..439c177 100755
--- a/pkg/xapp/xapp.go
+++ b/pkg/xapp/xapp.go
@@ -48,22 +48,23 @@ type ShutdownCB func()
 
 var (
 	// XApp is an application instance
-	Rmr           *RMRClient
-	Sdl           *SDLClient
-	SdlStorage    *SDLStorage
-	Rnib          *RNIBClient
-	Resource      *Router
-	Metric        *Metrics
-	Logger        *Log
-	Config        Configurator
-	Subscription  *Subscriber
-	Alarm         *AlarmClient
-	Util          *Utils
-	readyCb       ReadyCB
-	readyCbParams interface{}
-	shutdownCb    ShutdownCB
-	shutdownFlag  int32
-	shutdownCnt   int32
+	Rmr                *RMRClient
+	Sdl                *SDLClient
+	SdlStorage         *SDLStorage
+	Rnib               *RNIBClient
+	Resource           *Router
+	Metric             *Metrics
+	Logger             *Log
+	Config             Configurator
+	Subscription       *Subscriber
+	Alarm              *AlarmClient
+	Util               *Utils
+	readyCb            ReadyCB
+	readyCbParams      interface{}
+	shutdownCb         ShutdownCB
+	shutdownFlag       int32
+	shutdownCnt        int32
+	disableAlarmClient bool
 )
 
 var startTime time.Time
@@ -86,7 +87,9 @@ func SetReadyCB(cb ReadyCB, params interface{}) {
 }
 
 func XappReadyCb(params interface{}) {
-	Alarm = NewAlarmClient(viper.GetString("moId"), viper.GetString("name"))
+	if disableAlarmClient == false {
+		Alarm = NewAlarmClient(viper.GetString("moId"), viper.GetString("name"))
+	}
 	if readyCb != nil {
 		readyCb(readyCbParams)
 	}
@@ -317,7 +320,19 @@ func GetIpAddress() (string, error) {
 	return "<nil>", fmt.Errorf("Interface (%s) couldn't find ip", ifname)
 }
 
-func RunWithParams(c MessageConsumer, sdlcheck bool) {
+type RunParams struct {
+	SdlCheck           bool
+	DisableAlarmClient bool
+}
+
+func RunWithRunParams(c MessageConsumer, params RunParams) {
+
+	if params.DisableAlarmClient {
+		disableAlarmClient = true
+	} else {
+		disableAlarmClient = false
+	}
+
 	Rmr = NewRMRClient()
 
 	Rmr.SetReadyCB(XappReadyCb, nil)
@@ -334,7 +349,7 @@ func RunWithParams(c MessageConsumer, sdlcheck bool) {
 	go http.ListenAndServe(host, Resource.router)
 	Logger.Info(fmt.Sprintf("Xapp started, listening on: %s", host))
 
-	if sdlcheck {
+	if params.SdlCheck {
 		SdlStorage.TestConnection(viper.GetString("controls.db.namespace"))
 	}
 	go registerXapp()
@@ -342,6 +357,10 @@ func RunWithParams(c MessageConsumer, sdlcheck bool) {
 	Rmr.Start(c)
 }
 
+func RunWithParams(c MessageConsumer, sdlcheck bool) {
+	RunWithRunParams(c, RunParams{SdlCheck: sdlcheck, DisableAlarmClient: false})
+}
+
 func Run(c MessageConsumer) {
 	RunWithParams(c, true)
 }