X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Fxapp.go;h=12f1628db48373913f7fd27fdaf03bfa3208d7b4;hb=refs%2Fchanges%2F67%2F8567%2F1;hp=583d2889d6362b4260181e259d2a96ed6d03c4ee;hpb=82651fe96c123b61252dfef755ce7b9882e7db97;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/xapp.go b/pkg/xapp/xapp.go index 583d288..12f1628 100755 --- a/pkg/xapp/xapp.go +++ b/pkg/xapp/xapp.go @@ -66,6 +66,16 @@ var ( shutdownCnt int32 ) +var startTime time.Time + +func XappUpTime() time.Duration { + return time.Since(startTime) +} + +func init() { + startTime = time.Now() +} + func IsReady() bool { return Rmr != nil && Rmr.IsReady() && SdlStorage != nil && SdlStorage.IsReady() } @@ -156,6 +166,7 @@ func doRegister() error { xappversion := viper.GetString("version") pltNs := getPltNamespace("PLT_NAMESPACE", DEFAULT_PLT_NS) + //httpEp, rmrEp := getService(xappname, SERVICE_HTTP), getService(xappname, SERVICE_RMR) httpEp, rmrEp := getService(host, SERVICE_HTTP), getService(host, SERVICE_RMR) if httpEp == "" || rmrEp == "" { Logger.Warn("Couldn't resolve service endpoints: httpEp=%s rmrEp=%s", httpEp, rmrEp) @@ -273,34 +284,35 @@ func init() { InstallSignalHandler() } -func getIpAdress() string { - var ip net.IP - itf, err := net.InterfaceByName(os.Getenv("INTERFACE_NAME")) +func GetIpAddress() (string, error) { + ifname := os.Getenv("INTERFACE_NAME") + itf, err := net.InterfaceByName(ifname) if err != nil { - Logger.Info("Interface name is not able to resolve " + err.Error()) - return ip.String() + return "", fmt.Errorf("Interface (%s) %w", ifname, err) } item, err := itf.Addrs() if err != nil { - Logger.Info("IP address is not able to resolve " + err.Error()) - return ip.String() + return "", fmt.Errorf("Interface (%s) %w", ifname, err) } for _, addr := range item { switch v := addr.(type) { case *net.IPNet: if !v.IP.IsLinkLocalUnicast() { - ip = v.IP + return v.IP.String(), nil } } } - return ip.String() + return "", fmt.Errorf("Interface (%s) couldn't find ip", ifname) } func RunWithParams(c MessageConsumer, sdlcheck bool) { Rmr = NewRMRClient() Rmr.SetReadyCB(XappReadyCb, nil) - ipString := getIpAdress() + ipString, err := GetIpAddress() + if err != nil { + Logger.Info("IP address is not able to resolve " + err.Error()) + } var host string if ipString == "" { host = fmt.Sprintf(":%d", GetPortData("http").Port)