fixed offsets and views

Author: VarLad

lib/cl/state.jl

@@ -180,6 +180,17 @@ function default_memory_backend(dev::Device)
         caps.coarse_grain_buffer
     end
 
+    if haskey(ENV, "JULIA_OPENCL_BACKEND") && ENV["JULIA_OPENCL_BACKEND"] in ["usm", "bda", "svm"]
+        user_backend = ENV["JULIA_OPENCL_BACKEND"]
+        if user_backend == "usm" && usm
+            return USMBackend()
+        elseif user_backend == "bda" && bda
+            return BDABackend()
+        elseif user_backend == "svm" && svm
+            return SVMBackend()
+        end
+    end
+     
     if usm
         USMBackend()
     else

src/array.jl

@@ -384,11 +384,11 @@ for (srcty, dstty) in [(:Array, :CLArray), (:CLArray, :Array), (:CLArray, :CLArr
                     cl.enqueue_svm_copy(pointer(dst, dst_off), pointer(src, src_off), nbytes; blocking)
                 elseif memtype(device_array) == cl.BufferDeviceMemory
                     if src isa CLArray && dst isa CLArray
-                        cl.enqueue_bda_copy(convert(cl.cl_mem, dst.data[]), (dst_off - 1) * sizeof(T), convert(cl.cl_mem, src.data[]), (src_off - 1) * sizeof(T), nbytes; blocking)
+                        cl.enqueue_bda_copy(convert(cl.cl_mem, dst.data[]), (dst.offset * Base.elsize(dst)) + (dst_off - 1) * sizeof(T), convert(cl.cl_mem, src.data[]), (src.offset * Base.elsize(src)) + (src_off - 1) * sizeof(T), nbytes; blocking)
                     elseif dst isa CLArray
-                        cl.enqueue_bda_write(convert(cl.cl_mem, dst.data[]), (dst_off - 1) * sizeof(T), pointer(src, src_off), nbytes; blocking)
+                        cl.enqueue_bda_write(convert(cl.cl_mem, dst.data[]), (dst.offset * Base.elsize(dst)) + (dst_off - 1) * sizeof(T), pointer(src, src_off), nbytes; blocking)
                     elseif src isa CLArray
-                        cl.enqueue_bda_read(pointer(dst, dst_off), convert(cl.cl_mem, src.data[]), (src_off - 1) * sizeof(T), nbytes; blocking)
+                        cl.enqueue_bda_read(pointer(dst, dst_off), convert(cl.cl_mem, src.data[]), (src.offset * Base.elsize(src)) + (src_off - 1) * sizeof(T), nbytes; blocking)
                     end
                 else
                     cl.enqueue_usm_copy(pointer(dst, dst_off), pointer(src, src_off), nbytes; blocking)
@@ -433,7 +433,7 @@ function Base.fill!(A::DenseCLArray{T}, val) where {T}
             if memtype(A) == cl.SharedVirtualMemory
                 cl.enqueue_svm_fill(pointer(A), convert(T, val), length(A))
             elseif memtype(A) == cl.BufferDeviceMemory
-                cl.enqueue_bda_fill(convert(cl.cl_mem, A.data[]), 0, convert(T, val), length(A))
+                cl.enqueue_bda_fill(convert(cl.cl_mem, A.data[]), A.offset * Base.elsize(A), convert(T, val), length(A))
             else
                 cl.enqueue_usm_fill(pointer(A), convert(T, val), length(A))
             end
@@ -514,7 +514,7 @@ function Base.resize!(a::CLVector{T}, n::Integer) where {T}
                 if memtype(a) == cl.SharedVirtualMemory
                     cl.enqueue_svm_copy(ptr, pointer(a), m*sizeof(T); blocking=false)
                 elseif memtype(a) == cl.BufferDeviceMemory
-                    cl.enqueue_bda_copy(convert(cl.cl_mem, mem), 0, convert(cl.cl_mem, a.data[]), 0, m*sizeof(T); blocking=false)
+                    cl.enqueue_bda_copy(convert(cl.cl_mem, mem), 0, convert(cl.cl_mem, a.data[]), a.offset * Base.elsize(a), m*sizeof(T); blocking=false)
                 else
                     cl.enqueue_usm_copy(ptr, pointer(a), m*sizeof(T); blocking=false)
                 end