X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fcontrol.go;h=ccb4b3d083648ee7f4158ebd9d8534862a68c37b;hb=5d4f68f1b4cf03646bafeb98cea13a4c57e56a65;hp=c391d156835a7bb38a2b9ab945a766aa4544f274;hpb=27433e7186d593276c5c3b9a4af08dc36947882f;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/control.go b/pkg/control/control.go index c391d15..ccb4b3d 100755 --- a/pkg/control/control.go +++ b/pkg/control/control.go @@ -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,9 +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(cRestSubRespToXapp) } }