|
@@ -624,6 +624,7 @@ static int __starpu_handle_node_data_requests(struct _starpu_data_request_prio_l
|
|
|
/* Prefetch requests might have gotten promoted while in tmp list */
|
|
|
_starpu_data_request_prio_list_push_back(&new_data_requests[r->prefetch], r);
|
|
|
}
|
|
|
+ _starpu_data_request_prio_list_deinit(&local_list);
|
|
|
|
|
|
for (i = 0; i <= prefetch; i++)
|
|
|
if (!_starpu_data_request_prio_list_empty(&new_data_requests[i]))
|
|
@@ -787,6 +788,7 @@ static int _handle_pending_node_data_requests(unsigned src_node, unsigned force)
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
+ _starpu_data_request_prio_list_deinit(&local_list);
|
|
|
STARPU_PTHREAD_MUTEX_LOCK(&data_requests_pending_list_mutex[src_node]);
|
|
|
data_requests_npending[src_node] -= taken - kept;
|
|
|
if (kept)
|