Skip to content

Commit 88567cf

Browse files
committed
ensore on device
Signed-off-by: Andrew Duffy <andrew@a10y.dev>
1 parent eff523b commit 88567cf

3 files changed

Lines changed: 3 additions & 7 deletions

File tree

vortex-cuda/src/kernel/encodings/bitpacked.rs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,18 +18,15 @@ use vortex::array::match_each_integer_ptype;
1818
use vortex::dtype::NativePType;
1919
use vortex::encodings::fastlanes::BitPacked;
2020
use vortex::encodings::fastlanes::BitPackedArray;
21-
use vortex::encodings::fastlanes::BitPackedArrayExt;
2221
use vortex::encodings::fastlanes::BitPackedDataParts;
2322
use vortex::encodings::fastlanes::unpack_iter::BitPacked as BitPackedUnpack;
2423
use vortex::error::VortexResult;
2524
use vortex::error::vortex_ensure;
2625
use vortex::error::vortex_err;
27-
use vortex_array::patches::Patches;
2826
use vortex_error::vortex_bail;
2927

3028
use crate::CudaBufferExt;
3129
use crate::CudaDeviceBuffer;
32-
use crate::executor::CudaArrayExt;
3330
use crate::executor::CudaExecute;
3431
use crate::executor::CudaExecutionCtx;
3532
use crate::kernel::patches::gpu::GPUPatches;

vortex-cuda/src/kernel/encodings/for_.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ use vortex::array::match_each_integer_ptype;
1818
use vortex::array::match_each_native_simd_ptype;
1919
use vortex::dtype::NativePType;
2020
use vortex::encodings::fastlanes::BitPacked;
21-
use vortex::encodings::fastlanes::BitPackedArrayExt;
2221
use vortex::encodings::fastlanes::FoR;
2322
use vortex::encodings::fastlanes::FoRArray;
2423
use vortex::encodings::fastlanes::FoRArrayExt;

vortex-cuda/src/kernel/encodings/patched.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -98,9 +98,9 @@ impl CudaExecute for PatchedExecutor {
9898
bitpacked.into_owned(),
9999
P::default(),
100100
Some(DevicePatches {
101-
lane_offsets,
102-
indices: patch_indices,
103-
values: patch_values,
101+
lane_offsets: ctx.ensure_on_device(lane_offsets).await?,
102+
indices: ctx.ensure_on_device(patch_indices).await?,
103+
values: ctx.ensure_on_device(patch_values).await?,
104104
}),
105105
ctx,
106106
)

0 commit comments

Comments
 (0)