diff --git a/src/cpp/ripple/RPCSub.cpp b/src/cpp/ripple/RPCSub.cpp index c4ecc609cf..cc043a9f72 100644 --- a/src/cpp/ripple/RPCSub.cpp +++ b/src/cpp/ripple/RPCSub.cpp @@ -55,9 +55,11 @@ void RPCSub::sendThread() // Send outside of the lock. if (bSend) { - // Drop result. try { + cLog(lsDEBUG) << boost::str(boost::format("callRPC calling: %s") % mIp); + + // Drop result. (void) callRPC(mIp, mPort, mUsername, mPassword, mPath, "event", jvEvent); } catch (const std::exception& e) @@ -76,9 +78,12 @@ void RPCSub::send(const Json::Value& jvObj) { // Drop the previous event. + cLog(lsDEBUG) << boost::str(boost::format("callRPC drop")); mDeque.pop_back(); } + cLog(lsDEBUG) << boost::str(boost::format("callRPC push: %s") % jvObj); + mDeque.push_back(std::make_pair(mSeq++, jvObj)); if (!mSending) @@ -86,6 +91,7 @@ void RPCSub::send(const Json::Value& jvObj) // Start a sending thread. mSending = true; + cLog(lsDEBUG) << boost::str(boost::format("callRPC start"); boost::thread(boost::bind(&RPCSub::sendThread, this)).detach(); } }