/
task_trigger.cc
56 lines (48 loc) · 1.29 KB
/
task_trigger.cc
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
/*
* Copyright (c) 2013 Juniper Networks, Inc. All rights reserved.
*/
#include "base/task_trigger.h"
#include "base/task.h"
class TaskTrigger::WorkerTask : public Task {
public:
explicit WorkerTask(TaskTrigger *parent)
: Task(parent->task_id_, parent->task_instance_), parent_(parent) {
}
bool Run() {
if (parent_->disabled()) {
parent_->Reset();
return true;
}
if (parent_->deferred()) {
return false;
}
bool done = (parent_->func_)();
if (done) {
parent_->Reset();
}
return done;
}
std::string Description() const { return "TaskTrigger::WorkerTask"; }
private:
TaskTrigger *parent_;
};
TaskTrigger::TaskTrigger(FunctionPtr func, int task_id, int task_instance)
: func_(func), task_id_(task_id), task_instance_(task_instance) {
trigger_ = false;
disabled_ = false;
deferred_ = false;
}
TaskTrigger::~TaskTrigger() {
assert(!trigger_);
}
void TaskTrigger::Set() {
bool current = trigger_.fetch_and_store(true);
if (!current) {
WorkerTask *task = new WorkerTask(this);
TaskScheduler *scheduler = TaskScheduler::GetInstance();
scheduler->Enqueue(task);
}
}
void TaskTrigger::Reset() {
trigger_ = false;
}