diff --git a/src/logdb/LogDBManager.cc b/src/logdb/LogDBManager.cc index a28047417e..cb4a525b31 100644 --- a/src/logdb/LogDBManager.cc +++ b/src/logdb/LogDBManager.cc @@ -359,6 +359,17 @@ void LogDBManager::ReplicaThread::do_replication() follower->set_match(id); zone->unlock(); + + LogDBRequest * lr = logdb->get_request(id); + + if ( lr == 0 ) + { + lr->lock(); + + lr->replicated(); + + lr->unlock(); + } } else {