mirrors
/
gnss-sdr
mirror of https://github.com/gnss-sdr/gnss-sdr
1
0
Fork 0
Code Issues Releases Wiki Activity

Merge branch 'vladisslav2011-monitor_spam_fix' into next

This commit is contained in:
Carles Fernandez 2022-10-11 09:17:20 +02:00
parent 4f2d73dfe3 652c03430f
commit 0ff811d00d
No known key found for this signature in database
GPG Key ID: 4C583C52B0C3877D
3 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/algorithms/PVT/libs/monitor_ephemeris_udp_sink.cc
View File

@ -58,11 +58,10 @@ bool Monitor_Ephemeris_Udp_Sink::write_galileo_ephemeris(const std::shared_ptr<G
for (const auto& endpoint : endpoints)
{
socket.open(endpoint.protocol(), error);
socket.connect(endpoint, error);
try
{
if (socket.send(boost::asio::buffer(outbound_data)) == 0)
if (socket.send_to(boost::asio::buffer(outbound_data), endpoint) == 0)
{
return false;
}
@ -95,11 +94,10 @@ bool Monitor_Ephemeris_Udp_Sink::write_gps_ephemeris(const std::shared_ptr<Gps_E
for (const auto& endpoint : endpoints)
{
socket.open(endpoint.protocol(), error);
socket.connect(endpoint, error);
try
{
if (socket.send(boost::asio::buffer(outbound_data)) == 0)
if (socket.send_to(boost::asio::buffer(outbound_data), endpoint) == 0)
{
return false;
}

3
src/algorithms/PVT/libs/monitor_pvt_udp_sink.cc
View File

@ -57,11 +57,10 @@ bool Monitor_Pvt_Udp_Sink::write_monitor_pvt(const Monitor_Pvt* const monitor_pv
for (const auto& endpoint : endpoints)
{
socket.open(endpoint.protocol(), error);
socket.connect(endpoint, error);
try
{
if (socket.send(boost::asio::buffer(outbound_data)) == 0)
if (socket.send_to(boost::asio::buffer(outbound_data), endpoint) == 0)
{
return false;
}

3
src/core/monitor/gnss_synchro_udp_sink.cc
View File

@ -56,11 +56,10 @@ bool Gnss_Synchro_Udp_Sink::write_gnss_synchro(const std::vector<Gnss_Synchro>&
for (const auto& endpoint : endpoints)
{
socket.open(endpoint.protocol(), error);
socket.connect(endpoint, error);
try
{
if (socket.send(boost::asio::buffer(outbound_data)) == 0)
if (socket.send_to(boost::asio::buffer(outbound_data), endpoint) == 0)
{
std::cerr << "Gnss_Synchro_Udp_Sink sent 0 bytes\n";
}