From 28654efde1e9e987e014603ef93033a90169cdf4 Mon Sep 17 00:00:00 2001 From: 0g-peterzhb <158457852+0g-peterzhb@users.noreply.github.com> Date: Thu, 3 Jul 2025 19:42:06 +0800 Subject: [PATCH] @peter/fix upload (#378) * record error message when uploading segments --- node/rpc/src/zgs/impl.rs | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/node/rpc/src/zgs/impl.rs b/node/rpc/src/zgs/impl.rs index f0462b2..229cdb5 100644 --- a/node/rpc/src/zgs/impl.rs +++ b/node/rpc/src/zgs/impl.rs @@ -77,8 +77,19 @@ impl RpcServer for RpcServerImpl { let maybe_tx = self.ctx.log_store.get_tx_by_seq_number(tx_seq).await?; for segment in segments.into_iter() { - self.put_segment_with_maybe_tx(segment, maybe_tx.clone()) - .await?; + match self + .put_segment_with_maybe_tx(segment, maybe_tx.clone()) + .await + { + Ok(()) => {} // success + Err(e) + if e.to_string() + .contains("segment has already been uploaded or is being uploaded") => + { + debug!(?e, "duplicate segment - skipping"); + } + Err(e) => return Err(e), + } } Ok(())