Skip to content
Snippets Groups Projects
Commit 077003c7 authored by Eric Cano's avatar Eric Cano
Browse files

Fixed partial fix in previous commit

parent 0fb955c3
Branches
Tags
No related merge requests found
......@@ -212,6 +212,7 @@ BackendRados::LockWatcher::LockWatcher(librados::IoCtx& context, const std::stri
void BackendRados::LockWatcher::handle_error(uint64_t cookie, int err) {
threading::MutexLocker ml(m_promiseMutex);
if (m_promiseSet) return;
m_promise.set_value();
TIMESTAMPEDPRINT("Handled notify");
m_promiseSet = true;
......@@ -219,6 +220,7 @@ void BackendRados::LockWatcher::handle_error(uint64_t cookie, int err) {
void BackendRados::LockWatcher::handle_notify(uint64_t notify_id, uint64_t cookie, uint64_t notifier_id, librados::bufferlist& bl) {
threading::MutexLocker ml(m_promiseMutex);
if (m_promiseSet) return;
m_promise.set_value();
TIMESTAMPEDPRINT("Handled notify");
m_promiseSet = true;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment