ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-12-06 17:27:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Notification optimizations.

Browse Source
This commit is contained in:
JoelKatz
2013-07-23 12:56:27 -07:00
parent 80db6e1228
commit 273f50a10f
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/cpp/ripple/NetworkOPs.cpp
View File

@@ -1119,6 +1119,9 @@ void NetworkOPs::pubServer ()
jvObj ["load_base"] = (mLastLoadBase = getApp().getFeeTrack ().getLoadBase ()); jvObj ["load_base"] = (mLastLoadBase = getApp().getFeeTrack ().getLoadBase ());
jvObj ["load_factor"] = (mLastLoadFactor = getApp().getFeeTrack ().getLoadFactor ()); jvObj ["load_factor"] = (mLastLoadFactor = getApp().getFeeTrack ().getLoadFactor ());
Json::FastWriter w;
std::string sObj = w.write (jvObj);
NetworkOPs::SubMapType::const_iterator it = mSubServer.begin (); NetworkOPs::SubMapType::const_iterator it = mSubServer.begin ();
while (it != mSubServer.end ()) while (it != mSubServer.end ())
@@ -1129,7 +1132,7 @@ void NetworkOPs::pubServer ()
// the deletion of subscribers with the sending of JSON data. // the deletion of subscribers with the sending of JSON data.
if (p) if (p)
{ {
p->send (jvObj, true); p->send (jvObj, sObj, true);
++it; ++it;
} }
@@ -1674,6 +1677,9 @@ void NetworkOPs::pubValidatedTransaction (Ledger::ref alAccepted, const Accepted
Json::Value jvObj = transJson (*alTx.getTxn (), alTx.getResult (), true, alAccepted); Json::Value jvObj = transJson (*alTx.getTxn (), alTx.getResult (), true, alAccepted);
jvObj["meta"] = alTx.getMeta ()->getJson (0); jvObj["meta"] = alTx.getMeta ()->getJson (0);
Json::FastWriter w;
std::string sObj = w.write (jvObj);
{ {
boost::recursive_mutex::scoped_lock sl (mMonitorLock); boost::recursive_mutex::scoped_lock sl (mMonitorLock);
@@ -1685,7 +1691,7 @@ void NetworkOPs::pubValidatedTransaction (Ledger::ref alAccepted, const Accepted
if (p) if (p)
{ {
p->send (jvObj, true); p->send (jvObj, sObj, true);
++it; ++it;
} }
else else
@@ -1700,7 +1706,7 @@ void NetworkOPs::pubValidatedTransaction (Ledger::ref alAccepted, const Accepted
if (p) if (p)
{ {
p->send (jvObj, true); p->send (jvObj, sObj, true);
++it; ++it;
} }
else else
@@ -1782,9 +1788,12 @@ void NetworkOPs::pubAccountTransaction (Ledger::ref lpCurrent, const AcceptedLed
if (alTx.isApplied ()) if (alTx.isApplied ())
jvObj["meta"] = alTx.getMeta ()->getJson (0); jvObj["meta"] = alTx.getMeta ()->getJson (0);
Json::FastWriter w;
std::string sObj = w.write (jvObj);
BOOST_FOREACH (InfoSub::ref isrListener, notify) BOOST_FOREACH (InfoSub::ref isrListener, notify)
{ {
isrListener->send (jvObj, true); isrListener->send (jvObj, sObj, true);
} }
} }
} }