So we can send requests more than once per second.
Signed-off-by: Sage Weil <sage@newdream.net>
}
Mutex lock;
+ Cond cond;
LoadGen(Rados *_rados) : rados(_rados), going_down(false), lock("LoadGen") {
read_percent = 80;
op->completion->release();
delete op;
+
+ cond.Signal();
}
};
uint32_t total_sec = 0;
while (1) {
- usleep(1000);
-
+ lock.Lock();
+ utime_t one_second(1, 0);
+ cond.WaitInterval(g_ceph_context, lock, one_second);
+ lock.Unlock();
utime_t now = ceph_clock_now(g_ceph_context);
if (now > end_time)