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

Protocol bugfixes.

Browse Source
This commit is contained in:
JoelKatz
2012-05-31 01:02:32 -07:00
parent 9f080e357d
commit 9d974c9f2c
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/Peer.cpp
View File

@@ -437,20 +437,20 @@ void Peer::processReadBuffer()
}
break;
case newcoin::mtLEDGER:
case newcoin::mtLEDGER_DATA:
{
newcoin::TMHaveTransactionSet msg;
newcoin::TMLedgerData msg;
if(msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvHaveTxSet(msg);
recvLedger(msg);
else std::cerr << "parse error: " << type << std::endl;
}
break;
case newcoin::mtHAVE_SET:
{
newcoin::TMLedgerData msg;
newcoin::TMHaveTransactionSet msg;
if(msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvLedger(msg);
recvHaveTxSet(msg);
else std::cerr << "parse error: " << type << std::endl;
}
break;
@@ -789,7 +789,7 @@ void Peer::recvGetLedger(newcoin::TMGetLedger& packet)
Serializer nData(128);
ledger->addRaw(nData);
reply.add_nodes()->set_nodedata(nData.getDataPtr(), nData.getLength());
PackedMessage::pointer oPacket = boost::make_shared<PackedMessage>(reply, newcoin::mtLEDGER);
PackedMessage::pointer oPacket = boost::make_shared<PackedMessage>(reply, newcoin::mtLEDGER_DATA);
sendPacket(oPacket);
return;
}
@@ -830,7 +830,7 @@ void Peer::recvGetLedger(newcoin::TMGetLedger& packet)
}
}
}
PackedMessage::pointer oPacket = boost::make_shared<PackedMessage>(reply, newcoin::mtLEDGER);
PackedMessage::pointer oPacket = boost::make_shared<PackedMessage>(reply, newcoin::mtLEDGER_DATA);
sendPacket(oPacket);
}

2
src/newcoin.proto
View File

@@ -18,7 +18,7 @@ enum MessageType {
// transaction and ledger processing
mtTRANSACTION= 30;
mtGET_LEDGER= 31;
mtLEDGER= 32;
mtLEDGER_DATA= 32;
mtPROPOSE_LEDGER= 33;
mtSTATUS_CHANGE= 34;
mtHAVE_SET= 35;