X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fcontrol.go;h=ccb4b3d083648ee7f4158ebd9d8534862a68c37b;hb=refs%2Fchanges%2F68%2F6168%2F1;hp=800145e87c2f672cce03875db6d45d6d92a65c53;hpb=5112239fe7bf1a53f43d8898d2862921594b1f80;p=ric-plt%2Fsubmgr.git

diff --git a/pkg/control/control.go b/pkg/control/control.go
index 800145e..ccb4b3d 100755
--- a/pkg/control/control.go
+++ b/pkg/control/control.go
@@ -233,7 +233,7 @@ func (c *Control) SubscriptionHandler(params interface{}) (*models.SubscriptionR
 
 	c.CntRecvMsg++
 
-	c.UpdateCounter(cSubReqFromXapp)
+	c.UpdateCounter(cRestSubReqFromXapp)
 
 	if p.ClientEndpoint == nil {
 		xapp.Logger.Error("ClientEndpoint == nil")
@@ -311,6 +311,7 @@ func (c *Control) processSubscriptionRequests(restSubscription *RESTSubscription
 			restSubscription.SetProcessed()
 			xapp.Logger.Info("Sending unsuccessful REST notification to endpoint=%v:%v, InstanceId=%v, %s", clientEndpoint.Host, clientEndpoint.HTTPPort, instanceId, idstring(nil, trans))
 			xapp.Subscription.Notify(resp, *clientEndpoint)
+			c.UpdateCounter(cRestSubFailToXapp)
 		} else {
 			xapp.Logger.Info("SubscriptionRequest index=%v processed successfully. endpoint=%v, InstanceId=%v, %s", index, *clientEndpoint, instanceId, idstring(nil, trans))
 
@@ -330,8 +331,9 @@ func (c *Control) processSubscriptionRequests(restSubscription *RESTSubscription
 			restSubscription.SetProcessed()
 			xapp.Logger.Info("Sending successful REST notification to endpoint=%v, InstanceId=%v, %s", *clientEndpoint, instanceId, idstring(nil, trans))
 			xapp.Subscription.Notify(resp, *clientEndpoint)
+			c.UpdateCounter(cRestSubRespToXapp)
+
 		}
-		c.UpdateCounter(cSubRespToXapp)
 	}
 }
 
@@ -386,7 +388,7 @@ func (c *Control) handleSubscriptionRequest(trans *TransactionXapp, subReqMsg *e
 func (c *Control) SubscriptionDeleteHandlerCB(restSubId string) error {
 
 	c.CntRecvMsg++
-	c.UpdateCounter(cSubDelReqFromXapp)
+	c.UpdateCounter(cRestSubDelReqFromXapp)
 
 	xapp.Logger.Info("SubscriptionDeleteRequest from XAPP")
 
@@ -422,7 +424,7 @@ func (c *Control) SubscriptionDeleteHandlerCB(restSubId string) error {
 		c.registry.DeleteRESTSubscription(&restSubId)
 	}()
 
-	c.UpdateCounter(cSubDelRespToXapp)
+	c.UpdateCounter(cRestSubDelRespToXapp)
 
 	return nil
 }