mirror of
https://github.com/XRPLF/rippled.git
synced 2025-12-06 17:27:55 +00:00
Use JobQueue for RPCSub instead of boost::thread
This commit is contained in:
2
TODO.txt
2
TODO.txt
@@ -40,6 +40,8 @@ David Feature:
|
|||||||
|
|
||||||
--------------------------------------------------------------------------------
|
--------------------------------------------------------------------------------
|
||||||
|
|
||||||
|
- Add convenience variadic functions to JobQueue that do the bind for you
|
||||||
|
|
||||||
- Consolidate databases
|
- Consolidate databases
|
||||||
|
|
||||||
- Figure out why we need WAL sqlite mode if we no longer use sqlite for the node store
|
- Figure out why we need WAL sqlite mode if we no longer use sqlite for the node store
|
||||||
|
|||||||
@@ -112,8 +112,8 @@ void RPCSub::send (const Json::Value& jvObj, bool broadcast)
|
|||||||
mSending = true;
|
mSending = true;
|
||||||
|
|
||||||
WriteLog (lsINFO, RPCSub) << boost::str (boost::format ("callRPC start"));
|
WriteLog (lsINFO, RPCSub) << boost::str (boost::format ("callRPC start"));
|
||||||
boost::thread (BIND_TYPE (&RPCSub::sendThread, this)).detach ();
|
|
||||||
|
getApp().getJobQueue ().addJob (
|
||||||
|
jtCLIENT, "RPCSub::sendThread", BIND_TYPE (&RPCSub::sendThread, this));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// vim:ts=4
|
|
||||||
|
|||||||
Reference in New Issue
Block a user