Skip to content

Commit

Permalink
Simplify opaque node pointer casting to concrete
Browse files Browse the repository at this point in the history
**Description**
 - Remove dependency on `sptr` by adding shim functions in the
   nightly module as replacement
 - Remove some `#[inline(always)]` complete and change all other
   instances to `#[inline]`
 - Modify `count_words` example to use nul-terminated string
   internally
 - Remove the `TaggedPointer::<T>::cast` cast function in favour of
   casting directly on the resulting `NonNull<T>`

**Motivation**
 - The `sptr` crate hasn't been updated to include strict provenance
   methods for `NonNull`, see Gankra/sptr#17
 - `#[inline(always)]` is generally too strong of a requirement, I'd
   rather leave it to the compiler heuristic without strong evidence
   to the contrary.
 - The `count_words` example was failing on some inputs because of
   words that were prefixes of other words
 - The `cast` function was showing up in a hot part of the call stack
   and it seemed inefficient to carry the data tag over for the cast
   for my use-case

**Testing Done**
`./scripts/full-test.sh nightly`

See PR for benchmark results
  • Loading branch information
declanvk committed Oct 12, 2024
1 parent 7cbc24c commit d316092
Show file tree
Hide file tree
Showing 15 changed files with 259 additions and 219 deletions.
3 changes: 3 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -16,3 +16,6 @@ profile.json

# coverage info
lcov.info

# perf data
perf.data*
1 change: 0 additions & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@ autobenches = false
[dependencies]
bytemuck = { version = "1.16.1", features = ["min_const_generics"] }
paste = "1.0.15"
sptr = "0.3.2"

[features]
nightly = []
Expand Down
18 changes: 17 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -100,6 +100,22 @@ cargo +nightly fuzz coverage fuzz_tree_map_api && cargo cov -- show fuzz/target/
> index.html
```

```bash
TARGET_TRIPLE="x86_64-unknown-linux-gnu"
/home/declan/.rustup/toolchains/nightly-x86_64-unknown-linux-gnu/lib/rustlib/x86_64-unknown-linux-gnu/bin/llvm-cov show -format=html \
-instr-profile=fuzz/coverage/fuzz_tree_map_api/coverage.profdata \
-Xdemangler=rustfilt \
-ignore-filename-regex=\.cargo/registry \
fuzz/target/x86_64-unknown-linux-gnu/release/fuzz_tree_map_api
> cov.html

/home/declan/.rustup/toolchains/nightly-x86_64-unknown-linux-gnu/lib/rustlib/x86_64-unknown-linux-gnu/bin/llvm-cov show \
--instr-profile=/home/declan/repos/github/declanvk/blart/fuzz/coverage/fuzz_tree_map_api/coverage.profdata \
--show-instantiations --show-line-counts-or-regions --Xdemangler=rustfilt \
--format=html --ignore-filename-regex=/home/declan/.cargo/registry --ignore-filename-regex=/home/declan/.rustup/\
target/x86_64-unknown-linux-gnu/coverage/x86_64-unknown-linux-gnu/release/fuzz_tree_map_api > coverage.html
```

## Benchmarks

To run the benchmarks, install [`cargo-criterion`][cargo-criterion], then run:
Expand Down Expand Up @@ -134,7 +150,7 @@ curl -o data/Ulysses.txt https://www.gutenberg.org/cache/epub/4300/pg4300.txt
Then build the word count example using the `profiling` profile:

```bash
cargo build --profile profiling --exampleps
RUSTFLAGS="-C force-frame-pointers=yes" cargo build --profile profiling --examples
```

Then run the count words workload on the downloaded data while profiling:
Expand Down
3 changes: 0 additions & 3 deletions benches/tree/generated_get.rs
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ use blart::{
};
use criterion::{criterion_group, measurement::Measurement, BenchmarkGroup, Criterion};

#[inline(always)]
fn run_benchmarks<M: Measurement>(
group: &mut BenchmarkGroup<M>,
key_vec: &[Box<[u8]>],
Expand Down Expand Up @@ -38,7 +37,6 @@ fn run_benchmarks<M: Measurement>(
// - a tree node that is full and will need to grow
}

#[inline(always)]
fn setup_tree_run_benches_cleanup(
c: &mut Criterion,
keys: impl Iterator<Item = Box<[u8]>>,
Expand All @@ -60,7 +58,6 @@ fn setup_tree_run_benches_cleanup(
}
}

#[inline(always)]
fn bench(c: &mut Criterion) {
// number of keys = 256
setup_tree_run_benches_cleanup(
Expand Down
1 change: 0 additions & 1 deletion benches/tree/generated_insert.rs
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@ fn gen_group(c: &mut Criterion, group: &str, keys: Vec<Box<[u8]>>) {
});
}

#[inline(always)]
fn bench(c: &mut Criterion) {
let skewed: Vec<_> = generate_keys_skewed(u8::MAX as usize).collect();
let fixed_length: Vec<_> = generate_key_fixed_length([2; 8]).map(Box::from).collect();
Expand Down
36 changes: 21 additions & 15 deletions examples/count_words.rs
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
use argh::FromArgs;
use blart::TreeMap;
use std::{collections::BTreeMap, error::Error, fs::OpenOptions, io::Read, path::PathBuf};
use std::{
collections::BTreeMap, error::Error, ffi::CString, fs::OpenOptions, io::Read, path::PathBuf,
};

/// Count words in file
#[derive(FromArgs)]
Expand Down Expand Up @@ -50,23 +52,25 @@ fn main() -> Result<(), Box<dyn Error>> {

#[derive(Debug)]
#[allow(dead_code)] // this struct is used for its debug repr
struct WordStats<'b> {
struct WordStats {
num_unique: u64,
first_word: &'b [u8],
first_word: CString,
first_word_count: u64,
last_word: &'b [u8],
last_word: CString,
last_word_count: u64,
}

fn count_words_blart(contents: &[u8]) -> WordStats {
let mut map = TreeMap::<&[u8], u64>::new();
let mut map = TreeMap::<CString, u64>::new();

for word in contents.split_inclusive(|b| *b == SPLIT_BYTE) {
if let Some(count) = map.get_mut(word) {
*count += 1;
} else {
map.try_insert(word, 1).unwrap();
}
let word = CString::new(word).unwrap();

map.entry(word)
.and_modify(|count| {
*count += 1;
})
.or_insert(1);
}

let (first_word, first_word_count) = map
Expand All @@ -79,19 +83,21 @@ fn count_words_blart(contents: &[u8]) -> WordStats {

WordStats {
num_unique: map.len() as u64,
last_word,
last_word: last_word.clone(),
last_word_count: *last_word_count,
first_word,
first_word: first_word.clone(),
first_word_count: *first_word_count,
}
}

const SPLIT_BYTE: u8 = b' ';

fn count_words_std(contents: &[u8]) -> WordStats {
let mut map = BTreeMap::<&[u8], u64>::new();
let mut map = BTreeMap::<CString, u64>::new();

for word in contents.split_inclusive(|b| *b == SPLIT_BYTE) {
let word = CString::new(word).unwrap();

map.entry(word)
.and_modify(|count| {
*count += 1;
Expand All @@ -109,9 +115,9 @@ fn count_words_std(contents: &[u8]) -> WordStats {

WordStats {
num_unique: map.len() as u64,
last_word,
last_word: last_word.clone(),
last_word_count: *last_word_count,
first_word,
first_word: first_word.clone(),
first_word_count: *first_word_count,
}
}
28 changes: 14 additions & 14 deletions fuzz/fuzz_targets/fuzz_tree_map_api.rs
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ enum Action {

libfuzzer_sys::fuzz_target!(|actions: Vec<Action>| {
let mut tree = TreeMap::<_, u32>::new();
let mut next_key = 0;
let mut next_value = 0;

for action in actions {
match action {
Expand All @@ -58,25 +58,25 @@ libfuzzer_sys::fuzz_target!(|actions: Vec<Action>| {
Action::GetMinimum => {
let min = tree.first_key_value();
if let Some((_, min_value)) = min {
assert!(*min_value < next_key);
assert!(*min_value < next_value);
}
},
Action::PopMinimum => {
let min = tree.pop_first();
if let Some((_, min_value)) = min {
assert!(min_value < next_key);
assert!(min_value < next_value);
}
},
Action::GetMaximum => {
let max = tree.last_key_value();
if let Some((_, max_value)) = max {
assert!(*max_value < next_key);
assert!(*max_value < next_value);
}
},
Action::PopMaximum => {
let max = tree.pop_last();
if let Some((_, max_value)) = max {
assert!(max_value < next_key);
assert!(max_value < next_value);
}
},
Action::GetKey(key) => {
Expand Down Expand Up @@ -104,19 +104,19 @@ libfuzzer_sys::fuzz_target!(|actions: Vec<Action>| {
},
Action::Remove(key) => {
if let Some(value) = tree.remove(key.as_ref()) {
assert!(value < next_key);
assert!(value < next_value);
}
},
Action::TryInsert(key) => {
let value = next_key;
next_key += 1;
let value = next_value;
next_value += 1;

let _ = tree.try_insert(key, value);
},
Action::Extend(new_keys) => {
for key in new_keys {
let value = next_key;
next_key += 1;
let value = next_value;
next_value += 1;

let _ = tree.try_insert(key, value);
}
Expand All @@ -137,8 +137,8 @@ libfuzzer_sys::fuzz_target!(|actions: Vec<Action>| {
},
Action::Entry(ea, key) => {
if let Ok(entry) = tree.try_entry(key) {
let value = next_key;
next_key += 1;
let value = next_value;
next_value += 1;
match ea {
EntryAction::AndModify => {
entry.and_modify(|v| *v = v.saturating_sub(1));
Expand Down Expand Up @@ -174,8 +174,8 @@ libfuzzer_sys::fuzz_target!(|actions: Vec<Action>| {
},
Action::EntryRef(ea, key) => {
if let Ok(entry) = tree.try_entry_ref(&key) {
let value = next_key;
next_key += 1;
let value = next_value;
next_value += 1;
match ea {
EntryAction::AndModify => {
entry.and_modify(|v| *v = v.saturating_sub(1));
Expand Down
8 changes: 4 additions & 4 deletions src/collections/map/iterators/fuzzy.rs
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ impl StackArena {
/// SAFETY: `old` and `new` must have the same length, and be >= 1
///
/// SAFETY: `key` length + 1 == `new` or `old` length
#[inline(always)]
#[inline]
fn edit_dist(
key: &[u8],
c: u8,
Expand Down Expand Up @@ -142,7 +142,7 @@ fn edit_dist(
}

/// SAFETY: `old_row` length == `new_row` length
#[inline(always)]
#[inline]
unsafe fn swap(old_row: &mut &mut [usize], new_row: &mut &mut [MaybeUninit<usize>]) {
// SAFETY: It's safe to transmute initialized data to uninitialized
let temp = unsafe {
Expand All @@ -162,7 +162,7 @@ trait FuzzySearch<K: AsBytes, V, const PREFIX_LEN: usize> {
max_edit_dist: usize,
) -> bool;

#[inline(always)]
#[inline]
fn fuzzy_search_prefix(
&self,
key: &[u8],
Expand Down Expand Up @@ -355,7 +355,7 @@ macro_rules! gen_iter {
{
type Item = $ret;

#[inline(always)]
#[inline]
fn next(&mut self) -> Option<Self::Item> {
let mut old_row = self.old_row.as_mut();
let mut new_row = self.new_row.as_mut();
Expand Down
4 changes: 2 additions & 2 deletions src/nodes/operations/delete.rs
Original file line number Diff line number Diff line change
Expand Up @@ -401,7 +401,7 @@ where
/// - This function cannot be called concurrently with any mutating operation
/// on `root` or any child node of `root`. This function will arbitrarily
/// read to any child in the given tree.
#[inline(always)]
#[inline]
pub unsafe fn find_minimum_to_delete<K, V, const PREFIX_LEN: usize>(
root: OpaqueNodePtr<K, V, PREFIX_LEN>,
) -> DeletePoint<K, V, PREFIX_LEN> {
Expand Down Expand Up @@ -439,7 +439,7 @@ pub unsafe fn find_minimum_to_delete<K, V, const PREFIX_LEN: usize>(
/// - This function cannot be called concurrently with any mutating operation
/// on `root` or any child node of `root`. This function will arbitrarily
/// read to any child in the given tree.
#[inline(always)]
#[inline]
pub unsafe fn find_maximum_to_delete<K, V, const PREFIX_LEN: usize>(
root: OpaqueNodePtr<K, V, PREFIX_LEN>,
) -> DeletePoint<K, V, PREFIX_LEN> {
Expand Down
1 change: 1 addition & 0 deletions src/nodes/operations/insert.rs
Original file line number Diff line number Diff line change
Expand Up @@ -607,6 +607,7 @@ pub unsafe fn search_for_insert_point<K, V, const PREFIX_LEN: usize>(
where
K: AsBytes,
{
#[inline]
fn test_prefix_identify_insert<K, V, N, const PREFIX_LEN: usize>(
inner_ptr: NodePtr<PREFIX_LEN, N>,
key: &[u8],
Expand Down
4 changes: 2 additions & 2 deletions src/nodes/operations/minmax.rs
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ use crate::{ConcreteNodePtr, InnerNode, LeafNode, NodePtr, OpaqueNodePtr};
/// - This function cannot be called concurrently with any mutating operation
/// on `root` or any child node of `root`. This function will arbitrarily
/// read to any child in the given tree.
#[inline(always)]
#[inline]
pub unsafe fn minimum_unchecked<K, V, const PREFIX_LEN: usize>(
root: OpaqueNodePtr<K, V, PREFIX_LEN>,
) -> NodePtr<PREFIX_LEN, LeafNode<K, V, PREFIX_LEN>> {
Expand All @@ -31,7 +31,7 @@ pub unsafe fn minimum_unchecked<K, V, const PREFIX_LEN: usize>(
/// - This function cannot be called concurrently with any mutating operation
/// on `root` or any child node of `root`. This function will arbitrarily
/// read to any child in the given tree.
#[inline(always)]
#[inline]
pub unsafe fn maximum_unchecked<K, V, const PREFIX_LEN: usize>(
root: OpaqueNodePtr<K, V, PREFIX_LEN>,
) -> NodePtr<PREFIX_LEN, LeafNode<K, V, PREFIX_LEN>> {
Expand Down
Loading

0 comments on commit d316092

Please sign in to comment.