diff options
Diffstat (limited to 'main.cpp')
| -rw-r--r-- | main.cpp | 19 |
1 files changed, 10 insertions, 9 deletions
@@ -259,13 +259,15 @@ int main(int argc, char **argv) std::thread correlator_thread(find_peak_correlation); do { - double first_sample_time = 0; + const double first_sample_time = 4.0; + const double sample_time = first_sample_time + (double)total_samps_read / (double)samplerate; if (fd) { std::vector<complexf> input_samples(samps_per_buffer); samps_read = read_samples_from_file(fd, input_samples, samps_per_buffer); - sent = output_uhd.Transmit(&input_samples.front(), samps_read, &first_sample_time); - aligner.push_tx_samples(&input_samples.front(), samps_read, first_sample_time); + + sent = output_uhd.Transmit(&input_samples.front(), samps_read, sample_time); + aligner.push_tx_samples(&input_samples.front(), samps_read, sample_time); } else { zmq::message_t msg; @@ -280,15 +282,14 @@ int main(int argc, char **argv) } samps_read = msg.size() / sizeof(complexf); - sent = output_uhd.Transmit((complexf*)msg.data(), samps_read, &first_sample_time); - - aligner.push_tx_samples((complexf*)msg.data(), samps_read, first_sample_time); + sent = output_uhd.Transmit((complexf*)msg.data(), samps_read, sample_time); + aligner.push_tx_samples((complexf*)msg.data(), samps_read, sample_time); } - if (first_sample_time - last_print_time > 1) { - //MDEBUG("Tx %zu samples at t=%f\n", samps_read, first_sample_time); - last_print_time = first_sample_time; + if (sample_time - last_print_time > 1) { + //MDEBUG("Tx %zu samples at t=%f\n", samps_read, sample_time); + last_print_time = sample_time; } total_samps_read += samps_read; |