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

refactor: rm next lamport from app state diff

Browse source
This commit is contained in:
Zixuan Chen 2023-07-12 21:29:21 +08:00
parent 6d2d28a721
commit 097d86915a
2 changed files with 1 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
crates/loro-internal/src/refactor/loro.rs
View file

@ -65,7 +65,6 @@ impl LoroApp {
state.apply_diff(AppStateDiff {
diff: &diff,
frontiers: oplog.frontiers(),
next_lamport: oplog.latest_lamport + 1,
});
}
@ -109,7 +108,6 @@ impl LoroApp {
state.apply_diff(AppStateDiff {
diff: &diff,
frontiers: oplog.frontiers(),
next_lamport: oplog.latest_lamport + 1,
});
}

11
crates/loro-internal/src/refactor/state.rs
View file

@ -4,7 +4,6 @@ use fxhash::{FxHashMap, FxHashSet};
use ring::rand::SystemRandom;
use crate::{
change::Lamport,
configure::SecureRandomGenerator,
container::{registry::ContainerIdx, ContainerIdRaw},
event::Diff,
@ -84,7 +83,6 @@ pub struct ContainerStateDiff {
pub struct AppStateDiff<'a> {
pub(crate) diff: &'a [ContainerStateDiff],
pub(crate) frontiers: &'a Frontiers,
pub(crate) next_lamport: Lamport,
}
impl AppState {
@ -106,14 +104,7 @@ impl AppState {
self.peer = peer;
}
pub fn apply_diff(
&mut self,
AppStateDiff {
diff,
frontiers,
next_lamport,
}: AppStateDiff,
) {
pub fn apply_diff(&mut self, AppStateDiff { diff, frontiers }: AppStateDiff) {
if self.in_txn {
panic!("apply_diff should not be called in a transaction");
}