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

Identify peer commands by name.

Browse Source
This commit is contained in:
JoelKatz
2013-03-06 18:37:35 -08:00
parent e219aa67bc
commit 0ce965948e
1 changed files with 20 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/cpp/ripple/Peer.cpp
View File

@@ -440,6 +440,7 @@ void Peer::processReadBuffer()
{
case ripple::mtHELLO:
{
event->reName("Peer::hello");
ripple::TMHello msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvHello(msg);
@@ -450,6 +451,7 @@ void Peer::processReadBuffer()
case ripple::mtERROR_MSG:
{
event->reName("Peer::errormessage");
ripple::TMErrorMsg msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvErrorMessage(msg);
@@ -460,6 +462,7 @@ void Peer::processReadBuffer()
case ripple::mtPING:
{
event->reName("Peer::ping");
ripple::TMPing msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvPing(msg);
@@ -470,6 +473,7 @@ void Peer::processReadBuffer()
case ripple::mtGET_CONTACTS:
{
event->reName("Peer::getcontacts");
ripple::TMGetContacts msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvGetContacts(msg);
@@ -480,6 +484,7 @@ void Peer::processReadBuffer()
case ripple::mtCONTACT:
{
event->reName("Peer::contact");
ripple::TMContact msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
@@ -491,6 +496,7 @@ void Peer::processReadBuffer()
case ripple::mtGET_PEERS:
{
event->reName("Peer::getpeers");
ripple::TMGetPeers msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
@@ -502,6 +508,7 @@ void Peer::processReadBuffer()
case ripple::mtPEERS:
{
event->reName("Peer::peers");
ripple::TMPeers msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
@@ -513,6 +520,7 @@ void Peer::processReadBuffer()
case ripple::mtSEARCH_TRANSACTION:
{
event->reName("Peer::searchtransaction");
ripple::TMSearchTransaction msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvSearchTransaction(msg);
@@ -523,6 +531,7 @@ void Peer::processReadBuffer()
case ripple::mtGET_ACCOUNT:
{
event->reName("Peer::getaccount");
ripple::TMGetAccount msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvGetAccount(msg);
@@ -533,6 +542,7 @@ void Peer::processReadBuffer()
case ripple::mtACCOUNT:
{
event->reName("Peer::account");
ripple::TMAccount msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvAccount(msg);
@@ -543,6 +553,7 @@ void Peer::processReadBuffer()
case ripple::mtTRANSACTION:
{
event->reName("Peer::transaction");
ripple::TMTransaction msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvTransaction(msg);
@@ -553,6 +564,7 @@ void Peer::processReadBuffer()
case ripple::mtSTATUS_CHANGE:
{
event->reName("Peer::statuschange");
ripple::TMStatusChange msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvStatus(msg);
@@ -563,6 +575,7 @@ void Peer::processReadBuffer()
case ripple::mtPROPOSE_LEDGER:
{
event->reName("Peer::propose");
boost::shared_ptr<ripple::TMProposeSet> msg = boost::make_shared<ripple::TMProposeSet>();
if (msg->ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvPropose(msg);
@@ -573,6 +586,7 @@ void Peer::processReadBuffer()
case ripple::mtGET_LEDGER:
{
event->reName("Peer::getledger");
ripple::TMGetLedger msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvGetLedger(msg);
@@ -583,6 +597,7 @@ void Peer::processReadBuffer()
case ripple::mtLEDGER_DATA:
{
event->reName("Peer::ledgerdata");
ripple::TMLedgerData msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvLedger(msg);
@@ -593,6 +608,7 @@ void Peer::processReadBuffer()
case ripple::mtHAVE_SET:
{
event->reName("Peer::haveset");
ripple::TMHaveTransactionSet msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvHaveTxSet(msg);
@@ -603,6 +619,7 @@ void Peer::processReadBuffer()
case ripple::mtVALIDATION:
{
event->reName("Peer::validation");
boost::shared_ptr<ripple::TMValidation> msg = boost::make_shared<ripple::TMValidation>();
if (msg->ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvValidation(msg);
@@ -624,6 +641,7 @@ void Peer::processReadBuffer()
#endif
case ripple::mtGET_OBJECTS:
{
event->reName("Peer::getobjects");
ripple::TMGetObjectByHash msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvGetObjectByHash(msg);
@@ -634,6 +652,7 @@ void Peer::processReadBuffer()
case ripple::mtPROOFOFWORK:
{
event->reName("Peer::proofofwork");
ripple::TMProofWork msg;
if (msg.ParseFromArray(&mReadbuf[HEADER_SIZE], mReadbuf.size() - HEADER_SIZE))
recvProofWork(msg);
@@ -644,6 +663,7 @@ void Peer::processReadBuffer()
default:
event->reName("Peer::unknown");
cLog(lsWARNING) << "Unknown Msg: " << type;
cLog(lsWARNING) << strHex(&mReadbuf[0], mReadbuf.size());
}