mirror of
https://github.com/loro-dev/loro.git
synced 2025-02-02 19:13:57 +00:00
5cac1ed092
- Allow changes to be merged when possible. This makes realtime collaboration more efficient with Loro. - Refactor the code to make modifications of changes in oplog in one place - Optimize the diff calculation so that it doesn't have to go back to the beginning of the change. Note: we still keep the invariants that dependency pointers in Loro always point to the last op in a change
92 lines
2.8 KiB
Rust
92 lines
2.8 KiB
Rust
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 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();
|
|
// }
|
|
|
|
// {
|
|
// // Delta encoding
|
|
|
|
// // let start = Instant::now();
|
|
// // for _ in 0..10 {
|
|
// // loro.export_from(&Default::default());
|
|
// // }
|
|
|
|
// // println!("Avg encode {}ms", start.elapsed().as_millis() as f64 / 10.0);
|
|
|
|
// let data = loro.export_from(&Default::default());
|
|
// let start = Instant::now();
|
|
// for _ in 0..5 {
|
|
// let b = LoroDoc::default();
|
|
// b.import(&data).unwrap();
|
|
// }
|
|
|
|
// println!("Avg decode {}ms", start.elapsed().as_millis() as f64 / 10.0);
|
|
// println!("size len={}", data.len());
|
|
// let d = miniz_oxide::deflate::compress_to_vec(&data, 10);
|
|
// println!("size after compress len={}", d.len());
|
|
// }
|
|
|
|
// {
|
|
// // Snapshot encoding
|
|
// // println!("\n=======================\nSnapshot Encoding:");
|
|
|
|
// // let start = Instant::now();
|
|
// // for _ in 0..10 {
|
|
// // loro.export_snapshot();
|
|
// // }
|
|
|
|
// // println!("Avg encode {}ms", start.elapsed().as_millis() as f64 / 10.0);
|
|
|
|
// // let data = loro.export_snapshot();
|
|
// // let start = Instant::now();
|
|
// // let times = 300;
|
|
// // for _ in 0..times {
|
|
// // let b = LoroDoc::default();
|
|
// // b.import(&data).unwrap();
|
|
// // }
|
|
|
|
// // println!(
|
|
// // "Avg decode {}ms",
|
|
// // start.elapsed().as_millis() as f64 / times as f64
|
|
// // );
|
|
// // println!("size len={}", data.len());
|
|
// // let d = miniz_oxide::deflate::compress_to_vec(&data, 10);
|
|
// // println!("size after compress len={}", d.len());
|
|
// }
|
|
}
|