working on tests

src/algorithms/acquisition/adapters/galileo_e1_pcps_quicksync_ambiguous_acquisition.cc

@@ -294,6 +294,16 @@ GalileoE1PcpsQuickSyncAmbiguousAcquisition::reset()
         }
 }
 
+void GalileoE1PcpsQuickSyncAmbiguousAcquisition::set_state(int state)
+{
+    if (item_type_.compare("gr_complex") == 0)
+    {
+        acquisition_cc_->set_state(state);
+    }
+}
+
+
+
 float GalileoE1PcpsQuickSyncAmbiguousAcquisition::calculate_threshold(float pfa)
 {
     unsigned int frequency_bins = 0;

src/algorithms/acquisition/adapters/galileo_e1_pcps_quicksync_ambiguous_acquisition.h

@@ -129,6 +129,8 @@ public:
      */
     void reset();
 
+    void set_state(int state);
+
 private:
     ConfigurationInterface* configuration_;
     pcps_quicksync_acquisition_cc_sptr acquisition_cc_;

src/algorithms/acquisition/adapters/gps_l1_ca_pcps_acquisition.cc

@@ -60,6 +60,7 @@ GpsL1CaPcpsAcquisition::GpsL1CaPcpsAcquisition(
 
     item_type_ = configuration_->property(role + ".item_type",
             default_item_type);
+    //float pfa =  configuration_->property(role + ".pfa", 0.0);
 
     fs_in_ = configuration_->property("GNSS-SDR.internal_fs_hz", 2048000);
     if_ = configuration_->property(role + ".ifreq", 0);
@@ -129,27 +130,27 @@ void GpsL1CaPcpsAcquisition::set_channel(unsigned int channel)
 
 void GpsL1CaPcpsAcquisition::set_threshold(float threshold)
 {
-	float pfa = configuration_->property(role_ + boost::lexical_cast<std::string>(channel_) + ".pfa", 0.0);
+    float pfa = configuration_->property(role_ + boost::lexical_cast<std::string>(channel_) + ".pfa", 0.0);
 
-	if(pfa == 0.0)
+    if(pfa == 0.0)
         {
-                 pfa = configuration_->property(role_+".pfa", 0.0);
+            pfa = configuration_->property(role_+".pfa", 0.0);
+        }
+    if(pfa == 0.0)
+        {
+            threshold_ = threshold;
+        }
+    else
+        {
+            threshold_ = calculate_threshold(pfa);
         }
-	if(pfa == 0.0)
-		{
-			threshold_ = threshold;
-		}
-	else
-		{
-			threshold_ = calculate_threshold(pfa);
-		}
 
-	DLOG(INFO) <<"Channel "<<channel_<<" Threshold = " << threshold_;
+    DLOG(INFO) <<"Channel "<<channel_<<" Threshold = " << threshold_;
 
     if (item_type_.compare("gr_complex") == 0)
-    {
-        acquisition_cc_->set_threshold(threshold_);
-    }
+        {
+            acquisition_cc_->set_threshold(threshold_);
+        }
 }
 
 
@@ -244,6 +245,15 @@ void GpsL1CaPcpsAcquisition::reset()
     }
 }
 
+void GpsL1CaPcpsAcquisition::set_state(int state)
+{
+    if (item_type_.compare("gr_complex") == 0)
+    {
+        acquisition_cc_->set_state(state);
+    }
+}
+
+
 
 float GpsL1CaPcpsAcquisition::calculate_threshold(float pfa)
 {

src/algorithms/acquisition/adapters/gps_l1_ca_pcps_acquisition.h

@@ -134,6 +134,8 @@ public:
      */
     void reset();
 
+    void set_state(int state);
+
 private:
     ConfigurationInterface* configuration_;
     pcps_acquisition_cc_sptr acquisition_cc_;

src/algorithms/acquisition/adapters/gps_l1_ca_pcps_quicksync_acquisition.cc

@@ -276,6 +276,14 @@ void GpsL1CaPcpsQuickSyncAcquisition::reset()
         }
 }
 
+void GpsL1CaPcpsQuickSyncAcquisition::set_state(int state)
+{
+    if (item_type_.compare("gr_complex") == 0)
+        {
+            acquisition_cc_->set_state(state);
+        }
+}
+
 
 float GpsL1CaPcpsQuickSyncAcquisition::calculate_threshold(float pfa)
 {

src/algorithms/acquisition/adapters/gps_l1_ca_pcps_quicksync_acquisition.h

@@ -132,7 +132,7 @@ public:
      */
     void reset();
 
-
+    void set_state(int state);
 private:
     ConfigurationInterface* configuration_;
     pcps_quicksync_acquisition_cc_sptr acquisition_cc_;

src/algorithms/acquisition/adapters/gps_l1_ca_pcps_tong_acquisition.cc

@@ -229,6 +229,14 @@ void GpsL1CaPcpsTongAcquisition::reset()
         }
 }
 
+void GpsL1CaPcpsTongAcquisition::set_state(int state)
+{
+    if (item_type_.compare("gr_complex") == 0)
+    {
+        acquisition_cc_->set_state(state);
+    }
+}
+
 float GpsL1CaPcpsTongAcquisition::calculate_threshold(float pfa)
 {
 	//Calculate the threshold

src/algorithms/acquisition/adapters/gps_l1_ca_pcps_tong_acquisition.h

@@ -131,6 +131,8 @@ public:
 
     void reset();
 
+    void set_state(int state);
+
 private:
     ConfigurationInterface* configuration_;
     pcps_tong_acquisition_cc_sptr acquisition_cc_;

src/algorithms/acquisition/gnuradio_blocks/galileo_e5a_noncoherent_iq_acquisition_caf_cc.cc

@@ -281,6 +281,29 @@ void galileo_e5a_noncoherentIQ_acquisition_caf_cc::init()
 }
 
 
+
+void galileo_e5a_noncoherentIQ_acquisition_caf_cc::set_state(int state)
+{
+    d_state = state;
+    if (d_state == 1)
+        {
+            d_gnss_synchro->Acq_delay_samples = 0.0;
+            d_gnss_synchro->Acq_doppler_hz = 0.0;
+            d_gnss_synchro->Acq_samplestamp_samples = 0;
+            d_well_count = 0;
+            d_mag = 0.0;
+            d_input_power = 0.0;
+            d_test_statistics = 0.0;
+        }
+    else if (d_state == 0)
+        {}
+    else
+        {
+            LOG(ERROR) << "State can only be set to 0 or 1";
+        }
+}
+
+
 int galileo_e5a_noncoherentIQ_acquisition_caf_cc::general_work(int noutput_items,
         gr_vector_int &ninput_items, gr_vector_const_void_star &input_items,
         gr_vector_void_star &output_items)

src/algorithms/acquisition/gnuradio_blocks/galileo_e5a_noncoherent_iq_acquisition_caf_cc.h

@@ -203,6 +203,13 @@ public:
          d_active = active;
      }
 
+     /*!
+      * \brief If set to 1, ensures that acquisition starts at the
+      * first available sample.
+      * \param state - int=1 forces start of acquisition
+      */
+     void set_state(int state);
+
      /*!
       * \brief Set acquisition channel unique ID
       * \param channel - receiver channel.

src/algorithms/acquisition/gnuradio_blocks/galileo_pcps_8ms_acquisition_cc.cc

@@ -166,6 +166,30 @@ void galileo_pcps_8ms_acquisition_cc::init()
         }
 }
 
+
+void galileo_pcps_8ms_acquisition_cc::set_state(int state)
+{
+    d_state = state;
+    if (d_state == 1)
+        {
+            d_gnss_synchro->Acq_delay_samples = 0.0;
+            d_gnss_synchro->Acq_doppler_hz = 0.0;
+            d_gnss_synchro->Acq_samplestamp_samples = 0;
+            d_well_count = 0;
+            d_mag = 0.0;
+            d_input_power = 0.0;
+            d_test_statistics = 0.0;
+        }
+    else if (d_state == 0)
+        {}
+    else
+        {
+            LOG(ERROR) << "State can only be set to 0 or 1";
+        }
+}
+
+
+
 int galileo_pcps_8ms_acquisition_cc::general_work(int noutput_items,
         gr_vector_int &ninput_items, gr_vector_const_void_star &input_items,
         gr_vector_void_star &output_items)

src/algorithms/acquisition/gnuradio_blocks/galileo_pcps_8ms_acquisition_cc.h

@@ -161,6 +161,13 @@ public:
         d_active = active;
     }
 
+    /*!
+     * \brief If set to 1, ensures that acquisition starts at the
+     * first available sample.
+     * \param state - int=1 forces start of acquisition
+     */
+    void set_state(int state);
+
     /*!
      * \brief Set acquisition channel unique ID
      * \param channel - receiver channel.

src/algorithms/acquisition/gnuradio_blocks/pcps_acquisition_cc.cc

@@ -158,6 +158,29 @@ void pcps_acquisition_cc::init()
         }
 }
 
+
+
+void pcps_acquisition_cc::set_state(int state)
+    {
+        d_state = state;
+        if (d_state == 1)
+            {
+                d_gnss_synchro->Acq_delay_samples = 0.0;
+                d_gnss_synchro->Acq_doppler_hz = 0.0;
+                d_gnss_synchro->Acq_samplestamp_samples = 0;
+                d_well_count = 0;
+                d_mag = 0.0;
+                d_input_power = 0.0;
+                d_test_statistics = 0.0;
+            }
+        else if (d_state == 0)
+            {}
+        else
+            {
+                LOG(ERROR) << "State can only be set to 0 or 1";
+            }
+    }
+
 int pcps_acquisition_cc::general_work(int noutput_items,
         gr_vector_int &ninput_items, gr_vector_const_void_star &input_items,
         gr_vector_void_star &output_items)

src/algorithms/acquisition/gnuradio_blocks/pcps_acquisition_cc.h

@@ -182,6 +182,13 @@ public:
          d_active = active;
      }
 
+     /*!
+      * \brief If set to 1, ensures that acquisition starts at the
+      * first available sample.
+      * \param state - int=1 forces start of acquisition
+      */
+     void set_state(int state);
+
      /*!
       * \brief Set acquisition channel unique ID
       * \param channel - receiver channel.

src/algorithms/acquisition/gnuradio_blocks/pcps_acquisition_fine_doppler_cc.h

@@ -45,8 +45,8 @@
  * -------------------------------------------------------------------------
  */
 
-#ifndef GNSS_SDR_PCPS_acquisition_fine_doppler_cc_H_
-#define GNSS_SDR_PCPS_acquisition_fine_doppler_cc_H_
+#ifndef GNSS_SDR_PCPS_ACQUISITION_FINE_DOPPLER_CC_H_
+#define GNSS_SDR_PCPS_ACQUISITION_FINE_DOPPLER_CC_H_
 
 #include <fstream>
 #include <queue>
@@ -61,8 +61,10 @@
 #include "gnss_synchro.h"
 
 class pcps_acquisition_fine_doppler_cc;
+
 typedef boost::shared_ptr<pcps_acquisition_fine_doppler_cc>
 pcps_acquisition_fine_doppler_cc_sptr;
+
 pcps_acquisition_fine_doppler_cc_sptr
 pcps_make_acquisition_fine_doppler_cc(int max_dwells, unsigned int sampled_ms,
         int doppler_max, int doppler_min, long freq, long fs_in, int samples_per_ms,
@@ -78,166 +80,166 @@ pcps_make_acquisition_fine_doppler_cc(int max_dwells, unsigned int sampled_ms,
 class pcps_acquisition_fine_doppler_cc: public gr::block
 {
 private:
-	friend pcps_acquisition_fine_doppler_cc_sptr
-	pcps_make_acquisition_fine_doppler_cc(int max_dwells, unsigned int sampled_ms,
-		    int doppler_max, int doppler_min, long freq, long fs_in,
-			int samples_per_ms, boost::shared_ptr<gr::msg_queue> queue, bool dump,
-			std::string dump_filename);
+    friend pcps_acquisition_fine_doppler_cc_sptr
+    pcps_make_acquisition_fine_doppler_cc(int max_dwells, unsigned int sampled_ms,
+            int doppler_max, int doppler_min, long freq, long fs_in,
+            int samples_per_ms, boost::shared_ptr<gr::msg_queue> queue, bool dump,
+            std::string dump_filename);
 
-	pcps_acquisition_fine_doppler_cc(int max_dwells, unsigned int sampled_ms,
-		    int doppler_max, int doppler_min, long freq, long fs_in,
-			int samples_per_ms, boost::shared_ptr<gr::msg_queue> queue, bool dump,
-			std::string dump_filename);
+    pcps_acquisition_fine_doppler_cc(int max_dwells, unsigned int sampled_ms,
+            int doppler_max, int doppler_min, long freq, long fs_in,
+            int samples_per_ms, boost::shared_ptr<gr::msg_queue> queue, bool dump,
+            std::string dump_filename);
 
-	void calculate_magnitudes(gr_complex* fft_begin, int doppler_shift,
-			int doppler_offset);
+    void calculate_magnitudes(gr_complex* fft_begin, int doppler_shift,
+            int doppler_offset);
 
-	int compute_and_accumulate_grid(gr_vector_const_void_star &input_items);
-	int estimate_Doppler(gr_vector_const_void_star &input_items, int available_samples);
-	float estimate_input_power(gr_vector_const_void_star &input_items);
-	double search_maximum();
-	void reset_grid();
-	void update_carrier_wipeoff();
-	void free_grid_memory();
+    int compute_and_accumulate_grid(gr_vector_const_void_star &input_items);
+    int estimate_Doppler(gr_vector_const_void_star &input_items, int available_samples);
+    float estimate_input_power(gr_vector_const_void_star &input_items);
+    double search_maximum();
+    void reset_grid();
+    void update_carrier_wipeoff();
+    void free_grid_memory();
 
-	long d_fs_in;
-	long d_freq;
-	int d_samples_per_ms;
-	int d_max_dwells;
-	unsigned int d_doppler_resolution;
-	int d_gnuradio_forecast_samples;
-	float d_threshold;
-	std::string d_satellite_str;
-	int d_config_doppler_max;
-	int d_config_doppler_min;
+    long d_fs_in;
+    long d_freq;
+    int d_samples_per_ms;
+    int d_max_dwells;
+    unsigned int d_doppler_resolution;
+    int d_gnuradio_forecast_samples;
+    float d_threshold;
+    std::string d_satellite_str;
+    int d_config_doppler_max;
+    int d_config_doppler_min;
 
-	int d_num_doppler_points;
+    int d_num_doppler_points;
     int d_doppler_step;
-	unsigned int d_sampled_ms;
-	unsigned int d_fft_size;
-	unsigned long int d_sample_counter;
-	gr_complex* d_carrier;
-	gr_complex* d_fft_codes;
-	float* d_magnitude;
+    unsigned int d_sampled_ms;
+    unsigned int d_fft_size;
+    unsigned long int d_sample_counter;
+    gr_complex* d_carrier;
+    gr_complex* d_fft_codes;
+    float* d_magnitude;
 
-	float** d_grid_data;
-	gr_complex** d_grid_doppler_wipeoffs;
+    float** d_grid_data;
+    gr_complex** d_grid_doppler_wipeoffs;
 
-	gr::fft::fft_complex* d_fft_if;
-	gr::fft::fft_complex* d_ifft;
-	Gnss_Synchro *d_gnss_synchro;
-	unsigned int d_code_phase;
-	float d_doppler_freq;
-	float d_input_power;
-	float d_test_statistics;
-	boost::shared_ptr<gr::msg_queue> d_queue;
-	concurrent_queue<int> *d_channel_internal_queue;
-	std::ofstream d_dump_file;
-	int d_state;
-	bool d_active;
-	int d_well_count;
-	bool d_dump;
-	unsigned int d_channel;
+    gr::fft::fft_complex* d_fft_if;
+    gr::fft::fft_complex* d_ifft;
+    Gnss_Synchro *d_gnss_synchro;
+    unsigned int d_code_phase;
+    float d_doppler_freq;
+    float d_input_power;
+    float d_test_statistics;
+    boost::shared_ptr<gr::msg_queue> d_queue;
+    concurrent_queue<int> *d_channel_internal_queue;
+    std::ofstream d_dump_file;
+    int d_state;
+    bool d_active;
+    int d_well_count;
+    bool d_dump;
+    unsigned int d_channel;
 
-	std::string d_dump_filename;
+    std::string d_dump_filename;
 
 public:
-	/*!
-	 * \brief Default destructor.
-	 */
-	 ~pcps_acquisition_fine_doppler_cc();
+    /*!
+     * \brief Default destructor.
+     */
+    ~pcps_acquisition_fine_doppler_cc();
 
-	/*!
-	 * \brief Set acquisition/tracking common Gnss_Synchro object pointer
-	 * to exchange synchronization data between acquisition and tracking blocks.
-	 * \param p_gnss_synchro Satellite information shared by the processing blocks.
-	 */
-	 void set_gnss_synchro(Gnss_Synchro* p_gnss_synchro)
-	 {
-		 d_gnss_synchro = p_gnss_synchro;
-	 }
+    /*!
+     * \brief Set acquisition/tracking common Gnss_Synchro object pointer
+     * to exchange synchronization data between acquisition and tracking blocks.
+     * \param p_gnss_synchro Satellite information shared by the processing blocks.
+     */
+    void set_gnss_synchro(Gnss_Synchro* p_gnss_synchro)
+    {
+        d_gnss_synchro = p_gnss_synchro;
+    }
 
-	 /*!
-	  * \brief Returns the maximum peak of grid search.
-	  */
-	 unsigned int mag()
-	 {
-		 return d_test_statistics;
-	 }
+    /*!
+     * \brief Returns the maximum peak of grid search.
+     */
+    unsigned int mag()
+    {
+        return d_test_statistics;
+    }
 
-	 /*!
-	  * \brief Initializes acquisition algorithm.
-	  */
-	 void init();
+    /*!
+     * \brief Initializes acquisition algorithm.
+     */
+    void init();
 
-	 /*!
-	  * \brief Sets local code for PCPS acquisition algorithm.
-	  * \param code - Pointer to the PRN code.
-	  */
-	 void set_local_code(std::complex<float> * code);
+    /*!
+     * \brief Sets local code for PCPS acquisition algorithm.
+     * \param code - Pointer to the PRN code.
+     */
+    void set_local_code(std::complex<float> * code);
 
-	 /*!
-	  * \brief Starts acquisition algorithm, turning from standby mode to
-	  * active mode
-	  * \param active - bool that activates/deactivates the block.
-	  */
-	 void set_active(bool active)
-	 {
-		 d_active = active;
-	 }
+    /*!
+     * \brief Starts acquisition algorithm, turning from standby mode to
+     * active mode
+     * \param active - bool that activates/deactivates the block.
+     */
+    void set_active(bool active)
+    {
+        d_active = active;
+    }
 
-	 /*!
-	  * \brief Set acquisition channel unique ID
-	  * \param channel - receiver channel.
-	  */
-	 void set_channel(unsigned int channel)
-	 {
-		 d_channel = channel;
-	 }
+    /*!
+     * \brief Set acquisition channel unique ID
+     * \param channel - receiver channel.
+     */
+    void set_channel(unsigned int channel)
+    {
+        d_channel = channel;
+    }
 
-	 /*!
-	  * \brief Set statistics threshold of PCPS algorithm.
-	  * \param threshold - Threshold for signal detection (check \ref Navitec2012,
-	  * Algorithm 1, for a definition of this threshold).
-	  */
-	 void set_threshold(float threshold)
-	 {
-		 d_threshold = threshold;
-	 }
+    /*!
+     * \brief Set statistics threshold of PCPS algorithm.
+     * \param threshold - Threshold for signal detection (check \ref Navitec2012,
+     * Algorithm 1, for a definition of this threshold).
+     */
+    void set_threshold(float threshold)
+    {
+        d_threshold = threshold;
+    }
 
-	 /*!
-	  * \brief Set maximum Doppler grid search
-	  * \param doppler_max - Maximum Doppler shift considered in the grid search [Hz].
-	  */
-	 void set_doppler_max(unsigned int doppler_max)
-	 {
-		 d_config_doppler_max = doppler_max;
-	 }
+    /*!
+     * \brief Set maximum Doppler grid search
+     * \param doppler_max - Maximum Doppler shift considered in the grid search [Hz].
+     */
+    void set_doppler_max(unsigned int doppler_max)
+    {
+        d_config_doppler_max = doppler_max;
+    }
 
-	 /*!
-	  * \brief Set Doppler steps for the grid search
-	  * \param doppler_step - Frequency bin of the search grid [Hz].
-	  */
-	 void set_doppler_step(unsigned int doppler_step);
+    /*!
+     * \brief Set Doppler steps for the grid search
+     * \param doppler_step - Frequency bin of the search grid [Hz].
+     */
+    void set_doppler_step(unsigned int doppler_step);
 
 
-	 /*!
-	  * \brief Set tracking channel internal queue.
-	  * \param channel_internal_queue - Channel's internal blocks information queue.
-	  */
-	 void set_channel_queue(concurrent_queue<int> *channel_internal_queue)
-	 {
-		 d_channel_internal_queue = channel_internal_queue;
-	 }
+    /*!
+     * \brief Set tracking channel internal queue.
+     * \param channel_internal_queue - Channel's internal blocks information queue.
+     */
+    void set_channel_queue(concurrent_queue<int> *channel_internal_queue)
+    {
+        d_channel_internal_queue = channel_internal_queue;
+    }
 
-	 /*!
-	 * \brief Parallel Code Phase Search Acquisition signal processing.
-	 */
-	 int general_work(int noutput_items, gr_vector_int &ninput_items,
-			 gr_vector_const_void_star &input_items,
-			 gr_vector_void_star &output_items);
+    /*!
+     * \brief Parallel Code Phase Search Acquisition signal processing.
+     */
+    int general_work(int noutput_items, gr_vector_int &ninput_items,
+            gr_vector_const_void_star &input_items,
+            gr_vector_void_star &output_items);
 
-	 void forecast (int noutput_items, gr_vector_int &ninput_items_required);
+    void forecast (int noutput_items, gr_vector_int &ninput_items_required);
 
 };
 

src/algorithms/acquisition/gnuradio_blocks/pcps_cccwsr_acquisition_cc.cc

@@ -182,6 +182,29 @@ void pcps_cccwsr_acquisition_cc::init()
         }
 }
 
+
+void pcps_cccwsr_acquisition_cc::set_state(int state)
+{
+    d_state = state;
+    if (d_state == 1)
+        {
+            d_gnss_synchro->Acq_delay_samples = 0.0;
+            d_gnss_synchro->Acq_doppler_hz = 0.0;
+            d_gnss_synchro->Acq_samplestamp_samples = 0;
+            d_well_count = 0;
+            d_mag = 0.0;
+            d_input_power = 0.0;
+            d_test_statistics = 0.0;
+        }
+    else if (d_state == 0)
+        {}
+    else
+        {
+            LOG(ERROR) << "State can only be set to 0 or 1";
+        }
+}
+
+
 int pcps_cccwsr_acquisition_cc::general_work(int noutput_items,
         gr_vector_int &ninput_items, gr_vector_const_void_star &input_items,
         gr_vector_void_star &output_items)

src/algorithms/acquisition/gnuradio_blocks/pcps_cccwsr_acquisition_cc.h

@@ -172,6 +172,13 @@ public:
          d_active = active;
      }
 
+     /*!
+      * \brief If set to 1, ensures that acquisition starts at the
+      * first available sample.
+      * \param state - int=1 forces start of acquisition
+      */
+     void set_state(int state);
+
      /*!
       * \brief Set acquisition channel unique ID
       * \param channel - receiver channel.

src/algorithms/acquisition/gnuradio_blocks/pcps_multithread_acquisition_cc.cc

@@ -299,6 +299,33 @@ void pcps_multithread_acquisition_cc::acquisition_core()
     d_core_working = false;
 }
 
+
+
+void pcps_multithread_acquisition_cc::set_state(int state)
+{
+    d_state = state;
+    if (d_state == 1)
+        {
+            d_gnss_synchro->Acq_delay_samples = 0.0;
+            d_gnss_synchro->Acq_doppler_hz = 0.0;
+            d_gnss_synchro->Acq_samplestamp_samples = 0;
+            d_well_count = 0;
+            d_mag = 0.0;
+            d_input_power = 0.0;
+            d_test_statistics = 0.0;
+            d_in_dwell_count = 0;
+            d_sample_counter_buffer.clear();
+        }
+    else if (d_state == 0)
+        {}
+    else
+        {
+            LOG(ERROR) << "State can only be set to 0 or 1";
+        }
+}
+
+
+
 int pcps_multithread_acquisition_cc::general_work(int noutput_items,
         gr_vector_int &ninput_items, gr_vector_const_void_star &input_items,
         gr_vector_void_star &output_items)

src/algorithms/acquisition/gnuradio_blocks/pcps_multithread_acquisition_cc.h

@@ -190,6 +190,13 @@ public:
         d_active = active;
     }
 
+    /*!
+     * \brief If set to 1, ensures that acquisition starts at the
+     * first available sample.
+     * \param state - int=1 forces start of acquisition
+     */
+    void set_state(int state);
+
     /*!
      * \brief Set acquisition channel unique ID
      * \param channel - receiver channel.

src/algorithms/acquisition/gnuradio_blocks/pcps_opencl_acquisition_cc.cc

@@ -664,6 +664,28 @@ void pcps_opencl_acquisition_cc::acquisition_core_opencl()
 }
 
 
+void pcps_multithread_acquisition_cc::set_state(int state)
+{
+    d_state = state;
+    if (d_state == 1)
+        {
+            d_gnss_synchro->Acq_delay_samples = 0.0;
+            d_gnss_synchro->Acq_doppler_hz = 0.0;
+            d_gnss_synchro->Acq_samplestamp_samples = 0;
+            d_well_count = 0;
+            d_mag = 0.0;
+            d_input_power = 0.0;
+            d_test_statistics = 0.0;
+            d_in_dwell_count = 0;
+            d_sample_counter_buffer.clear();
+        }
+    else if (d_state == 0)
+        {}
+    else
+        {
+            LOG(ERROR) << "State can only be set to 0 or 1";
+        }
+}
 
 int pcps_opencl_acquisition_cc::general_work(int noutput_items,
         gr_vector_int &ninput_items, gr_vector_const_void_star &input_items,

src/algorithms/acquisition/gnuradio_blocks/pcps_opencl_acquisition_cc.h

@@ -216,6 +216,13 @@ public:
          d_active = active;
      }
 
+     /*!
+      * \brief If set to 1, ensures that acquisition starts at the
+      * first available sample.
+      * \param state - int=1 forces start of acquisition
+      */
+     void set_state(int state);
+
      /*!
       * \brief Set acquisition channel unique ID
       * \param channel - receiver channel.

src/algorithms/acquisition/gnuradio_blocks/pcps_quicksync_acquisition_cc.cc

@@ -208,6 +208,28 @@ void pcps_quicksync_acquisition_cc::init()
 }
 
 
+void pcps_quicksync_acquisition_cc::set_state(int state)
+    {
+        d_state = state;
+        if (d_state == 1)
+            {
+                d_gnss_synchro->Acq_delay_samples = 0.0;
+                d_gnss_synchro->Acq_doppler_hz = 0.0;
+                d_gnss_synchro->Acq_samplestamp_samples = 0;
+                d_well_count = 0;
+                d_mag = 0.0;
+                d_input_power = 0.0;
+                d_test_statistics = 0.0;
+                d_active = 1;
+            }
+        else if (d_state == 0)
+            {}
+        else
+            {
+                LOG(ERROR) << "State can only be set to 0 or 1";
+            }
+    }
+
 int pcps_quicksync_acquisition_cc::general_work(int noutput_items,
         gr_vector_int &ninput_items, gr_vector_const_void_star &input_items,
         gr_vector_void_star &output_items)

src/algorithms/acquisition/gnuradio_blocks/pcps_quicksync_acquisition_cc.h

@@ -202,6 +202,13 @@ public:
         d_active = active;
     }
 
+    /*!
+     * \brief If set to 1, ensures that acquisition starts at the
+     * first available sample.
+     * \param state - int=1 forces start of acquisition
+     */
+    void set_state(int state);
+
     /*!
      * \brief Set acquisition channel unique ID
      * \param channel - receiver channel.

src/algorithms/acquisition/gnuradio_blocks/pcps_tong_acquisition_cc.cc

@@ -186,6 +186,37 @@ void pcps_tong_acquisition_cc::init()
         }
 }
 
+void pcps_tong_acquisition_cc::set_state(int state)
+{
+    d_state = state;
+    if (d_state == 1)
+        {
+            d_gnss_synchro->Acq_delay_samples = 0.0;
+            d_gnss_synchro->Acq_doppler_hz = 0.0;
+            d_gnss_synchro->Acq_samplestamp_samples = 0;
+            d_well_count = 0;
+            d_well_count = 0;
+            d_tong_count = d_tong_init_val;
+            d_mag = 0.0;
+            d_input_power = 0.0;
+            d_test_statistics = 0.0;
+
+            for (unsigned int doppler_index = 0; doppler_index < d_num_doppler_bins; doppler_index++)
+                {
+                    for (unsigned int i = 0; i < d_fft_size; i++)
+                        {
+                            d_grid_data[doppler_index][i] = 0;
+                        }
+                }
+        }
+    else if (d_state == 0)
+        {}
+    else
+        {
+            LOG(ERROR) << "State can only be set to 0 or 1";
+        }
+}
+
 int pcps_tong_acquisition_cc::general_work(int noutput_items,
         gr_vector_int &ninput_items, gr_vector_const_void_star &input_items,
         gr_vector_void_star &output_items)

src/algorithms/acquisition/gnuradio_blocks/pcps_tong_acquisition_cc.h

@@ -180,6 +180,13 @@ public:
          d_active = active;
      }
 
+     /*!
+      * \brief If set to 1, ensures that acquisition starts at the
+      * first available sample.
+      * \param state - int=1 forces start of acquisition
+      */
+     void set_state(int state);
+
      /*!
       * \brief Set acquisition channel unique ID
       * \param channel - receiver channel.

src/algorithms/libs/CMakeLists.txt

@@ -23,6 +23,7 @@ if(OPENCL_FOUND)
          gnss_signal_processing.cc
          gps_sdr_signal_processing.cc
          nco_lib.cc
+         fix_fft.cc
          pass_through.cc
          fft_execute.cc # Needs OpenCL
          fft_setup.cc # Needs OpenCL
@@ -36,6 +37,7 @@ else(OPENCL_FOUND)
          gnss_signal_processing.cc
          gps_sdr_signal_processing.cc
          nco_lib.cc
+         fix_fft.cc
          pass_through.cc
          galileo_e5_signal_processing.cc
     )