import (
"fmt"
+ "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/xapptweaks"
"gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
"sync"
)
func (t *Tracker) NewSubsTransaction(subs *Subscription) *TransactionSubs {
trans := &TransactionSubs{}
trans.Meid = subs.GetMeid()
- rid := subs.GetReqId()
- if rid != nil {
- trans.ReqId = *rid
- }
t.initTransaction(&trans.Transaction)
xapp.Logger.Debug("CREATE %s", trans.String())
return trans
}
func (t *Tracker) NewXappTransaction(
- endpoint *RmrEndpoint,
+ endpoint *xapptweaks.RmrEndpoint,
xid string,
- reqId *RequestId,
+ subid uint32,
meid *xapp.RMRMeid) *TransactionXapp {
trans := &TransactionXapp{}
trans.XappKey = &TransactionXappKey{*endpoint, xid}
trans.Meid = meid
- if reqId != nil {
- trans.ReqId = *reqId
- }
+ trans.SubId = subid
t.initTransaction(&trans.Transaction)
xapp.Logger.Debug("CREATE %s", trans.String())
return trans