mirror of
https://github.com/Xahau/xahaud.git
synced 2025-12-06 17:27:52 +00:00
Clean this up a bit.
This commit is contained in:
@@ -51,7 +51,7 @@ void LedgerAcquire::peerHas(Peer::pointer ptr)
|
|||||||
it=mPeers.erase(it);
|
it=mPeers.erase(it);
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
if(pr==ptr) return; // we already have this peer
|
if(pr->samePeer(ptr)) return; // we already have this peer
|
||||||
++it;
|
++it;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -69,7 +69,7 @@ void LedgerAcquire::badPeer(Peer::pointer ptr)
|
|||||||
it=mPeers.erase(it);
|
it=mPeers.erase(it);
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
if(pr==ptr)
|
if(ptr->samePeer(pr))
|
||||||
{ // We found a pointer to the bad peer
|
{ // We found a pointer to the bad peer
|
||||||
mPeers.erase(it);
|
mPeers.erase(it);
|
||||||
return;
|
return;
|
||||||
|
|||||||
3
Peer.h
3
Peer.h
@@ -35,7 +35,6 @@ protected:
|
|||||||
void processReadBuffer();
|
void processReadBuffer();
|
||||||
void start_read_header();
|
void start_read_header();
|
||||||
void start_read_body(unsigned msg_len);
|
void start_read_body(unsigned msg_len);
|
||||||
|
|
||||||
|
|
||||||
void sendPacketForce(PackedMessage::pointer packet);
|
void sendPacketForce(PackedMessage::pointer packet);
|
||||||
|
|
||||||
@@ -77,6 +76,8 @@ public:
|
|||||||
|
|
||||||
void connected(const boost::system::error_code& error);
|
void connected(const boost::system::error_code& error);
|
||||||
void detach();
|
void detach();
|
||||||
|
bool samePeer(Peer::pointer p) { return samePeer(*p); }
|
||||||
|
bool samePeer(const Peer& p) { return this == &p; }
|
||||||
|
|
||||||
void sendPacket(PackedMessage::pointer packet);
|
void sendPacket(PackedMessage::pointer packet);
|
||||||
void sendLedgerProposal(Ledger::pointer ledger);
|
void sendLedgerProposal(Ledger::pointer ledger);
|
||||||
|
|||||||
Reference in New Issue
Block a user