mirrors/gnss-sdr
1
0
Fork 0
mirror of https://github.com/gnss-sdr/gnss-sdr synced 2025-01-22 15:07:23 +00:00
Code Issues Releases Wiki Activity

Fix termination of TTFF test

Browse Source
This commit is contained in:
Carles Fernandez 2024-12-21 15:24:46 +01:00
parent cfb56d35d6
commit 381cf4fb3c
No known key found for this signature in database
GPG Key ID: 4C583C52B0C3877D
1 changed files with 31 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
tests/system-tests/ttff.cc
View File

@ -316,24 +316,6 @@ void receive_msg()
} }
} }
const std::string queue_name_stop = "receiver_control_queue";
std::unique_ptr<boost::interprocess::message_queue> d_mq_stop;
bool queue_found2 = false;
while (!queue_found2)
{
try
{
// Attempt to open the message queue
d_mq_stop = std::make_unique<boost::interprocess::message_queue>(boost::interprocess::open_only, queue_name_stop.c_str());
queue_found2 = true; // Queue found
}
catch (const boost::interprocess::interprocess_exception &)
{
// Queue not found, wait and retry
std::this_thread::sleep_for(std::chrono::milliseconds(100));
}
}
double received_message; double received_message;
unsigned int priority; unsigned int priority;
std::size_t received_size; std::size_t received_size;
@ -347,6 +329,23 @@ void receive_msg()
LOG(INFO) << "Valid Time-To-First-Fix: " << received_message << " [s]"; LOG(INFO) << "Valid Time-To-First-Fix: " << received_message << " [s]";
// Stop the receiver // Stop the receiver
double stop_message = -200.0; double stop_message = -200.0;
const std::string queue_name_stop = "receiver_control_queue";
std::unique_ptr<boost::interprocess::message_queue> d_mq_stop;
bool queue_found2 = false;
while (!queue_found2)
{
try
{
// Attempt to open the message queue
d_mq_stop = std::make_unique<boost::interprocess::message_queue>(boost::interprocess::open_only, queue_name_stop.c_str());
queue_found2 = true; // Queue found
}
catch (const boost::interprocess::interprocess_exception &)
{
// Queue not found, wait and retry
std::this_thread::sleep_for(std::chrono::milliseconds(100));
}
}
d_mq_stop->send(&stop_message, sizeof(stop_message), 0); d_mq_stop->send(&stop_message, sizeof(stop_message), 0);
} }
if (received_size == sizeof(double) && std::abs(received_message - (-1.0)) < 10 * std::numeric_limits<double>::epsilon()) if (received_size == sizeof(double) && std::abs(received_message - (-1.0)) < 10 * std::numeric_limits<double>::epsilon())
@ -735,24 +734,21 @@ int main(int argc, char **argv)
// Terminate the queue thread // Terminate the queue thread
const std::string queue_name = "gnss_sdr_ttff_message_queue"; const std::string queue_name = "gnss_sdr_ttff_message_queue";
std::unique_ptr<boost::interprocess::message_queue> mq; boost::interprocess::message_queue::remove(queue_name.c_str());
bool queue_found = false;
while (!queue_found) // Create a new message queue
{ auto mq = std::make_unique<boost::interprocess::message_queue>(
try boost::interprocess::create_only, // Create a new queue
{ queue_name.c_str(), // Queue name
// Attempt to open the message queue 10, // Maximum number of messages
mq = std::make_unique<boost::interprocess::message_queue>(boost::interprocess::open_only, queue_name.c_str()); sizeof(double) // Maximum message size
queue_found = true; // Queue found );
}
catch (const boost::interprocess::interprocess_exception &)
{
// Queue not found, wait and retry
std::this_thread::sleep_for(std::chrono::milliseconds(100));
}
}
double finish = -1.0; double finish = -1.0;
mq->send(&finish, sizeof(finish), 0); if (mq)
{
mq->send(&finish, sizeof(finish), 0);
}
receive_msg_thread.join();
boost::interprocess::message_queue::remove(queue_name.c_str()); boost::interprocess::message_queue::remove(queue_name.c_str());
#if USE_GLOG_AND_GFLAGS #if USE_GLOG_AND_GFLAGS