ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-12-06 17:27:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Updates to support the new HaveTXSet message.

Browse Source
This commit is contained in:
JoelKatz
2012-06-07 12:26:12 -07:00
parent 6c49630bf6
commit 2f7beb970f
3 changed files with 12 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/Peer.cpp
View File

@@ -636,17 +636,16 @@ void Peer::recvPropose(newcoin::TMProposeSet& packet)
void Peer::recvHaveTxSet(newcoin::TMHaveTransactionSet& packet)
{
std::vector<uint256> hashes;
for (int i = 0; i < packet.hashes_size(); ++i)
// FIXME: We should have some limit on the number of HaveTxSet messages a peer can send us
// per consensus pass, to keep a peer from running up our memory without limit
uint256 hashes;
if (packet.hash().size() != (256 / 8))
{
if (packet.hashes(i).size() == 32)
{
uint256 hash;
memcpy(hash.begin(), packet.hashes(i).data(), 32);
hashes.push_back(hash);
}
punishPeer(PP_INVALID_REQUEST);
return;
}
if (hashes.empty() || !theApp->getOPs().hasTXSet(shared_from_this(), hashes))
memcpy(hashes.begin(), packet.hash().data(), 32);
if (!theApp->getOPs().hasTXSet(shared_from_this(), hashes, packet.status()))
punishPeer(PP_UNWANTED_DATA);
}
@@ -846,9 +845,9 @@ void Peer::recvGetLedger(newcoin::TMGetLedger& packet)
node->set_nodedata(&rawNodeIterator->front(), rawNodeIterator->size());
++count;
}
Log(lsTRACE) << "GetNodeFat: sending " << count << " nodes";
}
}
if (packet.has_requestcookie()) reply.set_requestcookie(packet.requestcookie());
PackedMessage::pointer oPacket = boost::make_shared<PackedMessage>(reply, newcoin::mtLEDGER_DATA);
Log(lsTRACE) << "sending reply";
sendPacket(oPacket);