Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>

@@ -29,3 +31,2 @@
 
-func NewSimpleCounter() *SimpleCounter {
-	return &SimpleCounter{}
+func NewSimpleCounter(assert bool) *SimpleCounter {

@@ -225,0 +228,4 @@
+}
+type IterateInfoHandler func(ObjectInfo) error
+
+func (t *FSTree) IterateInfo(ctx context.Context, handler IterateInfoHandler) error {

@@ -128,0 +124,4 @@
+	w.fileGuard.Lock(p)
+	defer w.fileGuard.Unlock(p)
+
+	stat, err := os.Stat(p)

@@ -51,6 +61,10 @@ func (w *linuxWriter) writeData(p string, data []byte) error {
 }
 
 func (w *linuxWriter) writeFile(p string, data []byte) error {
+	if w.fileCounterEnabled {

@@ -52,2 +62,4 @@
 
 func (w *linuxWriter) writeFile(p string, data []byte) error {
+	if w.fileCounterEnabled {
+		w.fileGuard.Lock(p)

@@ -0,0 +132,4 @@
+	defer c.modeMtx.Unlock()
+
+	var err error
+	if c.fsTree != nil {

@@ -197,9 +153,6 @@ func (c *cache) flushFSTree(ctx context.Context, ignoreErrors bool) error {
 
 		err = c.flushObject(ctx, &obj, e.ObjectData, StorageTypeFSTree)
 		if err != nil {
-			if ignoreErrors {

@@ -172,0 +110,4 @@
+		Address: objInfo.addr,
+	})
+	if err != nil {
+		if !client.IsErrObjectNotFound(err) {

@@ -305,0 +238,4 @@
+	address string
+}
+
+func (c *cache) flushAndDropBBoltDB(ctx context.Context) error {

@@ -321,3 +269,1 @@
-					continue
-				}
-				return err
+				return fmt.Errorf("unmarshal object from database: %w", err)

@@ -0,0 +5,4 @@
+	"sync"
+)
+
+type flushLimiter struct {

@@ -0,0 +18,4 @@
+	}
+}
+
+func (l *flushLimiter) acquire(ctx context.Context, size uint64) error {

@@ -0,0 +19,4 @@
+}
+
+func (l *flushLimiter) acquire(ctx context.Context, size uint64) error {
+	stopf := context.AfterFunc(ctx, func() {

@@ -0,0 +49,4 @@
+	if l.size >= size {
+		l.size -= size
+	} else {
+		l.size = 0

@@ -0,0 +32,4 @@
+
+	// it is allowed to overflow maxSize to allow flushing objects with size > maxSize
+	for l.count > 0 && l.size+size > l.maxSize {
+		l.cond.Wait()

@@ -164,0 +69,4 @@
+				}:
+					return nil
+				case <-ctx.Done():
+					c.flushLimiter.release(oi.DataSize)

@@ -0,0 +19,4 @@
+			defer l.release(single)
+			defer currSize.Add(-1)
+			l.acquire(single)
+			require.True(t, currSize.Add(1) <= 3)

@@ -225,0 +278,4 @@
+			continue
+		}
+		path := filepath.Join(curPath...)
+		info, err := os.Stat(path)

@@ -119,4 +114,3 @@
 	} else {
 		err = os.Remove(p)
 	}
-