From a732f397cb64b4093177b0924fbe8144cd31681f Mon Sep 17 00:00:00 2001 From: JoelKatz Date: Wed, 3 Jul 2013 09:38:22 -0700 Subject: [PATCH] Limit transaction queue size. --- src/cpp/ripple/ripple_Peer.cpp | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/cpp/ripple/ripple_Peer.cpp b/src/cpp/ripple/ripple_Peer.cpp index c0d3a57e6..e968aa6db 100644 --- a/src/cpp/ripple/ripple_Peer.cpp +++ b/src/cpp/ripple/ripple_Peer.cpp @@ -1122,8 +1122,11 @@ void PeerImp::recvTransaction (protocol::TMTransaction& packet, ScopedLock& Mast if (mCluster) flags |= SF_TRUSTED | SF_SIGGOOD; - theApp->getJobQueue ().addJob (jtTRANSACTION, "recvTransction->checkTransaction", + if (theApp->getJobQueue().getJobCount(jtTRANSACTION) < 100) + theApp->getJobQueue ().addJob (jtTRANSACTION, "recvTransction->checkTransaction", BIND_TYPE (&checkTransaction, P_1, flags, stx, boost::weak_ptr (shared_from_this ()))); + else + WriteLog(lsINFO, Peer) << " Transaction queue is full"; #ifndef TRUST_NETWORK }