remove failed blob in mem

0glabs · Jul 17, 2024 · f8f5d33 · f8f5d33
1 parent a535992
commit f8f5d33
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/disperser/batcher/batcher.go b/disperser/batcher/batcher.go
@@ -328,6 +328,7 @@ func (b *Batcher) HandleSingleBatch(ctx context.Context) (uint64, error) {
 				if meta.BlobStatus == disperser.Failed {
 					log.Info("[batcher] disperse batch reach max retries", "key", metadata.GetBlobKey())
 					b.EncodingStreamer.RemoveEncodedBlob(metadata)
+					b.Queue.RemoveBlob(ctx, metadata)
 				}
 			}
 		}
@@ -394,6 +395,7 @@ func (b *Batcher) HandleSignedBatch(ctx context.Context) error {
 							log.Info("[batcher] submit aggregateSignatures reach max retries", "key", metadata.GetBlobKey())
 							b.EncodingStreamer.RemoveEncodedBlob(metadata)
 							b.sliceSigner.RemoveSignedBlob(ts[idx])
+							b.Queue.RemoveBlob(ctx, metadata)
 						}
 					}
 				}

diff --git a/disperser/batcher/slice_signer.go b/disperser/batcher/slice_signer.go
@@ -692,6 +692,7 @@ func (s *SliceSigner) aggregateSignature(ctx context.Context, signInfo *SignInfo
 					if meta.BlobStatus == disperser.Failed {
 						s.logger.Info("[signer] signing blob reach max retries", "key", metadata.GetBlobKey())
 						s.EncodingStreamer.RemoveEncodedBlob(metadata)
+						s.blobStore.RemoveBlob(ctx, metadata)
 					}
 				}
 			}