breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Simplify WFFacilities::ReplyGuard.

Browse Source
This commit is contained in:
Xie Han
2023-09-15 23:27:34 +08:00
parent 6c27878216
commit 744792a6d5
1 changed files with 6 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
src/manager/WFFacilities.h
View File

@@ -81,43 +81,21 @@ public:
class ReplyGuard
{
public:
ReplyGuard(SubTask *task)
ReplyGuard(SubTask *server_task)
{
SeriesWork *series = series_of(task);
SeriesWork *series = series_of(server_task);
assert(series);
assert(task == series->get_last_task());
this->cond = new Conditional(task, this);
assert(server_task == series->get_last_task());
this->cond = WFTaskFactory::create_conditional(server_task);
series->set_last_task(this->cond);
}
~ReplyGuard()
{
if (this->cond)
this->cond->signal(NULL);
this->cond->signal(NULL);
}
protected:
class Conditional : public WFConditional
{
public:
Conditional(SubTask *task, ReplyGuard *guard) :
WFConditional(task)
{
this->guard = guard;
}
/* Make it compatible with series->cancel(). */
virtual ~Conditional()
{
if (this->task)
{
this->task = NULL;
this->guard->cond = NULL;
}
}
ReplyGuard *guard;
} *cond;
WFConditional *cond;
};
private: