|
@@ -969,9 +969,10 @@ unsigned _starpu_can_push_task(struct _starpu_sched_ctx *sched_ctx, struct starp
|
|
|
if(!env_window_size) return 1;
|
|
|
double window_size = atof(env_window_size);
|
|
|
|
|
|
- STARPU_PTHREAD_RWLOCK_RDLOCK(&changing_ctx_mutex[sched_ctx_id]);
|
|
|
+ starpu_pthread_rwlock_t *changing_ctx_mutex = _starpu_sched_ctx_get_changing_ctx_mutex(sched_ctx->id);
|
|
|
+ STARPU_PTHREAD_RWLOCK_RDLOCK(changing_ctx_mutex);
|
|
|
double expected_end = sched_ctx->sched_policy->simulate_push_task(task);
|
|
|
- STARPU_PTHREAD_RWLOCK_UNLOCK(&changing_ctx_mutex[sched_ctx_id]);
|
|
|
+ STARPU_PTHREAD_RWLOCK_UNLOCK(changing_ctx_mutex);
|
|
|
|
|
|
double expected_len = 0.0;
|
|
|
if(hyp_actual_start_sample[sched_ctx->id] != 0.0)
|