X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/2546a41ad36fdc9ef6471cb35a1d56930ae1b527..5bb7eb131773abd9e642f83629528b4c4e706b2e:/rsm_client.cc diff --git a/rsm_client.cc b/rsm_client.cc index bff32c2..310d1ad 100644 --- a/rsm_client.cc +++ b/rsm_client.cc @@ -1,14 +1,10 @@ +#include "types.h" #include "rsm_client.h" -#include #include -#include #include #include -#include "lang/verify.h" -#include "lock.h" -#include "threaded_log.h" -rsm_client::rsm_client(std::string dst) : primary(dst) { +rsm_client::rsm_client(string dst) : primary(dst) { LOG("create rsm_client"); lock ml(rsm_client_mutex); VERIFY (init_members(ml)); @@ -20,10 +16,10 @@ void rsm_client::primary_failure(lock &) { known_mems.pop_back(); } -rsm_protocol::status rsm_client::invoke(unsigned int proc, std::string &rep, const std::string &req) { +rsm_protocol::status rsm_client::invoke(unsigned int proc, string &rep, const string &req) { lock ml(rsm_client_mutex); while (1) { - LOG("rsm_client::invoke proc " << std::hex << proc << " primary " << primary); + LOG("rsm_client::invoke proc " << hex << proc << " primary " << primary); handle h(primary); ml.unlock(); @@ -36,7 +32,7 @@ rsm_protocol::status rsm_client::invoke(unsigned int proc, std::string &rep, con if (!cl) goto prim_fail; - LOG("rsm_client::invoke proc " << std::hex << proc << " primary " << primary << " ret " << std::dec << ret); + LOG("rsm_client::invoke proc " << hex << proc << " primary " << primary << " ret " << dec << ret); if (ret == rsm_client_protocol::OK) return rsm_protocol::OK; if (ret == rsm_client_protocol::BUSY) { @@ -50,7 +46,7 @@ rsm_protocol::status rsm_client::invoke(unsigned int proc, std::string &rep, con continue; } prim_fail: - LOG("primary " << primary << " failed ret " << std::dec << ret); + LOG("primary " << primary << " failed ret " << dec << ret); primary_failure(ml); LOG("rsm_client::invoke: retry new primary " << primary); }