ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-11-20 18:45:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Cosmetic changes.

Browse Source
This commit is contained in:
Arthur Britto
2012-06-15 16:09:17 -07:00
parent 0b60693c7a
commit 347b903393
2 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
database/SqliteDatabase.h
View File

@@ -40,5 +40,6 @@ public:
uint64 getBigInt(int colIndex); uint64 getBigInt(int colIndex);
void escape(const unsigned char* start,int size,std::string& retStr); void escape(const unsigned char* start,int size,std::string& retStr);
}; };
// vim:ts=4

9
src/ConnectionPool.cpp
View File

@@ -81,26 +81,27 @@ bool ConnectionPool::savePeer(const std::string& strIp, int iPort,char code)
return false; return false;
} }
// <-- true, if a peer is available to connect to
bool ConnectionPool::peerAvailable(std::string& strIp, int& iPort) bool ConnectionPool::peerAvailable(std::string& strIp, int& iPort)
{ {
Database* db = theApp->getWalletDB()->getDB(); Database* db = theApp->getWalletDB()->getDB();
std::vector<std::string> vstrIpPort; std::vector<std::string> vstrIpPort;
// Convert mIpMap (list of open connections) to a vector of "<ip> <port>".
{ {
boost::mutex::scoped_lock sl(mPeerLock); boost::mutex::scoped_lock sl(mPeerLock);
pipPeer ipPeer;
vstrIpPort.reserve(mIpMap.size()); vstrIpPort.reserve(mIpMap.size());
BOOST_FOREACH(ipPeer, mIpMap) BOOST_FOREACH(pipPeer ipPeer, mIpMap)
{ {
std::string& strIp = ipPeer.first.first; const std::string& strIp = ipPeer.first.first;
int iPort = ipPeer.first.second; int iPort = ipPeer.first.second;
vstrIpPort.push_back(db->escape(str(boost::format("%s %d") % strIp % iPort))); vstrIpPort.push_back(db->escape(str(boost::format("%s %d") % strIp % iPort)));
} }
} }
// Get the first IpPort entry which is not in vector and which is not scheduled for scanning.
std::string strIpPort; std::string strIpPort;
ScopedLock sl(theApp->getWalletDB()->getDBLock()); ScopedLock sl(theApp->getWalletDB()->getDBLock());