Reset receive timestamps on error

1 files changed, 12 insertions, 9 deletions

diff --git a/AlignSample.hpp b/AlignSample.hpp
index 20bd2c8..78c430f 100644
--- a/AlignSample.hpp
+++ b/AlignSample.hpp
@@ -56,23 +56,29 @@ class AlignSample {
             m_first_tx_sample_time = 0;
             m_num_rx_samples_dropped = 0;
             m_num_tx_samples_dropped = 0;
-
-            fd_rx = fopen("rx.debug", "wb");
-            fd_tx = fopen("tx.debug", "wb");
-
         }
 
         void push_tx_samples(complexf* samps, size_t len, double first_sample_time);
 
         void push_rx_samples(complexf* samps, size_t len, double first_sample_time);
 
+        void reset_rx(void);
+
         bool ready(size_t min_samples);
 
         void debug() {
             std::lock_guard<std::mutex> lock(m_mutex);
             MDEBUG("Aligner\n");
-            MDEBUG("  RX: %f %zu\n", m_rx_sample_time(), m_rxsamples.size());
-            MDEBUG("  TX: %f %zu\n", m_tx_sample_time(), m_txsamples.size());
+            MDEBUG("  RX: %f--%f %zu\n",
+                    m_rx_sample_time(),
+                    m_rx_sample_time() +
+                    (double)m_rxsamples.size() / (double)samplerate,
+                    m_rxsamples.size());
+            MDEBUG("  TX: %f--%f %zu\n",
+                    m_tx_sample_time(),
+                    m_tx_sample_time() +
+                    (double)m_txsamples.size() / (double)samplerate,
+                    m_txsamples.size());
         }
 
         CorrelationResult crosscorrelate(size_t len);
@@ -100,9 +106,6 @@ class AlignSample {
         double m_first_tx_sample_time;
         size_t m_num_tx_samples_dropped;
         std::deque<complexf> m_txsamples;
-
-        FILE* fd_rx;
-        FILE* fd_tx;
 };