Skip to content

Commit

Permalink
Revert unnecessary change
Browse files Browse the repository at this point in the history
  • Loading branch information
slowli committed Aug 1, 2024
1 parent 4276379 commit a5d000e
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 9 deletions.
2 changes: 1 addition & 1 deletion core/node/state_keeper/src/batch_executor/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -126,7 +126,7 @@ impl BatchExecutorHandle {
let (response_sender, response_receiver) = oneshot::channel();
let send_failed = self
.commands
.send(Command::ExecuteTx(Box::new(tx.clone()), response_sender))
.send(Command::ExecuteTx(Box::new(tx), response_sender))
.await
.is_err();
if send_failed {
Expand Down
10 changes: 2 additions & 8 deletions core/node/vm_runner/src/tests/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -80,18 +80,12 @@ impl VmRunnerIo for Arc<RwLock<IoMock>> {
Ok(self.read().await.current)
}

// FIXME: revert?
async fn last_ready_to_be_loaded_batch(
&self,
conn: &mut Connection<'_, Core>,
_conn: &mut Connection<'_, Core>,
) -> anyhow::Result<L1BatchNumber> {
let sealed_batch = conn
.blocks_dal()
.get_sealed_l1_batch_number()
.await?
.unwrap_or(L1BatchNumber(u32::MAX));
let io = self.read().await;
Ok((io.current + io.max).min(sealed_batch))
Ok(io.current + io.max)
}

async fn mark_l1_batch_as_processing(
Expand Down

0 comments on commit a5d000e

Please sign in to comment.