Signed-off-by: Yehuda Sadeh <yehuda@redhat.com>
RGWAsyncWait(RGWAioCompletionNotifier *cn, CephContext *_cct, Mutex *_lock, Cond *_cond, int _secs) : RGWAsyncRadosRequest(cn),
cct(_cct),
lock(_lock), cond(_cond), interval(_secs, 0) {}
+
+ void wakeup() {
+ Mutex::Locker l(*lock);
+ cond->Signal();
+ }
};
class RGWWaitCR : public RGWSimpleCoroutine {
}
~RGWWaitCR() {
+ wakeup();
delete req;
}
int request_complete() {
return req->get_ret_status();
}
+
+ void wakeup() {
+ req->wakeup();
+ }
};
class RGWAsyncReadMDLogEntries : public RGWAsyncRadosRequest {