update chunk data pack remove

zhangchiqing · zhangchiqing · commit 59b5ae49ae4f · 2025-10-15T09:32:08.000-07:00
diff --git a/storage/store/chunk_data_packs_stored.go b/storage/store/chunk_data_packs_stored.go
@@ -81,10 +81,7 @@ func (ch *StoredChunkDataPacks) BatchRemove(chunkDataPackIDs []flow.Identifier,
 }
 
 func (ch *StoredChunkDataPacks) batchRemove(chunkDataPackID flow.Identifier, rw storage.ReaderBatchWriter) error {
-	storage.OnCommitSucceed(rw, func() {
-		ch.byIDCache.Remove(chunkDataPackID)
-	})
-	return operation.RemoveChunkDataPack(rw.Writer(), chunkDataPackID)
+	return ch.byIDCache.RemoveTx(rw, chunkDataPackID)
 }
 
 // StoreChunkDataPacks stores multiple StoredChunkDataPacks cs in a batch.

Original file line number	Diff line number	Diff line change
`@@ -81,10 +81,7 @@ func (ch *StoredChunkDataPacks) BatchRemove(chunkDataPackIDs []flow.Identifier,`
`81`	`81`	`}`
`82`	`82`
`83`	`83`	`func (ch *StoredChunkDataPacks) batchRemove(chunkDataPackID flow.Identifier, rw storage.ReaderBatchWriter) error {`
`84`		`- storage.OnCommitSucceed(rw, func() {`
`85`		`- ch.byIDCache.Remove(chunkDataPackID)`
`86`		`- })`
`87`		`- return operation.RemoveChunkDataPack(rw.Writer(), chunkDataPackID)`
	`84`	`+ return ch.byIDCache.RemoveTx(rw, chunkDataPackID)`
`88`	`85`	`}`
`89`	`86`
`90`	`87`	`// StoreChunkDataPacks stores multiple StoredChunkDataPacks cs in a batch.`