Skip to content

Commit b9ac775

Browse files
committed
fix: update BitPacked::encode calls for new ExecutionCtx parameter
Signed-off-by: Alexander Droste <alexander.droste@protonmail.com>
1 parent bd547a0 commit b9ac775

1 file changed

Lines changed: 12 additions & 12 deletions

File tree

  • vortex-cuda/src/dynamic_dispatch

vortex-cuda/src/dynamic_dispatch/mod.rs

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -2137,7 +2137,7 @@ mod tests {
21372137
.collect();
21382138

21392139
let prim = PrimitiveArray::new(Buffer::from(values.clone()), NonNullable);
2140-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2140+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
21412141
assert!(bp.patches().is_some(), "expected patches");
21422142

21432143
// Slice crossing chunk boundaries.
@@ -2174,7 +2174,7 @@ mod tests {
21742174
let all_values: Vec<u32> = residuals.iter().map(|&v| v + reference).collect();
21752175

21762176
let prim = PrimitiveArray::new(Buffer::from(residuals), NonNullable);
2177-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2177+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
21782178
assert!(bp.patches().is_some(), "expected patches");
21792179
let for_arr = FoR::try_new(bp.into_array(), Scalar::from(reference))?;
21802180

@@ -2319,7 +2319,7 @@ mod tests {
23192319
.collect();
23202320

23212321
let prim = PrimitiveArray::new(Buffer::from(values.clone()), NonNullable);
2322-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2322+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
23232323
assert!(bp.patches().is_some(), "expected patches");
23242324

23252325
let cuda_ctx = CudaSession::create_execution_ctx(&VortexSession::empty())?;
@@ -2348,7 +2348,7 @@ mod tests {
23482348
let expected: Vec<u32> = residuals.iter().map(|&v| v + reference).collect();
23492349

23502350
let prim = PrimitiveArray::new(Buffer::from(residuals), NonNullable);
2351-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2351+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
23522352
assert!(bp.patches().is_some(), "expected patches");
23532353
let for_arr = FoR::try_new(bp.into_array(), Scalar::from(reference))?;
23542354

@@ -2406,7 +2406,7 @@ mod tests {
24062406
.collect();
24072407

24082408
let prim = PrimitiveArray::new(Buffer::from(values.clone()), NonNullable);
2409-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2409+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
24102410
assert!(bp.patches().is_some(), "expected patches");
24112411

24122412
let mut cuda_ctx = CudaSession::create_execution_ctx(&VortexSession::empty())?;
@@ -2435,7 +2435,7 @@ mod tests {
24352435
.collect();
24362436

24372437
let prim = PrimitiveArray::new(Buffer::from(values.clone()), NonNullable);
2438-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2438+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
24392439
assert!(bp.patches().is_some(), "expected patches");
24402440

24412441
let mut cuda_ctx = CudaSession::create_execution_ctx(&VortexSession::empty())?;
@@ -2464,7 +2464,7 @@ mod tests {
24642464
.collect();
24652465

24662466
let prim = PrimitiveArray::new(Buffer::from(values.clone()), NonNullable);
2467-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2467+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
24682468
assert!(bp.patches().is_some(), "expected patches");
24692469

24702470
let mut cuda_ctx = CudaSession::create_execution_ctx(&VortexSession::empty())?;
@@ -2496,7 +2496,7 @@ mod tests {
24962496
let expected: Vec<u32> = codes.iter().map(|&c| dict_values[c as usize]).collect();
24972497

24982498
let codes_prim = PrimitiveArray::new(Buffer::from(codes), NonNullable);
2499-
let codes_bp = BitPacked::encode(&codes_prim.into_array(), bit_width)?;
2499+
let codes_bp = BitPacked::encode(&codes_prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
25002500
assert!(codes_bp.patches().is_some(), "expected patches on codes");
25012501

25022502
let values_prim = PrimitiveArray::new(Buffer::from(dict_values), NonNullable);
@@ -2524,7 +2524,7 @@ mod tests {
25242524
values[2048] = 4000; // start of chunk 2
25252525

25262526
let prim = PrimitiveArray::new(Buffer::from(values.clone()), NonNullable);
2527-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2527+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
25282528
assert!(bp.patches().is_some(), "expected patches");
25292529

25302530
let cuda_ctx = CudaSession::create_execution_ctx(&VortexSession::empty())?;
@@ -2552,7 +2552,7 @@ mod tests {
25522552
.collect();
25532553

25542554
let prim = PrimitiveArray::new(Buffer::from(values.clone()), NonNullable);
2555-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2555+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
25562556
assert!(bp.patches().is_some(), "expected patches");
25572557

25582558
let cuda_ctx = CudaSession::create_execution_ctx(&VortexSession::empty())?;
@@ -2589,7 +2589,7 @@ mod tests {
25892589
let prim = PrimitiveArray::from_option_iter(values.iter().copied());
25902590
let cpu = crate::canonicalize_cpu(prim.clone())?.into_array();
25912591

2592-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2592+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
25932593
assert!(bp.patches().is_some(), "expected patches");
25942594

25952595
let gpu = try_gpu_dispatch(&bp.into_array(), &mut cuda_ctx)
@@ -2612,7 +2612,7 @@ mod tests {
26122612
let values: Vec<u32> = (0..len).map(|i| (i as u32) + 2).collect();
26132613

26142614
let prim = PrimitiveArray::new(Buffer::from(values.clone()), NonNullable);
2615-
let bp = BitPacked::encode(&prim.into_array(), bit_width)?;
2615+
let bp = BitPacked::encode(&prim.into_array(), bit_width, &mut LEGACY_SESSION.create_execution_ctx())?;
26162616
assert!(bp.patches().is_some(), "expected patches");
26172617

26182618
let cuda_ctx = CudaSession::create_execution_ctx(&VortexSession::empty())?;

0 commit comments

Comments
 (0)