Skip to content

Commit

Permalink
Change Error type for mark_mui_as_* methods
Browse files Browse the repository at this point in the history
  • Loading branch information
density215 committed Jan 28, 2025
1 parent c1012dd commit 719dc2b
Showing 1 changed file with 8 additions and 4 deletions.
12 changes: 8 additions & 4 deletions src/local_array/store/custom_alloc.rs
Original file line number Diff line number Diff line change
Expand Up @@ -652,7 +652,9 @@ impl<
if log_enabled!(log::Level::Debug) {
debug!(
"{} store: Create new prefix record",
std::thread::current().name().unwrap_or("unnamed-thread")
std::thread::current()
.name()
.unwrap_or("unnamed-thread")
);
}

Expand All @@ -678,7 +680,9 @@ impl<
if log_enabled!(log::Level::Debug) {
debug!(
"{} store: Found existing prefix record for {}/{}",
std::thread::current().name().unwrap_or("unnamed-thread"),
std::thread::current()
.name()
.unwrap_or("unnamed-thread"),
prefix.get_net(),
prefix.get_len()
);
Expand Down Expand Up @@ -718,7 +722,7 @@ impl<
self.non_recursive_retrieve_prefix_mut(prefix);

if !exists {
return Err(PrefixStoreError::StoreNotReadyError);
return Err(PrefixStoreError::PrefixNotFound);
}

stored_prefix.record_map.mark_as_withdrawn_for_mui(mui);
Expand All @@ -737,7 +741,7 @@ impl<
self.non_recursive_retrieve_prefix_mut(prefix);

if !exists {
return Err(PrefixStoreError::StoreNotReadyError);
return Err(PrefixStoreError::PrefixNotFound);
}

stored_prefix.record_map.mark_as_active_for_mui(mui);
Expand Down

0 comments on commit 719dc2b

Please sign in to comment.