Signed-off-by: Igor Fedotov <ifedotov@mirantis.com>
if (kv_stop)
break;
dout(20) << __func__ << " sleep" << dendl;
- kv_sync_cond.notify_all();
kv_cond.wait(l);
dout(20) << __func__ << " wake" << dendl;
} else {
KVSyncThread kv_sync_thread;
std::mutex kv_lock;
- std::condition_variable kv_cond, kv_sync_cond;
+ std::condition_variable kv_cond;
bool kv_stop = false;
deque<TransContext*> kv_queue; ///< ready, already submitted
deque<TransContext*> kv_queue_unsubmitted; ///< ready, need submit by kv thread