ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-20 19:15:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Skeleton for accepting cluster messages.

Browse Source
This commit is contained in:
JoelKatz
2013-07-09 10:17:11 -07:00
parent cc8af2275d
commit 08af000895
1 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/cpp/ripple/ripple_Peer.cpp
View File

@@ -160,6 +160,7 @@ private:
void sendHello (); void sendHello ();
void recvHello (protocol::TMHello & packet); void recvHello (protocol::TMHello & packet);
void recvCluster (protocol::TMCluster & packet);
void recvTransaction (protocol::TMTransaction & packet, ScopedLock & MasterLockHolder); void recvTransaction (protocol::TMTransaction & packet, ScopedLock & MasterLockHolder);
void recvValidation (const boost::shared_ptr<protocol::TMValidation>& packet, ScopedLock & MasterLockHolder); void recvValidation (const boost::shared_ptr<protocol::TMValidation>& packet, ScopedLock & MasterLockHolder);
void recvGetValidation (protocol::TMGetValidations & packet); void recvGetValidation (protocol::TMGetValidations & packet);
@@ -670,6 +671,17 @@ void PeerImp::processReadBuffer ()
} }
break; break;
case protocol::mtCLUSTER:
{
event->reName ("PeerImp::cluster");
protocol::TMCluster msg;
if (msg.ParseFromArray (&mReadbuf[PackedMessage::kHeaderBytes], mReadbuf.size () - PackedMessage::kHeaderBytes))
recvCluster (msg);
else
WriteLog (lsWARNING, Peer) << "parse error: " << type;
}
case protocol::mtERROR_MSG: case protocol::mtERROR_MSG:
{ {
event->reName ("PeerImp::errormessage"); event->reName ("PeerImp::errormessage");
@@ -1406,6 +1418,11 @@ void PeerImp::recvValidation (const boost::shared_ptr<protocol::TMValidation>& p
#endif #endif
} }
void PeerImp::recvCluster (protocol::TMCluster& packet)
{
// WRITEME
}
void PeerImp::recvGetValidation (protocol::TMGetValidations& packet) void PeerImp::recvGetValidation (protocol::TMGetValidations& packet)
{ {
} }