- std::cout <<"Using id = " << new_req_id << std::endl;
+ mdclog_write(MDCLOG_INFO, "%s, %d:: Generated new request id %d\n", __FILE__, __LINE__, new_req_id);
he.set_request(new_req_id, he.get_req_seq());
E2AP_PDU_t *e2ap_pdu = 0;
he.set_request(new_req_id, he.get_req_seq());
E2AP_PDU_t *e2ap_pdu = 0;
_cv.get()->wait_for(_local_lock, _time_out);
// we have woken and acquired data_lock
_cv.get()->wait_for(_local_lock, _time_out);
// we have woken and acquired data_lock
// woken up spuriously or timed out
auto end = std::chrono::system_clock::now();
std::chrono::duration<double> f = end - start;
if (_time_out_flag && f > _num_retries * _time_out){
delete_request_entry(he.get_request_id());
// woken up spuriously or timed out
auto end = std::chrono::system_clock::now();
std::chrono::duration<double> f = end - start;
if (_time_out_flag && f > _num_retries * _time_out){
delete_request_entry(he.get_request_id());
- mdclog_write(MDCLOG_ERR, "Subscription request %d timed out waiting for response ", he.get_request_id());
+ mdclog_write(MDCLOG_ERR, "%s, %d:: Subscription request %d timed out waiting for response ", __FILE__, __LINE__, he.get_request_id());
+ 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);