16728097825

Committed 04 Aug 2025 04:00PM UTC coverage: 48.355% (-35.1%) from 83.429%

Build # 16728097825

Build Type

Pull #4108

github

Committed by

web-flow

Commit Message

Merge 1b2d27fd8 into 649ba9576

Pull Request Pull Request #4108: perf[vortex-array]: use all_valid instead of `invalid_count() == 0`

Run Details

1 of 1 new or added line in 1 file covered. (100.0%)

11596 existing lines in 378 files now uncovered.

18635 of 38538 relevant lines covered (48.35%)

151786.4 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/vortex-layout/src/segments/test.rs

// SPDX-License-Identifier: Apache-2.0
// SPDX-FileCopyrightText: Copyright the Vortex contributors

use std::sync::Arc;

use futures::FutureExt;
use parking_lot::Mutex;
use vortex_buffer::{ByteBuffer, ByteBufferMut};
use vortex_error::{VortexResult, vortex_err};

use crate::segments::sink::SegmentWriter;
use crate::segments::{SegmentFuture, SegmentId, SegmentSource};

/// A dummy in-memory implementation of a segment reader and writer.
#[derive(Default, Clone)]
pub struct TestSegments {
    segments: Arc<Mutex<Vec<ByteBuffer>>>,
}

impl SegmentSource for TestSegments {
    fn request(&self, id: SegmentId, _for_whom: &Arc<str>) -> SegmentFuture {
        let buffer = self.segments.lock().get(*id as usize).cloned();
        async move { buffer.ok_or_else(|| vortex_err!("Segment not found")) }.boxed()
    }
}

impl SegmentWriter for TestSegments {
    fn put(&mut self, _segment_id: SegmentId, data: Vec<ByteBuffer>) -> VortexResult<()> {
        // Combine all the buffers since we're only a test implementation
        let mut buffer = ByteBufferMut::empty();
        for segment in data {
            buffer.extend_from_slice(segment.as_ref());
        }
        self.segments.lock().push(buffer.freeze());
        Ok(())
    }
}

1	// SPDX-License-Identifier: Apache-2.0
2	// SPDX-FileCopyrightText: Copyright the Vortex contributors
3
4	use std::sync::Arc;
5
6	use futures::FutureExt;
7	use parking_lot::Mutex;
8	use vortex_buffer::{ByteBuffer, ByteBufferMut};
9	use vortex_error::{VortexResult, vortex_err};
10
11	use crate::segments::sink::SegmentWriter;
12	use crate::segments::{SegmentFuture, SegmentId, SegmentSource};
13
14	/// A dummy in-memory implementation of a segment reader and writer.
15	#[derive(Default, Clone)]
16	pub struct TestSegments {
17	segments: Arc<Mutex<Vec<ByteBuffer>>>,
18	}
19
20	impl SegmentSource for TestSegments {
UNCOV 21	fn request(&self, id: SegmentId, _for_whom: &Arc<str>) -> SegmentFuture {	×
UNCOV 22	let buffer = self.segments.lock().get(*id as usize).cloned();	×
UNCOV 23	async move { buffer.ok_or_else(\|\| vortex_err!("Segment not found")) }.boxed()	×
UNCOV 24	}	×
25	}
26
27	impl SegmentWriter for TestSegments {
UNCOV 28	fn put(&mut self, _segment_id: SegmentId, data: Vec<ByteBuffer>) -> VortexResult<()> {	×
29	// Combine all the buffers since we're only a test implementation
UNCOV 30	let mut buffer = ByteBufferMut::empty();	×
UNCOV 31	for segment in data {	×
UNCOV 32	buffer.extend_from_slice(segment.as_ref());	×
UNCOV 33	}	×
UNCOV 34	self.segments.lock().push(buffer.freeze());	×
UNCOV 35	Ok(())	×
UNCOV 36	}	×
37	}

vortex-data / vortex / 16728097825

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous