From c009fc5d72d91f3f77a7040b2eca1730f2d08a00 Mon Sep 17 00:00:00 2001 From: orignal Date: Sat, 20 Dec 2014 20:16:45 -0500 Subject: [PATCH] look for LeaseSet in shared local destination --- AddressBook.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/AddressBook.cpp b/AddressBook.cpp index 1d64f038..939c258a 100644 --- a/AddressBook.cpp +++ b/AddressBook.cpp @@ -337,12 +337,12 @@ namespace client i2p::data::IdentHash ident; if (m_Book.GetIdentHash (u.host_, ident)) { - auto leaseSet = i2p::data::netdb.FindLeaseSet (ident); + const i2p::data::LeasetSet * leaseSet = i2p::data::netdb.FindLeaseSet (ident); if (!leaseSet) { i2p::data::netdb.RequestDestination (ident, true, i2p::client::context.GetSharedLocalDestination ()->GetTunnelPool ()); std::this_thread::sleep_for (std::chrono::seconds (5)); // wait for 5 seconds - leaseSet = i2p::data::netdb.FindLeaseSet (ident); + leaseSet = i2p::client::context.GetSharedLocalDestination ()->FindLeaseSet (ident); } if (leaseSet) { @@ -359,6 +359,7 @@ namespace client { std::condition_variable newDataReceived; std::mutex newDataReceivedMutex; + std::unique_lock l(newDataReceivedMutex); stream->AsyncReceive (boost::asio::buffer (buf, 4096), [&](const boost::system::error_code& ecode, std::size_t bytes_transferred) { @@ -369,7 +370,6 @@ namespace client newDataReceived.notify_one (); }, 30); // wait for 30 seconds - std::unique_lock l(newDataReceivedMutex); newDataReceived.wait (l); if (!end) end = !stream->IsOpen ();