diff --git a/src/engine.c b/src/engine.c index c34214c05b6fb45991208dd78689b58ba5d9731f..1ce6aeec95a57e93416a9b9796954fc2ece2d5de 100644 --- a/src/engine.c +++ b/src/engine.c @@ -755,7 +755,7 @@ void engine_maketasks(struct engine *e) { /* Add the space sorting tasks. */ for (int i = 0; i < e->nr_threads; i++) - scheduler_addtask(sched, task_type_psort, task_subtype_none, i, 0, NULL, + scheduler_addtask(sched, task_type_part_sort, task_subtype_none, i, 0, NULL, NULL, 0); /* Run through the highest level of cells and add pairs. */ @@ -2050,7 +2050,7 @@ void engine_init(struct engine *e, struct space *s, float dt, int nr_threads, /* Create the sorting tasks. */ for (int i = 0; i < e->nr_threads; i++) - scheduler_addtask(&e->sched, task_type_psort, task_subtype_none, i, 0, NULL, + scheduler_addtask(&e->sched, task_type_part_sort, task_subtype_none, i, 0, NULL, NULL, 0); scheduler_ranktasks(&e->sched); diff --git a/src/runner.c b/src/runner.c index 7eedb6adc72755ba12faed5429edad43d3849451..7591091b2b54ae5ce7fbea5be4e1462f783e24ef 100644 --- a/src/runner.c +++ b/src/runner.c @@ -1057,7 +1057,7 @@ void *runner_main(void *data) { case task_type_grav_down: runner_dograv_down(r, t->ci); break; - case task_type_psort: + case task_type_part_sort: space_do_parts_sort(); break; case task_type_split_cell: diff --git a/src/scheduler.c b/src/scheduler.c index 722e344b5a86b5fbdc42c7038fd3cb00e44b2ee8..d8002e8da69e3dac0c1637cbb33b78190ba17398 100644 --- a/src/scheduler.c +++ b/src/scheduler.c @@ -127,7 +127,7 @@ void scheduler_splittasks(struct scheduler *s) { } /* Skip sorting tasks. */ - if (t->type == task_type_psort) continue; + if (t->type == task_type_part_sort) continue; /* Empty task? */ if (t->ci == NULL || (t->type == task_type_pair && t->cj == NULL)) { diff --git a/src/space.c b/src/space.c index fa2541c2872c38f5000e78ef2802d9a4f719f9fc..941bbc8f48f520b809fd1ca7026e88e690c6f88a 100644 --- a/src/space.c +++ b/src/space.c @@ -582,7 +582,7 @@ void space_parts_sort(struct space *s, size_t *ind, size_t N, int min, int max, space_sort_struct.waiting = 1; /* Launch the sorting tasks. */ - engine_launch(s->e, s->e->nr_threads, (1 << task_type_psort), 0); + engine_launch(s->e, s->e->nr_threads, (1 << task_type_part_sort), 0); /* Verify space_sort_struct. */ /* for (int i = 1; i < N; i++) diff --git a/src/task.c b/src/task.c index 69109f9e6d4fe8730a317db46ea3862e65ab90b2..6e9a715760c9a32ede0191bdb0595c39b995439d 100644 --- a/src/task.c +++ b/src/task.c @@ -45,7 +45,8 @@ const char *taskID_names[task_type_count] = { "none", "sort", "self", "pair", "sub", "init", "ghost", "drift", "kick", "send", "recv", "grav_pp", - "grav_mm", "grav_up", "grav_down", "psort", "split_cell", "rewait"}; + "grav_mm", "grav_up", "grav_down", "part_sort", "gpart_sort", + "split_cell", "rewait"}; const char *subtaskID_names[task_type_count] = {"none", "density", "force", "grav"}; @@ -78,9 +79,9 @@ float task_overlap(const struct task *ta, const struct task *tb) { /* First check if any of the two tasks are of a type that don't use cells. */ if (ta == NULL || tb == NULL || ta->type == task_type_none || - ta->type == task_type_psort || ta->type == task_type_split_cell || + ta->type == task_type_part_sort || ta->type == task_type_split_cell || ta->type == task_type_rewait || tb->type == task_type_none || - tb->type == task_type_psort || tb->type == task_type_split_cell || + tb->type == task_type_part_sort || tb->type == task_type_split_cell || tb->type == task_type_rewait) return 0.0f; diff --git a/src/task.h b/src/task.h index b86631cc49bfad102302e3bab380bfb5eb8ed1e0..9c0ba6087d772d7362a98bc40a838c6fa3713166 100644 --- a/src/task.h +++ b/src/task.h @@ -45,7 +45,8 @@ enum task_types { task_type_grav_mm, task_type_grav_up, task_type_grav_down, - task_type_psort, + task_type_part_sort, + task_type_gpart_sort, task_type_split_cell, task_type_rewait, task_type_count