mirrors/gnss-sdr
1
0
Fork 0
mirror of https://github.com/gnss-sdr/gnss-sdr synced 2024-11-17 23:34:56 +00:00
Code Issues Releases Wiki Activity

Merge branch 'acebrianjuan-monitor-decimator-name' into next

Browse Source
This commit is contained in:
Carles Fernandez 2019-02-18 22:38:54 +01:00
commit 39fd9cbf9e
No known key found for this signature in database
GPG Key ID: 4C583C52B0C3877D
3 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/core/monitor/gnss_synchro_monitor.cc
View File

@ -43,25 +43,25 @@ using google::LogMessage;
gnss_synchro_monitor_sptr gnss_synchro_make_monitor(unsigned int n_channels, gnss_synchro_monitor_sptr gnss_synchro_make_monitor(unsigned int n_channels,
int output_rate_ms, int decimation_factor,
int udp_port, int udp_port,
const std::vector<std::string>& udp_addresses) const std::vector<std::string>& udp_addresses)
{ {
return gnss_synchro_monitor_sptr(new gnss_synchro_monitor(n_channels, return gnss_synchro_monitor_sptr(new gnss_synchro_monitor(n_channels,
output_rate_ms, decimation_factor,
udp_port, udp_port,
udp_addresses)); udp_addresses));
} }
gnss_synchro_monitor::gnss_synchro_monitor(unsigned int n_channels, gnss_synchro_monitor::gnss_synchro_monitor(unsigned int n_channels,
int output_rate_ms, int decimation_factor,
int udp_port, int udp_port,
const std::vector<std::string>& udp_addresses) : gr::sync_block("gnss_synchro_monitor", const std::vector<std::string>& udp_addresses) : gr::sync_block("gnss_synchro_monitor",
gr::io_signature::make(n_channels, n_channels, sizeof(Gnss_Synchro)), gr::io_signature::make(n_channels, n_channels, sizeof(Gnss_Synchro)),
gr::io_signature::make(0, 0, 0)) gr::io_signature::make(0, 0, 0))
{ {
d_output_rate_ms = output_rate_ms; d_decimation_factor = decimation_factor;
d_nchannels = n_channels; d_nchannels = n_channels;
udp_sink_ptr = std::unique_ptr<Gnss_Synchro_Udp_Sink>(new Gnss_Synchro_Udp_Sink(udp_addresses, udp_port)); udp_sink_ptr = std::unique_ptr<Gnss_Synchro_Udp_Sink>(new Gnss_Synchro_Udp_Sink(udp_addresses, udp_port));
@ -80,7 +80,7 @@ int gnss_synchro_monitor::work(int noutput_items, gr_vector_const_void_star& inp
for (int epoch = 0; epoch < noutput_items; epoch++) for (int epoch = 0; epoch < noutput_items; epoch++)
{ {
count++; count++;
if (count >= d_output_rate_ms) if (count >= d_decimation_factor)
{ {
for (unsigned int i = 0; i < d_nchannels; i++) for (unsigned int i = 0; i < d_nchannels; i++)
{ {

8
src/core/monitor/gnss_synchro_monitor.h
View File

@ -46,7 +46,7 @@ class gnss_synchro_monitor;
using gnss_synchro_monitor_sptr = boost::shared_ptr<gnss_synchro_monitor>; using gnss_synchro_monitor_sptr = boost::shared_ptr<gnss_synchro_monitor>;
gnss_synchro_monitor_sptr gnss_synchro_make_monitor(unsigned int n_channels, gnss_synchro_monitor_sptr gnss_synchro_make_monitor(unsigned int n_channels,
int output_rate_ms, int decimation_factor,
int udp_port, int udp_port,
const std::vector<std::string>& udp_addresses); const std::vector<std::string>& udp_addresses);
@ -57,13 +57,13 @@ class gnss_synchro_monitor : public gr::sync_block
{ {
private: private:
friend gnss_synchro_monitor_sptr gnss_synchro_make_monitor(unsigned int nchannels, friend gnss_synchro_monitor_sptr gnss_synchro_make_monitor(unsigned int nchannels,
int output_rate_ms, int decimation_factor,
int udp_port, int udp_port,
const std::vector<std::string>& udp_addresses); const std::vector<std::string>& udp_addresses);
unsigned int d_nchannels; unsigned int d_nchannels;
int d_output_rate_ms; int d_decimation_factor;
std::unique_ptr<Gnss_Synchro_Udp_Sink> udp_sink_ptr; std::unique_ptr<Gnss_Synchro_Udp_Sink> udp_sink_ptr;
@ -72,7 +72,7 @@ private:
public: public:
gnss_synchro_monitor(unsigned int nchannels, gnss_synchro_monitor(unsigned int nchannels,
int output_rate_ms, int decimation_factor,
int udp_port, int udp_port,
const std::vector<std::string>& udp_addresses); const std::vector<std::string>& udp_addresses);

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

@ -1538,7 +1538,7 @@ void GNSSFlowgraph::init()
if (enable_monitor_) if (enable_monitor_)
{ {
GnssSynchroMonitor_ = gr::basic_block_sptr(new gnss_synchro_monitor(channels_count_, GnssSynchroMonitor_ = gr::basic_block_sptr(new gnss_synchro_monitor(channels_count_,
configuration_->property("Monitor.output_rate_ms", 1), configuration_->property("Monitor.decimation_factor", 1),
configuration_->property("Monitor.udp_port", 1234), configuration_->property("Monitor.udp_port", 1234),
udp_addr_vec)); udp_addr_vec));
} }