Skip to content

Commit 0542328

Browse files
committed
rename insert_frames to inject_frames
1 parent 2713648 commit 0542328

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

libsql-wal/src/replication/injector.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ impl<'a, IO: Io> Injector<'a, IO> {
5454
self.max_tx_frame_no = 0;
5555
}
5656
let buffer = current
57-
.insert_frames_inject(buffer, commit_data, &mut self.tx)
57+
.inject_frames(buffer, commit_data, &mut self.tx)
5858
.await?;
5959
self.buffer = buffer;
6060

libsql-wal/src/segment/current.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ impl<F> CurrentSegment<F> {
119119
/// insert a bunch of frames in the Wal. The frames needn't be ordered, therefore, on commit
120120
/// the last frame no needs to be passed alongside the new size_after.
121121
#[tracing::instrument(skip_all)]
122-
pub async fn insert_frames_inject(
122+
pub async fn inject_frames(
123123
&self,
124124
frames: Vec<Box<Frame>>,
125125
// (size_after, last_frame_no)
@@ -520,7 +520,6 @@ impl<F> CurrentSegment<F> {
520520
self.file.read_exact_at(checked_frame.as_bytes_mut(), frame_offset)?;
521521
current_checksum = checked_frame.frame.checksum(current_checksum);
522522
self.file.write_all_at(&current_checksum.to_le_bytes(), frame_offset)?;
523-
524523
}
525524

526525
Ok(())

0 commit comments

Comments
 (0)