X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pkg%2Fcontrol%2Fsdl.go;h=0d7f845d000f711094ddc0fd6f5939e364f1b326;hb=refs%2Fchanges%2F40%2F5640%2F1;hp=ecf6a8554aebf5ba76f11ca7f170f0f0fba083d2;hpb=6d629ad71687993ee08b6193e957439f5c87aa22;p=ric-plt%2Fsubmgr.git

diff --git a/pkg/control/sdl.go b/pkg/control/sdl.go
index ecf6a85..0d7f845 100644
--- a/pkg/control/sdl.go
+++ b/pkg/control/sdl.go
@@ -68,6 +68,7 @@ func (c *Control) WriteSubscriptionToSdl(subId uint32, subs *Subscription) error
 	}
 
 	if err = c.db.Set(strconv.FormatUint(uint64(subId), 10), jsonData); err != nil {
+		c.UpdateCounter(cSDLWriteFailure)
 		return fmt.Errorf("SDL: WriteSubscriptionToSdl(): %s", err.Error())
 	} else {
 		xapp.Logger.Debug("SDL: Subscription written in db. subId = %v", subId)
@@ -81,6 +82,7 @@ func (c *Control) ReadSubscriptionFromSdl(subId uint32) (*Subscription, error) {
 	key := strconv.FormatUint(uint64(subId), 10)
 	retMap, err := c.db.Get([]string{key})
 	if err != nil {
+		c.UpdateCounter(cSDLReadFailure)
 		return nil, fmt.Errorf("SDL: ReadSubscriptionFromSdl(): %s", err.Error())
 	} else {
 		xapp.Logger.Debug("SDL: Subscription read from db.  subId = %v", subId)
@@ -162,6 +164,7 @@ func (c *Control) ReadAllSubscriptionsFromSdl() ([]uint32, map[uint32]*Subscript
 	// Get all keys
 	keys, err := c.db.GetAll()
 	if err != nil {
+		c.UpdateCounter(cSDLReadFailure)
 		return nil, nil, fmt.Errorf("SDL: ReadAllSubscriptionsFromSdl(), GetAll(). Error while reading keys from DBAAS %s\n", err.Error())
 	}
 
@@ -172,6 +175,7 @@ func (c *Control) ReadAllSubscriptionsFromSdl() ([]uint32, map[uint32]*Subscript
 	// Get all subscriptionInfos
 	iSubscriptionMap, err := c.db.Get(keys)
 	if err != nil {
+		c.UpdateCounter(cSDLReadFailure)
 		return nil, nil, fmt.Errorf("SDL: ReadAllSubscriptionsFromSdl(), Get():  Error while reading subscriptions from DBAAS %s\n", err.Error())
 	}
 
@@ -196,8 +200,7 @@ func (c *Control) ReadAllSubscriptionsFromSdl() ([]uint32, map[uint32]*Subscript
 		retMap[subscriptionInfo.ReqId.InstanceId] = subs
 
 		// Remove subId from free subIds. Original slice is modified here!
-		subIds, err = removeNumber(subIds, subscriptionInfo.ReqId.InstanceId)
-		if err != nil {
+		if subIds, err = removeNumber(subIds, subscriptionInfo.ReqId.InstanceId); err != nil {
 			return nil, nil, fmt.Errorf("SDL: ReadAllSubscriptionsFromSdl() error: %s\n", err.Error())
 		}
 	}
@@ -216,6 +219,7 @@ func removeNumber(s []uint32, removedNum uint32) ([]uint32, error) {
 func (c *Control) RemoveAllSubscriptionsFromSdl() error {
 
 	if err := c.db.RemoveAll(); err != nil {
+		c.UpdateCounter(cSDLRemoveFailure)
 		return fmt.Errorf("SDL: RemoveAllSubscriptionsFromSdl(): %s\n", err.Error())
 	} else {
 		xapp.Logger.Debug("SDL: All subscriptions removed from db")