package control
import (
- "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
"strconv"
"sync"
)
tracker *Tracker // tracker instance
Subs *Subscription
RmrEndpoint RmrEndpoint
- Xid string // xapp xid in req
- OrigParams *xapp.RMRParams // request orginal params
+ Mtype int
+ Xid string // xapp xid in req
+ OrigParams *RMRParams // request orginal params
RespReceived bool
ForwardRespToXapp bool
}
return subId + "/" + t.RmrEndpoint.String() + "/" + t.Xid
}
+func (t *Transaction) GetXid() string {
+ t.mutex.Lock()
+ defer t.mutex.Unlock()
+ return t.Xid
+}
+
+func (t *Transaction) GetMtype() int {
+ t.mutex.Lock()
+ defer t.mutex.Unlock()
+ return t.Mtype
+}
+
+func (t *Transaction) GetSrc() string {
+ t.mutex.Lock()
+ defer t.mutex.Unlock()
+ return t.RmrEndpoint.String()
+}
+
func (t *Transaction) CheckResponseReceived() bool {
t.mutex.Lock()
defer t.mutex.Unlock()