}
void lock_client::releaser() {
- while (1) {
- maybe<lock_protocol::lockid_t> mlid;
- release_fifo.deq(&mlid);
-
- if (!mlid) {
- LOG << "Releaser stopping";
- break;
- }
-
+ while (auto mlid = release_fifo.deq()) {
lock_protocol::lockid_t lid = mlid;
LOG << "Releaser: " << lid;
LOG << "Lock " << lid << ": none";
st.signal();
}
+ LOG << "Releaser stopping";
}
int lock_client::stat(lock_protocol::lockid_t lid) {