save

turbo/snapshotsync/freezeblocks/block_snapshots.go

@@ -279,9 +279,7 @@ func (s *DirtySegment) reopenSeg(dir string) (err error) {
 	if s.refcount.Load() > 0 {
 		return
 	}
-	if s.Decompressor != nil {
-		return
-	}
+	s.closeSeg()
 	s.Decompressor, err = seg.NewDecompressor(filepath.Join(dir, s.FileName()))
 	if err != nil {
 		return fmt.Errorf("%w, fileName: %s", err, s.FileName())
@@ -355,25 +353,37 @@ func (s *DirtySegment) reopenIdx(dir string) (err error) {
 	if s.refcount.Load() > 0 {
 		return nil
 	}
+
+	s.closeIdx()
 	if s.Decompressor == nil {
 		return nil
 	}
-	for len(s.indexes) <= len(s.Type().Indexes()) {
-		s.indexes = append(s.indexes, nil)
-	}
-
-	for i, index := range s.Type().Indexes() {
-		if s.indexes[i] != nil {
-			continue
-		}
-
-		fileName := s.Type().IdxFileName(s.version, s.from, s.to, index)
+	//for len(s.indexes) <= len(s.Type().Indexes()) {
+	//	s.indexes = append(s.indexes, nil)
+	//}
+	//
+	//for i, index := range s.Type().Indexes() {
+	//	if s.indexes[i] != nil {
+	//		continue
+	//	}
+	//
+	//	fileName := s.Type().IdxFileName(s.version, s.from, s.to, index)
+	//	index, err := recsplit.OpenIndex(filepath.Join(dir, fileName))
+	//	if err != nil {
+	//		return fmt.Errorf("%w, fileName: %s", err, fileName)
+	//	}
+	//
+	//	s.indexes[i] = index
+	//}
+
+	for _, fileName := range s.Type().IdxFileNames(s.version, s.from, s.to) {
 		index, err := recsplit.OpenIndex(filepath.Join(dir, fileName))
+
 		if err != nil {
 			return fmt.Errorf("%w, fileName: %s", err, fileName)
 		}
 
-		s.indexes[i] = index
+		s.indexes = append(s.indexes, index)
 	}
 
 	return nil