From e8cfd1f5860338426e1523d18fec9d41e8ff8b1b Mon Sep 17 00:00:00 2001 From: JoelKatz Date: Thu, 8 Aug 2013 17:00:48 -0700 Subject: [PATCH] Cleanup. --- modules/ripple_app/ledger/LedgerMaster.cpp | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/modules/ripple_app/ledger/LedgerMaster.cpp b/modules/ripple_app/ledger/LedgerMaster.cpp index e00f230af..0b09759d1 100644 --- a/modules/ripple_app/ledger/LedgerMaster.cpp +++ b/modules/ripple_app/ledger/LedgerMaster.cpp @@ -575,9 +575,6 @@ void LedgerMaster::setFullLedger (Ledger::pointer ledger, bool isSynchronous, bo WriteLog (lsDEBUG, LedgerMaster) << "Ledger " << ledger->getLedgerSeq () << " accepted :" << ledger->getHash (); assert (ledger->peekAccountStateMap ()->getHash ().isNonZero ()); - if (getApp().getOPs ().isNeedNetworkLedger ()) - return; - boost::recursive_mutex::scoped_lock ml (mLock); mCompleteLedgers.setValue (ledger->getLedgerSeq ()); @@ -803,12 +800,16 @@ void LedgerMaster::tryPublish () } } - if (!mPubLedgers.empty () && !mPubThread) + if (!mPubLedgers.empty ()) { getApp().getOPs ().clearNeedNetworkLedger (); - mPubThread = true; - getApp().getJobQueue ().addJob (jtPUBLEDGER, "Ledger::pubThread", - BIND_TYPE (&LedgerMaster::pubThread, this)); + + if (!mPubThread) + { + mPubThread = true; + getApp().getJobQueue ().addJob (jtPUBLEDGER, "Ledger::pubThread", + BIND_TYPE (&LedgerMaster::pubThread, this)); + } mPathFindNewLedger = true; if (!mPathFindThread)