We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
DataSharingListener
1 parent 28552ce commit 185b937Copy full SHA for 185b937
src/cpp/rtps/DataSharing/DataSharingListener.cpp
@@ -49,18 +49,15 @@ DataSharingListener::~DataSharingListener()
49
50
void DataSharingListener::run()
51
{
52
- std::unique_lock<Segment::mutex> lock(notification_->notification_->notification_mutex, std::defer_lock);
53
while (is_running_.load())
54
55
try
56
57
- lock.lock();
+ std::unique_lock<Segment::mutex> lock(notification_->notification_->notification_mutex);
58
notification_->notification_->notification_cv.wait(lock, [&]
59
60
return !is_running_.load() || notification_->notification_->new_data.load();
61
});
62
-
63
- lock.unlock();
64
}
65
catch (const boost::interprocess::interprocess_exception& /*e*/)
66
0 commit comments