We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
DataSharingListener
1 parent aef5108 commit 6acc122Copy full SHA for 6acc122
src/cpp/rtps/DataSharing/DataSharingListener.cpp
@@ -56,18 +56,15 @@ DataSharingListener::~DataSharingListener()
56
57
void DataSharingListener::run()
58
{
59
- std::unique_lock<Segment::mutex> lock(notification_->notification_->notification_mutex, std::defer_lock);
60
while (is_running_.load())
61
62
try
63
64
- lock.lock();
+ std::unique_lock<Segment::mutex> lock(notification_->notification_->notification_mutex);
65
notification_->notification_->notification_cv.wait(lock, [&]
66
67
return !is_running_.load() || notification_->notification_->new_data.load();
68
});
69
-
70
- lock.unlock();
71
}
72
catch (const boost::interprocess::interprocess_exception& /*e*/)
73
0 commit comments