X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/d54215aea2a7321ab0f2dc7b0042fea2b7ff5df5..03b35a9a1bd1f583e32b27d260b223a0989d6c75:/handle.cc diff --git a/handle.cc b/handle.cc index 792ce40..926cb59 100644 --- a/handle.cc +++ b/handle.cc @@ -5,18 +5,18 @@ public: unique_ptr client; bool valid = true; string destination; - mutex client_mutex; + std::mutex client_mutex; hinfo(const string & destination_) : destination(destination_) {} }; -static mutex mgr_mutex; -static map> hmap; +static std::mutex mgr_mutex; +static std::map> hmap; handle::handle(const string & destination) : destination_(destination) { lock ml(mgr_mutex); h = hmap[destination]; if (!h || !h->valid) - h = (hmap[destination] = make_shared(destination)); + h = (hmap[destination] = std::make_shared(destination)); } rpcc * handle::safebind() { @@ -27,14 +27,14 @@ rpcc * handle::safebind() { return nullptr; if (!h->client) { unique_ptr client(new rpcc(h->destination)); - LOG("bind(\"" << h->destination << "\")"); + LOG << "bind(\"" << h->destination << "\")"; int ret = client->bind(milliseconds(1000)); if (ret < 0) { - LOG("bind failure! " << h->destination << " " << ret); + LOG << "bind failure! " << h->destination << " " << ret; h->valid = false; } else { - LOG("bind succeeded " << h->destination); - h->client = move(client); + LOG << "bind succeeded " << h->destination; + h->client = std::move(client); } } return h->client.get(); @@ -45,7 +45,7 @@ void handle::invalidate() { lock ml(mgr_mutex); if (hmap.find(destination_) != hmap.end()) { hmap[destination_]->valid = false; - LOG_NONMEMBER("cl " << destination_ << " refcnt " << hmap[destination_].use_count()); + LOG << "cl " << destination_ << " refcnt " << hmap[destination_].use_count(); hmap.erase(destination_); } }