From cabdad133f66e71348753904c847b77604752269 Mon Sep 17 00:00:00 2001 From: MiniFrenchBread <103425574+MiniFrenchBread@users.noreply.github.com> Date: Thu, 19 Sep 2024 18:24:19 +0800 Subject: [PATCH] fix: rust fmt --- node/log_entry_sync/src/sync_manager/mod.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/node/log_entry_sync/src/sync_manager/mod.rs b/node/log_entry_sync/src/sync_manager/mod.rs index db17fd8..39b0b3e 100644 --- a/node/log_entry_sync/src/sync_manager/mod.rs +++ b/node/log_entry_sync/src/sync_manager/mod.rs @@ -7,12 +7,12 @@ use ethers::{prelude::Middleware, types::BlockNumber}; use futures::FutureExt; use jsonrpsee::tracing::{debug, error, warn}; use shared_types::{bytes_to_chunks, ChunkArray, Transaction}; -use storage::log_store::log_manager::{sector_to_segment}; use std::collections::BTreeMap; use std::fmt::Debug; use std::future::Future; use std::sync::Arc; use std::time::{Duration, Instant}; +use storage::log_store::log_manager::sector_to_segment; use storage::log_store::{tx_store::BlockHashAndSubmissionIndex, Store}; use task_executor::{ShutdownReason, TaskExecutor}; use thiserror::Error; @@ -481,7 +481,9 @@ impl LogSyncManager { } else { let store = self.store.clone(); let shard_config = store.flow().get_shard_config(); - if sector_to_segment(bytes_to_chunks(tx.size as usize) as u64) < shard_config.shard_id { + if sector_to_segment(bytes_to_chunks(tx.size as usize) as u64) + < shard_config.shard_id + { if let Err(e) = store.finalize_tx_with_hash(tx.seq, tx.hash()) { error!("finalize file that does not need to store: e={:?}", e); return false;