X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/06282fd37814c4a9d53bca089b048709b368f5b3..869c0cc91d8f6b2bb80026616372d16450b64d9f:/paxos.cc diff --git a/paxos.cc b/paxos.cc index a055c36..2c7e79a 100644 --- a/paxos.cc +++ b/paxos.cc @@ -1,5 +1,4 @@ #include "paxos.h" -#include "handle.h" using namespace std::placeholders; @@ -94,8 +93,7 @@ bool proposer_acceptor::prepare(unsigned instance, nodes_t & accepts, prepareres res; prop_t highest_n_a{0, ""}; for (auto i : nodes) { - handle h(i); - rpcc *r = h.safebind(); + auto r = rpcc::bind_cached(i); if (!r) continue; auto status = (paxos_protocol::status)r->call_timeout( @@ -124,8 +122,7 @@ bool proposer_acceptor::prepare(unsigned instance, nodes_t & accepts, void proposer_acceptor::accept(unsigned instance, nodes_t & accepts, const nodes_t & nodes, const value_t & v) { for (auto i : nodes) { - handle h(i); - rpcc *r = h.safebind(); + auto r = rpcc::bind_cached(i); if (!r) continue; bool accept = false; @@ -138,8 +135,7 @@ void proposer_acceptor::accept(unsigned instance, nodes_t & accepts, void proposer_acceptor::decide(unsigned instance, const nodes_t & accepts, const value_t & v) { for (auto i : accepts) { - handle h(i); - rpcc *r = h.safebind(); + auto r = rpcc::bind_cached(i); if (!r) continue; int res = 0;