diff --git a/ecal/core/src/io/udp/ecal_udp_sample_sender.cpp b/ecal/core/src/io/udp/ecal_udp_sample_sender.cpp index 70c16a5399..6a353572f2 100644 --- a/ecal/core/src/io/udp/ecal_udp_sample_sender.cpp +++ b/ecal/core/src/io/udp/ecal_udp_sample_sender.cpp @@ -47,6 +47,7 @@ namespace eCAL { if (!m_udp_sender) return(0); + std::lock_guard const send_lock(m_payload_mutex); // return value size_t sent_sum(0); diff --git a/ecal/core/src/io/udp/ecal_udp_sample_sender.h b/ecal/core/src/io/udp/ecal_udp_sample_sender.h index afb4dc5411..5a90d2e68f 100644 --- a/ecal/core/src/io/udp/ecal_udp_sample_sender.h +++ b/ecal/core/src/io/udp/ecal_udp_sample_sender.h @@ -35,6 +35,7 @@ #endif #include +#include #include namespace eCAL @@ -51,6 +52,7 @@ namespace eCAL IO::UDP::SSenderAttr m_attr; std::shared_ptr m_udp_sender; + std::mutex m_payload_mutex; std::vector m_payload; }; }