From 9c6d073d89af82858edada7252abded36d65791c Mon Sep 17 00:00:00 2001 From: Arthur Britto Date: Mon, 14 Jan 2013 21:21:22 -0800 Subject: [PATCH] More logging for RPC subscribe. --- src/cpp/ripple/RPCSub.cpp | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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(); } }