Skip to content

Commit 48add4d

Browse files
committed
Refs #21355. Protect InnerDataWriterListener::on_writer_matched.
Signed-off-by: Miguel Company <miguelcompany@eprosima.com>
1 parent 9e2dcc6 commit 48add4d

2 files changed

Lines changed: 5 additions & 0 deletions

File tree

src/cpp/fastdds/publisher/DataWriterImpl.cpp

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1348,6 +1348,8 @@ void DataWriterImpl::InnerDataWriterListener::on_writer_matched(
13481348
RTPSWriter* /*writer*/,
13491349
const MatchingInfo& info)
13501350
{
1351+
std::lock_guard<std::mutex> scoped_lock(matching_info_mutex_);
1352+
13511353
data_writer_->update_publication_matched_status(info);
13521354

13531355
StatusMask notify_status = StatusMask::publication_matched();

src/cpp/fastdds/publisher/DataWriterImpl.hpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -531,7 +531,10 @@ class DataWriterImpl : protected rtps::IReaderDataFilter
531531
const uint32_t& status_id);
532532
#endif //FASTDDS_STATISTICS
533533

534+
private:
535+
534536
DataWriterImpl* data_writer_;
537+
std::mutex matching_info_mutex_;
535538
}
536539
writer_listener_;
537540

0 commit comments

Comments
 (0)