Commit f7c2b4e0 by Tobias Langer

Start task with deadline policy.

parent 33a1d208
...@@ -183,7 +183,12 @@ static void TaskStarter() ...@@ -183,7 +183,12 @@ static void TaskStarter()
task_arguments[i][count - 1] = std::make_pair(i,count); task_arguments[i][count - 1] = std::make_pair(i,count);
auto job = node.GetJob(ACTION_ID + i + 1, DOMAIN_ID); auto job = node.GetJob(ACTION_ID + i + 1, DOMAIN_ID);
int tmp; auto t = node.Start(job, &task_arguments[i][count - 1], &tmp); /* Detached TaskAttribute so we don't have to wait for task completion. */
embb::mtapi::TaskAttributes detached_attribute;
// detached_attribute.SetDetached(true);
detached_attribute.SetPolicy(deadline_policy[i]);
int tmp; auto t = node.Start(job, &task_arguments[i][count - 1], &tmp, detached_attribute);
/* Store task to wait for it. */ /* Store task to wait for it. */
running.push_back(t); running.push_back(t);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment