ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-12-06 17:27:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove some functionality that belongs in ConnectionPool

Browse Source
This commit is contained in:
JoelKatz
2012-01-19 10:02:34 -08:00
parent 94e4e1d04b
commit 805990618e
2 changed files with 0 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
PeerDoor.cpp
View File

@@ -34,37 +34,3 @@ void PeerDoor::handleConnect(Peer::pointer new_connection,
startListening(); startListening();
} }
bool PeerDoor::addToMap(const uint160& hanko, Peer::pointer peer)
{
boost::mutex::scoped_lock sl(peerLock);
return peerMap.insert(std::make_pair(hanko, peer)).second;
}
bool PeerDoor::delFromMap(const uint160& hanko, Peer::pointer peer)
{
boost::mutex::scoped_lock sl(peerLock);
std::map<uint160, Peer::pointer>::iterator it=peerMap.find(hanko);
if((it==peerMap.end()) || (it->first!=hanko)) return false;
peerMap.erase(it);
return true;
}
Peer::pointer PeerDoor::findInMap(const uint160& hanko)
{
boost::mutex::scoped_lock sl(peerLock);
std::map<uint160, Peer::pointer>::iterator it=peerMap.find(hanko);
if(it==peerMap.end()) return Peer::pointer();
return it->second;
}
bool PeerDoor::inMap(const uint160& hanko)
{
boost::mutex::scoped_lock sl(peerLock);
return peerMap.find(hanko) != peerMap.end();
}
std::map<uint160, Peer::pointer> PeerDoor::getAllConnected()
{
boost::mutex::scoped_lock sl(peerLock);
return peerMap;
}

12
PeerDoor.h
View File

@@ -2,7 +2,6 @@
#include <set> #include <set>
#include <boost/asio.hpp> #include <boost/asio.hpp>
#include <boost/thread/mutex.hpp>
#include "Peer.h" #include "Peer.h"
@@ -17,17 +16,6 @@ class PeerDoor
void handleConnect(Peer::pointer new_connection, void handleConnect(Peer::pointer new_connection,
const boost::system::error_code& error); const boost::system::error_code& error);
boost::mutex peerLock;
std::map<uint160, Peer::pointer> peerMap;
public: public:
PeerDoor(boost::asio::io_service& io_service); PeerDoor(boost::asio::io_service& io_service);
// hanko->peer mapping functions
bool inMap(const uint160& hanko);
bool addToMap(const uint160& hanko, Peer::pointer peer);
bool delFromMap(const uint160& hanko, Peer::pointer peer);
Peer::pointer findInMap(const uint160& hanko);
std::map<uint160, Peer::pointer> getAllConnected();
}; };