Cond cond;
int unack = 0;
- int unsafe = 0;
while (1) {
if (time_to_stop()) break;
}
client->objecter->mutate(oid, oloc, m, snapc, ceph_clock_now(client->cct), 0,
NULL, new C_Ref(lock, cond, &unack));
- /*client->objecter->write(oid, layout, 0, osize, snapc, bl, 0,
- new C_Ref(lock, cond, &unack),
- new C_Ref(lock, cond, &unsafe));*/
} else {
dout(10) << "read from " << oid << dendl;
bufferlist inbl;
}
}
-
- lock.Lock();
- while (unsafe > 0) {
- dout(10) << "waiting for " << unsafe << " unsafe" << dendl;
- cond.Wait(lock);
- }
- lock.Unlock();
return 0;
}