GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-26 09:39:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #178 from Barenboim/master

Browse Source 
fix WFComplexClientTask::dispatch
This commit is contained in:
xiehan
2020-12-14 00:10:52 +08:00
committed by GitHub
parent ca36bd2dc5 5514ef2246
commit 05a2c28e9b
1 changed files with 13 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/factory/WFTaskFactory.inl
+13 -7
View File
@@ -403,20 +403,26 @@ void WFComplexClientTask<REQ, RESP, CTX>::router_callback(WFRouterTask *task)
template<class REQ, class RESP, typename CTX>
void WFComplexClientTask<REQ, RESP, CTX>::dispatch()
{
if (this->state == WFT_STATE_UNDEFINED)
switch (this->state)
{
case WFT_STATE_UNDEFINED:
if (this->check_request())
{
if (this->route_result_.request_object)
{
case WFT_STATE_SUCCESS:
this->set_request_object(route_result_.request_object);
this->WFClientTask<REQ, RESP>::dispatch();
return;
}
router_task_ = this->route();
series_of(this)->push_front(this);
series_of(this)->push_front(router_task_);
}
}
else if (this->state == WFT_STATE_SUCCESS)
{
this->set_request_object(route_result_.request_object);
this->WFClientTask<REQ, RESP>::dispatch();
return;
default:
break;
}
this->subtask_done();