rlsrpc->start();
}
-void lock_client::releaser() [[noreturn]] {
+void lock_client::releaser() {
while (1) {
lock_protocol::lockid_t lid;
release_fifo.deq(&lid);
LOG("Releaser: " << lid);
- lock_state &st = get_lock_state(lid);
+ lock_state & st = get_lock_state(lid);
lock sl(st.m);
VERIFY(st.state == lock_state::locked && st.held_by == releaser_thread.get_id());
st.state = lock_state::releasing;
int lock_client::stat(lock_protocol::lockid_t lid) {
VERIFY(0);
int r;
- auto ret = (lock_protocol::status)cl->call(lock_protocol::stat, r, cl->id(), lid);
+ auto ret = (lock_protocol::status)cl->call(lock_protocol::stat, r, lid, id);
VERIFY (ret == lock_protocol::OK);
return r;
}
lock_protocol::status lock_client::acquire(lock_protocol::lockid_t lid) {
- lock_state &st = get_lock_state(lid);
+ lock_state & st = get_lock_state(lid);
lock sl(st.m);
auto self = this_thread::get_id();
}
lock_protocol::status lock_client::release(lock_protocol::lockid_t lid) {
- lock_state &st = get_lock_state(lid);
+ lock_state & st = get_lock_state(lid);
lock sl(st.m);
auto self = this_thread::get_id();
VERIFY(st.state == lock_state::locked && st.held_by == self);
rlock_protocol::status lock_client::revoke_handler(int &, lock_protocol::lockid_t lid, lock_protocol::xid_t xid) {
LOG("Revoke handler " << lid << " " << xid);
- lock_state &st = get_lock_state(lid);
+ lock_state & st = get_lock_state(lid);
lock sl(st.m);
if (st.state == lock_state::releasing || st.state == lock_state::none)
}
rlock_protocol::status lock_client::retry_handler(int &, lock_protocol::lockid_t lid, lock_protocol::xid_t) {
- lock_state &st = get_lock_state(lid);
+ lock_state & st = get_lock_state(lid);
lock sl(st.m);
VERIFY(st.state == lock_state::acquiring);
st.state = lock_state::retrying;