mirrors/gnss-sdr
1
0
Fork 0
mirror of https://github.com/gnss-sdr/gnss-sdr synced 2025-07-09 05:22:54 +00:00
Code Issues Releases Wiki Activity

Improve channel state management in multisystem configurations

Browse Source
This commit is contained in:
Carles Fernandez 2018-06-13 21:01:40 +02:00
parent 36ac696a46
commit 5b2040ae50
No known key found for this signature in database
GPG Key ID: 4C583C52B0C3877D
1 changed files with 28 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/core/receiver/gnss_flowgraph.cc
View File

@ -763,10 +763,35 @@ void GNSSFlowgraph::apply_action(unsigned int who, unsigned int what)
{ {
std::lock_guard<std::mutex> lock(signal_list_mutex); std::lock_guard<std::mutex> lock(signal_list_mutex);
available_GNSS_signals_.push_back(channels_[who]->get_signal()); available_GNSS_signals_.push_back(channels_[who]->get_signal());
channels_[who]->set_signal(search_next_signal(channels_[who]->get_signal().get_signal_str(), true));
} }
DLOG(INFO) << "Channel " << who << " Starting acquisition " << channels_[who]->get_signal().get_satellite() << ", Signal " << channels_[who]->get_signal().get_signal_str(); channels_state_[who] = 0;
channels_[who]->start_acquisition(); acq_channels_count_--;
for (unsigned int i = 0; i < channels_count_; i++)
{
unsigned int ii = (i + 1) % channels_count_;
unsigned int sat_ = 0;
try
{
sat_ = configuration_->property("Channel" + std::to_string(ii) + ".satellite", 0);
}
catch (const std::exception& e)
{
LOG(WARNING) << e.what();
}
if (!available_GNSS_signals_.empty() && (acq_channels_count_ < max_acq_channels_) && (channels_state_[ii] == 0))
{
channels_state_[ii] = 1;
if (sat_ == 0)
{
std::lock_guard<std::mutex> lock(signal_list_mutex);
channels_[ii]->set_signal(search_next_signal(channels_[ii]->get_signal().get_signal_str(), true));
}
acq_channels_count_++;
DLOG(INFO) << "Channel " << ii << " Starting acquisition " << channels_[ii]->get_signal().get_satellite() << ", Signal " << channels_[ii]->get_signal().get_signal_str();
channels_[ii]->start_acquisition();
}
DLOG(INFO) << "Channel " << ii << " in state " << channels_state_[ii];
}
break; break;
case 1: case 1: