- err := fmt.Errorf("transaction record for Subscription ID %d and action %s does not exist", subID, act)
- return nil, err
-}
-
-/*
-Deletes the transaction table entry for the given request and returns the deleted xapp's address and port for reference.
-Returns error in case the transaction cannot be found.
-*/
-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
- }
- err := fmt.Errorf("transaction record for Subscription ID %d and action %s does not exist", subID, act)
- return err