mirrors/loro
1
0
Fork 0
mirror of https://github.com/loro-dev/loro.git synced 2025-02-06 12:25:03 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

chore: rename encode changes to rle updates

Browse source
This commit is contained in:
leeeon233 2022-12-15 11:26:37 +08:00 committed by Leonzhao
parent b0b1fddef3
commit ffce7d81eb
3 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
crates/loro-core/examples/encoding.rs
View file

@ -41,7 +41,7 @@ fn main() {
let start = Instant::now();
let buf = loro
.encode(EncodeConfig::new(
EncodeMode::Changes(VersionVector::new()),
EncodeMode::RleUpdates(VersionVector::new()),
None,
))
.unwrap();
@ -67,7 +67,7 @@ fn main() {
println!("decode changes used {}ms", start.elapsed().as_millis());
let buf2 = loro
.encode(EncodeConfig::new(
EncodeMode::Changes(VersionVector::new()),
EncodeMode::RleUpdates(VersionVector::new()),
None,
))
.unwrap();

6
crates/loro-core/src/fuzz.rs
View file

@ -316,16 +316,16 @@ pub fn test_single_client_encode(mut actions: Vec<Action>) {
}
let encode_bytes = store
.encode(EncodeConfig::new(
EncodeMode::Changes(VersionVector::new()),
EncodeMode::RleUpdates(VersionVector::new()),
None,
))
.unwrap();
let json1 = store.to_json();
let mut store2 = LoroCore::new(Default::default(), None);
store2.decode(&encode_bytes);
store2.decode(&encode_bytes).unwrap();
let _encode_bytes2 = store2
.encode(EncodeConfig::new(
EncodeMode::Changes(VersionVector::new()),
EncodeMode::RleUpdates(VersionVector::new()),
None,
))
.unwrap();

8
crates/loro-core/src/log_store/encoding.rs
View file

@ -14,7 +14,7 @@ const MAGIC_BYTES: [u8; 4] = [0x6c, 0x6f, 0x72, 0x6f];
pub enum EncodeMode {
Auto(Option<VersionVector>),
Updates(VersionVector),
Changes(VersionVector),
RleUpdates(VersionVector),
Snapshot,
}
@ -72,7 +72,7 @@ impl LoroEncoder {
let self_vv = store.vv();
let diff = self_vv.diff(&vv);
if diff.left.len() > UPDATE_ENCODE_THRESHOLD {
EncodeMode::Changes(vv)
EncodeMode::RleUpdates(vv)
} else {
EncodeMode::Updates(vv)
}
@ -84,7 +84,7 @@ impl LoroEncoder {
};
let encoded = match &mode {
EncodeMode::Updates(vv) => Self::encode_updates(&store, vv),
EncodeMode::Changes(vv) => Self::encode_changes(&store, vv),
EncodeMode::RleUpdates(vv) => Self::encode_changes(&store, vv),
EncodeMode::Snapshot => Self::encode_snapshot(&store),
_ => unreachable!(),
}?;
@ -170,7 +170,7 @@ impl EncodeMode {
match self {
EncodeMode::Auto(_) => unreachable!(),
EncodeMode::Updates(_) => 0,
EncodeMode::Changes(_) => 1,
EncodeMode::RleUpdates(_) => 1,
EncodeMode::Snapshot => 2,
}
}