From 76222945bd7e3db6b013b77ec604f64edf338488 Mon Sep 17 00:00:00 2001
From: Carles Fernandez <carles.fernandez@gmail.com>
Date: Tue, 16 Jul 2019 12:02:13 +0200
Subject: [PATCH] Add missing include, reordering

---
 src/algorithms/PVT/libs/rtcm.h          | 12 ++++++------
 src/algorithms/PVT/libs/rtcm_printer.cc |  2 +-
 src/core/receiver/concurrent_queue.h    | 21 +++++++++++----------
 3 files changed, 18 insertions(+), 17 deletions(-)

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 <galileo_ephemeris.h>
-#include <gps_ephemeris.h>
-#include <gps_cnav_ephemeris.h>
-#include <glonass_gnav_ephemeris.h>
-#include <glonass_gnav_utc_model.h>
+#include "gps_cnav_ephemeris.h"
+#include "gps_ephemeris.h"
 #include <boost/asio.hpp>
 #include <boost/date_time/posix_time/posix_time.hpp>
 #include <glog/logging.h>
@@ -48,6 +48,7 @@
 #include <cstdint>
 #include <cstring>  // for memcpy
 #include <deque>
+#include <list>
 #include <map>
 #include <memory>
 #include <set>
@@ -55,7 +56,6 @@
 #include <thread>
 #include <utility>
 #include <vector>
-#include <list>
 
 #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 <boost/exception/diagnostic_information.hpp>
 #include <glog/logging.h>
 #include <ctime>      // for tm
 #include <exception>  // for exception
@@ -46,7 +47,6 @@
 #include <iostream>   // for cout, cerr
 #include <termios.h>  // for tcgetattr
 #include <unistd.h>   // for close, write
-#include <boost/exception/diagnostic_information.hpp>
 
 #if HAS_STD_FILESYSTEM
 #include <system_error>
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 <mutex>
-#include <thread>
 #include <chrono>
+#include <condition_variable>
+#include <mutex>
 #include <queue>
+#include <thread>
 
 template <typename Data>
 
@@ -50,7 +51,7 @@ class Concurrent_Queue
 public:
     void push(Data const& data)
     {
-    	std::unique_lock<std::mutex> lock(the_mutex);
+        std::unique_lock<std::mutex> 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<std::mutex> lock(the_mutex);
+        std::unique_lock<std::mutex> lock(the_mutex);
         return the_queue.empty();
     }
 
     bool try_pop(Data& popped_value)
     {
-    	std::unique_lock<std::mutex> lock(the_mutex);
+        std::unique_lock<std::mutex> lock(the_mutex);
         if (the_queue.empty())
             {
                 return false;
@@ -76,7 +77,7 @@ public:
 
     void wait_and_pop(Data& popped_value)
     {
-    	std::unique_lock<std::mutex> lock(the_mutex);
+        std::unique_lock<std::mutex> 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<std::mutex> lock(the_mutex);
+        std::unique_lock<std::mutex> 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();