fstree: clean up temporary files

Add method to remove temporary files from `genericWriter.writeData` and call it
in `FSTree.Init`.

Closes #2291.

Signed-off-by: Andrey Butusov <[email protected]>

CHANGELOG.md

@@ -11,6 +11,7 @@ Changelog for NeoFS Node
 - `node` config option `storage.ignore_uninited_shards` (#2953)
 - For `neofs-cli container create`, add `--global-name` flag, that sets name attribute as the value of `__NEOFS__NAME` 
 attribute, which is used for container domain name in NNS contracts (#2954)
+- Clean up temporary files in FSTree on start (#2967)
 
 ### Fixed
 - Do not search for tombstones when handling their expiration, use local indexes instead (#2929)

pkg/local_object_storage/blobstor/fstree/control.go

@@ -24,6 +24,11 @@ func (t *FSTree) Init() error {
  t.writer = w
  }
  }
+
+ err = t.CleanUpTmp()
+ if err != nil {
+ return fmt.Errorf("clean up tmp: %w", err)
+ }
  return nil
 }
 

pkg/local_object_storage/blobstor/fstree/fstree.go

@@ -11,6 +11,7 @@ import (
  "math"
  "os"
  "path/filepath"
+ "regexp"
  "strings"
  "time"
 
@@ -477,3 +478,23 @@ func (t *FSTree) SetCompressor(cc *compression.Config) {
 func (t *FSTree) SetReportErrorFunc(_ func(string, error)) {
  // Do nothing, FSTree can encounter only one error which is returned.
 }
+
+// CleanUpTmp removes all temporary files garbage
+func (t *FSTree) CleanUpTmp() error {
+ re := regexp.MustCompile(`.*#[0-9]+$`)
+
+ err := filepath.WalkDir(t.RootPath,
+ func(path string, d fs.DirEntry, _ error) error {
+ if !d.IsDir() && re.MatchString(d.Name()) {
+ _ = os.RemoveAll(path)
+ }
+
+ return nil
+ },
+ )
+ if err != nil {
+ return fmt.Errorf("could not walk through %q directory: %w", t.RootPath, err)
+ }
+
+ return nil
+}