ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-27 14:35:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Move lock from RPCHandler to InfoSub.

Browse Source
This commit is contained in:
Stefan Thomas
2012-11-10 15:16:30 -08:00
parent a92202c7e4
commit b6bbef84cf
3 changed files with 7 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/cpp/ripple/NetworkOPs.h
View File

@@ -33,9 +33,12 @@ protected:
boost::unordered_set<RippleAddress> mSubAccountInfo;
boost::unordered_set<RippleAddress> mSubAccountTransaction;
boost::mutex mLock;
public:
void insertSubAccountInfo(RippleAddress addr)
{
boost::mutex::scoped_lock sl(mLock);
mSubAccountInfo.insert(addr);
}
};

8
src/cpp/ripple/RPCHandler.cpp
View File

@@ -2023,8 +2023,6 @@ Json::Value RPCHandler::doSubscribe(const Json::Value& jvRequest)
jvResult["error"] = "malformedAccount";
}else
{
boost::mutex::scoped_lock sl(mLock);
BOOST_FOREACH(const RippleAddress& naAccountID, usnaAccoundIds)
{
isCurrent->insertSubAccountInfo(naAccountID);
@@ -2043,8 +2041,6 @@ Json::Value RPCHandler::doSubscribe(const Json::Value& jvRequest)
jvResult["error"] = "malformedAccount";
}else
{
boost::mutex::scoped_lock sl(mLock);
BOOST_FOREACH(const RippleAddress& naAccountID, usnaAccoundIds)
{
isCurrent->insertSubAccountInfo(naAccountID);
@@ -2101,8 +2097,6 @@ Json::Value RPCHandler::doUnsubscribe(const Json::Value& jvRequest)
jvResult["error"] = "malformedAccount";
}else
{
boost::mutex::scoped_lock sl(mLock);
BOOST_FOREACH(const RippleAddress& naAccountID, usnaAccoundIds)
{
isCurrent->insertSubAccountInfo(naAccountID);
@@ -2121,8 +2115,6 @@ Json::Value RPCHandler::doUnsubscribe(const Json::Value& jvRequest)
jvResult["error"] = "malformedAccount";
}else
{
boost::mutex::scoped_lock sl(mLock);
BOOST_FOREACH(const RippleAddress& naAccountID, usnaAccoundIds)
{
isCurrent->insertSubAccountInfo(naAccountID);

1
src/cpp/ripple/RPCHandler.h
View File

@@ -8,7 +8,6 @@ class RPCHandler
{
NetworkOPs* mNetOps;
InfoSub* isCurrent;
boost::mutex mLock;
typedef Json::Value (RPCHandler::*doFuncPtr)(const Json::Value &params);
enum {