Explorar o código

followup to r2394

Nathalie Furmento %!s(int64=15) %!d(string=hai) anos
pai
achega
8aeea06d7f
Modificáronse 1 ficheiros con 6 adicións e 14 borrados
  1. 6 14
      src/datawizard/interfaces/block_interface.c

+ 6 - 14
src/datawizard/interfaces/block_interface.c

@@ -721,24 +721,16 @@ static int copy_ram_to_opencl_async(void *src_interface, unsigned src_node __att
 {
 {
 	starpu_block_interface_t *src_block = src_interface;
 	starpu_block_interface_t *src_block = src_interface;
 	starpu_block_interface_t *dst_block = dst_interface;
 	starpu_block_interface_t *dst_block = dst_interface;
-        int err,ret=EAGAIN;
+        int err,ret;
 
 
 	/* XXX non contiguous buffers are not properly supported yet. (TODO) */
 	/* XXX non contiguous buffers are not properly supported yet. (TODO) */
 	STARPU_ASSERT((src_block->nx == src_block->ldy) && (src_block->ldy == dst_block->ldy));
 	STARPU_ASSERT((src_block->nx == src_block->ldy) && (src_block->ldy == dst_block->ldy));
 
 
-	err = _starpu_opencl_copy_to_opencl((void*)src_block->ptr, (cl_mem)dst_block->dev_handle,
-                                            src_block->nx*src_block->ny*src_block->nz*src_block->elemsize,
-                                            dst_block->offset, (cl_event*)_event);
-        if (STARPU_UNLIKELY(err)) {
-                if (_event) {
-                        err = _starpu_opencl_copy_to_opencl((void*)src_block->ptr, (cl_mem)dst_block->dev_handle,
-                                                            src_block->nx*src_block->ny*src_block->nz*src_block->elemsize,
-                                                            dst_block->offset, NULL);
-                        ret = 0;
-                }
-                if (STARPU_UNLIKELY(err))
-                        STARPU_OPENCL_REPORT_ERROR(err);
-        }
+	err = _starpu_opencl_copy_to_opencl_async_sync((void*)src_block->ptr, (cl_mem)dst_block->dev_handle,
+                                                       src_block->nx*src_block->ny*src_block->nz*src_block->elemsize,
+                                                       dst_block->offset, (cl_event*)_event, &ret);
+        if (STARPU_UNLIKELY(err))
+                STARPU_OPENCL_REPORT_ERROR(err);
 
 
 	STARPU_TRACE_DATA_COPY(src_node, dst_node, src_block->nx*src_block->ny*src_block->nz*src_block->elemsize);
 	STARPU_TRACE_DATA_COPY(src_node, dst_node, src_block->nx*src_block->ny*src_block->nz*src_block->elemsize);