diff --git a/crates/loro-core/examples/encoding.rs b/crates/loro-core/examples/encoding.rs index 8659c3aa..95947e59 100644 --- a/crates/loro-core/examples/encoding.rs +++ b/crates/loro-core/examples/encoding.rs @@ -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(); diff --git a/crates/loro-core/src/fuzz.rs b/crates/loro-core/src/fuzz.rs index f99921d3..473ef62a 100644 --- a/crates/loro-core/src/fuzz.rs +++ b/crates/loro-core/src/fuzz.rs @@ -316,16 +316,16 @@ pub fn test_single_client_encode(mut actions: Vec) { } 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(); diff --git a/crates/loro-core/src/log_store/encoding.rs b/crates/loro-core/src/log_store/encoding.rs index 6e6085e3..72268b5e 100644 --- a/crates/loro-core/src/log_store/encoding.rs +++ b/crates/loro-core/src/log_store/encoding.rs @@ -14,7 +14,7 @@ const MAGIC_BYTES: [u8; 4] = [0x6c, 0x6f, 0x72, 0x6f]; pub enum EncodeMode { Auto(Option), 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, } }