From 9e56592be3794ccdc8d3724cc42dcc5feacdfcc3 Mon Sep 17 00:00:00 2001
From: Pavel Karpy <p.karpy@yadro.com>
Date: Fri, 5 May 2023 18:40:57 +0300
Subject: [PATCH] [#314] writecache: Simplify background workers naming

Also, drop not used arg.

Signed-off-by: Pavel Karpy <p.karpy@yadro.com>
---
 pkg/local_object_storage/writecache/flush.go | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/pkg/local_object_storage/writecache/flush.go b/pkg/local_object_storage/writecache/flush.go
index 04fccced..1e24a42e 100644
--- a/pkg/local_object_storage/writecache/flush.go
+++ b/pkg/local_object_storage/writecache/flush.go
@@ -37,12 +37,12 @@ const (
 func (c *cache) runFlushLoop() {
 	for i := 0; i < c.workersCount; i++ {
 		c.wg.Add(1)
-		go c.flushWorker(i)
+		go c.workerFlushSmall()
 	}
 
 	c.wg.Add(1)
 	go func() {
-		c.flushBigObjects(context.TODO())
+		c.workerFlushBig(context.TODO())
 		c.wg.Done()
 	}()
 
@@ -56,7 +56,7 @@ func (c *cache) runFlushLoop() {
 		for {
 			select {
 			case <-tt.C:
-				c.flushDB()
+				c.flushSmallObjects()
 				tt.Reset(defaultFlushInterval)
 			case <-c.closeCh:
 				return
@@ -65,7 +65,7 @@ func (c *cache) runFlushLoop() {
 	}()
 }
 
-func (c *cache) flushDB() {
+func (c *cache) flushSmallObjects() {
 	var lastKey []byte
 	var m []objectInfo
 	for {
@@ -148,7 +148,7 @@ func (c *cache) flushDB() {
 	}
 }
 
-func (c *cache) flushBigObjects(ctx context.Context) {
+func (c *cache) workerFlushBig(ctx context.Context) {
 	tick := time.NewTicker(defaultFlushInterval * 10)
 	for {
 		select {
@@ -228,8 +228,8 @@ func (c *cache) flushFSTree(ctx context.Context, ignoreErrors bool) error {
 	return err
 }
 
-// flushWorker writes objects to the main storage.
-func (c *cache) flushWorker(_ int) {
+// workerFlushSmall writes small objects to the main storage.
+func (c *cache) workerFlushSmall() {
 	defer c.wg.Done()
 
 	var obj *object.Object