From c6c7dea84d2ff41fff70f218839e210a4e784b93 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Rok=20=C4=8Cerni=C4=8D?= Date: Tue, 18 Feb 2025 17:06:26 +0100 Subject: [PATCH 1/2] fix precommit scheduling --- storage-provider/server/src/pipeline/add_piece.rs | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/storage-provider/server/src/pipeline/add_piece.rs b/storage-provider/server/src/pipeline/add_piece.rs index c537d4373..05d5a996f 100644 --- a/storage-provider/server/src/pipeline/add_piece.rs +++ b/storage-provider/server/src/pipeline/add_piece.rs @@ -61,7 +61,11 @@ pub async fn add_piece( fill_percentage, fill_threshold, ); - return state.send_pre_commit(sector_number); + + // Schedule a new precommit to be executed immediately + let when = Duration::from_secs(0); + schedule_pre_commit(state.clone(), tracker, sector_number, when).await; + return Ok(()); } tracing::debug!( %sector_number, @@ -76,6 +80,7 @@ pub async fn add_piece( state.server_info.sealing_configuration.wait_deals_delay, duration_to_deal_start, ); + // We always try to schedule a new pre-commit schedule_pre_commit(state.clone(), tracker, sector_number, when).await; From c806775a9ba6fb9e72a5b514ea6c5118eaf21670 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Rok=20=C4=8Cerni=C4=8D?= Date: Tue, 18 Feb 2025 17:33:53 +0100 Subject: [PATCH 2/2] small change --- storage-provider/server/src/pipeline/add_piece.rs | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/storage-provider/server/src/pipeline/add_piece.rs b/storage-provider/server/src/pipeline/add_piece.rs index 05d5a996f..e8e7a22da 100644 --- a/storage-provider/server/src/pipeline/add_piece.rs +++ b/storage-provider/server/src/pipeline/add_piece.rs @@ -63,8 +63,7 @@ pub async fn add_piece( ); // Schedule a new precommit to be executed immediately - let when = Duration::from_secs(0); - schedule_pre_commit(state.clone(), tracker, sector_number, when).await; + schedule_pre_commit(state.clone(), tracker, sector_number, Duration::ZERO).await; return Ok(()); } tracing::debug!(