+
+ //
+ // WIP RICPLT-2979
+ //
+ /*
+ e2SubReq := packerif.NewPackerSubscriptionRequest()
+ packedData := &packer.PackedData{}
+ packedData.Buf = params.Payload
+ err = e2SubReq.UnPack(packedData)
+ if err != nil {
+ xapp.Logger.Error("SubReq: UnPack() failed: %s", err.Error())
+ }
+ getErr, subReq := e2SubReq.Get()
+ if getErr != nil {
+ xapp.Logger.Error("SubReq: Get() failed: %s", err.Error())
+ }
+
+
+ subReq.RequestId.Seq = uint32(subs.GetSubId())
+
+ err = e2SubReq.Set(subReq)
+ if err != nil {
+ xapp.Logger.Error("SubReq: Set() failed: %s", err.Error())
+ return
+ }
+ err, packedData = e2SubReq.Pack(nil)
+ if err != nil {
+ xapp.Logger.Error("SubReq: Pack() failed: %s", err.Error())
+ return
+ }
+
+ params.PayloadLen = len(packedData.Buf)
+ params.Payload = packedData.Buf
+ */
+ //
+ //
+ //
+
+ params.SubId = int(subs.GetSubId())
+ err = c.e2ap.SetSubscriptionRequestSequenceNumber(params.Payload, subs.GetSubId())
+ if err != nil {
+ xapp.Logger.Error("SubReq: Unable to get Sequence Number from Payload. Dropping this msg. Err: %v, %s", err, params.String())
+ c.registry.DelSubscription(subs.Seq)
+ return
+ }
+
+ // Create transatcion record for every subscription request
+ var forwardRespToXapp bool = true
+ var responseReceived bool = false
+ trans, err := c.tracker.TrackTransaction(RmrEndpoint{*srcAddr, *srcPort}, params, responseReceived, forwardRespToXapp)
+ if err != nil {
+ xapp.Logger.Error("SubReq: %s, Dropping this msg.", err.Error())
+ c.registry.DelSubscription(subs.Seq)
+ return
+ }
+
+ err = subs.SetTransaction(trans)
+ if err != nil {
+ xapp.Logger.Error("SubReq: %s, Dropping this msg.", err.Error())
+ c.registry.DelSubscription(subs.Seq)
+ trans.Release()
+ return
+ }
+
+ c.rmrSend("SubReq to E2T", subs, trans, params.Payload, params.PayloadLen)
+
+ c.timerMap.StartTimer("RIC_SUB_REQ", int(subs.Seq), subReqTime, FirstTry, c.handleSubscriptionRequestTimer)
+ xapp.Logger.Debug("SubReq: Debugging trans table = %v", c.tracker.transactionXappTable)