From 0ce965948e08c06021cc71f3afaf0fb793e8bf14 Mon Sep 17 00:00:00 2001
From: JoelKatz <DavidJoelSchwartz@GMail.com>
Date: Wed, 6 Mar 2013 18:37:35 -0800
Subject: [PATCH] Identify peer commands by name.

---
 src/cpp/ripple/Peer.cpp | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/src/cpp/ripple/Peer.cpp b/src/cpp/ripple/Peer.cpp
index 122228323a..2fba475cb4 100644
--- a/src/cpp/ripple/Peer.cpp
+++ b/src/cpp/ripple/Peer.cpp
@@ -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());
 		}