diff --git a/src/algorithms/PVT/libs/monitor_ephemeris_udp_sink.cc b/src/algorithms/PVT/libs/monitor_ephemeris_udp_sink.cc index 8da16d190..ca4ac6fbd 100644 --- a/src/algorithms/PVT/libs/monitor_ephemeris_udp_sink.cc +++ b/src/algorithms/PVT/libs/monitor_ephemeris_udp_sink.cc @@ -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; } diff --git a/src/algorithms/PVT/libs/monitor_pvt_udp_sink.cc b/src/algorithms/PVT/libs/monitor_pvt_udp_sink.cc index dd77788d6..ba5d55b52 100644 --- a/src/algorithms/PVT/libs/monitor_pvt_udp_sink.cc +++ b/src/algorithms/PVT/libs/monitor_pvt_udp_sink.cc @@ -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; } diff --git a/src/core/monitor/gnss_synchro_udp_sink.cc b/src/core/monitor/gnss_synchro_udp_sink.cc index ca613d460..84d484385 100644 --- a/src/core/monitor/gnss_synchro_udp_sink.cc +++ b/src/core/monitor/gnss_synchro_udp_sink.cc @@ -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"; }