ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-11-25 04:55:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Always use co-routines:

Browse Source 
This permits RPC handlers to suspend and reschedule:
This commit is contained in:
JoelKatz
2015-06-17 12:39:28 -07:00
committed by Vinnie Falco
parent 48d6a4ab6a
commit 3d6e76046c
3 changed files with 6 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/ripple/server/impl/ServerHandlerImp.cpp
View File

@@ -181,24 +181,12 @@ ServerHandlerImp::onRequest (HTTP::Session& session)
auto detach = session.detach();
if (setup_.yieldStrategy.useCoroutines ==
RPC::YieldStrategy::UseCoroutines::yes)
{
RPC::SuspendCallback suspend (
[this, detach] (RPC::Suspend const& suspend) {
processSession (detach, suspend);
});
RPC::Coroutine coroutine (suspend);
coroutine.run();
}
else
{
m_jobQueue.addJob (
jtCLIENT, "RPC-Client",
[=] (Job&) {
processSession (detach, RPC::Suspend());
});
}
RPC::SuspendCallback suspend (
[this, detach] (RPC::Suspend const& suspend) {
processSession (detach, suspend);
});
RPC::Coroutine coroutine (suspend);
coroutine.run();
}
void