From afa16c6769394e9dce6a9827f8e62e76a0ce7b38 Mon Sep 17 00:00:00 2001
From: Carles Fernandez <carles.fernandez@gmail.com>
Date: Sat, 20 Jun 2020 22:18:38 +0200
Subject: [PATCH] Remove sleeps

---
 src/algorithms/signal_source/libs/gnss_sdr_valve.cc | 7 ++-----
 src/core/receiver/control_thread.cc                 | 1 -
 2 files changed, 2 insertions(+), 6 deletions(-)

diff --git a/src/algorithms/signal_source/libs/gnss_sdr_valve.cc b/src/algorithms/signal_source/libs/gnss_sdr_valve.cc
index b9048dace..7f8277781 100644
--- a/src/algorithms/signal_source/libs/gnss_sdr_valve.cc
+++ b/src/algorithms/signal_source/libs/gnss_sdr_valve.cc
@@ -26,8 +26,6 @@
 #include <gnuradio/io_signature.h>  // for io_signature
 #include <algorithm>                // for min
 #include <cstring>                  // for memcpy
-#include <unistd.h>                 // for usleep
-#include <utility>
 
 Gnss_Sdr_Valve::Gnss_Sdr_Valve(size_t sizeof_stream_item,
     uint64_t nitems,
@@ -93,7 +91,6 @@ int Gnss_Sdr_Valve::work(int noutput_items,
                         {
                             return -1;  // Done!
                         }
-                    usleep(1000000);
                     return 0;  // do not produce or consume
                 }
             uint64_t n = std::min(d_nitems - d_ncopied_items, static_cast<uint64_t>(noutput_items));
@@ -104,14 +101,14 @@ int Gnss_Sdr_Valve::work(int noutput_items,
             // multichannel support
             for (size_t ch = 0; ch < output_items.size(); ch++)
                 {
-                    memcpy(output_items[ch], input_items[ch], n * input_signature()->sizeof_stream_item(ch));
+                    std::memcpy(output_items[ch], input_items[ch], n * input_signature()->sizeof_stream_item(ch));
                 }
             d_ncopied_items += n;
             return n;
         }
     for (size_t ch = 0; ch < output_items.size(); ch++)
         {
-            memcpy(output_items[ch], input_items[ch], noutput_items * input_signature()->sizeof_stream_item(ch));
+            std::memcpy(output_items[ch], input_items[ch], noutput_items * input_signature()->sizeof_stream_item(ch));
         }
     return noutput_items;
 }
diff --git a/src/core/receiver/control_thread.cc b/src/core/receiver/control_thread.cc
index ff56f1572..9b8e7f99f 100644
--- a/src/core/receiver/control_thread.cc
+++ b/src/core/receiver/control_thread.cc
@@ -357,7 +357,6 @@ int ControlThread::run()
     fpga_helper_thread_.try_join_until(boost::chrono::steady_clock::now() + boost::chrono::milliseconds(1000));
 #endif
 
-    std::this_thread::sleep_for(std::chrono::milliseconds(500));
     // Terminate keyboard thread
     pthread_t id = keyboard_thread_.native_handle();
     keyboard_thread_.detach();