fix(store/v2): chunk.Close is called twice (#23168)

Co-authored-by: Alex | Skip <alex@skip.money>
2025-01-07 16:03:51 +08:00 · 2025-01-07 16:03:51 +08:00 · 26ea9b2f84
commit 26ea9b2f84
parent f77a27432a
1 changed files with 9 additions and 8 deletions
--- a/store/v2/snapshots/store.go
+++ b/store/v2/snapshots/store.go
@ -172,14 +172,15 @@ func (s *Store) Load(height uint64, format uint32) (*types.Snapshot, <-chan io.R
 				_ = pw.CloseWithError(err)
 				return
 			}
-			defer chunk.Close()
-			_, err = io.Copy(pw, chunk)
-			if err != nil {
-				_ = pw.CloseWithError(err)
-				return
-			}
-			chunk.Close()
-			pw.Close()
+			func() {
+				defer chunk.Close()
+				_, err = io.Copy(pw, chunk)
+				if err != nil {
+					_ = pw.CloseWithError(err)
+					return
+				}
+				pw.Close()
+			}()
 		}
 	}()