From 537b0f1088f05f63a71392775345b7c094234ee2 Mon Sep 17 00:00:00 2001 From: JoelKatz Date: Wed, 3 Jul 2013 09:43:21 -0700 Subject: [PATCH] Temporary workaround. --- src/cpp/ripple/ripple_Peer.cpp | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/cpp/ripple/ripple_Peer.cpp b/src/cpp/ripple/ripple_Peer.cpp index e968aa6db..2daddf52c 100644 --- a/src/cpp/ripple/ripple_Peer.cpp +++ b/src/cpp/ripple/ripple_Peer.cpp @@ -1122,11 +1122,13 @@ void PeerImp::recvTransaction (protocol::TMTransaction& packet, ScopedLock& Mast if (mCluster) flags |= SF_TRUSTED | SF_SIGGOOD; - if (theApp->getJobQueue().getJobCount(jtTRANSACTION) < 100) + if (theApp->getJobQueue().getJobCount(jtTRANSACTION) > 100) + WriteLog(lsINFO, Peer) << "Transaction queue is full"; + else if (theApp->getLedgerMaster()->getValidatedLedgerAge() > 240) + WriteLog(lsINFO, Peer) << "No new transactions until synchronized"; + else 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 }