mirrors/loro
1
0
Fork 0
mirror of https://github.com/loro-dev/loro.git synced 2025-01-23 05:24:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

chore: refine err msg

Browse source
This commit is contained in:
Zixuan Chen 2023-11-08 14:18:01 +08:00
parent 9b18ff9847
commit 116190c817
No known key found for this signature in database
2 changed files with 38 additions and 32 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

60
crates/loro-internal/examples/encoding.rs
View file

@ -1,44 +1,50 @@
use std::time::Instant;
use bench_utils::TextAction;
use loro_internal::LoroDoc;
fn main() {
let actions = bench_utils::get_automerge_actions();
let loro = LoroDoc::default();
let loro_b = LoroDoc::default();
let text = loro.get_text("text");
let mut i = 0;
let start = Instant::now();
for TextAction { pos, ins, del } in actions.iter() {
{
let mut txn = loro.txn().unwrap();
text.delete(&mut txn, *pos, *del).unwrap();
text.insert(&mut txn, *pos, ins).unwrap();
}
loro_b
.import(&loro.export_from(&loro_b.oplog_vv()))
.unwrap();
i += 1;
if i == 30000 {
break;
}
}
println!("{}ms", start.elapsed().as_millis());
// let loro = LoroDoc::default();
// let loro_b = LoroDoc::default();
// let text = loro.get_text("text");
// let mut i = 0;
// let start = Instant::now();
// for TextAction { pos, ins, del } in actions.iter() {
// {
// let mut txn = loro.txn().unwrap();
// text.delete(&mut txn, *pos, *del).unwrap();
// text.insert(&mut txn, *pos, ins).unwrap();
// txn.commit().unwrap();
// }
// loro_b
// .import(&loro.export_from(&loro_b.oplog_vv()))
// .unwrap();
// i += 1;
// if i == 30000 {
// break;
// }
// }
// println!("{}ms", start.elapsed().as_millis());
let loro = LoroDoc::default();
let text = loro.get_text("text");
for TextAction { pos, ins, del } in actions.iter() {
let mut txn = loro.txn().unwrap();
text.delete(&mut txn, *pos, *del).unwrap();
text.insert(&mut txn, *pos, ins).unwrap();
txn.commit().unwrap();
}
let snapshot = loro.export_snapshot();
let output = miniz_oxide::deflate::compress_to_vec(&snapshot, 6);
println!(
"snapshot size {} after compression {}",
snapshot.len(),
output.len()
);
// {
// // Delta encoding

2
crates/loro-internal/src/container/richtext/richtext_state.rs
View file

@ -1547,7 +1547,7 @@ impl RichtextState {
"pos: {}, len: {}, self.len(): {}",
pos,
len,
&self.to_string()
&self.len_entity(),
);
// PERF: may use cache to speed up
self.cursor_cache.invalidate();