|
@@ -239,11 +239,12 @@ int starpu_data_acquire_on_node(starpu_data_handle_t handle, unsigned node, enum
|
|
.handle = handle,
|
|
.handle = handle,
|
|
.mode = mode,
|
|
.mode = mode,
|
|
.node = node,
|
|
.node = node,
|
|
- .cond = _STARPU_PTHREAD_COND_INITIALIZER,
|
|
|
|
- .lock = _STARPU_PTHREAD_MUTEX_INITIALIZER,
|
|
|
|
.finished = 0
|
|
.finished = 0
|
|
};
|
|
};
|
|
|
|
|
|
|
|
+ _STARPU_PTHREAD_COND_INIT(&wrapper.cond, NULL);
|
|
|
|
+ _STARPU_PTHREAD_MUTEX_INIT(&wrapper.lock, NULL);
|
|
|
|
+
|
|
// _STARPU_DEBUG("TAKE sequential_consistency_mutex starpu_data_acquire\n");
|
|
// _STARPU_DEBUG("TAKE sequential_consistency_mutex starpu_data_acquire\n");
|
|
_STARPU_PTHREAD_MUTEX_LOCK(&handle->sequential_consistency_mutex);
|
|
_STARPU_PTHREAD_MUTEX_LOCK(&handle->sequential_consistency_mutex);
|
|
int sequential_consistency = handle->sequential_consistency;
|
|
int sequential_consistency = handle->sequential_consistency;
|