X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fcontrol.go;fp=pkg%2Fcontrol%2Fcontrol.go;h=c391d156835a7bb38a2b9ab945a766aa4544f274;hb=27433e7186d593276c5c3b9a4af08dc36947882f;hp=800145e87c2f672cce03875db6d45d6d92a65c53;hpb=0bb76b8349891790788a622c69591bac5f5930d1;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/control.go b/pkg/control/control.go index 800145e..c391d15 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") @@ -330,8 +330,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(cSubRespToXapp) + c.UpdateCounter(cRestSubRespToXapp) } } @@ -386,7 +387,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 +423,7 @@ func (c *Control) SubscriptionDeleteHandlerCB(restSubId string) error { c.registry.DeleteRESTSubscription(&restSubId) }() - c.UpdateCounter(cSubDelRespToXapp) + c.UpdateCounter(cRestSubDelRespToXapp) return nil }