diff --git a/src/algorithms/PVT/libs/rtcm.h b/src/algorithms/PVT/libs/rtcm.h index 26635b5b3..792eafb9a 100644 --- a/src/algorithms/PVT/libs/rtcm.h +++ b/src/algorithms/PVT/libs/rtcm.h @@ -34,12 +34,12 @@ #include "concurrent_queue.h" +#include "galileo_ephemeris.h" +#include "glonass_gnav_ephemeris.h" +#include "glonass_gnav_utc_model.h" #include "gnss_synchro.h" -#include -#include -#include -#include -#include +#include "gps_cnav_ephemeris.h" +#include "gps_ephemeris.h" #include #include #include @@ -48,6 +48,7 @@ #include #include // for memcpy #include +#include #include #include #include @@ -55,7 +56,6 @@ #include #include #include -#include #if BOOST_GREATER_1_65 using b_io_context = boost::asio::io_context; diff --git a/src/algorithms/PVT/libs/rtcm_printer.cc b/src/algorithms/PVT/libs/rtcm_printer.cc index 7526cbb78..9c94a78d4 100644 --- a/src/algorithms/PVT/libs/rtcm_printer.cc +++ b/src/algorithms/PVT/libs/rtcm_printer.cc @@ -39,6 +39,7 @@ #include "gps_cnav_ephemeris.h" #include "gps_ephemeris.h" #include "rtcm.h" +#include #include #include // for tm #include // for exception @@ -46,7 +47,6 @@ #include // for cout, cerr #include // for tcgetattr #include // for close, write -#include #if HAS_STD_FILESYSTEM #include diff --git a/src/core/receiver/concurrent_queue.h b/src/core/receiver/concurrent_queue.h index da223d16c..7769a1406 100644 --- a/src/core/receiver/concurrent_queue.h +++ b/src/core/receiver/concurrent_queue.h @@ -31,10 +31,11 @@ #ifndef GNSS_SDR_CONCURRENT_QUEUE_H #define GNSS_SDR_CONCURRENT_QUEUE_H -#include -#include #include +#include +#include #include +#include template @@ -50,7 +51,7 @@ class Concurrent_Queue public: void push(Data const& data) { - std::unique_lock lock(the_mutex); + std::unique_lock lock(the_mutex); the_queue.push(data); lock.unlock(); the_condition_variable.notify_one(); @@ -58,13 +59,13 @@ public: bool empty() const { - std::unique_lock lock(the_mutex); + std::unique_lock lock(the_mutex); return the_queue.empty(); } bool try_pop(Data& popped_value) { - std::unique_lock lock(the_mutex); + std::unique_lock lock(the_mutex); if (the_queue.empty()) { return false; @@ -76,7 +77,7 @@ public: void wait_and_pop(Data& popped_value) { - std::unique_lock lock(the_mutex); + std::unique_lock lock(the_mutex); while (the_queue.empty()) { the_condition_variable.wait(lock); @@ -84,16 +85,16 @@ public: popped_value = the_queue.front(); the_queue.pop(); } - + bool timed_wait_and_pop(Data& popped_value, int wait_ms) { - std::unique_lock lock(the_mutex); + std::unique_lock lock(the_mutex); if (the_queue.empty()) { - the_condition_variable.wait_for(lock,std::chrono::milliseconds(wait_ms)); + the_condition_variable.wait_for(lock, std::chrono::milliseconds(wait_ms)); if (the_queue.empty()) { - return false; + return false; } } popped_value = the_queue.front();