-func (t *Tracker) complete_transaction(subID uint16, act Action) (*string, *uint16, error){
- key := Transaction_key{subID, act}
- if xact, ok := t.transaction_table[key]; ok {
- delete(t.transaction_table, key)
- return &(xact.Xapp_instance_address), &(xact.Xapp_port), nil
+func (t *Tracker) completeTransaction(subID uint16, act Action) (*Transaction, error) {
+ key := TransactionKey{subID, act}
+ t.mutex.Lock()
+ defer t.mutex.Unlock()
+ if trans, ok1 := t.transactionTable[key]; ok1 {
+ if _, ok2 := t.transactionXappTable[trans.Xappkey]; ok2 {
+ delete(t.transactionXappTable, trans.Xappkey)
+ }
+ delete(t.transactionTable, key)
+ return trans, nil
+ }
+ err := fmt.Errorf("transaction record for Subscription ID %d and action %s does not exist", subID, act)
+ return nil, err
+}
+
+/*
+Makes possible to to detect has response already received from BTS
+Returns error in case the transaction cannot be found.
+*/
+func (t *Tracker) CheckResponseReceived(subID uint16, act Action) (*Transaction, bool, error) {
+ key := TransactionKey{subID, act}
+ t.mutex.Lock()
+ defer t.mutex.Unlock()
+ if trans, ok := t.transactionTable[key]; ok {
+ if trans.RespReceived == false {
+ trans.RespReceived = true
+ // This is used to control that only one response action (success response, failure or timer) is excecuted for the transaction
+ return trans, false, nil
+ }
+ return trans, true, nil
+ }
+ err := fmt.Errorf("transaction record for Subscription ID %d and action %s does not exist", subID, act)
+ return nil, false, err
+}
+
+/*
+Makes possible to receive response to retransmitted request to BTS
+Returns error in case the transaction cannot be found.
+*/
+func (t *Tracker) RetryTransaction(subID uint16, act Action) error {
+ key := TransactionKey{subID, act}
+ t.mutex.Lock()
+ defer t.mutex.Unlock()
+ if trans, ok := t.transactionTable[key]; ok {
+ trans.RespReceived = false
+ return nil