c.CntRecvMsg++
- c.UpdateCounter(cSubReqFromXapp)
+ c.UpdateCounter(cRestSubReqFromXapp)
if p.ClientEndpoint == nil {
xapp.Logger.Error("ClientEndpoint == nil")
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))
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)
}
}
func (c *Control) SubscriptionDeleteHandlerCB(restSubId string) error {
c.CntRecvMsg++
- c.UpdateCounter(cSubDelReqFromXapp)
+ c.UpdateCounter(cRestSubDelReqFromXapp)
xapp.Logger.Info("SubscriptionDeleteRequest from XAPP")
c.registry.DeleteRESTSubscription(&restSubId)
}()
- c.UpdateCounter(cSubDelRespToXapp)
+ c.UpdateCounter(cRestSubDelRespToXapp)
return nil
}
func (c *Control) handleE2TSubscriptionResponse(params *xapp.RMRParams) {
xapp.Logger.Info("MSG from E2T: %s", params.String())
c.UpdateCounter(cSubRespFromE2)
+
subRespMsg, err := c.e2ap.UnpackSubscriptionResponse(params.Payload)
if err != nil {
xapp.Logger.Error("MSG-SubResp %s", idstring(err, params))
return "NIL"
}
switch v.(type) {
- case *e2ap.E2APSubscriptionRequest:
- return "SubReq"
+ //case *e2ap.E2APSubscriptionRequest:
+ // return "SubReq"
case *e2ap.E2APSubscriptionResponse:
return "SubResp"
case *e2ap.E2APSubscriptionFailure:
return "SubFail"
- case *e2ap.E2APSubscriptionDeleteRequest:
- return "SubDelReq"
+ //case *e2ap.E2APSubscriptionDeleteRequest:
+ // return "SubDelReq"
case *e2ap.E2APSubscriptionDeleteResponse:
return "SubDelResp"
case *e2ap.E2APSubscriptionDeleteFailure: