From 83de06272eb16d96fa582540b8ff484cdeafcba6 Mon Sep 17 00:00:00 2001
From: Pedro Gonnet <gonnet@google.com>
Date: Tue, 18 Apr 2017 23:51:05 +0200
Subject: [PATCH] only add drift tasks to local cells.
---
src/scheduler.c | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/scheduler.c b/src/scheduler.c
index 298dcc2b3d..d97fd65fe4 100644
--- a/src/scheduler.c
+++ b/src/scheduler.c
@@ -634,7 +634,7 @@ static void scheduler_splittask(struct task *t, struct scheduler *s) {
/* Create the drift and sort for ci. */
lock_lock(&ci->lock);
- if (ci->drift == NULL)
+ if (ci->drift == NULL && ci->nodeID == engine_rank)
ci->drift = scheduler_addtask(s, task_type_drift, task_subtype_none,
0, 0, ci, NULL, 0);
if (ci->sorts == NULL)
@@ -647,7 +647,7 @@ static void scheduler_splittask(struct task *t, struct scheduler *s) {
/* Create the sort for cj. */
lock_lock(&cj->lock);
- if (cj->drift == NULL)
+ if (cj->drift == NULL && cj->nodeID == engine_rank)
cj->drift = scheduler_addtask(s, task_type_drift, task_subtype_none,
0, 0, cj, NULL, 0);
if (cj->sorts == NULL)
--
GitLab