// status obtained or request failed . we return false
mdclog_write(MDCLOG_ERR, "Error :: %s, %d : Spurious time out caused by invalid state of request %d -- state = %d. Deleting request entry and failing .. \n", __FILE__, __LINE__, he.get_request_id(), status);
// if we are here, some spurious
// status obtained or request failed . we return false
mdclog_write(MDCLOG_ERR, "Error :: %s, %d : Spurious time out caused by invalid state of request %d -- state = %d. Deleting request entry and failing .. \n", __FILE__, __LINE__, he.get_request_id(), status);
- delete_request_entry(he.get_request_id());
-
- // release data lock
- _local_lock.unlock();
-
- return false;
-
+ res = SUBSCR_ERR_UNKNOWN;
+ break;
};
};
-
+
+ delete_request_entry(he.get_request_id());
- return true;
+ // release data lock
+ _local_lock.unlock();
+ std::cout <<"Returning res = " << res << " for " << he.get_request_id() << std::endl;
+ return res;
};
template <typename Transmitter>
};
template <typename Transmitter>
-bool SubscriptionHandler::RequestSubscriptionDelete(subscription_helper &he, subscription_response_helper &response, int TxCode, Transmitter && tx){
+int subscription_handler::RequestSubscriptionDelete(subscription_helper &he, subscription_response_helper &response, int TxCode, Transmitter && tx){
- bool res;
+ int res;
// First check if we have this subscription
if(! is_subscription_entry(he.get_request_id())){
mdclog_write(MDCLOG_ERR, "subscription with id %d does not exist. Cannot be deleted", he.get_request_id());
// First check if we have this subscription
if(! is_subscription_entry(he.get_request_id())){
mdclog_write(MDCLOG_ERR, "subscription with id %d does not exist. Cannot be deleted", he.get_request_id());
- return false;
+ return SUBSCR_ERR_MISSING;
}
// Also check if such a request is queued
if (is_request_entry(he.get_request_id())){
mdclog_write(MDCLOG_ERR, "Subscription delete request with id %d already in queue", he.get_request_id());
}
// Also check if such a request is queued
if (is_request_entry(he.get_request_id())){
mdclog_write(MDCLOG_ERR, "Subscription delete request with id %d already in queue", he.get_request_id());
- return false;
+ return SUBSCR_ERR_UNKNOWN;
}
subscription_delete e2ap_sub_req_del;
}
subscription_delete e2ap_sub_req_del;
@@ -255,14+255,14 @@ bool SubscriptionHandler::RequestSubscriptionDelete(subscription_helper &he, sub
res = e2ap_sub_req_del.encode_e2ap_subscription(&buffer[0], &buf_len, he);
+ mdclog_write(MDCLOG_ERR, "Error :: %s, %d : Spurious time out caused by invalid state of delete request %d -- state = %d. Deleting request entry and failing .. \n", __FILE__, __LINE__, he.get_request_id(), status);
+ res = SUBSCR_ERR_UNKNOWN;
+ break;
};
};
- return true;
+ delete_request_entry(he.get_request_id());
+
+ // release data lock
+ _local_lock.unlock();
+ std::cout <<"Returning res = " << res << " for " << he.get_request_id() << std::endl;