snowykami/meilisearch
1
0
Fork 0
mirror of https://github.com/meilisearch/meilisearch.git synced 2025-02-22 02:25:32 +08:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

Rename serialize_into into serialize_into_writer

Browse Source
This commit is contained in:
Clément Renault 2024-12-02 10:03:27 +01:00
parent 13f21206a6
commit db4eaf4d2d
No known key found for this signature in database
GPG Key ID: F250A4C4E3AE5F5F
4 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
crates/milli/src/heed_codec/facet/mod.rs
View File

@ -97,7 +97,7 @@ impl<'a> heed::BytesEncode<'a> for FacetGroupValueCodec {
fn bytes_encode(value: &'a Self::EItem) -> Result<Cow<'a, [u8]>, BoxedError> { fn bytes_encode(value: &'a Self::EItem) -> Result<Cow<'a, [u8]>, BoxedError> {
let mut v = vec![value.size]; let mut v = vec![value.size];
CboRoaringBitmapCodec::serialize_into(&value.bitmap, &mut v); CboRoaringBitmapCodec::serialize_into_vec(&value.bitmap, &mut v);
Ok(Cow::Owned(v)) Ok(Cow::Owned(v))
} }
} }

4
crates/milli/src/heed_codec/roaring_bitmap/cbo_roaring_bitmap_codec.rs
View File

@ -152,7 +152,7 @@ impl CboRoaringBitmapCodec {
return Ok(None); return Ok(None);
} }
Self::serialize_into(&previous, buffer); Self::serialize_into_vec(&previous, buffer);
Ok(Some(&buffer[..])) Ok(Some(&buffer[..]))
} }
} }
@ -178,7 +178,7 @@ impl heed::BytesEncode<'_> for CboRoaringBitmapCodec {
fn bytes_encode(item: &Self::EItem) -> Result<Cow<'_, [u8]>, BoxedError> { fn bytes_encode(item: &Self::EItem) -> Result<Cow<'_, [u8]>, BoxedError> {
let mut vec = Vec::with_capacity(Self::serialized_size(item)); let mut vec = Vec::with_capacity(Self::serialized_size(item));
Self::serialize_into(item, &mut vec); Self::serialize_into_vec(item, &mut vec);
Ok(Cow::Owned(vec)) Ok(Cow::Owned(vec))
} }
} }

8
crates/milli/src/update/new/extract/cache.rs
View File

@ -415,21 +415,21 @@ fn spill_entry_to_sorter(
match deladd { match deladd {
DelAddRoaringBitmap { del: Some(del), add: None } => { DelAddRoaringBitmap { del: Some(del), add: None } => {
cbo_buffer.clear(); cbo_buffer.clear();
CboRoaringBitmapCodec::serialize_into(&del, cbo_buffer); CboRoaringBitmapCodec::serialize_into_vec(&del, cbo_buffer);
value_writer.insert(DelAdd::Deletion, &cbo_buffer)?; value_writer.insert(DelAdd::Deletion, &cbo_buffer)?;
} }
DelAddRoaringBitmap { del: None, add: Some(add) } => { DelAddRoaringBitmap { del: None, add: Some(add) } => {
cbo_buffer.clear(); cbo_buffer.clear();
CboRoaringBitmapCodec::serialize_into(&add, cbo_buffer); CboRoaringBitmapCodec::serialize_into_vec(&add, cbo_buffer);
value_writer.insert(DelAdd::Addition, &cbo_buffer)?; value_writer.insert(DelAdd::Addition, &cbo_buffer)?;
} }
DelAddRoaringBitmap { del: Some(del), add: Some(add) } => { DelAddRoaringBitmap { del: Some(del), add: Some(add) } => {
cbo_buffer.clear(); cbo_buffer.clear();
CboRoaringBitmapCodec::serialize_into(&del, cbo_buffer); CboRoaringBitmapCodec::serialize_into_vec(&del, cbo_buffer);
value_writer.insert(DelAdd::Deletion, &cbo_buffer)?; value_writer.insert(DelAdd::Deletion, &cbo_buffer)?;
cbo_buffer.clear(); cbo_buffer.clear();
CboRoaringBitmapCodec::serialize_into(&add, cbo_buffer); CboRoaringBitmapCodec::serialize_into_vec(&add, cbo_buffer);
value_writer.insert(DelAdd::Addition, &cbo_buffer)?; value_writer.insert(DelAdd::Addition, &cbo_buffer)?;
} }
DelAddRoaringBitmap { del: None, add: None } => return Ok(()), DelAddRoaringBitmap { del: None, add: None } => return Ok(()),

4
crates/milli/src/update/new/words_prefix_docids.rs
View File

@ -76,7 +76,7 @@ impl WordPrefixDocids {
.union()?; .union()?;
buffer.clear(); buffer.clear();
CboRoaringBitmapCodec::serialize_into(&output, buffer); CboRoaringBitmapCodec::serialize_into_vec(&output, buffer);
index.push(PrefixEntry { prefix, serialized_length: buffer.len() }); index.push(PrefixEntry { prefix, serialized_length: buffer.len() });
file.write_all(buffer) file.write_all(buffer)
})?; })?;
@ -211,7 +211,7 @@ impl WordPrefixIntegerDocids {
.union()?; .union()?;
buffer.clear(); buffer.clear();
CboRoaringBitmapCodec::serialize_into(&output, buffer); CboRoaringBitmapCodec::serialize_into_vec(&output, buffer);
index.push(PrefixIntegerEntry { prefix, pos, serialized_length: buffer.len() }); index.push(PrefixIntegerEntry { prefix, pos, serialized_length: buffer.len() });
file.write_all(buffer)?; file.write_all(buffer)?;
} }