mirror of
https://github.com/gnss-sdr/gnss-sdr
synced 2025-09-01 10:28:00 +00:00
Propagate extra data tags in Tracking and Telemetry Decoder
This commit is contained in:
@@ -636,9 +636,18 @@ int gps_l1_ca_telemetry_decoder_gs::general_work(int noutput_items __attribute__
|
|||||||
current_symbol.Flag_PLL_180_deg_phase_locked = false;
|
current_symbol.Flag_PLL_180_deg_phase_locked = false;
|
||||||
}
|
}
|
||||||
|
|
||||||
// time tags
|
// TODO - Merge these two loops
|
||||||
std::vector<gr::tag_t> tags_vec;
|
std::vector<gr::tag_t> tags_vec;
|
||||||
this->get_tags_in_range(tags_vec, 0, this->nitems_read(0), this->nitems_read(0) + 1);
|
get_tags_in_range(tags_vec, 0, this->nitems_read(0)-1, this->nitems_read(0), pmt::mp("extra_data"));
|
||||||
|
for (const auto & tag : tags_vec)
|
||||||
|
{
|
||||||
|
add_item_tag(0, this->nitems_written(0) + 1, tag.key, tag.value);
|
||||||
|
// std::cout << "[ED TAG (TRK)] [" << std::to_string(tag.offset) << "] ";
|
||||||
|
// std::cout << std::endl;
|
||||||
|
}
|
||||||
|
// time tags
|
||||||
|
tags_vec.clear();
|
||||||
|
this->get_tags_in_range(tags_vec, 0, this->nitems_read(0), this->nitems_read(0) + 1, pmt::mp("timetag"));
|
||||||
for (const auto &it : tags_vec)
|
for (const auto &it : tags_vec)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
|
@@ -2092,6 +2092,16 @@ int dll_pll_veml_tracking::general_work(int noutput_items __attribute__((unused)
|
|||||||
d_timetag_waiting = false;
|
d_timetag_waiting = false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
std::vector<gr::tag_t> tags{};
|
||||||
|
// get_tags_in_window(tags, 0, 0, ninput_items[0], pmt::mp("extra_data"));
|
||||||
|
get_tags_in_range(tags, 0, nitems_read(0) - d_current_prn_length_samples, nitems_read(0), pmt::mp("extra_data"));
|
||||||
|
|
||||||
|
for (const auto &tag : tags)
|
||||||
|
{
|
||||||
|
add_item_tag(0, this->nitems_written(0) + 1, tag.key, tag.value);
|
||||||
|
// std::cout << "[ED TAG (TRK)] [" << std::to_string(tag.offset) << "] ";
|
||||||
|
// std::cout << std::endl;
|
||||||
|
}
|
||||||
*out[0] = std::move(current_synchro_data);
|
*out[0] = std::move(current_synchro_data);
|
||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user