X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/603bac8fcb3697f283e6537d81b4a92e457ebbad..d54215aea2a7321ab0f2dc7b0042fea2b7ff5df5:/config.cc diff --git a/config.cc b/config.cc index 5373007..38c4c05 100644 --- a/config.cc +++ b/config.cc @@ -88,7 +88,7 @@ void config::paxos_commit(unsigned instance, const string &value) { LOG("is " << mem << " still a member?"); if (!isamember(mem, newmem) && me != mem) { LOG("delete " << mem); - invalidate_handle(mem); + handle(mem).invalidate(); } } @@ -202,18 +202,18 @@ config::heartbeat_t config::doheartbeat(const string &m, lock &cfg_mutex_lock) { handle h(m); cfg_mutex_lock.unlock(); - int r = 0, ret = rpc_const::bind_failure; + int r = 0, ret = rpc_protocol::bind_failure; if (rpcc *cl = h.safebind()) - ret = cl->call_timeout(paxos_protocol::heartbeat, rpcc::to(100), r, me, vid); + ret = cl->call_timeout(paxos_protocol::heartbeat, milliseconds(100), r, me, vid); cfg_mutex_lock.lock(); heartbeat_t res = OK; switch (ret) { case paxos_protocol::OK: break; - case rpc_const::atmostonce_failure: - case rpc_const::oldsrv_failure: - invalidate_handle(m); + case rpc_protocol::atmostonce_failure: + case rpc_protocol::oldsrv_failure: + h.invalidate(); break; default: LOG("problem with " << m << " (" << ret << ") my vid " << vid << " his vid " << r);